mirror/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-02-02 03:51:50 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

[t:3654] #3654 Create new BRT_STATUS to collect info on brt behavior.

Browse source 
git-svn-id: file:///svn/toku/tokudb@32971 c7de825b-a66e-492c-adef-691d508d4ae1
This commit is contained in:
Barry Perlman 2013-04-16 23:59:44 -04:00 • committed by Yoni Fogel
parent 519b3f4a53
commit 833583c7a6
3 changed files with 31 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
newbrt/brt-internal.h
View file

@ -641,13 +641,19 @@ typedef struct le_status {
void toku_le_get_status(LE_STATUS);
typedef struct update_status {
typedef struct brt_status {
u_int64_t updates;
u_int64_t updates_broadcast;
u_int64_t descriptor_set;
} UPDATE_STATUS_S, *UPDATE_STATUS;
u_int64_t partial_fetch_hit; // node partition is present
u_int64_t partial_fetch_miss; // node is present but partition is absent
u_int64_t partial_fetch_compressed; // node partition is present but compressed
u_int64_t msn_discards; // how many messages were ignored by leaf because of msn
u_int64_t max_workdone; // max workdone value of any buffer
u_int64_t dsn_gap; // dsn has detected a gap in continuity of root-to-leaf path (internal node was evicted and re-read)
} BRT_STATUS_S, *BRT_STATUS;
void toku_update_get_status(UPDATE_STATUS);
void toku_brt_get_status(BRT_STATUS);
void
brt_leaf_apply_cmd_once (

29
newbrt/brt.c
View file

@ -113,6 +113,14 @@ Lookup:
static const uint32_t this_version = BRT_LAYOUT_VERSION;
static BRT_STATUS_S brt_status;
void
toku_brt_get_status(BRT_STATUS s) {
*s = brt_status;
}
void
toku_brt_header_suppress_rollbacks(struct brt_header *h, TOKUTXN txn) {
@ -1657,8 +1665,11 @@ brt_leaf_apply_cmd_once (
workdone_this_le = newlen;
}
}
if (workdone) // test programs may call with NULL
if (workdone) { // test programs may call with NULL
*workdone += workdone_this_le;
if (*workdone > brt_status.max_workdone)
brt_status.max_workdone = *workdone;
}
// brt_leaf_check_leaf_stats(node);
@ -1716,13 +1727,6 @@ static void setval_fun (const DBT *new_val, void *svextra_v) {
svextra->made_change = TRUE;
}
static UPDATE_STATUS_S update_status;
void
toku_update_get_status(UPDATE_STATUS s) {
*s = update_status;
}
// We are already past the msn filter (in brt_leaf_put_cmd(), which calls do_update()),
// so capturing the msn in the setval_extra_s is not strictly required. The alternative
// would be to put a dummy msn in the messages created by setval_fun(), but preserving
@ -1741,7 +1745,7 @@ static int do_update(BRT t, BASEMENTNODE bn, SUBTREE_EST se, BRT_MSG cmd, int id
if (cmd->type == BRT_UPDATE) {
// key is passed in with command (should be same as from le)
// update function extra is passed in with command
update_status.updates++;
brt_status.updates++;
keyp = cmd->u.id.key;
update_function_extra = cmd->u.id.val;
} else if (cmd->type == BRT_UPDATE_BROADCAST_ALL) {
@ -1750,7 +1754,7 @@ static int do_update(BRT t, BASEMENTNODE bn, SUBTREE_EST se, BRT_MSG cmd, int id
assert(le); // for broadcast updates, we just hit all leafentries
// so this cannot be null
assert(cmd->u.id.key->size == 0);
update_status.updates_broadcast++;
brt_status.updates_broadcast++;
keyp = toku_fill_dbt(&key, le_key(le), le_keylen(le));
update_function_extra = cmd->u.id.val;
} else {
@ -1806,7 +1810,7 @@ brt_leaf_put_cmd (
LEAFENTRY storeddata;
OMTVALUE storeddatav=NULL;
if (cmd->msn.msn <= bn->max_msn_applied.msn) {
// TODO3514 add accountability counter here
brt_status.msn_discards++;
return;
}
else {
@ -2836,6 +2840,7 @@ partition_requires_msg_application(BRTNODE node, int childnum, ANCESTORS ancesto
{
if (curr_ancestors->node->dsn.dsn > BLB_MAX_DSN_APPLIED(node,childnum).dsn) {
requires_msg_application = TRUE;
brt_status.dsn_gap++;
break;
}
}
@ -3847,7 +3852,7 @@ toku_brt_change_descriptor(
fd = toku_cachefile_get_and_pin_fd (t->cf);
r = toku_update_descriptor(t->h, &new_d, fd);
if (r == 0) // very infrequent operation, worth precise threadsafe count
(void) toku_sync_fetch_and_increment_uint64(&update_status.descriptor_set);
(void) toku_sync_fetch_and_increment_uint64(&brt_status.descriptor_set);
toku_cachefile_unpin_fd(t->cf);
if (r!=0) goto cleanup;

10
src/ydb.c
View file

@ -1925,11 +1925,11 @@ env_get_engine_status(DB_ENV * env, ENGINE_STATUS * engstat, char * env_panic_st
engstat->directory_write_locks_fail = directory_write_locks_fail;
}
{
UPDATE_STATUS_S update_stat;
toku_update_get_status(&update_stat);
engstat->le_updates = update_stat.updates;
engstat->le_updates_broadcast = update_stat.updates_broadcast;
engstat->descriptor_set = update_stat.descriptor_set;
BRT_STATUS_S brt_stat;
toku_brt_get_status(&brt_stat);
engstat->le_updates = brt_stat.updates;
engstat->le_updates_broadcast = brt_stat.updates_broadcast;
engstat->descriptor_set = brt_stat.descriptor_set;
}
{
u_int64_t fsync_count, fsync_time;