diff --git a/src/generator.c b/src/generator.c index 8236d609..62e4ed89 100644 --- a/src/generator.c +++ b/src/generator.c @@ -1384,7 +1384,6 @@ static void submit_share(gdata_t *gdata, json_t *val) if (!proxi->alive) { LOGNOTICE("Client %"PRId64" attempting to send shares to dead proxy %d:%d, dropping", client_id, id, subid); - send_stratifier_deadproxy(ckp, id, subid); stratifier_reconnect_client(ckp, client_id); return json_decref(val); } diff --git a/src/stratifier.c b/src/stratifier.c index 54a31a9f..89d2d852 100644 --- a/src/stratifier.c +++ b/src/stratifier.c @@ -2209,7 +2209,8 @@ static void lazy_reconnect_client(sdata_t *sdata, stratum_instance_t *client) if (!client->reconnect) { LOGNOTICE("Flagging client %"PRId64, client->id); client->reconnect = true; - } + } else /* Already been flagged, force the send */ + reconnect_client(sdata, client); } }