Whamcloud - gitweb
LU-8703 libcfs: make tolerant to offline CPUs and empty NUMA nodes
[fs/lustre-release.git] / libcfs / include / libcfs / linux / linux-cpu.h
index 124523f..a46e252 100644 (file)
@@ -22,7 +22,8 @@
  */
 /*
  * Copyright (c) 2010, Oracle and/or its affiliates. All rights reserved.
- * Copyright (c) 2011, 2012, Whamcloud, Inc.
+ *
+ * Copyright (c) 2012, 2013, Intel Corporation.
  */
 /*
  * This file is part of Lustre, http://www.lustre.org/
 #include <linux/topology.h>
 #include <linux/version.h>
 
-#ifndef HAVE_CPUMASK_SIZE
-#define cpumask_size()         sizeof(cpumask_t)
-#endif
-
 #ifdef CONFIG_SMP
 
 #define HAVE_LIBCFS_CPT
@@ -65,117 +62,40 @@ struct cfs_cpu_partition {
        cpumask_t                       *cpt_cpumask;
        /* nodes mask for this partition */
        nodemask_t                      *cpt_nodemask;
+       /* NUMA distance between CPTs */
+       unsigned                        *cpt_distance;
        /* spread rotor for NUMA allocator */
-       unsigned                        cpt_spread_rotor;
+       int                              cpt_spread_rotor;
+       /* NUMA node if cpt_nodemask is empty */
+       int                              cpt_node;
 };
 
 /** descriptor for CPU partitions */
 struct cfs_cpt_table {
-       /* version, reserved for hotplug */
-       unsigned                        ctb_version;
        /* spread rotor for NUMA allocator */
-       unsigned                        ctb_spread_rotor;
+       int                             ctb_spread_rotor;
+       /* maximum NUMA distance between all nodes in table */
+       unsigned                        ctb_distance;
        /* # of CPU partitions */
-       unsigned                        ctb_nparts;
+       int                              ctb_nparts;
        /* partitions tables */
        struct cfs_cpu_partition        *ctb_parts;
        /* shadow HW CPU to CPU partition ID */
        int                             *ctb_cpu2cpt;
        /* all cpus in this partition table */
        cpumask_t                       *ctb_cpumask;
+       /* shadow HW node to CPU partition ID */
+       int                             *ctb_node2cpt;
        /* all nodes in this partition table */
        nodemask_t                      *ctb_nodemask;
 };
 
 void cfs_cpu_core_siblings(int cpu, cpumask_t *mask);
-void cfs_cpu_ht_siblings(int cpu, cpumask_t *mask);
-void cfs_node_to_cpumask(int node, cpumask_t *mask);
-int cfs_cpu_core_nsiblings(int cpu);
-int cfs_cpu_ht_nsiblings(int cpu);
-
-/**
- * comment out definitions for compatible layer
- * #define CFS_CPU_NR                          NR_CPUS
- *
- * typedef cpumask_t                           cfs_cpumask_t;
- *
- * #define cfs_cpu_current()                   smp_processor_id()
- * #define cfs_cpu_online(i)                   cpu_online(i)
- * #define cfs_cpu_online_num()                num_online_cpus()
- * #define cfs_cpu_online_for_each(i)          for_each_online_cpu(i)
- * #define cfs_cpu_possible_num()              num_possible_cpus()
- * #define cfs_cpu_possible_for_each(i)        for_each_possible_cpu(i)
- *
- * #ifdef CONFIG_CPUMASK_SIZE
- * #define cfs_cpu_mask_size()                 cpumask_size()
- * #else
- * #define cfs_cpu_mask_size()                 sizeof(cfs_cpumask_t)
- * #endif
- *
- * #define cfs_cpu_mask_set(i, mask)           cpu_set(i, mask)
- * #define cfs_cpu_mask_unset(i, mask)         cpu_clear(i, mask)
- * #define cfs_cpu_mask_isset(i, mask)         cpu_isset(i, mask)
- * #define cfs_cpu_mask_clear(mask)            cpus_clear(mask)
- * #define cfs_cpu_mask_empty(mask)            cpus_empty(mask)
- * #define cfs_cpu_mask_weight(mask)           cpus_weight(mask)
- * #define cfs_cpu_mask_first(mask)            first_cpu(mask)
- * #define cfs_cpu_mask_any_online(mask)      (any_online_cpu(mask) != NR_CPUS)
- * #define cfs_cpu_mask_for_each(i, mask)      for_each_cpu_mask(i, mask)
- * #define cfs_cpu_mask_bind(t, mask)          set_cpus_allowed(t, mask)
- *
- * #ifdef HAVE_CPUMASK_COPY
- * #define cfs_cpu_mask_copy(dst, src)         cpumask_copy(dst, src)
- * #else
- * #define cfs_cpu_mask_copy(dst, src)         memcpy(dst, src, sizeof(*src))
- * #endif
- *
- * static inline void
- * cfs_cpu_mask_of_online(cfs_cpumask_t *mask)
- * {
- * cfs_cpu_mask_copy(mask, &cpu_online_map);
- * }
- *
- * #ifdef CONFIG_NUMA
- *
- * #define CFS_NODE_NR                         MAX_NUMNODES
- *
- * typedef nodemask_t                          cfs_node_mask_t;
- *
- * #define cfs_node_of_cpu(cpu)                cpu_to_node(cpu)
- * #define cfs_node_online(i)                  node_online(i)
- * #define cfs_node_online_num()               num_online_nodes()
- * #define cfs_node_online_for_each(i)         for_each_online_node(i)
- * #define cfs_node_possible_num()             num_possible_nodes()
- * #define cfs_node_possible_for_each(i)       for_each_node(i)
- *
- * static inline void cfs_node_to_cpumask(int node, cfs_cpumask_t *mask)
- * {
- * #if defined(HAVE_NODE_TO_CPUMASK)
- *      *mask = node_to_cpumask(node);
- * #elif defined(HAVE_CPUMASK_OF_NODE)
- *      cfs_cpu_mask_copy(mask, cpumask_of_node(node));
- * #else
- * # error "Needs node_to_cpumask or cpumask_of_node"
- * #endif
- * }
- *
- * #define cfs_node_mask_set(i, mask)          node_set(i, mask)
- * #define cfs_node_mask_unset(i, mask)        node_clear(i, mask)
- * #define cfs_node_mask_isset(i, mask)        node_isset(i, mask)
- * #define cfs_node_mask_clear(mask)           nodes_reset(mask)
- * #define cfs_node_mask_empty(mask)           nodes_empty(mask)
- * #define cfs_node_mask_weight(mask)          nodes_weight(mask)
- * #define cfs_node_mask_for_each(i, mask)     for_each_node_mask(i, mask)
- * #define cfs_node_mask_copy(dst, src)        memcpy(dst, src, sizeof(*src))
- *
- * static inline void
- * cfs_node_mask_of_online(cfs_node_mask_t *mask)
- * {
- *       cfs_node_mask_copy(mask, &node_online_map);
- * }
- *
- * #endif
- */
 
 #endif /* CONFIG_SMP */
+
+#ifndef HAVE_TOPOLOGY_SIBLING_CPUMASK
+# define topology_sibling_cpumask(cpu) topology_thread_cpumask(cpu)
+#endif /* HAVE_TOPOLOGY_SIBLING_CPUMASK */
+
 #endif /* __LIBCFS_LINUX_CPU_H__ */