Commit a4239f4e authored by Zardosht Kasheff's avatar Zardosht Kasheff Committed by Yoni Fogel

[t:4529], some more cleanup

git-svn-id: file:///svn/toku/tokudb@41204 c7de825b-a66e-492c-adef-691d508d4ae1
parent 18b1d444
...@@ -859,9 +859,6 @@ typedef enum { ...@@ -859,9 +859,6 @@ typedef enum {
BRT_UPDATES = 0, BRT_UPDATES = 0,
BRT_UPDATES_BROADCAST, BRT_UPDATES_BROADCAST,
BRT_DESCRIPTOR_SET, BRT_DESCRIPTOR_SET,
BRT_PARTIAL_FETCH_HIT, // node partition is present
BRT_PARTIAL_FETCH_MISS, // node is present but partition is absent
BRT_PARTIAL_FETCH_COMPRESSED, // node partition is present but compressed
BRT_PARTIAL_EVICTIONS_NONLEAF, // number of nonleaf node partial evictions BRT_PARTIAL_EVICTIONS_NONLEAF, // number of nonleaf node partial evictions
BRT_PARTIAL_EVICTIONS_LEAF, // number of leaf node partial evictions BRT_PARTIAL_EVICTIONS_LEAF, // number of leaf node partial evictions
BRT_MSN_DISCARDS, // how many messages were ignored by leaf because of msn BRT_MSN_DISCARDS, // how many messages were ignored by leaf because of msn
......
...@@ -158,9 +158,6 @@ status_init(void) ...@@ -158,9 +158,6 @@ status_init(void)
STATUS_INIT(BRT_UPDATES, UINT64, "dictionary updates"); STATUS_INIT(BRT_UPDATES, UINT64, "dictionary updates");
STATUS_INIT(BRT_UPDATES_BROADCAST, UINT64, "dictionary broadcast updates"); STATUS_INIT(BRT_UPDATES_BROADCAST, UINT64, "dictionary broadcast updates");
STATUS_INIT(BRT_DESCRIPTOR_SET, UINT64, "descriptor set"); STATUS_INIT(BRT_DESCRIPTOR_SET, UINT64, "descriptor set");
STATUS_INIT(BRT_PARTIAL_FETCH_HIT, UINT64, "partial fetch hit, node partition is present");
STATUS_INIT(BRT_PARTIAL_FETCH_MISS, UINT64, "partial fetch miss, node present but partition absent");
STATUS_INIT(BRT_PARTIAL_FETCH_COMPRESSED, UINT64, "partial fetch, node partition is present but compressed");
STATUS_INIT(BRT_PARTIAL_EVICTIONS_NONLEAF, UINT64, "nonleaf node partial evictions"); STATUS_INIT(BRT_PARTIAL_EVICTIONS_NONLEAF, UINT64, "nonleaf node partial evictions");
STATUS_INIT(BRT_PARTIAL_EVICTIONS_LEAF, UINT64, "leaf node partial evictions"); STATUS_INIT(BRT_PARTIAL_EVICTIONS_LEAF, UINT64, "leaf node partial evictions");
STATUS_INIT(BRT_MSN_DISCARDS, UINT64, "messages ignored by leaf due to msn"); STATUS_INIT(BRT_MSN_DISCARDS, UINT64, "messages ignored by leaf due to msn");
...@@ -952,24 +949,6 @@ exit: ...@@ -952,24 +949,6 @@ exit:
return 0; return 0;
} }
static inline void
brt_status_update_partial_fetch(u_int8_t UU(state))
{
#if 0
if (state == PT_AVAIL) {
STATUS_VALUE(BRT_PARTIAL_FETCH_HIT)++;
}
else if (state == PT_COMPRESSED) {
STATUS_VALUE(BRT_PARTIAL_FETCH_COMPRESSED)++;
}
else if (state == PT_ON_DISK){
STATUS_VALUE(BRT_PARTIAL_FETCH_MISS)++;
}
else {
invariant(FALSE);
}
#endif
}
// Callback that states if a partial fetch of the node is necessary // Callback that states if a partial fetch of the node is necessary
// Currently, this function is responsible for the following things: // Currently, this function is responsible for the following things:
...@@ -1006,7 +985,6 @@ BOOL toku_brtnode_pf_req_callback(void* brtnode_pv, void* read_extraargs) { ...@@ -1006,7 +985,6 @@ BOOL toku_brtnode_pf_req_callback(void* brtnode_pv, void* read_extraargs) {
if (BP_STATE(node,i) != PT_AVAIL) { if (BP_STATE(node,i) != PT_AVAIL) {
retval = TRUE; retval = TRUE;
} }
brt_status_update_partial_fetch(BP_STATE(node, i));
} }
} }
else if (bfe->type == brtnode_fetch_subset) { else if (bfe->type == brtnode_fetch_subset) {
...@@ -1026,7 +1004,6 @@ BOOL toku_brtnode_pf_req_callback(void* brtnode_pv, void* read_extraargs) { ...@@ -1026,7 +1004,6 @@ BOOL toku_brtnode_pf_req_callback(void* brtnode_pv, void* read_extraargs) {
BP_TOUCH_CLOCK(node,bfe->child_to_read); BP_TOUCH_CLOCK(node,bfe->child_to_read);
// child we want to read is not available, must set retval to TRUE // child we want to read is not available, must set retval to TRUE
retval = (BP_STATE(node, bfe->child_to_read) != PT_AVAIL); retval = (BP_STATE(node, bfe->child_to_read) != PT_AVAIL);
brt_status_update_partial_fetch(BP_STATE(node, bfe->child_to_read));
} }
else if (bfe->type == brtnode_fetch_prefetch) { else if (bfe->type == brtnode_fetch_prefetch) {
// makes no sense to have prefetching disabled // makes no sense to have prefetching disabled
...@@ -1038,7 +1015,6 @@ BOOL toku_brtnode_pf_req_callback(void* brtnode_pv, void* read_extraargs) { ...@@ -1038,7 +1015,6 @@ BOOL toku_brtnode_pf_req_callback(void* brtnode_pv, void* read_extraargs) {
if (BP_STATE(node, i) != PT_AVAIL) { if (BP_STATE(node, i) != PT_AVAIL) {
retval = TRUE; retval = TRUE;
} }
brt_status_update_partial_fetch(BP_STATE(node, i));
} }
} }
else { else {
......
...@@ -486,8 +486,7 @@ void toku_cachetable_maybe_flush_some(CACHETABLE ct); ...@@ -486,8 +486,7 @@ void toku_cachetable_maybe_flush_some(CACHETABLE ct);
u_int64_t toku_cachefile_size_in_memory(CACHEFILE cf); u_int64_t toku_cachefile_size_in_memory(CACHEFILE cf);
typedef enum { typedef enum {
CT_HIT = 0, CT_MISS = 0,
CT_MISS,
CT_MISSTIME, // how many usec spent waiting for disk read because of cache miss CT_MISSTIME, // how many usec spent waiting for disk read because of cache miss
CT_WAITTIME, // how many usec spent waiting for another thread to release cache line CT_WAITTIME, // how many usec spent waiting for another thread to release cache line
CT_WAIT_READING, CT_WAIT_READING,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment