diff options
Diffstat (limited to 'xlators')
| -rw-r--r-- | xlators/cluster/dht/src/dht-rebalance.c | 5 | ||||
| -rw-r--r-- | xlators/cluster/dht/src/dht-shared.c | 6 | 
2 files changed, 7 insertions, 4 deletions
diff --git a/xlators/cluster/dht/src/dht-rebalance.c b/xlators/cluster/dht/src/dht-rebalance.c index 0a29ba30d3d..69d6f86019f 100644 --- a/xlators/cluster/dht/src/dht-rebalance.c +++ b/xlators/cluster/dht/src/dht-rebalance.c @@ -19,7 +19,6 @@  #include <signal.h>  #include <fnmatch.h>  #include <signal.h> -#include <sys/sysinfo.h>  #define GF_DISK_SECTOR_SIZE             512  #define DHT_REBALANCE_PID               4242 /* Change it if required */ @@ -28,7 +27,9 @@  #define MAX_MIGRATE_QUEUE_COUNT         500  #define MIN_MIGRATE_QUEUE_COUNT         200 +#ifndef MAX  #define MAX(a, b) (((a) > (b))?(a):(b)) +#endif  #define GF_CRAWL_INDEX_MOVE(idx, sv_cnt)  {     \                  idx++;                          \ @@ -2640,7 +2641,7 @@ gf_defrag_start_crawl (void *data)                  INIT_LIST_HEAD (&(defrag->queue[0].list)); -                thread_spawn_count = MAX ((get_nprocs() - 4), 4); +                thread_spawn_count = MAX ((sysconf(_SC_NPROCESSORS_ONLN) - 4), 4);                  gf_log (this->name, GF_LOG_DEBUG, "thread_spawn_count: %d",                          thread_spawn_count); diff --git a/xlators/cluster/dht/src/dht-shared.c b/xlators/cluster/dht/src/dht-shared.c index 0ab81c37890..04e96127ec6 100644 --- a/xlators/cluster/dht/src/dht-shared.c +++ b/xlators/cluster/dht/src/dht-shared.c @@ -15,12 +15,13 @@  #endif  /* TODO: add NS locking */ -#include <sys/sysinfo.h>  #include "statedump.h"  #include "dht-common.h"  #include "dht-messages.h" +#ifndef MAX  #define MAX(a, b) (((a) > (b))?(a):(b)) +#endif  #define GF_DECIDE_DEFRAG_THROTTLE_COUNT(throttle_count, conf) {         \                                                                          \ @@ -29,7 +30,8 @@                  if (!strcasecmp (conf->dthrottle, "lazy"))              \                          conf->defrag->recon_thread_count = 1;           \                                                                          \ -                throttle_count = MAX ((get_nprocs() - 4), 4);           \ +                throttle_count =                                        \ +                    MAX ((sysconf(_SC_NPROCESSORS_ONLN) - 4), 4);       \                                                                          \                  if (!strcasecmp (conf->dthrottle, "normal"))            \                          conf->defrag->recon_thread_count =              \  | 
