|
|
|
|
@ -811,23 +811,30 @@ static char *cmd_blocklist(__maybe_unused PGconn *conn, char *cmd, char *id,
|
|
|
|
|
__maybe_unused K_TREE *trf_root) |
|
|
|
|
{ |
|
|
|
|
K_TREE_CTX ctx[1]; |
|
|
|
|
K_ITEM *b_item, *w_item; |
|
|
|
|
K_ITEM *b_item; |
|
|
|
|
BLOCKS *blocks; |
|
|
|
|
char reply[1024] = ""; |
|
|
|
|
char tmp[1024]; |
|
|
|
|
char *buf; |
|
|
|
|
char *buf, *desc, desc_buf[64]; |
|
|
|
|
size_t len, off; |
|
|
|
|
int32_t height = -1; |
|
|
|
|
tv_t first_cd = {0,0}; |
|
|
|
|
int rows, tot; |
|
|
|
|
tv_t first_cd = {0,0}, stats_tv = {0,0}, stats_tv2 = {0,0}; |
|
|
|
|
int rows, srows, tot, seq; |
|
|
|
|
bool has_stats; |
|
|
|
|
|
|
|
|
|
LOGDEBUG("%s(): cmd '%s'", __func__, cmd); |
|
|
|
|
|
|
|
|
|
APPEND_REALLOC_INIT(buf, off, len); |
|
|
|
|
APPEND_REALLOC(buf, off, len, "ok."); |
|
|
|
|
rows = 0; |
|
|
|
|
|
|
|
|
|
redo: |
|
|
|
|
K_WLOCK(blocks_free); |
|
|
|
|
has_stats = check_update_blocks_stats(&stats_tv); |
|
|
|
|
K_WUNLOCK(blocks_free); |
|
|
|
|
|
|
|
|
|
srows = rows = 0; |
|
|
|
|
K_RLOCK(blocks_free); |
|
|
|
|
b_item = last_in_ktree(blocks_root, ctx); |
|
|
|
|
b_item = first_in_ktree(blocks_root, ctx); |
|
|
|
|
tot = 0; |
|
|
|
|
while (b_item) { |
|
|
|
|
DATA_BLOCKS(blocks, b_item); |
|
|
|
|
@ -835,16 +842,31 @@ static char *cmd_blocklist(__maybe_unused PGconn *conn, char *cmd, char *id,
|
|
|
|
|
if (blocks->confirmed[0] != BLOCKS_ORPHAN) |
|
|
|
|
tot++; |
|
|
|
|
} |
|
|
|
|
b_item = prev_in_ktree(ctx); |
|
|
|
|
b_item = next_in_ktree(ctx); |
|
|
|
|
} |
|
|
|
|
seq = tot; |
|
|
|
|
b_item = last_in_ktree(blocks_root, ctx); |
|
|
|
|
while (b_item && rows < 42) { |
|
|
|
|
DATA_BLOCKS(blocks, b_item); |
|
|
|
|
/* For each block remember the initial createdate
|
|
|
|
|
* Reverse sort order the oldest expirydate is first |
|
|
|
|
* which should be the 'n' record */ |
|
|
|
|
if (height != blocks->height) { |
|
|
|
|
height = blocks->height; |
|
|
|
|
copy_tv(&first_cd, &(blocks->createdate)); |
|
|
|
|
} |
|
|
|
|
if (CURRENT(&(blocks->expirydate))) { |
|
|
|
|
if (blocks->confirmed[0] == BLOCKS_ORPHAN) { |
|
|
|
|
snprintf(tmp, sizeof(tmp), |
|
|
|
|
"seq:%d=o%c", |
|
|
|
|
rows, FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
} else { |
|
|
|
|
snprintf(tmp, sizeof(tmp), |
|
|
|
|
"seq:%d=%d%c", |
|
|
|
|
rows, seq--, FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
} |
|
|
|
|
int_to_buf(blocks->height, reply, sizeof(reply)); |
|
|
|
|
snprintf(tmp, sizeof(tmp), "height:%d=%s%c", rows, reply, FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
@ -900,21 +922,21 @@ static char *cmd_blocklist(__maybe_unused PGconn *conn, char *cmd, char *id,
|
|
|
|
|
snprintf(tmp, sizeof(tmp), "elapsed:%d=%s%c", rows, reply, FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
|
|
|
|
|
w_item = find_workinfo(blocks->workinfoid, NULL); |
|
|
|
|
if (w_item) { |
|
|
|
|
char wdiffbin[TXT_SML+1]; |
|
|
|
|
double wdiff; |
|
|
|
|
WORKINFO *workinfo; |
|
|
|
|
DATA_WORKINFO(workinfo, w_item); |
|
|
|
|
hex2bin(wdiffbin, workinfo->bits, 4); |
|
|
|
|
wdiff = diff_from_nbits(wdiffbin); |
|
|
|
|
if (has_stats) { |
|
|
|
|
snprintf(tmp, sizeof(tmp), |
|
|
|
|
"netdiff:%d=%.1f%c", |
|
|
|
|
rows, wdiff, FLDSEP); |
|
|
|
|
"netdiff:%d=%.8f%cdiffratio:%d=%.8f%c" |
|
|
|
|
"cdf:%d=%.8f%cluck:%d=%.8f%c", |
|
|
|
|
rows, blocks->netdiff, FLDSEP, |
|
|
|
|
rows, blocks->blockdiffratio, FLDSEP, |
|
|
|
|
rows, blocks->blockcdf, FLDSEP, |
|
|
|
|
rows, blocks->blockluck, FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
} else { |
|
|
|
|
snprintf(tmp, sizeof(tmp), |
|
|
|
|
"netdiff:%d=?%c", rows, FLDSEP); |
|
|
|
|
"netdiff:%d=?%cdiffratio:%d=?%c" |
|
|
|
|
"cdf:%d=?%cluck:%d=?%c", |
|
|
|
|
rows, FLDSEP, rows, FLDSEP, |
|
|
|
|
rows, FLDSEP, rows, FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -922,17 +944,83 @@ static char *cmd_blocklist(__maybe_unused PGconn *conn, char *cmd, char *id,
|
|
|
|
|
} |
|
|
|
|
b_item = prev_in_ktree(ctx); |
|
|
|
|
} |
|
|
|
|
if (has_stats) { |
|
|
|
|
seq = tot; |
|
|
|
|
b_item = last_in_ktree(blocks_root, ctx); |
|
|
|
|
while (b_item) { |
|
|
|
|
DATA_BLOCKS(blocks, b_item); |
|
|
|
|
if (CURRENT(&(blocks->expirydate)) && |
|
|
|
|
blocks->confirmed[0] != BLOCKS_ORPHAN) { |
|
|
|
|
desc = NULL; |
|
|
|
|
if (seq == 1) { |
|
|
|
|
snprintf(desc_buf, sizeof(desc_buf), |
|
|
|
|
"All - Last %d", tot); |
|
|
|
|
desc = desc_buf; |
|
|
|
|
} else if (seq == tot - 4) { |
|
|
|
|
desc = "Last 5"; |
|
|
|
|
} else if (seq == tot - 9) { |
|
|
|
|
desc = "Last 10"; |
|
|
|
|
} else if (seq == tot - 24) { |
|
|
|
|
desc = "Last 25"; |
|
|
|
|
} else if (seq == tot - 49) { |
|
|
|
|
desc = "Last 50"; |
|
|
|
|
} else if (seq == tot - 99) { |
|
|
|
|
desc = "Last 100"; |
|
|
|
|
} |
|
|
|
|
if (desc) { |
|
|
|
|
snprintf(tmp, sizeof(tmp), |
|
|
|
|
"s_seq:%d=%d%c" |
|
|
|
|
"s_desc:%d=%s%c" |
|
|
|
|
"s_diffratio:%d=%.8f%c" |
|
|
|
|
"s_diffmean:%d=%.8f%c" |
|
|
|
|
"s_cdferl:%d=%.8f%c" |
|
|
|
|
"s_luck:%d=%.8f%c", |
|
|
|
|
srows, seq, FLDSEP, |
|
|
|
|
srows, desc, FLDSEP, |
|
|
|
|
srows, blocks->diffratio, FLDSEP, |
|
|
|
|
srows, blocks->diffmean, FLDSEP, |
|
|
|
|
srows, blocks->cdferl, FLDSEP, |
|
|
|
|
srows, blocks->luck, FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
srows++; |
|
|
|
|
} |
|
|
|
|
seq--; |
|
|
|
|
} |
|
|
|
|
b_item = prev_in_ktree(ctx); |
|
|
|
|
} |
|
|
|
|
copy_tv(&stats_tv2, &blocks_stats_time); |
|
|
|
|
} |
|
|
|
|
K_RUNLOCK(blocks_free); |
|
|
|
|
|
|
|
|
|
// Only check for a redo if we used the stats values
|
|
|
|
|
if (has_stats) { |
|
|
|
|
/* If the stats changed then redo with the new corrected values
|
|
|
|
|
* This isn't likely at all, but it guarantees the blocks |
|
|
|
|
* page shows correct information since any code that wants |
|
|
|
|
* to modify the blocks table must have it under write lock |
|
|
|
|
* then flag the stats as needing to be recalculated */ |
|
|
|
|
if (!tv_equal(&stats_tv, &stats_tv2)) { |
|
|
|
|
APPEND_REALLOC_RESET(buf, off); |
|
|
|
|
goto redo; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
snprintf(tmp, sizeof(tmp), |
|
|
|
|
"s_rows=%d%cs_flds=%s%c", |
|
|
|
|
srows, FLDSEP, |
|
|
|
|
"s_seq,s_desc,s_diffratio,s_diffmean,s_cdferl,s_luck", |
|
|
|
|
FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
|
|
|
|
|
snprintf(tmp, sizeof(tmp), |
|
|
|
|
"tot=%d%crows=%d%cflds=%s%c", |
|
|
|
|
tot, FLDSEP, |
|
|
|
|
"rows=%d%cflds=%s%c", |
|
|
|
|
rows, FLDSEP, |
|
|
|
|
"height,blockhash,nonce,reward,workername,firstcreatedate," |
|
|
|
|
"seq,height,blockhash,nonce,reward,workername,firstcreatedate," |
|
|
|
|
"createdate,status,diffacc,diffinv,shareacc,shareinv,elapsed," |
|
|
|
|
"netdiff", FLDSEP); |
|
|
|
|
"netdiff,diffratio,cdf,luck", FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
|
|
|
|
|
snprintf(tmp, sizeof(tmp), "arn=%s%carp=%s", "Blocks", FLDSEP, ""); |
|
|
|
|
snprintf(tmp, sizeof(tmp), "arn=%s%carp=%s", "Blocks,BlockStats", FLDSEP, ",s"); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
|
|
|
|
|
LOGDEBUG("%s.ok.%d_blocks", id, rows); |
|
|
|
|
@ -4186,6 +4274,70 @@ static char *cmd_payouts(PGconn *conn, char *cmd, char *id, tv_t *now,
|
|
|
|
|
copy_tv(&(payouts2->lastshareacc), &(payouts->lastshareacc)); |
|
|
|
|
payouts2->stats = strdup(payouts->stats); |
|
|
|
|
|
|
|
|
|
ok = payouts_add(conn, true, p2_item, &old_p2_item, |
|
|
|
|
by, code, inet, now, NULL, false); |
|
|
|
|
if (!ok) { |
|
|
|
|
snprintf(reply, siz, "failed payout %"PRId64, payoutid); |
|
|
|
|
return strdup(reply); |
|
|
|
|
} |
|
|
|
|
DATA_PAYOUTS(payouts2, p2_item); |
|
|
|
|
DATA_PAYOUTS(old_payouts2, old_p2_item); |
|
|
|
|
snprintf(msg, sizeof(msg), |
|
|
|
|
"payout %"PRId64" changed from '%s' to '%s' for " |
|
|
|
|
"%"PRId32"/%s", |
|
|
|
|
payoutid, old_payouts2->status, payouts2->status, |
|
|
|
|
payouts2->height, payouts2->blockhash); |
|
|
|
|
} else if (strcasecmp(action, "orphan") == 0) { |
|
|
|
|
/* Change the status of a generated payout to orphaned
|
|
|
|
|
* Require payoutid |
|
|
|
|
* Use this if the orphan process didn't automatically |
|
|
|
|
* update a generated payout to orphaned |
|
|
|
|
* TODO: get orphaned blocks to automatically do this */ |
|
|
|
|
i_payoutid = require_name(trf_root, "payoutid", 1, |
|
|
|
|
(char *)intpatt, reply, siz); |
|
|
|
|
if (!i_payoutid) |
|
|
|
|
return strdup(reply); |
|
|
|
|
TXT_TO_BIGINT("payoutid", transfer_data(i_payoutid), payoutid); |
|
|
|
|
|
|
|
|
|
K_WLOCK(payouts_free); |
|
|
|
|
p_item = find_payoutid(payoutid); |
|
|
|
|
if (!p_item) { |
|
|
|
|
K_WUNLOCK(payouts_free); |
|
|
|
|
snprintf(reply, siz, |
|
|
|
|
"no payout with id %"PRId64, payoutid); |
|
|
|
|
return strdup(reply); |
|
|
|
|
} |
|
|
|
|
DATA_PAYOUTS(payouts, p_item); |
|
|
|
|
if (!PAYGENERATED(payouts->status)) { |
|
|
|
|
K_WUNLOCK(payouts_free); |
|
|
|
|
snprintf(reply, siz, |
|
|
|
|
"status !generated (%s) for payout %"PRId64, |
|
|
|
|
payouts->status, payoutid); |
|
|
|
|
return strdup(reply); |
|
|
|
|
} |
|
|
|
|
p2_item = k_unlink_head(payouts_free); |
|
|
|
|
K_WUNLOCK(payouts_free); |
|
|
|
|
|
|
|
|
|
/* There is a risk of the p_item changing while it's unlocked,
|
|
|
|
|
* but since this is a manual interface it's not really likely |
|
|
|
|
* and there'll be an error if something goes wrong |
|
|
|
|
* It reports the old and new status */ |
|
|
|
|
DATA_PAYOUTS(payouts2, p2_item); |
|
|
|
|
bzero(payouts2, sizeof(*payouts2)); |
|
|
|
|
payouts2->payoutid = payouts->payoutid; |
|
|
|
|
payouts2->height = payouts->height; |
|
|
|
|
STRNCPY(payouts2->blockhash, payouts->blockhash); |
|
|
|
|
payouts2->minerreward = payouts->minerreward; |
|
|
|
|
payouts2->workinfoidstart = payouts->workinfoidstart; |
|
|
|
|
payouts2->workinfoidend = payouts->workinfoidend; |
|
|
|
|
payouts2->elapsed = payouts->elapsed; |
|
|
|
|
STRNCPY(payouts2->status, PAYOUTS_ORPHAN_STR); |
|
|
|
|
payouts2->diffwanted = payouts->diffwanted; |
|
|
|
|
payouts2->diffused = payouts->diffused; |
|
|
|
|
payouts2->shareacc = payouts->shareacc; |
|
|
|
|
copy_tv(&(payouts2->lastshareacc), &(payouts->lastshareacc)); |
|
|
|
|
payouts2->stats = strdup(payouts->stats); |
|
|
|
|
|
|
|
|
|
ok = payouts_add(conn, true, p2_item, &old_p2_item, |
|
|
|
|
by, code, inet, now, NULL, false); |
|
|
|
|
if (!ok) { |
|
|
|
|
@ -4393,12 +4545,13 @@ static char *cmd_shifts(__maybe_unused PGconn *conn, char *cmd, char *id,
|
|
|
|
|
__maybe_unused tv_t *notcd, |
|
|
|
|
__maybe_unused K_TREE *trf_root) |
|
|
|
|
{ |
|
|
|
|
K_ITEM *i_username, *u_item, ms_look, *wm_item, *ms_item, *wi_item; |
|
|
|
|
K_ITEM *i_username, *u_item, *m_item, ms_look, *wm_item, *ms_item, *wi_item; |
|
|
|
|
K_TREE_CTX wm_ctx[1], ms_ctx[1]; |
|
|
|
|
WORKMARKERS *wm; |
|
|
|
|
WORKINFO *wi; |
|
|
|
|
MARKERSUMMARY markersummary, *ms, ms_add; |
|
|
|
|
USERS *users; |
|
|
|
|
MARKS *marks = NULL; |
|
|
|
|
char reply[1024] = ""; |
|
|
|
|
char tmp[1024]; |
|
|
|
|
size_t siz = sizeof(reply); |
|
|
|
|
@ -4434,6 +4587,19 @@ static char *cmd_shifts(__maybe_unused PGconn *conn, char *cmd, char *id,
|
|
|
|
|
if (CURRENT(&(wm->expirydate)) && WMPROCESSED(wm->status)) { |
|
|
|
|
K_RUNLOCK(workmarkers_free); |
|
|
|
|
|
|
|
|
|
K_RLOCK(marks_free); |
|
|
|
|
m_item = find_marks(wm->workinfoidend); |
|
|
|
|
K_RUNLOCK(marks_free); |
|
|
|
|
DATA_MARKS_NULL(marks, m_item); |
|
|
|
|
if (m_item == NULL) { |
|
|
|
|
// Log it but keep going
|
|
|
|
|
LOGERR("%s() missing mark for markerid " |
|
|
|
|
"%"PRId64"/%s widend %"PRId64, |
|
|
|
|
__func__, wm->markerid, |
|
|
|
|
wm->description, |
|
|
|
|
wm->workinfoidend); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
bzero(&ms_add, sizeof(ms_add)); |
|
|
|
|
|
|
|
|
|
markersummary.markerid = wm->markerid; |
|
|
|
|
@ -4502,6 +4668,12 @@ static char *cmd_shifts(__maybe_unused PGconn *conn, char *cmd, char *id,
|
|
|
|
|
rows, reply, FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
|
|
|
|
|
snprintf(tmp, sizeof(tmp), "endmarkextra:%d=%s%c", |
|
|
|
|
rows, |
|
|
|
|
m_item ? marks->extra : EMPTY, |
|
|
|
|
FLDSEP); |
|
|
|
|
APPEND_REALLOC(buf, off, len, tmp); |
|
|
|
|
|
|
|
|
|
ftv_to_buf(&(wi->createdate), reply, sizeof(reply)); |
|
|
|
|
snprintf(tmp, sizeof(tmp), "start:%d=%s%c", |
|
|
|
|
rows, reply, FLDSEP); |
|
|
|
|
|
Con Kolivas
10 years ago
