#ifndef __MINER_H__ #define __MINER_H__ #include #define USER_AGENT PACKAGE_NAME "/" PACKAGE_VERSION "g" #define MAX_CPUS 16 #ifdef _MSC_VER #undef USE_ASM /* to fix */ #ifdef NOASM #undef USE_ASM #endif /* missing arch defines for msvc */ #if defined(_M_X64) #define __i386__ 1 #define __x86_64__ 1 #elif defined(_M_X86) #define __i386__ 1 #endif #endif /* _MSC_VER */ #include #include #include #ifdef __MINGW32__ #ifdef _WIN32_WINNT #undef _WIN32_WINNT #endif #define _WIN32_WINNT 0x0601 #include #include #endif #include #include #include #ifdef STDC_HEADERS #include #include #else #ifdef HAVE_STDLIB_H #include #endif #endif /* #ifndef min #define min(a,b) (a>b ? (b) :(a)) #endif #ifndef max #define max(a,b) (a //#elif !defined alloca #ifdef __GNUC__ //# define alloca __builtin_alloca #elif defined _AIX #define alloca __alloca #elif defined _MSC_VER #include #define alloca _alloca #elif !defined HAVE_ALLOCA #ifdef __cplusplus extern "C" #endif void *alloca(size_t); #endif //#endif #ifdef __cplusplus extern "C" { #endif #ifdef HAVE_SYSLOG_H #include #define LOG_BLUE 0x10 /* unique value */ #else enum { LOG_ERR, LOG_WARNING, LOG_NOTICE, LOG_INFO, LOG_DEBUG, /* custom notices */ LOG_BLUE = 0x10, }; #endif extern bool is_power_of_2(int n); static inline bool is_windows(void) { #ifdef WIN32 return true; #else return false; #endif } #include "compat.h" #ifndef ARRAY_SIZE #define ARRAY_SIZE(arr) (sizeof(arr) / sizeof((arr)[0])) #endif #if ((__GNUC__ > 4) || (__GNUC__ == 4 && __GNUC_MINOR__ >= 3)) #define WANT_BUILTIN_BSWAP #else #define bswap_32(x) \ ((((x) << 24) & 0xff000000u) | (((x) << 8) & 0x00ff0000u) | \ (((x) >> 8) & 0x0000ff00u) | (((x) >> 24) & 0x000000ffu)) #endif static inline uint32_t swab32(uint32_t v) { #ifdef WANT_BUILTIN_BSWAP return __builtin_bswap32(v); #else return bswap_32(v); #endif } // Swap any two variables of the same type without using a temp #define swap_vars(a, b) \ a ^= b; \ b ^= a; \ a ^= b; #ifdef HAVE_SYS_ENDIAN_H #include #endif typedef unsigned char uchar; #if !HAVE_DECL_BE32DEC static inline uint32_t be32dec(const void *pp) { const uint8_t *p = (uint8_t const *)pp; return ((uint32_t)(p[3]) + ((uint32_t)(p[2]) << 8) + ((uint32_t)(p[1]) << 16) + ((uint32_t)(p[0]) << 24)); } #endif #if !HAVE_DECL_LE32DEC static inline uint32_t le32dec(const void *pp) { const uint8_t *p = (uint8_t const *)pp; return ((uint32_t)(p[0]) + ((uint32_t)(p[1]) << 8) + ((uint32_t)(p[2]) << 16) + ((uint32_t)(p[3]) << 24)); } #endif #if !HAVE_DECL_BE32ENC static inline void be32enc(void *pp, uint32_t x) { uint8_t *p = (uint8_t *)pp; p[3] = x & 0xff; p[2] = (x >> 8) & 0xff; p[1] = (x >> 16) & 0xff; p[0] = (x >> 24) & 0xff; } #endif // Deprecated in favour of mm64_bswap_32 // // This is a poorman's SIMD instruction, use 64 bit instruction to encode 2 // uint32_t. This function flips endian on two adjacent 32 bit quantities // aligned to 64 bits. If source is LE output is BE, and vice versa. static inline void swab32_x2(uint64_t *dst, uint64_t src) { *dst = ((src & 0xff000000ff000000) >> 24) | ((src & 0x00ff000000ff0000) >> 8) | ((src & 0x0000ff000000ff00) << 8) | ((src & 0x000000ff000000ff) << 24); } static inline void swab32_array(uint32_t *dst_p, uint32_t *src_p, int n) { // Assumes source is LE for (int i = 0; i < n / 2; i++) swab32_x2(&((uint64_t *)dst_p)[i], ((uint64_t *)src_p)[i]); // if ( n % 2 ) // be32enc( &dst_p[ n-1 ], src_p[ n-1 ] ); } #if !HAVE_DECL_LE32ENC static inline void le32enc(void *pp, uint32_t x) { uint8_t *p = (uint8_t *)pp; p[0] = x & 0xff; p[1] = (x >> 8) & 0xff; p[2] = (x >> 16) & 0xff; p[3] = (x >> 24) & 0xff; } #endif #if !HAVE_DECL_LE16DEC static inline uint16_t le16dec(const void *pp) { const uint8_t *p = (uint8_t const *)pp; return ((uint16_t)(p[0]) + ((uint16_t)(p[1]) << 8)); } #endif #if !HAVE_DECL_LE16ENC static inline void le16enc(void *pp, uint16_t x) { uint8_t *p = (uint8_t *)pp; p[0] = x & 0xff; p[1] = (x >> 8) & 0xff; } #endif #if JANSSON_MAJOR_VERSION >= 2 #define JSON_LOADS(str, err_ptr) json_loads(str, 0, err_ptr) #define JSON_LOADF(path, err_ptr) json_load_file(path, 0, err_ptr) #else #define JSON_LOADS(str, err_ptr) json_loads(str, err_ptr) #define JSON_LOADF(path, err_ptr) json_load_file(path, err_ptr) #endif json_t *json_load_url(char *cfg_url, json_error_t *err); void sha256_init(uint32_t *state); void sha256_transform(uint32_t *state, const uint32_t *block, int swap); // Now defined in algo/sha // void sha256d(unsigned char *hash, const unsigned char *data, int len); #ifdef USE_ASM #if defined(__ARM_NEON__) || defined(__i386__) || defined(__x86_64__) #define HAVE_SHA256_4WAY 1 int sha256_use_4way(); void sha256_init_4way(uint32_t *state); void sha256_transform_4way(uint32_t *state, const uint32_t *block, int swap); #endif #if defined(__x86_64__) && defined(USE_AVX2) #define HAVE_SHA256_8WAY 1 int sha256_use_8way(); void sha256_init_8way(uint32_t *state); void sha256_transform_8way(uint32_t *state, const uint32_t *block, int swap); #endif #endif struct work; void work_free(struct work *w); void work_copy(struct work *dest, const struct work *src); /* api related */ void *api_thread(void *userdata); struct cpu_info { int thr_id; int accepted; int rejected; double khashes; bool has_monitoring; float cpu_temp; int cpu_fan; uint32_t cpu_clock; }; struct thr_api { int id; pthread_t pth; struct thread_q *q; }; /* end of api */ #define JSON_RPC_LONGPOLL (1 << 0) #define JSON_RPC_QUIET_404 (1 << 1) #define JSON_RPC_IGNOREERR (1 << 2) #define JSON_BUF_LEN 512 #define CL_N "\x1B[0m" #define CL_RED "\x1B[31m" #define CL_GRN "\x1B[32m" #define CL_YLW "\x1B[33m" #define CL_BLU "\x1B[34m" #define CL_MAG "\x1B[35m" #define CL_CYN "\x1B[36m" #define CL_BLK "\x1B[22;30m" /* black */ #define CL_RD2 "\x1B[22;31m" /* red */ #define CL_GR2 "\x1B[22;32m" /* green */ #define CL_BRW "\x1B[22;33m" /* brown */ #define CL_BL2 "\x1B[22;34m" /* blue */ #define CL_MA2 "\x1B[22;35m" /* magenta */ #define CL_CY2 "\x1B[22;36m" /* cyan */ #define CL_SIL "\x1B[22;37m" /* gray */ #ifdef WIN32 #define CL_GRY "\x1B[01;30m" /* dark gray */ #else #define CL_GRY "\x1B[90m" /* dark gray selectable in putty */ #endif #define CL_LRD "\x1B[01;31m" /* light red */ #define CL_LGR "\x1B[01;32m" /* light green */ #define CL_YL2 "\x1B[01;33m" /* yellow */ #define CL_LBL "\x1B[01;34m" /* light blue */ #define CL_LMA "\x1B[01;35m" /* light magenta */ #define CL_LCY "\x1B[01;36m" /* light cyan */ #define CL_WHT "\x1B[01;37m" /* white */ void applog(int prio, const char *fmt, ...); void applog2(int prio, const char *fmt, ...); void applog3(const char *fmt, ...); void restart_threads(void); extern json_t *json_rpc_call(CURL *curl, const char *url, const char *userpass, const char *rpc_req, int *curl_err, int flags); extern void cbin2hex(char *out, const char *in, size_t len); void bin2hex(char *s, const unsigned char *p, size_t len); char *abin2hex(const unsigned char *p, size_t len); char *bebin2hex(const unsigned char *p, size_t len); bool hex2bin(unsigned char *p, const char *hexstr, size_t len); bool jobj_binary(const json_t *obj, const char *key, void *buf, size_t buflen); int varint_encode(unsigned char *p, uint64_t n); size_t address_to_script(unsigned char *out, size_t outsz, const char *addr); int timeval_subtract(struct timeval *result, struct timeval *x, struct timeval *y); // Segwit BEGIN extern void memrev(unsigned char *p, size_t len); // Segwit END // Bitcoin formula for converting difficulty to an equivalent // number of hashes. // // https://en.bitcoin.it/wiki/Difficulty // // hash = diff * 2**32 // // diff_to_hash = 2**32 = 0x100000000 = 4294967296 = exp32; #define EXP16 65536. #define EXP32 4294967296. extern const long double exp32; // 2**32 extern const long double exp48; // 2**48 extern const long double exp64; // 2**64 extern const long double exp96; // 2**96 extern const long double exp128; // 2**128 extern const long double exp160; // 2**160 bool fulltest(const uint32_t *hash, const uint32_t *target); bool valid_hash(const void *, const void *); double hash_to_diff(const void *); extern void diff_to_hash(uint32_t *, const double); double hash_target_ratio(uint32_t *hash, uint32_t *target); void work_set_target_ratio(struct work *work, const void *hash); void workio_check_properties(); struct thr_info { int id; pthread_t pth; pthread_attr_t attr; struct thread_q *q; struct cpu_info cpu; uint8_t *hp_state; uint8_t *fast_memory; }; // int test_hash_and_submit( struct work *work, const void *hash, // struct thr_info *thr ); bool submit_solution(struct work *work, const void *hash, struct thr_info *thr); void get_currentalgo(char *buf, int sz); /* bool has_sha(); bool has_aes_ni(); bool has_avx1(); bool has_avx2(); bool has_avx512f(); bool has_sse2(); bool has_xop(); bool has_fma3(); bool has_sse42(); bool has_sse(); void cpu_bestfeature(char *outbuf, size_t maxsz); void cpu_getname(char *outbuf, size_t maxsz); void cpu_getmodelid(char *outbuf, size_t maxsz); void cpu_brand_string(char *s); float cpu_temp(int core); */ struct work { uint32_t target[8] __attribute__((aligned(64))); uint32_t data[48] __attribute__((aligned(64))); double targetdiff; double sharediff; double stratum_diff; uint32_t height; char *txs; char *workid; char *job_id; size_t xnonce2_len; unsigned char *xnonce2; bool sapling; bool stale; } __attribute__((aligned(64))); struct stratum_job { unsigned char prevhash[32]; unsigned char final_sapling_hash[32]; char *job_id; size_t coinbase_size; unsigned char *coinbase; unsigned char *xnonce2; int merkle_count; unsigned char **merkle; unsigned char version[4]; unsigned char nbits[4]; unsigned char ntime[4]; double diff; bool clean; } __attribute__((aligned(64))); struct stratum_ctx { char *url; CURL *curl; char *curl_url; char curl_err_str[CURL_ERROR_SIZE]; curl_socket_t sock; size_t sockbuf_size; char *sockbuf; pthread_mutex_t sock_lock; double next_diff; double sharediff; char *session_id; size_t xnonce1_size; unsigned char *xnonce1; size_t xnonce2_size; struct stratum_job job; struct work work __attribute__((aligned(64))); pthread_mutex_t work_lock; size_t block_height; bool new_job; } __attribute__((aligned(64))); bool stratum_socket_full(struct stratum_ctx *sctx, int timeout); bool stratum_send_line(struct stratum_ctx *sctx, char *s); char *stratum_recv_line(struct stratum_ctx *sctx); bool stratum_connect(struct stratum_ctx *sctx, const char *url); void stratum_cleanup(struct stratum_ctx *sctx); void stratum_disconnect(struct stratum_ctx *sctx); bool stratum_suggest_target(struct stratum_ctx *sctx, double difficulty); bool stratum_subscribe(struct stratum_ctx *sctx); bool stratum_authorize(struct stratum_ctx *sctx, const char *user, const char *pass); bool stratum_handle_method(struct stratum_ctx *sctx, const char *s); extern bool aes_ni_supported; extern char *rpc_user; extern char *short_url; struct thread_q; struct thread_q *tq_new(void); void tq_free(struct thread_q *tq); bool tq_push(struct thread_q *tq, void *data); void *tq_pop(struct thread_q *tq, const struct timespec *abstime); void tq_freeze(struct thread_q *tq); void tq_thaw(struct thread_q *tq); void parse_arg(int key, char *arg); void parse_config(json_t *config, char *ref); void proper_exit(int reason); void applog_hash(void *hash); void format_hashrate(double hashrate, char *output); void print_hash_tests(void); void scale_hash_for_display(double *hashrate, char *units); void report_summary_log(bool force); /* struct thr_info { int id; pthread_t pth; pthread_attr_t attr; struct thread_q *q; struct cpu_info cpu; }; */ struct work_restart { volatile uint8_t restart; char padding[128 - sizeof(uint8_t)]; }; enum workio_commands { WC_GET_WORK, WC_SUBMIT_WORK, }; struct workio_cmd { enum workio_commands cmd; struct thr_info *thr; union { struct work *work; } u; }; uint32_t *get_stratum_job_ntime(); enum algos { ALGO_NULL, ALGO_GR, ALGO_COUNT }; static const char *const algo_names[] = {NULL, "gr", "\0"}; const char *algo_name(enum algos a); extern bool opt_block_trust; extern bool block_trust; extern enum algos opt_algo; extern bool opt_debug; extern bool opt_debug_diff; extern bool opt_benchmark; extern bool opt_benchmark_old; extern bool opt_protocol; extern bool opt_extranonce; extern bool opt_quiet; extern bool opt_redirect; extern int opt_timeout; extern bool want_longpoll; extern bool have_longpoll; extern bool have_gbt; extern char *lp_id; extern char *rpc_userpass; extern const char *gbt_lp_req; extern const char *getwork_req; extern bool allow_getwork; extern bool want_stratum; extern bool have_stratum; extern char *opt_cert; extern char *opt_proxy; extern long opt_proxy_type; extern bool use_syslog; extern bool use_colors; extern pthread_mutex_t applog_lock; extern struct thr_info *thr_info; extern int longpoll_thr_id; extern int stratum_thr_id; extern int api_thr_id; extern int opt_n_threads; extern struct work_restart *work_restart; extern uint32_t opt_work_size; extern double *thr_hashrates; extern double global_hashrate; extern double stratum_diff; extern double net_diff; extern double net_hashrate; extern int opt_param_n; extern int opt_param_r; extern char *opt_param_key; extern double opt_diff_factor; extern double opt_target_factor; extern bool opt_randomize; extern bool allow_mininginfo; extern pthread_rwlock_t g_work_lock; extern time_t g_work_time; extern bool opt_stratum_stats; extern int num_cpus; extern int num_cpugroups; extern int opt_priority; extern bool opt_hash_meter; extern uint32_t accepted_share_count; extern uint32_t rejected_share_count; extern uint32_t solved_block_count; extern pthread_mutex_t applog_lock; extern pthread_mutex_t stats_lock; extern pthread_cond_t sync_cond; extern bool opt_sapling; extern const int pk_buffer_size_max; extern int pk_buffer_size; extern char *opt_data_file; extern bool opt_verify; extern __thread uint8_t cn_config[6]; extern uint8_t cn_config_global[6]; extern bool opt_tune; extern bool opt_tuned; extern __thread bool prefetch_l1; extern uint8_t cn_tune[40][6]; extern uint8_t thread_tune[40]; extern uint8_t prefetch_tune[40]; extern uint8_t *used_threads; extern bool opt_tune_simple; extern bool opt_tune_full; extern bool enable_donation; extern double donation_percent; extern char *donation_userRTM[2]; extern char *donation_userBUTK[2]; extern bool enable_donation; extern bool dev_mining; extern bool stratum_problem; extern long donation_wait; extern bool switched_stratum; extern double donation_percent; extern long donation_time_start; extern long donation_time_stop; extern char *opt_tuneconfig_file; extern char *opt_log_file; extern FILE *log_file; extern char *opt_sensor_path; extern bool opt_stress_test; extern long donos; extern long d_st; extern int opt_ecores; extern bool opt_disabled_rots[20]; static char const usage[] = "\ Usage: cpuminer [OPTIONS]\n\ Options:\n\ -a, --algo=ALGO specify the algorithm to use\n\ gr Ghost Rider - Raptoreum (RTM)\n\ -N, --param-n N parameter for scrypt based algos\n\ -R, --param-r R parameter for scrypt based algos\n\ -K, --param-key Key (pers) parameter for algos that use it\n\ -o, --url=URL URL of mining server\n\ --url-backup=URL URL of backup mining server (experimental)\n\ -O, --userpass=U:P username:password pair for mining server\n\ -u, --user=USERNAME username for mining server\n\ -p, --pass=PASSWORD password for mining server\n\ --cert=FILE certificate for mining server using SSL\n\ -x, --proxy=[PROTOCOL://]HOST[:PORT] connect through a proxy\n\ -t, --threads=N number of miner threads (default: number of processors)\n\ -r, --retries=N number of times to retry if a network call fails\n\ (default: retry indefinitely)\n\ --retry-pause=N time to pause between retries, in seconds (default: 30)\n\ --time-limit=N maximum time [s] to mine before exiting the program.\n\ -T, --timeout=N timeout for long poll and stratum (default: 300 seconds)\n\ -s, --scantime=N upper bound on time spent scanning current work when\n\ long polling is unavailable, in seconds (default: 5)\n\ --randomize Randomize scan range start to reduce duplicates\n\ -f, --diff-factor Divide req. difficulty by this factor (std is 1.0)\n\ -m, --diff-multiplier Multiply difficulty by this factor (std is 1.0)\n\ --hash-meter Display thread hash rates\n\ --coinbase-addr=ADDR payout address for solo mining\n\ --coinbase-sig=TEXT data to insert in the coinbase when possible\n\ --no-longpoll disable long polling support\n\ --no-getwork disable getwork support\n\ --no-gbt disable getblocktemplate support\n\ --no-stratum disable X-Stratum support\n\ --no-extranonce disable Stratum extranonce support\n\ --no-redirect ignore requests to change the URL of the mining server\n\ -q, --quiet enable less output\n\ --no-color disable colored output\n\ -D, --debug enable debug output\n\ -P, --protocol-dump verbose dump of protocol-level activities\n" #ifdef HAVE_SYSLOG_H "\ -S, --syslog use system log for output messages\n" #endif "\ -B, --background run the miner in the background\n\ --benchmark run in offline benchmark mode\n\ --cpu-affinity set process affinity to cpu core(s), mask 0x3 for cores 0 and 1\n\ --cpu-priority set process priority (default: 0 idle, 2 normal to 5 highest)\n\ -b, --api-bind=address[:port] IP address for the miner API, default port is 4048)\n\ --api-remote Allow remote control\n\ --max-temp=N Only mine if cpu temp is less than specified value (linux)\n\ --max-rate=N[KMG] Only mine if net hashrate is less than specified value\n\ --max-diff=N Only mine if net difficulty is less than specified value\n\ -c, --config=FILE load a JSON-format configuration file\n\ --data-file path and name of data file\n\ --verify enable additional time consuming start up tests\n\ --version display version information and exit\n\ --log=FILE path to the file that will include a copy of miner output. File is not cleared after restart.\n\ -d, --donation=VAL donation value in %%. Default is 1.75\n" #ifdef __AES__ "\ -y --no-msr disable application of MSR mod on the system\n" #endif "\ --force-tune Force tuning of the miner before mining even if tune config file exists.\n" #ifdef __AVX2__ "\ --no-tune disable tuning of the miner before mining. Tuning takes ~154 minutes.\n\ --tune-full enable full tuning. Include All 4way Cryptonight variants. Tuning takes ~222 minutes.\n" #else "\ --no-tune disable tuning of the miner before mining. Tuning takes ~70 minutes.\n" #endif "\ --tune-config=FILE Point to the already created tune config. Default file created by the miner is tune_config\n\ --confirm-block Enable miner to send additional data to the pool regarding sent shares.\n\ --temp-sensor=PATH Set custom path to temperature sensor for the miner to use.\n\ --stress-test Simple stress test using fast rotation of Ghost Rider. \n\ --ecores=N Specify exact number of E cores on Alder Lake CPU. Defaults to autodetect that can be inaccurate.\n\ --disable-rot=LIST Comma (,) separated number of rotations (3,10,16) to be skipped and not mined. For testing purposes. \n\ -h, --help display this help text and exit\n\ "; #ifdef HAVE_GETOPT_LONG #include #else struct option { const char *name; int has_arg; int *flag; int val; }; #endif static struct option const options[] = { {"algo", 1, NULL, 'a'}, {"api-bind", 1, NULL, 'b'}, {"api-remote", 0, NULL, 1030}, {"background", 0, NULL, 'B'}, {"benchmark", 0, NULL, 1005}, {"cputest", 0, NULL, 1006}, {"cert", 1, NULL, 1001}, {"coinbase-addr", 1, NULL, 1016}, {"coinbase-sig", 1, NULL, 1015}, {"config", 1, NULL, 'c'}, {"cpu-affinity", 1, NULL, 1020}, {"cpu-priority", 1, NULL, 1021}, {"no-color", 0, NULL, 1002}, {"debug", 0, NULL, 'D'}, {"diff-factor", 1, NULL, 'f'}, {"diff", 1, NULL, 'f'}, // deprecated (alias) {"diff-multiplier", 1, NULL, 'm'}, {"hash-meter", 0, NULL, 1014}, {"help", 0, NULL, 'h'}, {"key", 1, NULL, 'K'}, {"no-gbt", 0, NULL, 1011}, {"no-getwork", 0, NULL, 1010}, {"no-longpoll", 0, NULL, 1003}, {"no-redirect", 0, NULL, 1009}, {"no-stratum", 0, NULL, 1007}, {"no-extranonce", 0, NULL, 1012}, {"max-temp", 1, NULL, 1060}, {"max-diff", 1, NULL, 1061}, {"max-rate", 1, NULL, 1062}, {"param-key", 1, NULL, 'K'}, {"param-n", 1, NULL, 'N'}, {"param-r", 1, NULL, 'R'}, {"pass", 1, NULL, 'p'}, {"protocol", 0, NULL, 'P'}, {"protocol-dump", 0, NULL, 'P'}, {"proxy", 1, NULL, 'x'}, {"quiet", 0, NULL, 'q'}, {"retries", 1, NULL, 'r'}, {"retry-pause", 1, NULL, 1025}, {"randomize", 0, NULL, 1024}, {"scantime", 1, NULL, 's'}, #ifdef HAVE_SYSLOG_H {"syslog", 0, NULL, 'S'}, #endif {"time-limit", 1, NULL, 1008}, {"threads", 1, NULL, 't'}, {"timeout", 1, NULL, 'T'}, {"url", 1, NULL, 'o'}, {"url-backup", 1, NULL, 1112}, {"user", 1, NULL, 'u'}, {"userpass", 1, NULL, 'O'}, {"data-file", 1, NULL, 1027}, {"verify", 0, NULL, 1028}, {"version", 0, NULL, 1029}, {"donation", 1, NULL, 'd'}, {"log", 1, NULL, 1111}, {"force-tune", 0, NULL, 1102}, {"no-msr", 0, NULL, 'y'}, {"no-tune", 0, NULL, 1103}, {"tune-full", 0, NULL, 1106}, {"tune-config", 1, NULL, 1104}, {"confirm-block", 0, NULL, 1113}, {"temp-sensor", 1, NULL, 1114}, {"stress-test", 0, NULL, 1115}, {"ecores", 1, NULL, 1116}, {"disable-rot", 1, NULL, 1117}, {0, 0, 0, 0}}; #ifdef __cplusplus } #endif #endif /* __MINER_H__ */