|
|
@ -824,33 +824,14 @@ static void check_logwinsize(void) |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/* For mandatory printing when mutex is already locked */ |
|
|
|
/* For mandatory printing when mutex is already locked */ |
|
|
|
static void __wlog(const char *f, ...) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
va_list ap; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
check_logwinsize(); |
|
|
|
|
|
|
|
va_start(ap, f); |
|
|
|
|
|
|
|
vw_printw(logwin, f, ap); |
|
|
|
|
|
|
|
va_end(ap); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/* Print only if opt_loginput isn't set */ |
|
|
|
|
|
|
|
static void wlog(const char *f, ...) |
|
|
|
static void wlog(const char *f, ...) |
|
|
|
{ |
|
|
|
{ |
|
|
|
va_list ap; |
|
|
|
va_list ap; |
|
|
|
|
|
|
|
|
|
|
|
pthread_mutex_lock(&curses_lock); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
check_logwinsize(); |
|
|
|
check_logwinsize(); |
|
|
|
|
|
|
|
|
|
|
|
if (!opt_loginput) { |
|
|
|
|
|
|
|
va_start(ap, f); |
|
|
|
va_start(ap, f); |
|
|
|
vw_printw(logwin, f, ap); |
|
|
|
vw_printw(logwin, f, ap); |
|
|
|
va_end(ap); |
|
|
|
va_end(ap); |
|
|
|
wrefresh(logwin); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
pthread_mutex_unlock(&curses_lock); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/* Mandatory printing */ |
|
|
|
/* Mandatory printing */ |
|
|
@ -1519,20 +1500,20 @@ static void display_pool_summary(struct pool *pool) |
|
|
|
double efficiency = 0.0; |
|
|
|
double efficiency = 0.0; |
|
|
|
|
|
|
|
|
|
|
|
pthread_mutex_lock(&curses_lock); |
|
|
|
pthread_mutex_lock(&curses_lock); |
|
|
|
__wlog("Pool: %s\n", pool->rpc_url); |
|
|
|
wlog("Pool: %s\n", pool->rpc_url); |
|
|
|
__wlog(" Queued work requests: %d\n", pool->getwork_requested); |
|
|
|
wlog(" Queued work requests: %d\n", pool->getwork_requested); |
|
|
|
__wlog(" Share submissions: %d\n", pool->accepted + pool->rejected); |
|
|
|
wlog(" Share submissions: %d\n", pool->accepted + pool->rejected); |
|
|
|
__wlog(" Accepted shares: %d\n", pool->accepted); |
|
|
|
wlog(" Accepted shares: %d\n", pool->accepted); |
|
|
|
__wlog(" Rejected shares: %d\n", pool->rejected); |
|
|
|
wlog(" Rejected shares: %d\n", pool->rejected); |
|
|
|
if (pool->accepted || pool->rejected) |
|
|
|
if (pool->accepted || pool->rejected) |
|
|
|
__wlog(" Reject ratio: %.1f\n", (double)(pool->rejected * 100) / (double)(pool->accepted + pool->rejected)); |
|
|
|
wlog(" Reject ratio: %.1f\n", (double)(pool->rejected * 100) / (double)(pool->accepted + pool->rejected)); |
|
|
|
efficiency = pool->getwork_requested ? pool->accepted * 100.0 / pool->getwork_requested : 0.0; |
|
|
|
efficiency = pool->getwork_requested ? pool->accepted * 100.0 / pool->getwork_requested : 0.0; |
|
|
|
__wlog(" Efficiency (accepted / queued): %.0f%%\n", efficiency); |
|
|
|
wlog(" Efficiency (accepted / queued): %.0f%%\n", efficiency); |
|
|
|
|
|
|
|
|
|
|
|
__wlog(" Discarded work due to new blocks: %d\n", pool->discarded_work); |
|
|
|
wlog(" Discarded work due to new blocks: %d\n", pool->discarded_work); |
|
|
|
__wlog(" Stale submissions discarded due to new blocks: %d\n", pool->stale_shares); |
|
|
|
wlog(" Stale submissions discarded due to new blocks: %d\n", pool->stale_shares); |
|
|
|
__wlog(" Unable to get work from server occasions: %d\n", pool->localgen_occasions); |
|
|
|
wlog(" Unable to get work from server occasions: %d\n", pool->localgen_occasions); |
|
|
|
__wlog(" Submitting work remotely delay occasions: %d\n\n", pool->remotefail_occasions); |
|
|
|
wlog(" Submitting work remotely delay occasions: %d\n\n", pool->remotefail_occasions); |
|
|
|
wrefresh(logwin); |
|
|
|
wrefresh(logwin); |
|
|
|
pthread_mutex_unlock(&curses_lock); |
|
|
|
pthread_mutex_unlock(&curses_lock); |
|
|
|
} |
|
|
|
} |
|
|
@ -3037,7 +3018,7 @@ static void *watchdog_thread(void *userdata) |
|
|
|
gettimeofday(&rotate_tv, NULL); |
|
|
|
gettimeofday(&rotate_tv, NULL); |
|
|
|
|
|
|
|
|
|
|
|
while (1) { |
|
|
|
while (1) { |
|
|
|
int x, y, logx, logy, i; |
|
|
|
int i; |
|
|
|
struct timeval now; |
|
|
|
struct timeval now; |
|
|
|
|
|
|
|
|
|
|
|
sleep(interval); |
|
|
|
sleep(interval); |
|
|
|