greg/stasis-bLSM
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix under-counting of tuples inserted into c0, which was causing it to slowly grow over time

Browse source 
git-svn-id: svn+ssh://svn.corp.yahoo.com/yahoo/yrl/labs/pnuts/code/logstore@3798 8dad8b1f-cf64-0410-95b6-bcf113ffbcfe
This commit is contained in:
sears 2012-02-27 01:37:44 +00:00
parent 0d21fcb2ff
commit 292b938a07
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
mergeManager.cpp
View file

@ -428,11 +428,14 @@ void mergeManager::tick(mergeStats * s) {
void mergeManager::read_tuple_from_small_component(int merge_level, dataTuple * tup) { void mergeManager::read_tuple_from_small_component(int merge_level, dataTuple * tup) {
if(tup) { if(tup) {
mergeStats * s = get_merge_stats(merge_level); mergeStats * s = get_merge_stats(merge_level);
(s->num_tuples_in_small)++; __sync_fetch_and_add(&s->num_tuples_in_small, 1);
// (s->num_tuples_in_small)++;
#if EXTENDED_STATS #if EXTENDED_STATS
(s->stats_bytes_in_small_delta) += tup->byte_length(); // (s->stats_bytes_in_small_delta) += tup->byte_length();
__sync_fetch_and_add(&s->stats_bytes_in_small_delta, tup->byte_length());
#endif #endif
(s->bytes_in_small) += tup->byte_length(); // (s->bytes_in_small) += tup->byte_length();
__sync_fetch_and_add(&s->bytes_in_small, tup->byte_length());
if(merge_level != 0) { if(merge_level != 0) {
update_progress(s, tup->byte_length()); update_progress(s, tup->byte_length());
} }