LBRYFoundation/pool
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/pool.git synced 2025-08-23 17:37:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update job.cpp

Browse source
This commit is contained in:
Ralph 2024-03-01 15:51:47 -05:00 • committed by GitHub
parent 370b84b9d1
commit 94d8a35a1d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 234 additions and 233 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

467
stratum/job.cpp
View file

@ -5,224 +5,224 @@
//debuglog(" returning %x, %s, %s\n", job->id, client->sock->ip, #condition); \ //debuglog(" returning %x, %s, %s\n", job->id, client->sock->ip, #condition); \
#define RETURN_ON_CONDITION(condition, ret) \ #define RETURN_ON_CONDITION(condition, ret) \
if(condition) \ if(condition) \
{ \ { \
return ret; \ return ret; \
} }
static bool job_assign_client(YAAMP_JOB *job, YAAMP_CLIENT *client, double maxhash) static bool job_assign_client(YAAMP_JOB *job, YAAMP_CLIENT *client, double maxhash)
{ {
RETURN_ON_CONDITION(client->deleted, true); RETURN_ON_CONDITION(client->deleted, true);
RETURN_ON_CONDITION(client->jobid_next, true); RETURN_ON_CONDITION(client->jobid_next, true);
RETURN_ON_CONDITION(client->jobid_locked && client->jobid_locked != job->id, true); RETURN_ON_CONDITION(client->jobid_locked && client->jobid_locked != job->id, true);
RETURN_ON_CONDITION(client_find_job_history(client, job->id), true); RETURN_ON_CONDITION(client_find_job_history(client, job->id), true);
RETURN_ON_CONDITION(maxhash > 0 && job->speed + client->speed > maxhash, true); RETURN_ON_CONDITION(maxhash > 0 && job->speed + client->speed > maxhash, true);
if(!g_autoexchange && maxhash >= 0. && client->coinid != job->coind->id) { if(!g_autoexchange && maxhash >= 0. && client->coinid != job->coind->id) {
//debuglog("prevent client %c on %s, not the right coin\n", //debuglog("prevent client %c on %s, not the right coin\n",
// client->username[0], job->coind->symbol); // client->username[0], job->coind->symbol);
return true; return true;
} }
if(job->remote) if(job->remote)
{ {
YAAMP_REMOTE *remote = job->remote; YAAMP_REMOTE *remote = job->remote;
if(g_stratum_reconnect) if(g_stratum_reconnect)
{RETURN_ON_CONDITION(!client->extranonce_subscribe && !client->reconnectable, true);} {RETURN_ON_CONDITION(!client->extranonce_subscribe && !client->reconnectable, true);}
else else
{RETURN_ON_CONDITION(!client->extranonce_subscribe, true);} {RETURN_ON_CONDITION(!client->extranonce_subscribe, true);}
RETURN_ON_CONDITION(client->reconnecting, true); RETURN_ON_CONDITION(client->reconnecting, true);
RETURN_ON_CONDITION(job->count >= YAAMP_JOB_MAXSUBIDS, false); RETURN_ON_CONDITION(job->count >= YAAMP_JOB_MAXSUBIDS, false);
// RETURN_ON_CONDITION(client->difficulty_actual > remote->difficulty_actual, false); // RETURN_ON_CONDITION(client->difficulty_actual > remote->difficulty_actual, false);
double difficulty_remote = client->difficulty_remote; double difficulty_remote = client->difficulty_remote;
if(remote->difficulty_actual < client->difficulty_actual) if(remote->difficulty_actual < client->difficulty_actual)
{ {
RETURN_ON_CONDITION(client->difficulty_fixed, true); RETURN_ON_CONDITION(client->difficulty_fixed, true);
RETURN_ON_CONDITION(remote->difficulty_actual*4 < client->difficulty_actual, true); RETURN_ON_CONDITION(remote->difficulty_actual*4 < client->difficulty_actual, true);
difficulty_remote = remote->difficulty_actual; difficulty_remote = remote->difficulty_actual;
} }
else if(remote->difficulty_actual > client->difficulty_actual) else if(remote->difficulty_actual > client->difficulty_actual)
difficulty_remote = 0; difficulty_remote = 0;
if(remote->nonce2size == 2) if(remote->nonce2size == 2)
{ {
RETURN_ON_CONDITION(job->count > 0, false); RETURN_ON_CONDITION(job->count > 0, false);
strcpy(client->extranonce1, remote->nonce1); strcpy(client->extranonce1, remote->nonce1);
client->extranonce2size = 2; client->extranonce2size = 2;
} }
else if(job->id != client->jobid_sent) else if(job->id != client->jobid_sent)
{ {
if(!job->remote_subids[client->extranonce1_id]) if(!job->remote_subids[client->extranonce1_id])
job->remote_subids[client->extranonce1_id] = true; job->remote_subids[client->extranonce1_id] = true;
else else
{ {
int i=0; int i=0;
for(; i<YAAMP_JOB_MAXSUBIDS; i++) if(!job->remote_subids[i]) for(; i<YAAMP_JOB_MAXSUBIDS; i++) if(!job->remote_subids[i])
{ {
job->remote_subids[i] = true; job->remote_subids[i] = true;
client->extranonce1_id = i; client->extranonce1_id = i;
break; break;
} }
RETURN_ON_CONDITION(i == YAAMP_JOB_MAXSUBIDS, false); RETURN_ON_CONDITION(i == YAAMP_JOB_MAXSUBIDS, false);
} }
sprintf(client->extranonce1, "%s%02x", remote->nonce1, client->extranonce1_id); sprintf(client->extranonce1, "%s%02x", remote->nonce1, client->extranonce1_id);
client->extranonce2size = remote->nonce2size-1; client->extranonce2size = remote->nonce2size-1;
client->difficulty_remote = difficulty_remote; client->difficulty_remote = difficulty_remote;
} }
client->jobid_locked = job->id; client->jobid_locked = job->id;
} }
else else
{ {
strcpy(client->extranonce1, client->extranonce1_default); strcpy(client->extranonce1, client->extranonce1_default);
client->extranonce2size = client->extranonce2size_default; client->extranonce2size = client->extranonce2size_default;
// decred uses an extradata field in block header, 2 first uint32 are set by the miner // decred uses an extradata field in block header, 2 first uint32 are set by the miner
if (g_current_algo->name && !strcmp(g_current_algo->name,"decred")) { if (g_current_algo->name && !strcmp(g_current_algo->name,"decred")) {
memset(client->extranonce1, '0', sizeof(client->extranonce1)); memset(client->extranonce1, '0', sizeof(client->extranonce1));
memcpy(&client->extranonce1[16], client->extranonce1_default, 8); memcpy(&client->extranonce1[16], client->extranonce1_default, 8);
client->extranonce1[24] = '\0'; client->extranonce1[24] = '\0';
} }
client->difficulty_remote = 0; client->difficulty_remote = 0;
client->jobid_locked = 0; client->jobid_locked = 0;
} }
client->jobid_next = job->id; client->jobid_next = job->id;
job->speed += client->speed; job->speed += client->speed;
job->count++; job->count++;
// debuglog(" assign %x, %f, %d, %s\n", job->id, client->speed, client->reconnecting, client->sock->ip); // debuglog(" assign %x, %f, %d, %s\n", job->id, client->speed, client->reconnecting, client->sock->ip);
if(strcmp(client->extranonce1, client->extranonce1_last) || client->extranonce2size != client->extranonce2size_last) if(strcmp(client->extranonce1, client->extranonce1_last) || client->extranonce2size != client->extranonce2size_last)
{ {
// debuglog("new nonce %x %s %s\n", job->id, client->extranonce1_last, client->extranonce1); // debuglog("new nonce %x %s %s\n", job->id, client->extranonce1_last, client->extranonce1);
if(!client->extranonce_subscribe) if(!client->extranonce_subscribe)
{ {
strcpy(client->extranonce1_reconnect, client->extranonce1); strcpy(client->extranonce1_reconnect, client->extranonce1);
client->extranonce2size_reconnect = client->extranonce2size; client->extranonce2size_reconnect = client->extranonce2size;
strcpy(client->extranonce1, client->extranonce1_default); strcpy(client->extranonce1, client->extranonce1_default);
client->extranonce2size = client->extranonce2size_default; client->extranonce2size = client->extranonce2size_default;
client->reconnecting = true; client->reconnecting = true;
client->lock_count++; client->lock_count++;
client->unlock = true; client->unlock = true;
client->jobid_sent = client->jobid_next; client->jobid_sent = client->jobid_next;
socket_send(client->sock, "{\"id\":null,\"method\":\"client.reconnect\",\"params\":[\"%s\",%d,0]}\n", g_tcp_server, g_tcp_port); socket_send(client->sock, "{\"id\":null,\"method\":\"client.reconnect\",\"params\":[\"%s\",%d,0]}\n", g_tcp_server, g_tcp_port);
} }
else else
{ {
strcpy(client->extranonce1_last, client->extranonce1); strcpy(client->extranonce1_last, client->extranonce1);
client->extranonce2size_last = client->extranonce2size; client->extranonce2size_last = client->extranonce2size;
socket_send(client->sock, "{\"id\":null,\"method\":\"mining.set_extranonce\",\"params\":[\"%s\",%d]}\n", socket_send(client->sock, "{\"id\":null,\"method\":\"mining.set_extranonce\",\"params\":[\"%s\",%d]}\n",
client->extranonce1, client->extranonce2size); client->extranonce1, client->extranonce2size);
} }
} }
return true; return true;
} }
void job_assign_clients(YAAMP_JOB *job, double maxhash) void job_assign_clients(YAAMP_JOB *job, double maxhash)
{ {
if (!job) return; if (!job) return;
job->speed = 0; job->speed = 0;
job->count = 0; job->count = 0;
g_list_client.Enter(); g_list_client.Enter();
// pass0 locked // pass0 locked
for(CLI li = g_list_client.first; li; li = li->next) for(CLI li = g_list_client.first; li; li = li->next)
{ {
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data; YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->jobid_locked && client->jobid_locked != job->id) continue; if(client->jobid_locked && client->jobid_locked != job->id) continue;
bool b = job_assign_client(job, client, maxhash); bool b = job_assign_client(job, client, maxhash);
if(!b) break; if(!b) break;
} }
// pass1 sent // pass1 sent
for(CLI li = g_list_client.first; li; li = li->next) for(CLI li = g_list_client.first; li; li = li->next)
{ {
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data; YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->jobid_sent != job->id) continue; if(client->jobid_sent != job->id) continue;
bool b = job_assign_client(job, client, maxhash); bool b = job_assign_client(job, client, maxhash);
if(!b) break; if(!b) break;
} }
// pass2 extranonce_subscribe // pass2 extranonce_subscribe
if(job->remote) for(CLI li = g_list_client.first; li; li = li->next) if(job->remote) for(CLI li = g_list_client.first; li; li = li->next)
{ {
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data; YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(!client->extranonce_subscribe) continue; if(!client->extranonce_subscribe) continue;
bool b = job_assign_client(job, client, maxhash); bool b = job_assign_client(job, client, maxhash);
if(!b) break; if(!b) break;
} }
// pass3 the rest // pass3 the rest
for(CLI li = g_list_client.first; li; li = li->next) for(CLI li = g_list_client.first; li; li = li->next)
{ {
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data; YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
bool b = job_assign_client(job, client, maxhash); bool b = job_assign_client(job, client, maxhash);
if(!b) break; if(!b) break;
} }
g_list_client.Leave(); g_list_client.Leave();
} }
void job_assign_clients_left(double factor) void job_assign_clients_left(double factor)
{ {
bool b; bool b;
for(CLI li = g_list_coind.first; li; li = li->next) for(CLI li = g_list_coind.first; li; li = li->next)
{ {
if(!job_has_free_client()) return; if(!job_has_free_client()) return;
YAAMP_COIND *coind = (YAAMP_COIND *)li->data; YAAMP_COIND *coind = (YAAMP_COIND *)li->data;
if(!coind_can_mine(coind)) continue; if(!coind_can_mine(coind)) continue;
if(!coind->job) continue; if(!coind->job) continue;
double nethash = coind_nethash(coind); double nethash = coind_nethash(coind);
g_list_client.Enter(); g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next) for(CLI li = g_list_client.first; li; li = li->next)
{ {
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data; YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if (!g_autoexchange) { if (!g_autoexchange) {
if (client->coinid == coind->id) if (client->coinid == coind->id)
factor = 100.; factor = 100.;
else else
factor = 0.; factor = 0.;
} }
//debuglog("%s %s factor %f nethash %.3f\n", coind->symbol, client->username, factor, nethash); //debuglog("%s %s factor %f nethash %.3f\n", coind->symbol, client->username, factor, nethash);
if (factor > 0.) { if (factor > 0.) {
b = job_assign_client(coind->job, client, nethash*factor); b = job_assign_client(coind->job, client, nethash*factor);
if(!b) break; if(!b) break;
} }
} }
g_list_client.Leave(); g_list_client.Leave();
} }
} }
//////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////
@ -232,112 +232,114 @@ pthread_cond_t g_job_cond;
void *job_thread(void *p) void *job_thread(void *p)
{ {
CommonLock(&g_job_mutex); CommonLock(&g_job_mutex);
while(!g_exiting) while(!g_exiting)
{ {
job_update(); job_update();
pthread_cond_wait(&g_job_cond, &g_job_mutex); pthread_cond_wait(&g_job_cond, &g_job_mutex);
} }
} }
void job_init() void job_init()
{ {
pthread_mutex_init(&g_job_mutex, 0); pthread_mutex_init(&g_job_mutex, 0);
pthread_cond_init(&g_job_cond, 0); pthread_cond_init(&g_job_cond, 0);
pthread_t thread3; pthread_t thread3;
pthread_create(&thread3, NULL, job_thread, NULL); pthread_create(&thread3, NULL, job_thread, NULL);
} }
void job_signal() void job_signal()
{ {
CommonLock(&g_job_mutex); CommonLock(&g_job_mutex);
pthread_cond_signal(&g_job_cond); pthread_cond_signal(&g_job_cond);
CommonUnlock(&g_job_mutex); CommonUnlock(&g_job_mutex);
} }
void job_update() void job_update()
{ {
// debuglog("job_update()\n"); // debuglog("job_update()\n");
job_reset_clients(); job_reset_clients();
////////////////////////////////////////////////////////////////////////////////////////////////////// //////////////////////////////////////////////////////////////////////////////////////////////////////
g_list_job.Enter(); g_list_job.Enter();
job_sort(); job_sort();
for(CLI li = g_list_job.first; li; li = li->next) for(CLI li = g_list_job.first; li; li = li->next)
{ {
YAAMP_JOB *job = (YAAMP_JOB *)li->data; YAAMP_JOB *job = (YAAMP_JOB *)li->data;
if(!job_can_mine(job)) continue; if(!job_can_mine(job)) continue;
job_assign_clients(job, job->maxspeed); job_assign_clients(job, job->maxspeed);
job_unlock_clients(job); job_unlock_clients(job);
if(!job_has_free_client()) break; if(!job_has_free_client()) break;
} }
job_unlock_clients(); job_unlock_clients();
g_list_job.Leave(); g_list_job.Leave();
//////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////
g_list_coind.Enter(); g_list_coind.Enter();
coind_sort(); coind_sort();
job_assign_clients_left(1); job_assign_clients_left(1);
job_assign_clients_left(1); job_assign_clients_left(1);
job_assign_clients_left(-1); job_assign_clients_left(-1);
g_list_coind.Leave(); g_list_coind.Leave();
//////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////
g_list_client.Enter(); g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next) for(CLI li = g_list_client.first; li; li = li->next)
{ {
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data; YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->deleted) continue; if(client->deleted) continue;
if(client->jobid_next) continue; if(client->jobid_next) continue;
debuglog("clients with no job\n"); debuglog("clients with no job\n");
g_current_algo->overflow = true; g_current_algo->overflow = true;
if(!g_list_coind.first) break; if(!g_list_coind.first) break;
// here: todo: choose first can mine // here: todo: choose first can mine
YAAMP_COIND *coind = (YAAMP_COIND *)g_list_coind.first->data; YAAMP_COIND *coind = (YAAMP_COIND *)g_list_coind.first->data;
if(!coind) break; if(!coind) break;
job_reset_clients(coind->job); job_reset_clients(coind->job);
coind_create_job(coind, true); coind_create_job(coind, true);
job_assign_clients(coind->job, -1); job_assign_clients(coind->job, -1);
break; break;
} }
g_list_client.Leave(); g_list_client.Leave();
//////////////////////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////////////////////
// usleep(100*YAAMP_MS); // usleep(100*YAAMP_MS);
// int ready = 0; int ready = 0;
// debuglog("job_update\n"); debuglog("job_update\n");
g_list_job.Enter(); g_list_job.Enter();
for(CLI li = g_list_job.first; li; li = li->next) for(CLI li = g_list_job.first; li; li = li->next)
{ {
YAAMP_JOB *job = (YAAMP_JOB *)li->data; debuglog("entered job CLI for loop\n");
if(!job_can_mine(job)) continue; YAAMP_JOB *job = (YAAMP_JOB *)li->data;
debuglog("Printing YAAMP_JOB *job value: ",job,"\n");
if(!job_can_mine(job)) continue;
debuglog("ready to broadcast job\n");
job_broadcast(job);
ready++;
}
job_broadcast(job); debuglog("job_update %d / %d jobs\n", ready, g_list_job.count);
// ready++; g_list_job.Leave();
}
// debuglog("job_update %d / %d jobs\n", ready, g_list_job.count);
g_list_job.Leave();
} }
@ -347,4 +349,3 @@ void job_update()