mempool/ckpool
mempool/ckpool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Clear notifies completely including the ram and discard all notifies on reconnect

Browse Source
This commit is contained in:
Con Kolivas 2014-05-20 12:21:32 +10:00
parent b33e44c0fe
commit acfa048991
1 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/generator.c
View File

@ -809,11 +809,28 @@ out:
return ret;
}
static void clear_notify(notify_instance_t *ni)
{
free(ni->jobid);
free(ni->coinbase1);
free(ni->coinbase2);
free(ni);
}
static void reconnect_stratum(connsock_t *cs, proxy_instance_t *proxi)
{
notify_instance_t *ni, *tmp;
ckpool_t *ckp = proxi->ckp;
bool ret = true;
/* All our notify data is invalid if we reconnect so discard them */
mutex_lock(&proxi->notify_lock);
HASH_ITER(hh, proxi->notify_instances, ni, tmp) {
HASH_DEL(proxi->notify_instances, ni);
clear_notify(ni);
}
mutex_unlock(&proxi->notify_lock);
do {
if (!ret)
sleep(5);
@ -824,16 +841,9 @@ static void reconnect_stratum(connsock_t *cs, proxy_instance_t *proxi)
ret = subscribe_stratum(cs, proxi);
if (!ret)
continue;
send_proc(ckp->stratifier, "subscribe");
ret = auth_stratum(cs, proxi);
} while (!ret);
}
static void clear_notify(notify_instance_t *ni)
{
free(ni->jobid);
free(ni->coinbase1);
free(ni->coinbase2);
send_proc(ckp->stratifier, "subscribe");
}
/* FIXME: Return something useful to the stratifier based on this result */