mirror of
https://github.com/LBRYFoundation/pool.git
synced 2025-08-23 17:37:25 +00:00
162 lines
4 KiB
C++
162 lines
4 KiB
C++
|
|
#include "stratum.h"
|
|
|
|
static int g_job_next_id = 0;
|
|
|
|
int job_get_jobid()
|
|
{
|
|
CommonLock(&g_job_create_mutex);
|
|
int jobid = ++g_job_next_id;
|
|
|
|
CommonUnlock(&g_job_create_mutex);
|
|
return jobid;
|
|
}
|
|
|
|
static void job_mining_notify_buffer(YAAMP_JOB *job, char *buffer)
|
|
{
|
|
YAAMP_JOB_TEMPLATE *templ = job->templ;
|
|
|
|
sprintf(buffer, "{\"id\":null,\"method\":\"mining.notify\",\"params\":[\"%x\",\"%s\",\"%s\",\"%s\",[%s],\"%s\",\"%s\",\"%s\",true]}\n",
|
|
job->id, templ->prevhash_be, templ->coinb1, templ->coinb2, templ->txmerkles, templ->version, templ->nbits, templ->ntime);
|
|
}
|
|
|
|
static YAAMP_JOB *job_get_last()
|
|
{
|
|
g_list_job.Enter();
|
|
for(CLI li = g_list_job.first; li; li = li->prev)
|
|
{
|
|
YAAMP_JOB *job = (YAAMP_JOB *)li->data;
|
|
if(!job_can_mine(job)) continue;
|
|
if(!job->coind) continue;
|
|
|
|
g_list_job.Leave();
|
|
return job;
|
|
}
|
|
|
|
g_list_job.Leave();
|
|
return NULL;
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
void job_send_last(YAAMP_CLIENT *client)
|
|
{
|
|
YAAMP_JOB *job = job_get_last();
|
|
if(!job) return;
|
|
|
|
YAAMP_JOB_TEMPLATE *templ = job->templ;
|
|
client->jobid_sent = job->id;
|
|
|
|
char buffer[YAAMP_SMALLBUFSIZE];
|
|
job_mining_notify_buffer(job, buffer);
|
|
|
|
socket_send_raw(client->sock, buffer, strlen(buffer));
|
|
}
|
|
|
|
void job_send_jobid(YAAMP_CLIENT *client, int jobid)
|
|
{
|
|
YAAMP_JOB *job = (YAAMP_JOB *)object_find(&g_list_job, jobid, true);
|
|
if(!job)
|
|
{
|
|
job_send_last(client);
|
|
return;
|
|
}
|
|
|
|
char buffer[YAAMP_SMALLBUFSIZE];
|
|
job_mining_notify_buffer(job, buffer);
|
|
|
|
YAAMP_JOB_TEMPLATE *templ = job->templ;
|
|
client->jobid_sent = job->id;
|
|
|
|
socket_send_raw(client->sock, buffer, strlen(buffer));
|
|
object_unlock(job);
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
void job_broadcast(YAAMP_JOB *job)
|
|
{
|
|
int s1 = current_timestamp();
|
|
int count = 0;
|
|
|
|
YAAMP_JOB_TEMPLATE *templ = job->templ;
|
|
|
|
char buffer[YAAMP_SMALLBUFSIZE];
|
|
job_mining_notify_buffer(job, buffer);
|
|
|
|
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->reconnecting && client->locked) continue;
|
|
|
|
if(client->jobid_next != job->id) continue;
|
|
if(client->jobid_sent == job->id) continue;
|
|
|
|
client->jobid_sent = job->id;
|
|
client_add_job_history(client, job->id);
|
|
|
|
client_adjust_difficulty(client);
|
|
|
|
socket_send_raw(client->sock, buffer, strlen(buffer));
|
|
count++;
|
|
}
|
|
|
|
g_list_client.Leave();
|
|
g_last_broadcasted = time(NULL);
|
|
|
|
int s2 = current_timestamp();
|
|
if(!count) return;
|
|
|
|
///////////////////////
|
|
|
|
uint64_t coin_target = decode_compact(templ->nbits);
|
|
double coin_diff = target_to_diff(coin_target);
|
|
|
|
debuglog("%s %d - diff %.9f job %x to %d/%d/%d clients, hash %.3f/%.3f in %d ms\n", job->name,
|
|
templ->height, coin_diff, job->id, count, job->count, g_list_client.count, job->speed, job->maxspeed, s2-s1);
|
|
|
|
// for(int i=0; i<templ->auxs_size; i++)
|
|
// {
|
|
// if(!templ->auxs[i]) continue;
|
|
// YAAMP_COIND *coind_aux = templ->auxs[i]->coind;
|
|
//
|
|
// unsigned char target_aux[1024];
|
|
// binlify(target_aux, coind_aux->aux.target);
|
|
//
|
|
// uint64_t coin_target = get_hash_difficulty(target_aux);
|
|
// double coin_diff = target_to_diff(coin_target);
|
|
//
|
|
// debuglog("%s %d - diff %.9f chainid %d [%d]\n", coind_aux->symbol, coind_aux->height, coin_diff,
|
|
// coind_aux->aux.chainid, coind_aux->aux.index);
|
|
// }
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// double maxhash = 0;
|
|
// if(job->remote)
|
|
// {
|
|
// sprintf(name, "JOB%d%s (%.3f)", job->remote->id, job->remote->nonce2size == 2? "*": "", job->remote->speed_avg);
|
|
// maxhash = job->remote->speed;
|
|
// }
|
|
// else
|
|
// {
|
|
// strcpy(name, job->coind->symbol);
|
|
// for(int i=0; i<templ->auxs_size; i++)
|
|
// {
|
|
// if(!templ->auxs[i]) continue;
|
|
// YAAMP_COIND *coind_aux = templ->auxs[i]->coind;
|
|
//
|
|
// sprintf(name_auxs+strlen(name_auxs), ", %s %d", coind_aux->symbol, templ->auxs[i]->height);
|
|
// }
|
|
//
|
|
// maxhash = coind_nethash(job->coind)*coind_profitability(job->coind)/(g_current_algo->profit? g_current_algo->profit: 1);
|
|
// }
|
|
|