mirror of
https://github.com/LBRYFoundation/pool.git
synced 2025-09-20 01:09:48 +00:00
6d6fd9337f
blake (SFR) and whirlpool (J) tested ok with a sha256d merkleroot So add a stratum setting to allow single sha256 merkle root... The shares are now valid on the pool side, but remains to find an old wallet to test... like Whirlcoin or blakecoin keccak not tested, could have the same problem about merkle/miners
144 lines
3 KiB
C++
144 lines
3 KiB
C++
|
|
//struct YAAMP_SOURCE
|
|
//{
|
|
//public:
|
|
// int count;
|
|
// double speed;
|
|
//
|
|
// char ip[1024];
|
|
//};
|
|
|
|
struct YAAMP_ALGO
|
|
{
|
|
char name[1024];
|
|
YAAMP_HASH_FUNCTION hash_function;
|
|
|
|
double diff_multiplier;
|
|
double factor;
|
|
YAAMP_HASH_FUNCTION merkle_func;
|
|
|
|
double profit;
|
|
double rent;
|
|
|
|
bool overflow;
|
|
};
|
|
|
|
struct YAAMP_CLIENT_ALGO
|
|
{
|
|
double factor;
|
|
YAAMP_ALGO *algo;
|
|
};
|
|
|
|
#define YAAMP_JOB_MAXHISTORY 16
|
|
|
|
class YAAMP_CLIENT: public YAAMP_OBJECT
|
|
{
|
|
public:
|
|
YAAMP_SOCKET *sock;
|
|
// YAAMP_SOURCE *source;
|
|
|
|
char notify_id[1024];
|
|
|
|
int created;
|
|
int last_best;
|
|
|
|
bool reconnectable;
|
|
bool reconnecting;
|
|
|
|
int userid;
|
|
int workerid;
|
|
int coinid;
|
|
bool logtraffic;
|
|
|
|
int id_int;
|
|
const char *id_str;
|
|
|
|
char version[1024];
|
|
char username[1024];
|
|
char password[1024];
|
|
char worker[1024];
|
|
|
|
double difficulty_actual;
|
|
double difficulty_remote;
|
|
double difficulty_written;
|
|
bool difficulty_fixed;
|
|
|
|
long long last_submit_time;
|
|
double shares_per_minute;
|
|
|
|
char extranonce1[32];
|
|
int extranonce2size;
|
|
|
|
char extranonce1_default[32];
|
|
int extranonce2size_default;
|
|
|
|
char extranonce1_last[32];
|
|
int extranonce2size_last;
|
|
|
|
char extranonce1_reconnect[32];
|
|
int extranonce2size_reconnect;
|
|
|
|
bool extranonce_subscribe;
|
|
int submit_bad;
|
|
|
|
double speed;
|
|
int extranonce1_id;
|
|
|
|
int jobid_next;
|
|
int jobid_sent;
|
|
int jobid_locked;
|
|
|
|
YAAMP_CLIENT_ALGO algos_subscribed[YAAMP_MAXALGOS];
|
|
int job_history[YAAMP_JOB_MAXHISTORY];
|
|
};
|
|
|
|
inline void client_delete(YAAMP_OBJECT *object)
|
|
{
|
|
YAAMP_CLIENT *client = (YAAMP_CLIENT *)object;
|
|
socket_close(client->sock);
|
|
|
|
delete client;
|
|
}
|
|
|
|
//////////////////////////////////////////////////////////////////////////
|
|
|
|
YAAMP_CLIENT *client_find_notify_id(const char *notify_id, bool reconnecting);
|
|
|
|
void get_next_extraonce1(char *extraonce1);
|
|
void get_random_key(char *key);
|
|
|
|
void client_sort();
|
|
void client_block_ip(YAAMP_CLIENT *client, const char *reason);
|
|
|
|
bool client_reset_multialgo(YAAMP_CLIENT *client, bool first);
|
|
bool client_initialize_multialgo(YAAMP_CLIENT *client);
|
|
|
|
void client_add_job_history(YAAMP_CLIENT *client, int jobid);
|
|
bool client_find_job_history(YAAMP_CLIENT *client, int jobid, int startat=1);
|
|
|
|
bool client_find_my_ip(const char *ip);
|
|
|
|
//////////////////////////////////////////////////////////////////////////
|
|
|
|
int client_send_difficulty(YAAMP_CLIENT *client, double difficulty);
|
|
double client_normalize_difficulty(double difficulty);
|
|
|
|
void client_change_difficulty(YAAMP_CLIENT *client, double difficulty);
|
|
void client_record_difficulty(YAAMP_CLIENT *client);
|
|
void client_adjust_difficulty(YAAMP_CLIENT *client);
|
|
|
|
void client_initialize_difficulty(YAAMP_CLIENT *client);
|
|
|
|
//////////////////////////////////////////////////////////////////////////
|
|
|
|
int client_call(YAAMP_CLIENT *client, const char *method, const char *format, ...);
|
|
void client_dump_all();
|
|
|
|
int client_send_result(YAAMP_CLIENT *client, const char *format, ...);
|
|
int client_send_error(YAAMP_CLIENT *client, int error, const char *string);
|
|
|
|
bool client_submit(YAAMP_CLIENT *client, json_value *json_params);
|
|
void *client_thread(void *p);
|
|
|
|
//void source_prune();
|
|
|