|
@@ -2570,7 +2570,7 @@ out:
|
|
|
return cloned;
|
|
return cloned;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-static bool queue_request(struct thr_info *thr, bool needed);
|
|
|
|
|
|
|
+static bool queue_request(bool needed);
|
|
|
|
|
|
|
|
static void *get_work_thread(void *userdata)
|
|
static void *get_work_thread(void *userdata)
|
|
|
{
|
|
{
|
|
@@ -2592,10 +2592,7 @@ static void *get_work_thread(void *userdata)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
ret_work = make_work();
|
|
ret_work = make_work();
|
|
|
- if (wc->thr)
|
|
|
|
|
- ret_work->thr = wc->thr;
|
|
|
|
|
- else
|
|
|
|
|
- ret_work->thr = NULL;
|
|
|
|
|
|
|
+ ret_work->thr = NULL;
|
|
|
|
|
|
|
|
if (opt_benchmark) {
|
|
if (opt_benchmark) {
|
|
|
get_benchmark_work(ret_work);
|
|
get_benchmark_work(ret_work);
|
|
@@ -2611,7 +2608,7 @@ static void *get_work_thread(void *userdata)
|
|
|
/* pause, then restart work-request loop */
|
|
/* pause, then restart work-request loop */
|
|
|
applog(LOG_DEBUG, "json_rpc_call failed on get work, retrying");
|
|
applog(LOG_DEBUG, "json_rpc_call failed on get work, retrying");
|
|
|
dec_queued(pool);
|
|
dec_queued(pool);
|
|
|
- queue_request(ret_work->thr, wc->needed);
|
|
|
|
|
|
|
+ queue_request(wc->needed);
|
|
|
free_work(ret_work);
|
|
free_work(ret_work);
|
|
|
goto out;
|
|
goto out;
|
|
|
}
|
|
}
|
|
@@ -2985,7 +2982,7 @@ static void discard_stale(void)
|
|
|
if (stale) {
|
|
if (stale) {
|
|
|
applog(LOG_DEBUG, "Discarded %d stales that didn't match current hash", stale);
|
|
applog(LOG_DEBUG, "Discarded %d stales that didn't match current hash", stale);
|
|
|
while (stale-- > 0)
|
|
while (stale-- > 0)
|
|
|
- queue_request(NULL, false);
|
|
|
|
|
|
|
+ queue_request(false);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -4319,7 +4316,7 @@ static void pool_resus(struct pool *pool)
|
|
|
switch_pools(NULL);
|
|
switch_pools(NULL);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-static bool queue_request(struct thr_info *thr, bool needed)
|
|
|
|
|
|
|
+static bool queue_request(bool needed)
|
|
|
{
|
|
{
|
|
|
int ts, tq, maxq = opt_queue + mining_threads;
|
|
int ts, tq, maxq = opt_queue + mining_threads;
|
|
|
struct pool *pool, *cp;
|
|
struct pool *pool, *cp;
|
|
@@ -4348,7 +4345,6 @@ static bool queue_request(struct thr_info *thr, bool needed)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
wc->cmd = WC_GET_WORK;
|
|
wc->cmd = WC_GET_WORK;
|
|
|
- wc->thr = thr;
|
|
|
|
|
wc->pool = pool;
|
|
wc->pool = pool;
|
|
|
wc->needed = needed;
|
|
wc->needed = needed;
|
|
|
|
|
|
|
@@ -4391,7 +4387,7 @@ static struct work *hash_pop(const struct timespec *abstime)
|
|
|
}
|
|
}
|
|
|
mutex_unlock(stgd_lock);
|
|
mutex_unlock(stgd_lock);
|
|
|
|
|
|
|
|
- queue_request(NULL, false);
|
|
|
|
|
|
|
+ queue_request(false);
|
|
|
|
|
|
|
|
return work;
|
|
return work;
|
|
|
}
|
|
}
|
|
@@ -6257,7 +6253,7 @@ begin_bench:
|
|
|
#endif
|
|
#endif
|
|
|
|
|
|
|
|
for (i = 0; i < mining_threads + opt_queue; i++)
|
|
for (i = 0; i < mining_threads + opt_queue; i++)
|
|
|
- queue_request(NULL, false);
|
|
|
|
|
|
|
+ queue_request(false);
|
|
|
|
|
|
|
|
/* main loop - simply wait for workio thread to exit. This is not the
|
|
/* main loop - simply wait for workio thread to exit. This is not the
|
|
|
* normal exit path and only occurs should the workio_thread die
|
|
* normal exit path and only occurs should the workio_thread die
|