From 0d8b8793b5482cd14ee8abef1fc0b23f619fbbf5 Mon Sep 17 00:00:00 2001 From: Con Kolivas Date: Tue, 19 Jul 2011 17:00:56 +1000 Subject: [PATCH] Reset the queued count to allow more work to be queued for the new pool on pool switch. --- main.c | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/main.c b/main.c index 10a92b90..a2674a9c 100644 --- a/main.c +++ b/main.c @@ -271,6 +271,11 @@ static void switch_pools(void) gettimeofday(¤tpool->tv_localgen, NULL); applog(LOG_WARNING, "Prolonged outage. Attempting to switch to %s", currentpool->rpc_url); pthread_mutex_unlock(&control_lock); + + /* Reset the queued amount to allow more to be queued for the new pool */ + pthread_mutex_lock(&qd_lock); + total_queued = 0; + pthread_mutex_unlock(&qd_lock); } /* FIXME: Use asprintf for better errors. */