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

Update job_core.cpp

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

165
stratum/job_core.cpp
View file

@ -3,130 +3,135 @@
void job_sort()
{
for(CLI li = g_list_job.first; li && li->next; li = li->next)
{
YAAMP_JOB *job1 = (YAAMP_JOB *)li->data;
YAAMP_JOB *job2 = (YAAMP_JOB *)li->next->data;
for(CLI li = g_list_job.first; li && li->next; li = li->next)
{
YAAMP_JOB *job1 = (YAAMP_JOB *)li->data;
YAAMP_JOB *job2 = (YAAMP_JOB *)li->next->data;
if(job1->profit < job2->profit)
{
g_list_job.Swap(li, li->next);
job_sort();
if(job1->profit < job2->profit)
{
g_list_job.Swap(li, li->next);
job_sort();
return;
}
}
return;
}
}
}
bool job_has_free_client()
{
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->deleted) continue;
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->deleted) continue;
if(!client->jobid_next)
{
g_list_client.Leave();
return true;
}
}
if(!client->jobid_next)
{
g_list_client.Leave();
return true;
}
}
g_list_client.Leave();
return false;
g_list_client.Leave();
return false;
}
void job_reset_clients(YAAMP_JOB *job)
{
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->deleted) continue;
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->deleted) continue;
if(!job || job->id == client->jobid_next)
client->jobid_next = 0;
}
if(!job || job->id == client->jobid_next)
client->jobid_next = 0;
}
g_list_client.Leave();
g_list_client.Leave();
}
void job_relock_clients(int jobid_old, int jobid_new)
{
if(!jobid_old || !jobid_new) return;
if(!jobid_old || !jobid_new) return;
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->jobid_locked != jobid_old) continue;
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->jobid_locked != jobid_old) continue;
// debuglog("relock job %x to %x\n", client->jobid_locked, jobid_new);
client->jobid_locked = jobid_new;
}
// debuglog("relock job %x to %x\n", client->jobid_locked, jobid_new);
client->jobid_locked = jobid_new;
}
g_list_client.Leave();
g_list_client.Leave();
}
void job_assign_locked_clients(YAAMP_JOB *job)
{
if(!job) return;
if(!job) return;
job->speed = 0;
job->count = 0;
job->speed = 0;
job->count = 0;
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->jobid_locked != job->id) continue;
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->jobid_locked != job->id) continue;
// debuglog("assign job %x %x\n", client->jobid_locked, job->id);
// debuglog("assign job %x %x\n", client->jobid_locked, job->id);
client->jobid_next = job->id;
job->remote_subids[client->extranonce1_id] = true;
client->jobid_next = job->id;
job->remote_subids[client->extranonce1_id] = true;
job->speed += client->speed;
job->count++;
}
job->speed += client->speed;
job->count++;
}
g_list_client.Leave();
g_list_client.Leave();
}
void job_unlock_clients(YAAMP_JOB *job)
{
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->deleted) continue;
if(!client->jobid_locked) continue;
if(client->jobid_locked == client->jobid_next) continue;
if(job && client->jobid_locked != job->id) continue;
g_list_client.Enter();
for(CLI li = g_list_client.first; li; li = li->next)
{
YAAMP_CLIENT *client = (YAAMP_CLIENT *)li->data;
if(client->deleted) continue;
if(!client->jobid_locked) continue;
if(client->jobid_locked == client->jobid_next) continue;
if(job && client->jobid_locked != job->id) continue;
// debuglog("unlock job %x %x\n", client->jobid_locked, job->id);
client->jobid_locked = 0;
}
// debuglog("unlock job %x %x\n", client->jobid_locked, job->id);
client->jobid_locked = 0;
}
g_list_client.Leave();
g_list_client.Leave();
}
bool job_can_mine(YAAMP_JOB *job)
{
if(job->deleted) return false;
if(job->remote)
return remote_can_mine(job->remote);
else if(job->coind)
return coind_can_mine(job->coind);
return false;
if(job->deleted) {
debuglog("Job was deleted\n");
return false;
}
if(job->remote) {
debuglog("job is remote?\n");
return remote_can_mine(job->remote);
}
else if(job->coind) {
debuglog("job is coind\n");
return coind_can_mine(job->coind);
} else {
debuglog("returning false for job_can_mine\n");
return false;
}
}