d0s3t3ch/wownero-puddle
1
0
Fork 0
mirror of https://git.wownero.com/wownero/wownero-puddle.git synced 2024-08-15 01:03:20 +00:00
Code Issues Projects Releases Wiki Activity

stats: pool hashrate avg over last 5 blocks

Browse source
This commit is contained in:
Jethro Grassie 2018-08-18 09:27:16 -04:00
parent e652433684
commit 538994b2d0
No known key found for this signature in database
GPG key ID: DE8ED755616565BB
1 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/pool.c
View file

@ -77,6 +77,8 @@
#define MAX_PATH 1024 #define MAX_PATH 1024
#define RPC_PATH "/json_rpc" #define RPC_PATH "/json_rpc"
#define ADDRESS_MAX 128 #define ADDRESS_MAX 128
#define BLOCK_TIME 120
#define HR_BLOCK_COUNT 5
#define uint128_t unsigned __int128 #define uint128_t unsigned __int128
@ -878,14 +880,20 @@ update_pool_hr(uint64_t height)
} }
MDB_cursor_op op = MDB_SET; MDB_cursor_op op = MDB_SET;
MDB_val key = { sizeof(height), &height }; MDB_val key = { sizeof(height), &height };
uint64_t lowest = height - HR_BLOCK_COUNT;
uint64_t cd = 0; uint64_t cd = 0;
while (1) log_trace("Getting pool hashrate from block %llu to %llu", height, lowest+1);
while (height > lowest)
{ {
MDB_val val; MDB_val val;
rc = mdb_cursor_get(cursor, &key, &val, op); rc = mdb_cursor_get(cursor, &key, &val, op);
op = MDB_NEXT_DUP; op = MDB_NEXT_DUP;
if (rc == MDB_NOTFOUND) if (rc == MDB_NOTFOUND)
break; {
op = MDB_SET;
height--;
continue;
}
else if (rc != 0 && rc != MDB_NOTFOUND) else if (rc != 0 && rc != MDB_NOTFOUND)
{ {
err = mdb_strerror(rc); err = mdb_strerror(rc);
@ -895,7 +903,7 @@ update_pool_hr(uint64_t height)
share_t *s = (share_t*) val.mv_data; share_t *s = (share_t*) val.mv_data;
cd += s->difficulty; cd += s->difficulty;
} }
pool_stats.pool_hashrate = cd / 120; pool_stats.pool_hashrate = cd / (HR_BLOCK_COUNT * BLOCK_TIME);
cleanup: cleanup:
mdb_cursor_close(cursor); mdb_cursor_close(cursor);
mdb_txn_abort(txn); mdb_txn_abort(txn);
@ -1400,7 +1408,7 @@ rpc_on_last_block_header(const char* data, rpc_callback_t *callback)
free(block); free(block);
pool_stats.network_difficulty = last_block_headers[0]->difficulty; pool_stats.network_difficulty = last_block_headers[0]->difficulty;
pool_stats.network_hashrate = last_block_headers[0]->difficulty / 120; pool_stats.network_hashrate = last_block_headers[0]->difficulty / BLOCK_TIME;
if (need_new_template) if (need_new_template)
{ {