From 5b1f4e9219a8c0a1927f5d3fb42a716ab99fbea5 Mon Sep 17 00:00:00 2001 From: kanoi Date: Thu, 28 Aug 2014 21:47:02 +1000 Subject: [PATCH] ckdb/php - a blocklist of the last 42 blocks --- pool/db.php | 12 ++++++ pool/page_blocks.php | 45 +++++++++++++++++++++ pool/prime.php | 3 +- src/ckdb.c | 94 ++++++++++++++++++++++++++++++++++++++++---- 4 files changed, 145 insertions(+), 9 deletions(-) create mode 100644 pool/page_blocks.php diff --git a/pool/db.php b/pool/db.php index 7e705c81..d47931e8 100644 --- a/pool/db.php +++ b/pool/db.php @@ -151,4 +151,16 @@ function getPayments($user) return $rep; } # +function getBlocks($user) +{ + if ($user == false) + showIndex(); + $flds = array(); + $msg = msgEncode('blocklist', 'blk', $flds); + $rep = sendsockreply('getBlocks', $msg); + if (!$rep) + dbdown(); + return $rep; +} +# ?> diff --git a/pool/page_blocks.php b/pool/page_blocks.php new file mode 100644 index 00000000..f031a96b --- /dev/null +++ b/pool/page_blocks.php @@ -0,0 +1,45 @@ +Blocks'; + + $rep = getBlocks($user); + $ans = repDecode($rep); + + $pg .= "\n"; + $pg .= ""; + $pg .= ""; + $pg .= ""; + $pg .= ""; + $pg .= ""; + $pg .= "\n"; + if ($ans['STATUS'] == 'ok') + { + $count = $ans['rows']; + for ($i = 0; $i < $count; $i++) + { + if (($i % 2) == 0) + $row = 'even'; + else + $row = 'odd'; + + $pg .= ""; + $pg .= ''; + $pg .= ''; + $pg .= ''; + $pg .= ''; + $pg .= "\n"; + } + } + $pg .= "
HeightWhoRewardWhen
'.$ans['height'.$i].''.$ans['workername'.$i].''.btcfmt($ans['reward'.$i]).''.gmdate('Y-m-d H:i:s+00', $ans['createdate'.$i]).'
\n"; + + return $pg; +} +# +function show_blocks($menu, $name, $user) +{ + gopage(NULL, 'doblocks', $menu, $name, $user); +} +# +?> diff --git a/pool/prime.php b/pool/prime.php index 66e27b64..5385e566 100644 --- a/pool/prime.php +++ b/pool/prime.php @@ -15,7 +15,8 @@ function process($p, $user) 'Settings' => 'settings' ), 'Pool' => array( - 'Stats' => 'stats' + 'Stats' => 'stats', + 'Blocks' => 'blocks' ), 'gap' => NULL, 'Help' => array( diff --git a/src/ckdb.c b/src/ckdb.c index a4928a70..ad86f65f 100644 --- a/src/ckdb.c +++ b/src/ckdb.c @@ -47,7 +47,7 @@ #define DB_VLOCK "1" #define DB_VERSION "0.7" -#define CKDB_VERSION DB_VERSION"-0.100" +#define CKDB_VERSION DB_VERSION"-0.101" #define WHERE_FFL " - from %s %s() line %d" #define WHERE_FFL_HERE __FILE__, __func__, __LINE__ @@ -773,6 +773,7 @@ enum cmd_values { CMD_POOLSTAT, CMD_USERSTAT, CMD_BLOCK, + CMD_BLOCKLIST, CMD_NEWID, CMD_PAYMENTS, CMD_WORKERS, @@ -7073,6 +7074,72 @@ static char *cmd_userstats(__maybe_unused PGconn *conn, char *cmd, char *id, return strdup(reply); } +static char *cmd_blocklist(__maybe_unused PGconn *conn, char *cmd, char *id, + __maybe_unused tv_t *now, __maybe_unused char *by, + __maybe_unused char *code, __maybe_unused char *inet, + __maybe_unused tv_t *notcd, + __maybe_unused K_TREE *trf_root) +{ + K_TREE_CTX ctx[1]; + K_ITEM *b_item; + char reply[1024] = ""; + char tmp[1024]; + char *buf; + size_t len, off; + int rows; + int32_t height; + + LOGDEBUG("%s(): cmd '%s'", __func__, cmd); + + b_item = last_in_ktree(blocks_root, ctx); + APPEND_REALLOC_INIT(buf, off, len); + APPEND_REALLOC(buf, off, len, "ok."); + rows = 0; + height = -1; + while (b_item && rows < 42) { + if (height != DATA_BLOCKS(b_item)->height) { + height = DATA_BLOCKS(b_item)->height; + + snprintf(tmp, sizeof(tmp), "height%d=%d%c", rows, height, FLDSEP); + APPEND_REALLOC(buf, off, len, tmp); + + str_to_buf(DATA_BLOCKS(b_item)->blockhash, reply, sizeof(reply)); + snprintf(tmp, sizeof(tmp), "blockhash%d=%s%c", rows, reply, FLDSEP); + APPEND_REALLOC(buf, off, len, tmp); + + str_to_buf(DATA_BLOCKS(b_item)->nonce, reply, sizeof(reply)); + snprintf(tmp, sizeof(tmp), "nonce%d=%s%c", rows, reply, FLDSEP); + APPEND_REALLOC(buf, off, len, tmp); + + bigint_to_buf(DATA_BLOCKS(b_item)->reward, reply, sizeof(reply)); + snprintf(tmp, sizeof(tmp), "reward%d=%s%c", rows, reply, FLDSEP); + APPEND_REALLOC(buf, off, len, tmp); + + str_to_buf(DATA_BLOCKS(b_item)->workername, reply, sizeof(reply)); + snprintf(tmp, sizeof(tmp), "workername%d=%s%c", rows, reply, FLDSEP); + APPEND_REALLOC(buf, off, len, tmp); + + snprintf(tmp, sizeof(tmp), + "createdate%d=%ld%c", rows, + DATA_BLOCKS(b_item)->createdate.tv_sec, FLDSEP); + APPEND_REALLOC(buf, off, len, tmp); + + snprintf(tmp, sizeof(tmp), + "status%d=%s%c", rows, + blocks_confirmed(DATA_BLOCKS(b_item)->confirmed), FLDSEP); + APPEND_REALLOC(buf, off, len, tmp); + + rows++; + } + b_item = prev_in_ktree(ctx); + } + snprintf(tmp, sizeof(tmp), "rows=%d", rows); + APPEND_REALLOC(buf, off, len, tmp); + + LOGDEBUG("%s.ok.%d_blocks", id, rows); + return buf; +} + static char *cmd_newid(PGconn *conn, char *cmd, char *id, tv_t *now, char *by, char *code, char *inet, __maybe_unused tv_t *cd, K_TREE *trf_root) @@ -8624,6 +8691,7 @@ static struct CMDS { { CMD_POOLSTAT, "poolstats", false, true, cmd_poolstats, ACCESS_POOL }, { CMD_USERSTAT, "userstats", false, true, cmd_userstats, ACCESS_POOL }, { CMD_BLOCK, "block", false, true, cmd_blocks, ACCESS_POOL }, + { CMD_BLOCKLIST,"blocklist", false, false, cmd_blocklist, ACCESS_WEB }, { CMD_NEWID, "newid", false, false, cmd_newid, ACCESS_SYSTEM }, { CMD_PAYMENTS, "payments", false, false, cmd_payments, ACCESS_WEB }, { CMD_WORKERS, "workers", false, false, cmd_workers, ACCESS_WEB }, @@ -9183,13 +9251,6 @@ static void *socketer(__maybe_unused void *arg) else LOGWARNING("Empty message in listener"); } else { - if (want_first) { - ck_wlock(&fpm_lock); - first_pool_message = strdup(buf); - ck_wunlock(&fpm_lock); - want_first = false; - } - /* For duplicates: * Queued pool messages are handled by the queue code * but since they reply ok.queued that message can @@ -9295,9 +9356,17 @@ static void *socketer(__maybe_unused void *arg) break; // Always process immediately: case CMD_AUTH: + // First message from the pool + if (want_first) { + ck_wlock(&fpm_lock); + first_pool_message = strdup(buf); + ck_wunlock(&fpm_lock); + want_first = false; + } case CMD_CHKPASS: case CMD_ADDUSER: case CMD_NEWPASS: + case CMD_BLOCKLIST: case CMD_NEWID: case CMD_STATS: ans = cmds[which_cmds].func(NULL, cmd, id, &now, @@ -9405,6 +9474,14 @@ static void *socketer(__maybe_unused void *arg) case CMD_POOLSTAT: case CMD_USERSTAT: case CMD_BLOCK: + // First message from the pool + if (want_first) { + ck_wlock(&fpm_lock); + first_pool_message = strdup(buf); + ck_wunlock(&fpm_lock); + want_first = false; + } + snprintf(reply, sizeof(reply), "%s.%ld.ok.queued", id, now.tv_sec); @@ -9529,6 +9606,7 @@ static bool reload_line(PGconn *conn, char *filename, uint64_t count, char *buf) case CMD_ADDUSER: case CMD_NEWPASS: case CMD_CHKPASS: + case CMD_BLOCKLIST: case CMD_NEWID: case CMD_PAYMENTS: case CMD_WORKERS: