d0s3t3ch/wownero-puddle
1
0
Fork 0
mirror of https://git.wownero.com/wownero/wownero-puddle.git synced 2024-08-15 01:03:20 +00:00
Code Issues Projects Releases Wiki Activity

edge: fix stats on upstream disconnect

Browse source
This commit is contained in:
Jethro Grassie 2020-05-30 16:01:56 -04:00
parent 66507021e0
commit d544a042ae
No known key found for this signature in database
GPG key ID: DE8ED755616565BB
1 changed files with 9 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/pool.c
View file

@ -287,6 +287,7 @@ static struct bufferevent *upstream_event;
static struct event *timer_10s; static struct event *timer_10s;
static time_t upstream_last_time; static time_t upstream_last_time;
static uint64_t upstream_last_height; static uint64_t upstream_last_height;
static uint32_t miner_count;
#ifdef HAVE_RX #ifdef HAVE_RX
extern void rx_stop_mining(); extern void rx_stop_mining();
@ -2576,6 +2577,12 @@ upstream_on_event(struct bufferevent *bev, short error, void *ctx)
{ {
log_debug("Upstream timeout"); log_debug("Upstream timeout");
} }
/* Update stats due to upstream disconnect */
if (pool_stats.connected_miners != miner_count)
{
pool_stats.connected_miners = miner_count;
update_pool_hr();
}
/* Wait and try to reconnect */ /* Wait and try to reconnect */
if (upstream_event) if (upstream_event)
{ {
@ -2690,6 +2697,7 @@ client_add(int fd, struct bufferevent *bev, bool downstream)
c->connected_since = time(NULL); c->connected_since = time(NULL);
c->downstream = downstream; c->downstream = downstream;
bstack_new(&c->active_jobs, CLIENT_JOBS_MAX, sizeof(job_t), job_recycle); bstack_new(&c->active_jobs, CLIENT_JOBS_MAX, sizeof(job_t), job_recycle);
miner_count++;
if (!downstream) if (!downstream)
pool_stats.connected_miners++; pool_stats.connected_miners++;
if (upstream_event) if (upstream_event)
@ -2733,6 +2741,7 @@ client_clear(struct bufferevent *bev)
bufferevent_free(bev); bufferevent_free(bev);
if (upstream_event) if (upstream_event)
upstream_send_client_disconnect(); upstream_send_client_disconnect();
miner_count--;
} }
static void static void