| ';
$nd = $ans['end:'.$i];
diff --git a/pool/prime.php b/pool/prime.php
index 539ef33b..6ee31cfb 100644
--- a/pool/prime.php
+++ b/pool/prime.php
@@ -3,6 +3,9 @@
global $stt;
$stt = microtime();
#
+global $loginfailed;
+$loginfailed = false;
+#
include_once('param.php');
include_once('base.php');
#
diff --git a/src/Makefile.am b/src/Makefile.am
index 5e032e62..61d13a6d 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -23,5 +23,5 @@ if WANT_CKDB
bin_PROGRAMS += ckdb
ckdb_SOURCES = ckdb.c ckdb_cmd.c ckdb_data.c ckdb_dbio.c ckdb_btc.c \
ckdb.h klist.c ktree.c klist.h ktree.h
-ckdb_LDADD = libckpool.la @JANSSON_LIBS@ @PQ_LIBS@
+ckdb_LDADD = libckpool.la @JANSSON_LIBS@ @PQ_LIBS@ @MATH_LIBS@
endif
diff --git a/src/ckdb.c b/src/ckdb.c
index 8ad9a05e..ac39b470 100644
--- a/src/ckdb.c
+++ b/src/ckdb.c
@@ -399,6 +399,8 @@ const char *blocks_unknown = "?Unknown?";
K_TREE *blocks_root;
K_LIST *blocks_free;
K_STORE *blocks_store;
+tv_t blocks_stats_time;
+bool blocks_stats_rebuild = true;
// MININGPAYOUTS
K_TREE *miningpayouts_root;
diff --git a/src/ckdb.h b/src/ckdb.h
index 8986339d..ecddeebc 100644
--- a/src/ckdb.h
+++ b/src/ckdb.h
@@ -37,6 +37,9 @@
#include
#endif
+#include
+#include
+
#include "ckpool.h"
#include "libckpool.h"
@@ -52,7 +55,7 @@
#define DB_VLOCK "1"
#define DB_VERSION "1.0.0"
-#define CKDB_VERSION DB_VERSION"-1.012"
+#define CKDB_VERSION DB_VERSION"-1.023"
#define WHERE_FFL " - from %s %s() line %d"
#define WHERE_FFL_HERE __FILE__, __func__, __LINE__
@@ -192,6 +195,11 @@ extern POOLSTATUS pool;
_dstoff += _srclen; \
} while(0)
+#define APPEND_REALLOC_RESET(_buf, _off) do { \
+ (_buf)[0] = '\0'; \
+ _off = 0; \
+ } while(0)
+
enum data_type {
TYPE_STR,
TYPE_BIGINT,
@@ -1095,6 +1103,26 @@ typedef struct blocks {
char statsconfirmed[TXT_FLAG+1];
HISTORYDATECONTROLFIELDS;
bool ignore; // Non DB field
+
+ // Calculated only when = 0
+ double netdiff;
+
+ /* Non DB fields for the web page
+ * Calculate them once off/recalc them when required */
+ double blockdiffratio;
+ double blockcdf;
+ double blockluck;
+
+ /* diffacc for range calculations - includes orphans before it
+ * orphans have this set to 0 so they can't be double counted */
+ double diffcalc;
+
+ /* From the last found block to this one
+ * Orphans have these set to zero */
+ double diffratio;
+ double diffmean;
+ double cdferl;
+ double luck;
} BLOCKS;
#define ALLOC_BLOCKS 100
@@ -1134,6 +1162,8 @@ extern const char *blocks_unknown;
extern K_TREE *blocks_root;
extern K_LIST *blocks_free;
extern K_STORE *blocks_store;
+extern tv_t blocks_stats_time;
+extern bool blocks_stats_rebuild;
// MININGPAYOUTS
typedef struct miningpayouts {
@@ -1193,6 +1223,10 @@ extern cklock_t process_pplns_lock;
#define PAYOUTS_PROCESSING 'P'
#define PAYOUTS_PROCESSING_STR "P"
#define PAYPROCESSING(_status) ((_status)[0] == PAYOUTS_PROCESSING)
+// An orphaned payout must be ignored
+#define PAYOUTS_ORPHAN 'O'
+#define PAYOUTS_ORPHAN_STR "O"
+#define PAYORPHAN(_status) ((_status)[0] == PAYOUTS_ORPHAN)
/*
// EVENTLOG
@@ -1750,6 +1784,7 @@ extern K_ITEM *find_prev_blocks(int32_t height);
extern const char *blocks_confirmed(char *confirmed);
extern void zero_on_new_block();
extern void set_block_share_counters();
+extern bool check_update_blocks_stats(tv_t *stats);
extern cmp_t cmp_miningpayouts(K_ITEM *a, K_ITEM *b);
extern K_ITEM *find_miningpayouts(int64_t payoutid, int64_t userid);
extern K_ITEM *first_miningpayouts(int64_t payoutid, K_TREE_CTX *ctx);
diff --git a/src/ckdb_cmd.c b/src/ckdb_cmd.c
index 303be5cd..80b1f9d1 100644
--- a/src/ckdb_cmd.c
+++ b/src/ckdb_cmd.c
@@ -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);
- snprintf(tmp, sizeof(tmp),
- "netdiff:%d=%.1f%c",
- rows, wdiff, FLDSEP);
- APPEND_REALLOC(buf, off, len, tmp);
+ if (has_stats) {
+ snprintf(tmp, sizeof(tmp),
+ "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);
@@ -4195,7 +4283,71 @@ static char *cmd_payouts(PGconn *conn, char *cmd, char *id, tv_t *now,
DATA_PAYOUTS(payouts2, p2_item);
DATA_PAYOUTS(old_payouts2, old_p2_item);
snprintf(msg, sizeof(msg),
- "payout %"PRId64" changed from '%s' to '%s' for"
+ "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) {
+ 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);
@@ -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);
diff --git a/src/ckdb_data.c b/src/ckdb_data.c
index 3878f342..a4227e7e 100644
--- a/src/ckdb_data.c
+++ b/src/ckdb_data.c
@@ -2399,6 +2399,131 @@ void set_block_share_counters()
LOGWARNING("%s(): Update block counters complete", __func__);
}
+/* Must be under K_WLOCK(blocks_free) when called
+ * Call this before using the block stats and again check (under lock)
+ * the blocks_stats_time didn't change after you finish processing
+ * If it has changed, redo the processing from scratch
+ * If return is false, then stats aren't available
+ * TODO: consider storing the partial calculations in the BLOCKS structure
+ * and only recalc from the last block modified (remembered)
+ * Will be useful with a large block history */
+bool check_update_blocks_stats(tv_t *stats)
+{
+ static int64_t last_missing_workinfoid = 0;
+ static tv_t last_message = { 0L, 0L };
+ K_TREE_CTX ctx[1];
+ K_ITEM *b_item, *w_item;
+ WORKINFO *workinfo;
+ BLOCKS *blocks;
+ char ndiffbin[TXT_SML+1];
+ double ok, diffacc, netsumm, diffmean, pending;
+ tv_t now;
+
+ /* Wait for startup_complete rather than db_load_complete
+ * This avoids doing a 'long' lock stats update while reloading */
+ if (!startup_complete)
+ return false;
+
+ if (blocks_stats_rebuild) {
+ /* Have to first work out the diffcalc for each block
+ * Orphans count towards the next valid block after the orphan
+ * so this has to be done in the reverse order of the range
+ * calculations */
+ pending = 0.0;
+ b_item = first_in_ktree(blocks_root, ctx);
+ while (b_item) {
+ DATA_BLOCKS(blocks, b_item);
+ if (CURRENT(&(blocks->expirydate))) {
+ pending += blocks->diffacc;
+ if (blocks->confirmed[0] == BLOCKS_ORPHAN)
+ blocks->diffcalc = 0.0;
+ else {
+ blocks->diffcalc = pending;
+ pending = 0.0;
+ }
+ }
+ b_item = next_in_ktree(ctx);
+ }
+ ok = diffacc = netsumm = diffmean = 0.0;
+ b_item = last_in_ktree(blocks_root, ctx);
+ while (b_item) {
+ DATA_BLOCKS(blocks, b_item);
+ if (CURRENT(&(blocks->expirydate))) {
+ if (blocks->netdiff == 0) {
+ // Deadlock alert
+ K_RLOCK(workinfo_free);
+ w_item = find_workinfo(blocks->workinfoid, NULL);
+ K_RUNLOCK(workinfo_free);
+ if (!w_item) {
+ setnow(&now);
+ if (!blocks->workinfoid != last_missing_workinfoid ||
+ tvdiff(&now, &last_message) >= 5.0) {
+ LOGEMERG("%s(): missing block workinfoid %"
+ PRId32"/%"PRId64"/%s",
+ __func__, blocks->height,
+ blocks->workinfoid,
+ blocks->confirmed);
+ }
+ last_missing_workinfoid = blocks->workinfoid;
+ copy_tv(&last_message, &now);
+ return false;
+ }
+ DATA_WORKINFO(workinfo, w_item);
+ hex2bin(ndiffbin, workinfo->bits, 4);
+ blocks->netdiff = diff_from_nbits(ndiffbin);
+ }
+ /* Stats for each blocks are independent of
+ * if they are orphans or not */
+ if (blocks->netdiff == 0.0)
+ blocks->blockdiffratio = 0.0;
+ else
+ blocks->blockdiffratio = blocks->diffacc / blocks->netdiff;
+ blocks->blockcdf = 1.0 - exp(-1.0 * blocks->blockdiffratio);
+ if (blocks->blockdiffratio == 0.0)
+ blocks->blockluck = 0.0;
+ else
+ blocks->blockluck = 1.0 / blocks->blockdiffratio;
+
+ /* Orphans are treated as +diffacc but no block
+ * i.e. they simply add shares to the later block
+ * and have running stats set to zero */
+ if (blocks->confirmed[0] == BLOCKS_ORPHAN) {
+ blocks->diffratio = 0.0;
+ blocks->diffmean = 0.0;
+ blocks->cdferl = 0.0;
+ blocks->luck = 0.0;
+ } else {
+ ok++;
+ diffacc += blocks->diffcalc;
+ netsumm += blocks->netdiff;
+
+ if (netsumm == 0.0)
+ blocks->diffratio = 0.0;
+ else
+ blocks->diffratio = diffacc / netsumm;
+
+ diffmean = ((diffmean * (ok - 1)) +
+ (blocks->diffcalc / blocks->netdiff)) / ok;
+ blocks->diffmean = diffmean;
+
+ if (diffmean == 0.0) {
+ blocks->cdferl = 0.0;
+ blocks->luck = 0.0;
+ } else {
+ blocks->cdferl = gsl_cdf_gamma_P(diffmean, ok, 1.0 / ok);
+ blocks->luck = 1.0 / diffmean;
+ }
+ }
+ }
+ b_item = prev_in_ktree(ctx);
+ }
+ setnow(&blocks_stats_time);
+ blocks_stats_rebuild = false;
+ }
+ copy_tv(stats, &blocks_stats_time);
+ return true;
+}
+
/* order by payoutid asc,userid asc,expirydate asc
* i.e. only one payout amount per block per user */
cmp_t cmp_miningpayouts(K_ITEM *a, K_ITEM *b)
diff --git a/src/ckdb_dbio.c b/src/ckdb_dbio.c
index 4db4f0ba..91e43fd8 100644
--- a/src/ckdb_dbio.c
+++ b/src/ckdb_dbio.c
@@ -3996,9 +3996,13 @@ unparam:
blocks_root = remove_from_ktree(blocks_root, old_b_item, cmp_blocks);
copy_tv(&(oldblocks->expirydate), cd);
blocks_root = add_to_ktree(blocks_root, old_b_item, cmp_blocks);
- }
+ // Copy it over to avoid having to recalculate it
+ row->netdiff = oldblocks->netdiff;
+ } else
+ row->netdiff = 0;
blocks_root = add_to_ktree(blocks_root, b_item, cmp_blocks);
k_add_head(blocks_store, b_item);
+ blocks_stats_rebuild = true;
}
K_WUNLOCK(blocks_free);
@@ -4300,9 +4304,13 @@ flail:
blocks_root = remove_from_ktree(blocks_root, old_b_item, cmp_blocks);
copy_tv(&(oldblocks->expirydate), cd);
blocks_root = add_to_ktree(blocks_root, old_b_item, cmp_blocks);
- }
+ // Copy it over to avoid having to recalculate it
+ row->netdiff = oldblocks->netdiff;
+ } else
+ row->netdiff = 0;
blocks_root = add_to_ktree(blocks_root, b_item, cmp_blocks);
k_add_head(blocks_store, b_item);
+ blocks_stats_rebuild = true;
}
K_WUNLOCK(blocks_free);
|