diff --git a/src/generator.c b/src/generator.c index 04d36d2c..e0bbce89 100644 --- a/src/generator.c +++ b/src/generator.c @@ -188,7 +188,6 @@ struct generator_data { int subproxies_generated; int proxy_notify_id; // Globally increasing notify id - server_instance_t *si; /* Current server instance */ pthread_t pth_uprecv; // User proxy receive thread pthread_t pth_psend; // Combined proxy send thread @@ -205,7 +204,7 @@ struct generator_data { share_msg_t *shares; int64_t share_id; - server_instance_t *current_si; + server_instance_t *current_si; // Current server instance proxy_instance_t *current_proxy; }; @@ -3378,10 +3377,8 @@ static void *server_watchdog(void *arg) if (server_alive(ckp, si, true) && !best) best = si; } - if (best && best != gdata->si) { - gdata->si = best; + if (best && best != gdata->current_si) send_proc(ckp->generator, "reconnect"); - } cksleep_ms_r(&timer_t, 5000); } return NULL;