diff options
Diffstat (limited to 'cmogstored.c')
| -rw-r--r-- | cmogstored.c | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/cmogstored.c b/cmogstored.c index 1c2f7db..3c3f87c 100644 --- a/cmogstored.c +++ b/cmogstored.c @@ -261,10 +261,9 @@ MOG_NOINLINE static void setup(int argc, char *argv[]) master_pid = getpid(); - /* 10 - 100 threads based on number of devices, same as mogstored */ - nthr = mog_mkusage_all() * 10; + /* 10 - ??? threads based on number of devices, same as mogstored */ + nthr = mog_mkusage_all(NULL) * 10; nthr = MAX(10, nthr); - nthr = MIN(100, nthr); } /* Hash iterator function */ @@ -415,11 +414,11 @@ static void upgrade_handler(void) } } -static void main_worker_loop(const pid_t parent) +static void main_worker_loop(struct mog_queue *q, const pid_t parent) { mog_cancel_disable(); /* mog_idleq_wait() now relies on this */ while (parent == 0 || parent == getppid()) { - mog_notify_wait(have_mgmt); + mog_notify_wait(q, have_mgmt); if (sigchld_hit) sigchld_handler(); if (do_upgrade) @@ -454,7 +453,7 @@ static void run_worker(const pid_t parent) if (!iostat_running) syslog(LOG_WARNING, "iostat(1) not available/running"); } - main_worker_loop(parent); + main_worker_loop(q, parent); } static void fork_worker(unsigned worker_id) |