From 31a5e3d5cec22e8495a6d3e0993b9241a129a930 Mon Sep 17 00:00:00 2001 From: Con Kolivas Date: Fri, 13 Feb 2015 16:28:59 +1100 Subject: [PATCH] Delete the subproxy entry in the share after sending it to the proxy send thread --- src/generator.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/generator.c b/src/generator.c index 1e7f7965..340e9a88 100644 --- a/src/generator.c +++ b/src/generator.c @@ -1281,7 +1281,6 @@ static void submit_share(gdata_t *gdata, json_t *val) return json_decref(val); } json_get_int(&subid, val, "subproxy"); - json_object_del(val, "subproxy"); proxi = subproxy_by_id(proxy, subid); if (unlikely(!proxi)) { LOGWARNING("Failed to find subproxy %d to send share to", subid); @@ -1390,6 +1389,7 @@ static void *proxy_send(void *arg) continue; json_get_int(&subid, msg->json_msg, "subproxy"); + json_object_del(msg->json_msg, "subproxy"); json_uintcpy(&id, msg->json_msg, "jobid"); mutex_lock(&proxy->notify_lock);