Browse Source

Count each idle client as an idle worker instead of per workername

master
ckolivas 10 years ago
parent
commit
137203c01a
  1. 5
      src/stratifier.c

5
src/stratifier.c

@ -3502,7 +3502,7 @@ static void *statsupdate(void *arg)
decay_time(&client->dsps10080, 0, per_tdiff, 604800); decay_time(&client->dsps10080, 0, per_tdiff, 604800);
if (per_tdiff > 600) if (per_tdiff > 600)
client->idle = true; client->idle = true;
continue; idle_workers++;
} }
} }
@ -3514,7 +3514,7 @@ static void *statsupdate(void *arg)
/* Decay times per worker */ /* Decay times per worker */
DL_FOREACH(instance->worker_instances, worker) { DL_FOREACH(instance->worker_instances, worker) {
/* FIXME: This shouldn't happen and is purely a sanity /* FIXME: This shouldn't happen and is purely a sanity
* breakout till the real issue is found fixed. */ * breakout till the real issue is found and fixed. */
if (unlikely(iterations++ > instance->workers)) { if (unlikely(iterations++ > instance->workers)) {
LOGWARNING("Statsupdate trying to iterate more than %d existing workers for worker %s", LOGWARNING("Statsupdate trying to iterate more than %d existing workers for worker %s",
instance->workers, worker->workername); instance->workers, worker->workername);
@ -3526,7 +3526,6 @@ static void *statsupdate(void *arg)
decay_time(&worker->dsps5, 0, per_tdiff, 300); decay_time(&worker->dsps5, 0, per_tdiff, 300);
decay_time(&worker->dsps60, 0, per_tdiff, 3600); decay_time(&worker->dsps60, 0, per_tdiff, 3600);
decay_time(&worker->dsps1440, 0, per_tdiff, 86400); decay_time(&worker->dsps1440, 0, per_tdiff, 86400);
idle_workers++;
worker->idle = true; worker->idle = true;
} }
ghs = worker->dsps1 * nonces; ghs = worker->dsps1 * nonces;

Loading…
Cancel
Save