Browse Source

Fill enonce1 data properly for stratum reconnect support

master
Con Kolivas 10 years ago
parent
commit
98bf62ab67
  1. 20
      src/stratifier.c

20
src/stratifier.c

@ -1584,6 +1584,16 @@ out:
return ret; return ret;
} }
/* Enter holding workbase_lock */
static void __fill_enonce1data(workbase_t *wb, stratum_instance_t *client)
{
if (wb->enonce1constlen)
memcpy(client->enonce1bin, wb->enonce1constbin, wb->enonce1constlen);
memcpy(client->enonce1bin + wb->enonce1constlen, &client->enonce1_64, wb->enonce1varlen);
__bin2hex(client->enonce1var, &client->enonce1_64, wb->enonce1varlen);
__bin2hex(client->enonce1, client->enonce1bin, wb->enonce1constlen + wb->enonce1varlen);
}
/* Create a new enonce1 from the 64 bit enonce1_64 value, using only the number /* Create a new enonce1 from the 64 bit enonce1_64 value, using only the number
* of bytes we have to work with when we are proxying with a split nonce2. * of bytes we have to work with when we are proxying with a split nonce2.
* When the proxy space is less than 32 bits to work with, we look for an * When the proxy space is less than 32 bits to work with, we look for an
@ -1632,11 +1642,7 @@ static bool new_enonce1(stratum_instance_t *client)
} }
if (ret) if (ret)
client->enonce1_64 = sdata->enonce1u.u64; client->enonce1_64 = sdata->enonce1u.u64;
if (wb->enonce1constlen) __fill_enonce1data(wb, client);
memcpy(client->enonce1bin, wb->enonce1constbin, wb->enonce1constlen);
memcpy(client->enonce1bin + wb->enonce1constlen, &client->enonce1_64, wb->enonce1varlen);
__bin2hex(client->enonce1var, &client->enonce1_64, wb->enonce1varlen);
__bin2hex(client->enonce1, client->enonce1bin, wb->enonce1constlen + wb->enonce1varlen);
ck_wunlock(&sdata->workbase_lock); ck_wunlock(&sdata->workbase_lock);
if (unlikely(!ret)) if (unlikely(!ret))
@ -1685,6 +1691,10 @@ static json_t *parse_subscribe(stratum_instance_t *client, int64_t client_id, js
if (disconnected_sessionid_exists(sdata, buf, client_id)) { if (disconnected_sessionid_exists(sdata, buf, client_id)) {
sprintf(client->enonce1, "%016lx", client->enonce1_64); sprintf(client->enonce1, "%016lx", client->enonce1_64);
old_match = true; old_match = true;
ck_rlock(&sdata->workbase_lock);
__fill_enonce1data(sdata->current_workbase, client);
ck_runlock(&sdata->workbase_lock);
} }
} }
} else } else

Loading…
Cancel
Save