Skip to content

M
MariaDB
Commit 1c7e62ad authored by Leif Walsh's avatar Leif Walsh Committed by Yoni Fogel
Browse files
Options

refs #5155 merge some work to main: 

 - better delete marked algorithm
 - use marked omt for fresh message tree
 - little cleanup things


git-svn-id: file:///svn/toku/tokudb@46549 c7de825b-a66e-492c-adef-691d508d4ae1
parent f777bd0a
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 310 additions and 442 deletions
ft/fifo.cc
View file @ 1c7e62ad
...@@ -51,13 +51,13 @@ int toku_fifo_n_entries(FIFO fifo) { ...@@ -51,13 +51,13 @@ int toku_fifo_n_entries(FIFO fifo) {
static int next_power_of_two (int n) { static int next_power_of_two (int n) {
int r = 4096; int r = 4096;
while (r < n) { while (r < n) {
r*=2; r*=2;
assert(r>0); assert(r>0);
} }
return r; return r;
} }
int toku_fifo_enq(FIFO fifo, const void *key, unsigned int keylen, const void *data, unsigned int datalen, enum ft_msg_type type, MSN msn, XIDS xids, bool is_fresh, long *dest) { int toku_fifo_enq(FIFO fifo, const void *key, unsigned int keylen, const void *data, unsigned int datalen, enum ft_msg_type type, MSN msn, XIDS xids, bool is_fresh, int32_t *dest) {
int need_space_here = sizeof(struct fifo_entry) int need_space_here = sizeof(struct fifo_entry)
+ keylen + datalen + keylen + datalen
+ xids_get_size(xids) + xids_get_size(xids)
...@@ -134,7 +134,7 @@ DBT *fill_dbt_for_fifo_entry(DBT *dbt, const struct fifo_entry *entry) { ...@@ -134,7 +134,7 @@ DBT *fill_dbt_for_fifo_entry(DBT *dbt, const struct fifo_entry *entry) {
return toku_fill_dbt(dbt, xids_get_end_of_array((XIDS) &entry->xids_s), entry->keylen); return toku_fill_dbt(dbt, xids_get_end_of_array((XIDS) &entry->xids_s), entry->keylen);
} }
const struct fifo_entry *toku_fifo_get_entry(FIFO fifo, long off) { struct fifo_entry *toku_fifo_get_entry(FIFO fifo, int off) {
return toku_fifo_iterate_internal_get_entry(fifo, off); return toku_fifo_iterate_internal_get_entry(fifo, off);
} }
......
ft/fifo.h
View file @ 1c7e62ad
...@@ -55,7 +55,7 @@ void toku_fifo_free(FIFO *); ...@@ -55,7 +55,7 @@ void toku_fifo_free(FIFO *);
int toku_fifo_n_entries(FIFO); int toku_fifo_n_entries(FIFO);
int toku_fifo_enq (FIFO, const void *key, ITEMLEN keylen, const void *data, ITEMLEN datalen, enum ft_msg_type type, MSN msn, XIDS xids, bool is_fresh, long *dest); int toku_fifo_enq (FIFO, const void *key, ITEMLEN keylen, const void *data, ITEMLEN datalen, enum ft_msg_type type, MSN msn, XIDS xids, bool is_fresh, int32_t *dest);
unsigned int toku_fifo_buffer_size_in_use (FIFO fifo); unsigned int toku_fifo_buffer_size_in_use (FIFO fifo);
unsigned long toku_fifo_memory_size_in_use(FIFO fifo); // return how much memory in the fifo holds useful data unsigned long toku_fifo_memory_size_in_use(FIFO fifo); // return how much memory in the fifo holds useful data
...@@ -90,7 +90,7 @@ int toku_fifo_iterate_internal_next(FIFO fifo, int off); ...@@ -90,7 +90,7 @@ int toku_fifo_iterate_internal_next(FIFO fifo, int off);
struct fifo_entry * toku_fifo_iterate_internal_get_entry(FIFO fifo, int off); struct fifo_entry * toku_fifo_iterate_internal_get_entry(FIFO fifo, int off);
DBT *fill_dbt_for_fifo_entry(DBT *dbt, const struct fifo_entry *entry); DBT *fill_dbt_for_fifo_entry(DBT *dbt, const struct fifo_entry *entry);
const struct fifo_entry *toku_fifo_get_entry(FIFO fifo, long off); struct fifo_entry *toku_fifo_get_entry(FIFO fifo, int off);
void toku_fifo_clone(FIFO orig_fifo, FIFO* cloned_fifo); void toku_fifo_clone(FIFO orig_fifo, FIFO* cloned_fifo);
......
ft/ft-cachetable-wrappers.cc
View file @ 1c7e62ad
...@@ -149,8 +149,11 @@ toku_pin_ftnode( ...@@ -149,8 +149,11 @@ toku_pin_ftnode(
unlockers); unlockers);
if (r==0) { if (r==0) {
FTNODE node = (FTNODE) node_v; FTNODE node = (FTNODE) node_v;
if (apply_ancestor_messages) { if (apply_ancestor_messages && node->height == 0) {
maybe_apply_ancestors_messages_to_node(brt, node, ancestors, bounds, msgs_applied); toku_apply_ancestors_messages_to_node(brt, node, ancestors, bounds, msgs_applied);
}
if (may_modify_node && node->height > 0) {
toku_move_ftnode_messages_to_stale(brt->ft, node);
} }
*node_p = node; *node_p = node;
// printf("%*sPin %ld\n", 8-node->height, "", blocknum.b); // printf("%*sPin %ld\n", 8-node->height, "", blocknum.b);
...@@ -204,9 +207,26 @@ toku_pin_ftnode_off_client_thread( ...@@ -204,9 +207,26 @@ toku_pin_ftnode_off_client_thread(
); );
assert(r==0); assert(r==0);
FTNODE node = (FTNODE) node_v; FTNODE node = (FTNODE) node_v;
if (may_modify_node && node->height > 0) {
toku_move_ftnode_messages_to_stale(h, node);
}
*node_p = node; *node_p = node;
} }
int toku_maybe_pin_ftnode_clean(FT ft, BLOCKNUM blocknum, uint32_t fullhash, FTNODE *nodep, bool may_modify_node) {
void *node_v;
int r = toku_cachetable_maybe_get_and_pin_clean(ft->cf, blocknum, fullhash, &node_v);
if (r != 0) {
goto cleanup;
}
CAST_FROM_VOIDP(*nodep, node_v);
if (may_modify_node && (*nodep)->height > 0) {
toku_move_ftnode_messages_to_stale(ft, *nodep);
}
cleanup:
return r;
}
void void
toku_unpin_ftnode_off_client_thread(FT ft, FTNODE node) toku_unpin_ftnode_off_client_thread(FT ft, FTNODE node)
{ {
......
ft/ft-cachetable-wrappers.h
View file @ 1c7e62ad
...@@ -94,6 +94,12 @@ toku_pin_ftnode_off_client_thread( ...@@ -94,6 +94,12 @@ toku_pin_ftnode_off_client_thread(
FTNODE *node_p FTNODE *node_p
); );
/**
* This function may return a pinned ftnode to the caller, if pinning is cheap.
* If the node is already locked, or is pending a checkpoint, the node is not pinned and -1 is returned.
*/
int toku_maybe_pin_ftnode_clean(FT ft, BLOCKNUM blocknum, uint32_t fullhash, FTNODE *nodep, bool may_modify_node);
/** /**
* Effect: Unpin a brt node. Used for * Effect: Unpin a brt node. Used for
* nodes that were pinned off client thread. * nodes that were pinned off client thread.
......
ft/ft-flusher.cc
View file @ 1c7e62ad
...@@ -1784,15 +1784,9 @@ flush_node_on_background_thread(FT h, FTNODE parent) ...@@ -1784,15 +1784,9 @@ flush_node_on_background_thread(FT h, FTNODE parent)
// //
// see if we can pin the child // see if we can pin the child
// //
void *node_v;
FTNODE child; FTNODE child;
uint32_t childfullhash = compute_child_fullhash(h->cf, parent, childnum); uint32_t childfullhash = compute_child_fullhash(h->cf, parent, childnum);
int r = toku_cachetable_maybe_get_and_pin_clean ( int r = toku_maybe_pin_ftnode_clean(h, BP_BLOCKNUM(parent, childnum), childfullhash, &child, true);
h->cf,
BP_BLOCKNUM(parent,childnum),
childfullhash,
&node_v
);
if (r != 0) { if (r != 0) {
// In this case, we could not lock the child, so just place the parent on the background thread // In this case, we could not lock the child, so just place the parent on the background thread
// In the callback, we will use flush_some_child, which checks to // In the callback, we will use flush_some_child, which checks to
...@@ -1803,7 +1797,6 @@ flush_node_on_background_thread(FT h, FTNODE parent) ...@@ -1803,7 +1797,6 @@ flush_node_on_background_thread(FT h, FTNODE parent)
// //
// successfully locked child // successfully locked child
// //
child = (FTNODE) node_v;
bool may_child_be_reactive = may_node_be_reactive(child); bool may_child_be_reactive = may_node_be_reactive(child);
if (!may_child_be_reactive) { if (!may_child_be_reactive) {
// We're going to unpin the parent, so before we do, we must // We're going to unpin the parent, so before we do, we must
......
ft/ft-internal.h
View file @ 1c7e62ad
...@@ -104,7 +104,7 @@ struct toku_fifo_entry_key_msn_heaviside_extra { ...@@ -104,7 +104,7 @@ struct toku_fifo_entry_key_msn_heaviside_extra {
// comparison function for inserting messages into a // comparison function for inserting messages into a
// ftnode_nonleaf_childinfo's message_tree // ftnode_nonleaf_childinfo's message_tree
int int
toku_fifo_entry_key_msn_heaviside(const long &v, const struct toku_fifo_entry_key_msn_heaviside_extra &extra); toku_fifo_entry_key_msn_heaviside(const int32_t &v, const struct toku_fifo_entry_key_msn_heaviside_extra &extra);
struct toku_fifo_entry_key_msn_cmp_extra { struct toku_fifo_entry_key_msn_cmp_extra {
DESCRIPTOR desc; DESCRIPTOR desc;
...@@ -114,15 +114,16 @@ struct toku_fifo_entry_key_msn_cmp_extra { ...@@ -114,15 +114,16 @@ struct toku_fifo_entry_key_msn_cmp_extra {
// same thing for qsort_r // same thing for qsort_r
int int
toku_fifo_entry_key_msn_cmp(const struct toku_fifo_entry_key_msn_cmp_extra &extrap, const long &a, const long &b); toku_fifo_entry_key_msn_cmp(const struct toku_fifo_entry_key_msn_cmp_extra &extrap, const int &a, const int &b);
typedef toku::omt<long> off_omt_t; typedef toku::omt<int32_t> off_omt_t;
typedef toku::omt<int32_t, int32_t, true> marked_off_omt_t;
// data of an available partition of a nonleaf ftnode // data of an available partition of a nonleaf ftnode
struct ftnode_nonleaf_childinfo { struct ftnode_nonleaf_childinfo {
FIFO buffer; FIFO buffer;
off_omt_t broadcast_list; off_omt_t broadcast_list;
off_omt_t fresh_message_tree; marked_off_omt_t fresh_message_tree;
off_omt_t stale_message_tree; off_omt_t stale_message_tree;
}; };
...@@ -807,8 +808,9 @@ struct pivot_bounds { ...@@ -807,8 +808,9 @@ struct pivot_bounds {
const DBT * const upper_bound_inclusive; // NULL to indicate negative or positive infinity (which are in practice exclusive since there are now transfinite keys in messages). const DBT * const upper_bound_inclusive; // NULL to indicate negative or positive infinity (which are in practice exclusive since there are now transfinite keys in messages).
}; };
// FIXME needs toku prefix __attribute__((nonnull))
void maybe_apply_ancestors_messages_to_node (FT_HANDLE t, FTNODE node, ANCESTORS ancestors, struct pivot_bounds const * const bounds, bool* msgs_applied); void toku_move_ftnode_messages_to_stale(FT ft, FTNODE node);
void toku_apply_ancestors_messages_to_node (FT_HANDLE t, FTNODE node, ANCESTORS ancestors, struct pivot_bounds const * const bounds, bool* msgs_applied);
int int
toku_ft_search_which_child( toku_ft_search_which_child(
......
ft/ft-ops.cc
View file @ 1c7e62ad
This diff is collapsed.
ft/ft-verify.cc
View file @ 1c7e62ad
...@@ -106,9 +106,9 @@ struct count_msgs_extra { ...@@ -106,9 +106,9 @@ struct count_msgs_extra {
}; };
// template-only function, but must be extern // template-only function, but must be extern
int count_msgs(const long &offset, const uint32_t UU(idx), struct count_msgs_extra *const e) int count_msgs(const int32_t &offset, const uint32_t UU(idx), struct count_msgs_extra *const e)
__attribute__((nonnull(3))); __attribute__((nonnull(3)));
int count_msgs(const long &offset, const uint32_t UU(idx), struct count_msgs_extra *const e) int count_msgs(const int32_t &offset, const uint32_t UU(idx), struct count_msgs_extra *const e)
{ {
const struct fifo_entry *entry = toku_fifo_get_entry(e->fifo, offset); const struct fifo_entry *entry = toku_fifo_get_entry(e->fifo, offset);
if (entry->msn.msn == e->msn.msn) { if (entry->msn.msn == e->msn.msn) {
...@@ -128,9 +128,9 @@ struct verify_message_tree_extra { ...@@ -128,9 +128,9 @@ struct verify_message_tree_extra {
}; };
// template-only function, but must be extern // template-only function, but must be extern
int verify_message_tree(const long &offset, const uint32_t UU(idx), struct verify_message_tree_extra *const e) int verify_message_tree(const int32_t &offset, const uint32_t UU(idx), struct verify_message_tree_extra *const e)
__attribute__((nonnull(3))); __attribute__((nonnull(3)));
int verify_message_tree(const long &offset, const uint32_t UU(idx), struct verify_message_tree_extra *const e) int verify_message_tree(const int32_t &offset, const uint32_t UU(idx), struct verify_message_tree_extra *const e)
{ {
int verbose = e->verbose; int verbose = e->verbose;
BLOCKNUM blocknum = e->blocknum; BLOCKNUM blocknum = e->blocknum;
...@@ -155,16 +155,21 @@ int verify_message_tree(const long &offset, const uint32_t UU(idx), struct verif ...@@ -155,16 +155,21 @@ int verify_message_tree(const long &offset, const uint32_t UU(idx), struct verif
return result; return result;
} }
template<typename verify_omt_t>
static int static int
verify_sorted_by_key_msn(FT_HANDLE brt, FIFO fifo, const off_omt_t &mt) { verify_sorted_by_key_msn(FT_HANDLE brt, FIFO fifo, const verify_omt_t &mt) {
int result = 0; int result = 0;
size_t last_offset = 0; size_t last_offset = 0;
for (uint32_t i = 0; i < mt.size(); i++) { for (uint32_t i = 0; i < mt.size(); i++) {
long offset; int32_t offset;
int r = mt.fetch(i, &offset); int r = mt.fetch(i, &offset);
assert_zero(r); assert_zero(r);
if (i > 0) { if (i > 0) {
struct toku_fifo_entry_key_msn_cmp_extra extra = { .desc = &brt->ft->cmp_descriptor, .cmp = brt->ft->compare_fun, .fifo = fifo }; struct toku_fifo_entry_key_msn_cmp_extra extra;
ZERO_STRUCT(extra);
extra.desc = &brt->ft->cmp_descriptor;
extra.cmp = brt->ft->compare_fun;
extra.fifo = fifo;
if (toku_fifo_entry_key_msn_cmp(extra, last_offset, offset) >= 0) { if (toku_fifo_entry_key_msn_cmp(extra, last_offset, offset) >= 0) {
result = TOKUDB_NEEDS_REPAIR; result = TOKUDB_NEEDS_REPAIR;
break; break;
...@@ -175,12 +180,17 @@ verify_sorted_by_key_msn(FT_HANDLE brt, FIFO fifo, const off_omt_t &mt) { ...@@ -175,12 +180,17 @@ verify_sorted_by_key_msn(FT_HANDLE brt, FIFO fifo, const off_omt_t &mt) {
return result; return result;
} }
template<typename count_omt_t>
static int static int
count_eq_key_msn(FT_HANDLE brt, FIFO fifo, const off_omt_t &mt, const DBT *key, MSN msn) { count_eq_key_msn(FT_HANDLE brt, FIFO fifo, const count_omt_t &mt, const DBT *key, MSN msn) {
struct toku_fifo_entry_key_msn_heaviside_extra extra = { struct toku_fifo_entry_key_msn_heaviside_extra extra;
.desc = &brt->ft->cmp_descriptor, .cmp = brt->ft->compare_fun, .fifo = fifo, .key = key, .msn = msn ZERO_STRUCT(extra);
}; extra.desc = &brt->ft->cmp_descriptor;
int r = mt.find_zero<struct toku_fifo_entry_key_msn_heaviside_extra, toku_fifo_entry_key_msn_heaviside>(extra, nullptr, nullptr); extra.cmp = brt->ft->compare_fun;
extra.fifo = fifo;
extra.key = key;
extra.msn = msn;
int r = mt.template find_zero<struct toku_fifo_entry_key_msn_heaviside_extra, toku_fifo_entry_key_msn_heaviside>(extra, nullptr, nullptr);
int count; int count;
if (r == 0) { if (r == 0) {
count = 1; count = 1;
......
ft/ft_node-serialize.cc
View file @ 1c7e62ad
...@@ -918,8 +918,8 @@ deserialize_child_buffer(NONLEAF_CHILDINFO bnc, struct rbuf *rbuf, ...@@ -918,8 +918,8 @@ deserialize_child_buffer(NONLEAF_CHILDINFO bnc, struct rbuf *rbuf,
DESCRIPTOR desc, ft_compare_func cmp) { DESCRIPTOR desc, ft_compare_func cmp) {
int r; int r;
int n_in_this_buffer = rbuf_int(rbuf); int n_in_this_buffer = rbuf_int(rbuf);
long *fresh_offsets = NULL, *stale_offsets = NULL; int32_t *fresh_offsets = NULL, *stale_offsets = NULL;
long *broadcast_offsets = NULL; int32_t *broadcast_offsets = NULL;
int nfresh = 0, nstale = 0; int nfresh = 0, nstale = 0;
int nbroadcast_offsets = 0; int nbroadcast_offsets = 0;
if (cmp) { if (cmp) {
...@@ -940,7 +940,7 @@ deserialize_child_buffer(NONLEAF_CHILDINFO bnc, struct rbuf *rbuf, ...@@ -940,7 +940,7 @@ deserialize_child_buffer(NONLEAF_CHILDINFO bnc, struct rbuf *rbuf,
rbuf_bytes(rbuf, &key, &keylen); /* Returns a pointer into the rbuf. */ rbuf_bytes(rbuf, &key, &keylen); /* Returns a pointer into the rbuf. */
rbuf_bytes(rbuf, &val, &vallen); rbuf_bytes(rbuf, &val, &vallen);
//printf("Found %s,%s\n", (char*)key, (char*)val); //printf("Found %s,%s\n", (char*)key, (char*)val);
long *dest; int32_t *dest;
if (cmp) { if (cmp) {
if (ft_msg_type_applies_once(type)) { if (ft_msg_type_applies_once(type)) {
if (is_fresh) { if (is_fresh) {
...@@ -968,11 +968,11 @@ deserialize_child_buffer(NONLEAF_CHILDINFO bnc, struct rbuf *rbuf, ...@@ -968,11 +968,11 @@ deserialize_child_buffer(NONLEAF_CHILDINFO bnc, struct rbuf *rbuf,
if (cmp) { if (cmp) {
struct toku_fifo_entry_key_msn_cmp_extra extra = { .desc = desc, .cmp = cmp, .fifo = bnc->buffer }; struct toku_fifo_entry_key_msn_cmp_extra extra = { .desc = desc, .cmp = cmp, .fifo = bnc->buffer };
r = toku::sort<long, const struct toku_fifo_entry_key_msn_cmp_extra, toku_fifo_entry_key_msn_cmp>::mergesort_r(fresh_offsets, nfresh, extra); r = toku::sort<int32_t, const struct toku_fifo_entry_key_msn_cmp_extra, toku_fifo_entry_key_msn_cmp>::mergesort_r(fresh_offsets, nfresh, extra);
assert_zero(r); assert_zero(r);
bnc->fresh_message_tree.destroy(); bnc->fresh_message_tree.destroy();
bnc->fresh_message_tree.create_steal_sorted_array(&fresh_offsets, nfresh, n_in_this_buffer); bnc->fresh_message_tree.create_steal_sorted_array(&fresh_offsets, nfresh, n_in_this_buffer);
r = toku::sort<long, const struct toku_fifo_entry_key_msn_cmp_extra, toku_fifo_entry_key_msn_cmp>::mergesort_r(stale_offsets, nstale, extra); r = toku::sort<int32_t, const struct toku_fifo_entry_key_msn_cmp_extra, toku_fifo_entry_key_msn_cmp>::mergesort_r(stale_offsets, nstale, extra);
assert_zero(r); assert_zero(r);
bnc->stale_message_tree.destroy(); bnc->stale_message_tree.destroy();
bnc->stale_message_tree.create_steal_sorted_array(&stale_offsets, nstale, n_in_this_buffer); bnc->stale_message_tree.create_steal_sorted_array(&stale_offsets, nstale, n_in_this_buffer);
...@@ -1790,8 +1790,8 @@ deserialize_and_upgrade_internal_node(FTNODE node, ...@@ -1790,8 +1790,8 @@ deserialize_and_upgrade_internal_node(FTNODE node,
NONLEAF_CHILDINFO bnc = BNC(node, i); NONLEAF_CHILDINFO bnc = BNC(node, i);
int n_in_this_buffer = rbuf_int(rb); int n_in_this_buffer = rbuf_int(rb);
long *fresh_offsets = NULL; int32_t *fresh_offsets = NULL;
long *broadcast_offsets = NULL; int32_t *broadcast_offsets = NULL;
int nfresh = 0; int nfresh = 0;
int nbroadcast_offsets = 0; int nbroadcast_offsets = 0;
...@@ -1822,7 +1822,7 @@ deserialize_and_upgrade_internal_node(FTNODE node, ...@@ -1822,7 +1822,7 @@ deserialize_and_upgrade_internal_node(FTNODE node,
rbuf_bytes(rb, &val, &vallen); rbuf_bytes(rb, &val, &vallen);
// <CER> can we factor this out? // <CER> can we factor this out?
long *dest; int32_t *dest;
if (bfe->h->compare_fun) { if (bfe->h->compare_fun) {
if (ft_msg_type_applies_once(type)) { if (ft_msg_type_applies_once(type)) {
dest = &fresh_offsets[nfresh]; dest = &fresh_offsets[nfresh];
...@@ -1858,7 +1858,7 @@ deserialize_and_upgrade_internal_node(FTNODE node, ...@@ -1858,7 +1858,7 @@ deserialize_and_upgrade_internal_node(FTNODE node,
struct toku_fifo_entry_key_msn_cmp_extra extra = { .desc = &bfe->h->cmp_descriptor, struct toku_fifo_entry_key_msn_cmp_extra extra = { .desc = &bfe->h->cmp_descriptor,
.cmp = bfe->h->compare_fun, .cmp = bfe->h->compare_fun,
.fifo = bnc->buffer }; .fifo = bnc->buffer };
typedef toku::sort<long, const struct toku_fifo_entry_key_msn_cmp_extra, toku_fifo_entry_key_msn_cmp> key_msn_sort; typedef toku::sort<int32_t, const struct toku_fifo_entry_key_msn_cmp_extra, toku_fifo_entry_key_msn_cmp> key_msn_sort;
r = key_msn_sort::mergesort_r(fresh_offsets, nfresh, extra); r = key_msn_sort::mergesort_r(fresh_offsets, nfresh, extra);
assert_zero(r); assert_zero(r);
bnc->fresh_message_tree.destroy(); bnc->fresh_message_tree.destroy();
......
ft/omt-nontmpl-test.cc deleted 100644 → 0
View file @ f777bd0a
/* -*- mode: C++; c-basic-offset: 4; indent-tabs-mode: nil -*- */
// vim: ft=cpp:expandtab:ts=8:sw=4:softtabstop=4:
#ident "$Id$"
#ident "Copyright (c) 2007-2012 Tokutek Inc. All rights reserved."
#ident "The technology is licensed by the Massachusetts Institute of Technology, Rutgers State University of New Jersey, and the Research Foundation of State University of New York at Stony Brook under United States of America Serial No. 11/760379 and to the patents and/or patent applications resulting from it."
#include <toku_portability.h>
#include <toku_assert.h>
#include <toku_time.h>
#include <memory.h>
#include "fttypes.h"
#include "log-internal.h"
#include "omt.h"
/*static int intcmp(OMTVALUE onev, void *twov) {
int64_t one = (int64_t) onev;
int64_t two = (int64_t) twov;
return two - one;
}*/
static int find_by_xid(OMTVALUE txnv, void *findidv) {
TOKUTXN txn = (TOKUTXN) txnv;
TXNID findid = (TXNID) findidv;
if (txn->txnid64 > findid) {
return 1;
}
if (txn->txnid64 < findid) {
return -1;
}
return 0;
}
static int txn_iter(OMTVALUE UU(txnv), uint32_t UU(idx), void *UU(v)) {
return 0;
}
const int NTXNS = 1<<23;
void runit(void)
{
{
srandom(0);
double inserttime = 0.0, querytime = 0.0, itertime = 0.0;
size_t overhead = 0;
for (int trial = 0; trial < 100; ++trial) {
OMT txn_omt;
toku_omt_create(&txn_omt);
TOKUTXN XMALLOC_N(NTXNS, txns);
for (int i = 0; i < NTXNS; ++i) {
TOKUTXN txn = &txns[i];
txn->txnid64 = ((random() << 32) | random());
}
tokutime_t t0 = get_tokutime();
for (int i = 0; i < NTXNS; ++i) {
TOKUTXN txn = &txns[i];
int r = toku_omt_insert(txn_omt, (OMTVALUE) txn, find_by_xid, (void *) txn->txnid64, NULL);
invariant_zero(r);
//invariant(r == 0 || r == DB_KEYEXIST);
}
tokutime_t t1 = get_tokutime();
for (int i = 0; i < NTXNS; ++i) {
TOKUTXN txn;
int r = toku_omt_find_zero(txn_omt, find_by_xid, (void *) txns[i].txnid64, (OMTVALUE *) &txn, NULL);
invariant_zero(r);
invariant(txn == &txns[i]);
}
tokutime_t t2 = get_tokutime();
toku_omt_iterate(txn_omt, txn_iter, NULL);
tokutime_t t3 = get_tokutime();
inserttime += tokutime_to_seconds(t1-t0);
querytime += tokutime_to_seconds(t2-t1);
itertime += tokutime_to_seconds(t3-t2);
if (overhead == 0) {
overhead = toku_omt_memory_size(txn_omt);
}
toku_omt_destroy(&txn_omt);
invariant_null(txn_omt);
toku_free(txns);
}
printf("inserts: %.03lf\nqueries: %.03lf\niterate: %.03lf\noverhead: %lu\n",
inserttime, querytime, itertime, overhead);
}
int64_t maxrss;
toku_os_get_max_rss(&maxrss);
printf("memused: %" PRId64 "\n", maxrss);
/* {
srand(0);
OMT int_omt;
toku_omt_create(&int_omt);
int64_t *XMALLOC_N(NTXNS, ints);
for (int i = 0; i < NTXNS; ++i) {
ints[i] = rand() >> 8;
}
tokutime_t t0 = get_tokutime();
for (int i = 0; i < NTXNS; ++i) {
//int r =
toku_omt_insert(int_omt, (OMTVALUE) ints[i], intcmp, (void *) ints[i], NULL);
//invariant(r == 0 || r == DB_KEYEXIST);
}
tokutime_t t1 = get_tokutime();
OMT clone;
toku_omt_clone_noptr(&clone, int_omt);
tokutime_t t2 = get_tokutime();
for (int i = 0; i < NTXNS; ++i) {
//int r =
toku_omt_find_zero(clone, intcmp, (void *) ints[i], NULL, NULL);
//invariant_zero(r);
}
tokutime_t t3 = get_tokutime();
printf("omtsize: %" PRIu32 "\ninserts: %.03lf\nqueries: %.03lf\n",
toku_omt_size(clone), tokutime_to_seconds(t1-t0), tokutime_to_seconds(t3-t2));
toku_omt_destroy(&int_omt);
invariant_null(int_omt);
toku_omt_destroy(&clone);
invariant_null(clone);
toku_free(ints);
}*/
}
int main(void)
{
runit();
return 0;
}
ft/omt-tmpl.cc
View file @ 1c7e62ad
This diff is collapsed.
ft/omt-tmpl.h
View file @ 1c7e62ad
...@@ -82,7 +82,7 @@ class subtree_templated { ...@@ -82,7 +82,7 @@ class subtree_templated {
} }
inline bool is_null(void) const { inline bool is_null(void) const {
return NODE_NULL == get_index(); return NODE_NULL == this->get_index();
} }
inline uint32_t get_index(void) const { inline uint32_t get_index(void) const {
...@@ -108,11 +108,11 @@ class subtree_templated<true> { ...@@ -108,11 +108,11 @@ class subtree_templated<true> {
public: public:
static const uint32_t NODE_NULL = INT32_MAX; static const uint32_t NODE_NULL = INT32_MAX;
inline void set_to_null(void) { inline void set_to_null(void) {
set_index_internal(NODE_NULL); this->set_index_internal(NODE_NULL);
} }
inline bool is_null(void) const { inline bool is_null(void) const {
return NODE_NULL == get_index(); return NODE_NULL == this->get_index();
} }
inline uint32_t get_index(void) const { inline uint32_t get_index(void) const {
...@@ -121,7 +121,7 @@ class subtree_templated<true> { ...@@ -121,7 +121,7 @@ class subtree_templated<true> {
inline void set_index(uint32_t index) { inline void set_index(uint32_t index) {
invariant(index < NODE_NULL); invariant(index < NODE_NULL);
set_index_internal(index); this->set_index_internal(index);
} }
inline bool get_bit(void) const { inline bool get_bit(void) const {
...@@ -173,7 +173,7 @@ class omt_node_templated<omtdata_t, true> { ...@@ -173,7 +173,7 @@ class omt_node_templated<omtdata_t, true> {
inline void set_marks_below_bit(void) { inline void set_marks_below_bit(void) {
// This function can be called by multiple threads. // This function can be called by multiple threads.
// Checking first reduces cache invalidation. // Checking first reduces cache invalidation.
if (!get_marks_below()) { if (!this->get_marks_below()) {
right.enable_bit(); right.enable_bit();
} }
} }
...@@ -182,8 +182,8 @@ class omt_node_templated<omtdata_t, true> { ...@@ -182,8 +182,8 @@ class omt_node_templated<omtdata_t, true> {
} }
inline void clear_stolen_bits(void) { inline void clear_stolen_bits(void) {
unset_marked_bit(); this->unset_marked_bit();
unset_marks_below_bit(); this->unset_marks_below_bit();
} }
} __attribute__((__packed__,aligned(4))); } __attribute__((__packed__,aligned(4)));
...@@ -434,6 +434,12 @@ class omt { ...@@ -434,6 +434,12 @@ class omt {
*/ */
void verify_marks_consistent(void) const; void verify_marks_consistent(void) const;
/**
* Effect: None
* Returns whether there are any marks in the tree.
*/
bool has_marks(void) const;
/** /**
* Effect: Iterate over the values of the omt, from left to right, calling f on each value. * Effect: Iterate over the values of the omt, from left to right, calling f on each value.
* The first argument passed to f is a pointer to the value stored in the omt. * The first argument passed to f is a pointer to the value stored in the omt.
...@@ -459,7 +465,6 @@ class omt { ...@@ -459,7 +465,6 @@ class omt {
* Performance: time=O(\log N) * Performance: time=O(\log N)
*/ */
int fetch(const uint32_t idx, omtdataout_t *const value) const; int fetch(const uint32_t idx, omtdataout_t *const value) const;
/** /**
* Effect: Find the smallest i such that h(V_i, extra)>=0 * Effect: Find the smallest i such that h(V_i, extra)>=0
...@@ -577,6 +582,8 @@ class omt { ...@@ -577,6 +582,8 @@ class omt {
struct omt_tree t; struct omt_tree t;
} d; } d;
__attribute__((nonnull))
void unmark(const subtree &subtree, const uint32_t index, uint32_t *const num_indexes, uint32_t *const indexes);
void create_internal_no_array(const uint32_t new_capacity); void create_internal_no_array(const uint32_t new_capacity);
...@@ -611,6 +618,7 @@ class omt { ...@@ -611,6 +618,7 @@ class omt {
void set_at_internal(const subtree &subtree, const omtdata_t &value, const uint32_t idx); void set_at_internal(const subtree &subtree, const omtdata_t &value, const uint32_t idx);
__attribute__((nonnull(2,5)))
void delete_internal(subtree *const subtreep, const uint32_t idx, omt_node *const copyn, subtree **const rebalance_subtree); void delete_internal(subtree *const subtreep, const uint32_t idx, omt_node *const copyn, subtree **const rebalance_subtree);
template<typename iterate_extra_t, template<typename iterate_extra_t,
...@@ -648,9 +656,9 @@ class omt { ...@@ -648,9 +656,9 @@ class omt {
uint32_t verify_marks_consistent_internal(const subtree &subtree, const bool allow_marks) const; uint32_t verify_marks_consistent_internal(const subtree &subtree, const bool allow_marks) const;
void fetch_internal_array(const uint32_t i, omtdataout_t *value) const; void fetch_internal_array(const uint32_t i, omtdataout_t *const value) const;
void fetch_internal(const subtree &subtree, const uint32_t i, omtdataout_t *value) const; void fetch_internal(const subtree &subtree, const uint32_t i, omtdataout_t *const value) const;
__attribute__((nonnull)) __attribute__((nonnull))
void fill_array_with_subtree_idxs(node_idx *const array, const subtree &subtree) const; void fill_array_with_subtree_idxs(node_idx *const array, const subtree &subtree) const;
...@@ -675,27 +683,27 @@ class omt { ...@@ -675,27 +683,27 @@ class omt {
template<typename omtcmp_t, template<typename omtcmp_t,
int (*h)(const omtdata_t &, const omtcmp_t &)> int (*h)(const omtdata_t &, const omtcmp_t &)>
int find_internal_zero_array(const omtcmp_t &extra, omtdataout_t *value, uint32_t *const idxp) const; int find_internal_zero_array(const omtcmp_t &extra, omtdataout_t *const value, uint32_t *const idxp) const;
template<typename omtcmp_t, template<typename omtcmp_t,
int (*h)(const omtdata_t &, const omtcmp_t &)> int (*h)(const omtdata_t &, const omtcmp_t &)>
int find_internal_zero(const subtree &subtree, const omtcmp_t &extra, omtdataout_t *value, uint32_t *const idxp) const; int find_internal_zero(const subtree &subtree, const omtcmp_t &extra, omtdataout_t *const value, uint32_t *const idxp) const;
template<typename omtcmp_t, template<typename omtcmp_t,
int (*h)(const omtdata_t &, const omtcmp_t &)> int (*h)(const omtdata_t &, const omtcmp_t &)>
int find_internal_plus_array(const omtcmp_t &extra, omtdataout_t *value, uint32_t *const idxp) const; int find_internal_plus_array(const omtcmp_t &extra, omtdataout_t *const value, uint32_t *const idxp) const;
template<typename omtcmp_t, template<typename omtcmp_t,
int (*h)(const omtdata_t &, const omtcmp_t &)> int (*h)(const omtdata_t &, const omtcmp_t &)>
int find_internal_plus(const subtree &subtree, const omtcmp_t &extra, omtdataout_t *value, uint32_t *const idxp) const; int find_internal_plus(const subtree &subtree, const omtcmp_t &extra, omtdataout_t *const value, uint32_t *const idxp) const;
template<typename omtcmp_t, template<typename omtcmp_t,
int (*h)(const omtdata_t &, const omtcmp_t &)> int (*h)(const omtdata_t &, const omtcmp_t &)>
int find_internal_minus_array(const omtcmp_t &extra, omtdataout_t *value, uint32_t *const idxp) const; int find_internal_minus_array(const omtcmp_t &extra, omtdataout_t *const value, uint32_t *const idxp) const;
template<typename omtcmp_t, template<typename omtcmp_t,
int (*h)(const omtdata_t &, const omtcmp_t &)> int (*h)(const omtdata_t &, const omtcmp_t &)>
int find_internal_minus(const subtree &subtree, const omtcmp_t &extra, omtdataout_t *value, uint32_t *const idxp) const; int find_internal_minus(const subtree &subtree, const omtcmp_t &extra, omtdataout_t *const value, uint32_t *const idxp) const;
}; };
} // namespace toku } // namespace toku
......
ft/omt-tmpl-test.cc → ft/tests/omt-tmpl-test.cc
View file @ 1c7e62ad
...@@ -20,11 +20,13 @@ ...@@ -20,11 +20,13 @@
namespace toku { namespace toku {
namespace test {
struct four_xids { struct four_xids {
TXNID one, two, three, four; TXNID one, two, three, four;
}; };
inline int find_xid_one(const struct four_xids &xids, const TXNID &find) { static inline int find_xid_one(const struct four_xids &xids, const TXNID &find) {
if (xids.one > find) { if (xids.one > find) {
return 1; return 1;
} }
...@@ -34,7 +36,7 @@ namespace toku { ...@@ -34,7 +36,7 @@ namespace toku {
return 0; return 0;
} }
inline int find_xid_two(const struct four_xids &xids, const TXNID &find) { static inline int find_xid_two(const struct four_xids &xids, const TXNID &find) {
if (xids.two > find) { if (xids.two > find) {
return 1; return 1;
} }
...@@ -44,7 +46,7 @@ namespace toku { ...@@ -44,7 +46,7 @@ namespace toku {
return 0; return 0;
} }
inline int fx_iter(const struct four_xids &xids __attribute__((__unused__)), const uint32_t idx __attribute__((__unused__)), int &unused __attribute__((__unused__))) { static inline int fx_iter(const struct four_xids &UU(xids), const uint32_t UU(idx), void *const UU(unused)) {
return 0; return 0;
} }
...@@ -52,7 +54,7 @@ namespace toku { ...@@ -52,7 +54,7 @@ namespace toku {
static_assert(std::is_pod<fx_omt_t>::value, "fx_omt_t isn't POD"); static_assert(std::is_pod<fx_omt_t>::value, "fx_omt_t isn't POD");
static_assert(24 == sizeof(fx_omt_t), "fx_omt_t is bigger than 24 bytes"); static_assert(24 == sizeof(fx_omt_t), "fx_omt_t is bigger than 24 bytes");
inline int find_by_xid(const TOKUTXN &txn, const TXNID &findid) { static inline int find_by_xid(const TOKUTXN &txn, const TXNID &findid) {
if (txn->txnid64 > findid) { if (txn->txnid64 > findid) {
return 1; return 1;
} }
...@@ -62,7 +64,7 @@ namespace toku { ...@@ -62,7 +64,7 @@ namespace toku {
return 0; return 0;
} }
inline int txn_iter(const TOKUTXN &txn __attribute__((__unused__)), const uint32_t idx __attribute__((__unused__)), int &unused __attribute__((__unused__))) { static inline int txn_iter(const TOKUTXN &UU(txn), const uint32_t UU(idx), void *const UU(unused)) {
return 0; return 0;
} }
...@@ -72,7 +74,7 @@ namespace toku { ...@@ -72,7 +74,7 @@ namespace toku {
const int NTXNS = 1<<13; const int NTXNS = 1<<13;
void runit(void) static void perftest(void)
{ {
if (0) { if (0) {
srandom(0); srandom(0);
...@@ -80,8 +82,8 @@ namespace toku { ...@@ -80,8 +82,8 @@ namespace toku {
size_t overhead = 0; size_t overhead = 0;
for (int trial = 0; trial < 100; ++trial) { for (int trial = 0; trial < 100; ++trial) {
fx_omt_t *fx_omt; fx_omt_t *XMALLOC(fx_omt);
fx_omt_t::create(fx_omt); fx_omt->create();
struct four_xids *XMALLOC_N(NTXNS, txns); struct four_xids *XMALLOC_N(NTXNS, txns);
for (int i = 0; i < NTXNS; ++i) { for (int i = 0; i < NTXNS; ++i) {
...@@ -103,8 +105,7 @@ namespace toku { ...@@ -103,8 +105,7 @@ namespace toku {
invariant(v != &txns[i]); invariant(v != &txns[i]);
} }
tokutime_t t2 = get_tokutime(); tokutime_t t2 = get_tokutime();
int unused = 0; fx_omt->iterate<void, fx_iter>(nullptr);
fx_omt->iterate<int, fx_iter>(unused);
tokutime_t t3 = get_tokutime(); tokutime_t t3 = get_tokutime();
for (int i = 0; i < NTXNS; ++i) { for (int i = 0; i < NTXNS; ++i) {
struct four_xids *v; struct four_xids *v;
...@@ -121,7 +122,8 @@ namespace toku { ...@@ -121,7 +122,8 @@ namespace toku {
overhead = fx_omt->memory_size(); overhead = fx_omt->memory_size();
} }
fx_omt_t::destroy(fx_omt); fx_omt->destroy();
toku_free(fx_omt);
toku_free(txns); toku_free(txns);
} }
...@@ -134,13 +136,14 @@ namespace toku { ...@@ -134,13 +136,14 @@ namespace toku {
size_t overhead = 0; size_t overhead = 0;
for (int trial = 0; trial < 100; ++trial) { for (int trial = 0; trial < 100; ++trial) {
txn_omt_t *txn_omt; txn_omt_t *XMALLOC(txn_omt);
txn_omt_t::create(txn_omt); txn_omt->create();
TOKUTXN XMALLOC_N(NTXNS, txns); TOKUTXN XMALLOC_N(NTXNS, txns);
for (int i = 0; i < NTXNS; ++i) { for (int i = 0; i < NTXNS; ++i) {
TOKUTXN txn = &txns[i]; TOKUTXN txn = &txns[i];
txn->txnid64 = ((random() << 32) | random()); // eww, sorry:
*(const_cast<TXNID *>(&txn->txnid64)) = ((random() << 32) | random());
} }
tokutime_t t0 = get_tokutime(); tokutime_t t0 = get_tokutime();
for (int i = 0; i < NTXNS; ++i) { for (int i = 0; i < NTXNS; ++i) {
...@@ -157,8 +160,7 @@ namespace toku { ...@@ -157,8 +160,7 @@ namespace toku {
invariant(txn == &txns[i]); invariant(txn == &txns[i]);
} }
tokutime_t t2 = get_tokutime(); tokutime_t t2 = get_tokutime();
int unused = 0; txn_omt->iterate<void, txn_iter>(nullptr);
txn_omt->iterate<int, txn_iter>(unused);
tokutime_t t3 = get_tokutime(); tokutime_t t3 = get_tokutime();
inserttime += tokutime_to_seconds(t1-t0); inserttime += tokutime_to_seconds(t1-t0);
...@@ -168,8 +170,8 @@ namespace toku { ...@@ -168,8 +170,8 @@ namespace toku {
overhead = txn_omt->memory_size(); overhead = txn_omt->memory_size();
} }
txn_omt_t::destroy(txn_omt); txn_omt->destroy();
invariant_null(txn_omt); toku_free(txn_omt);
toku_free(txns); toku_free(txns);
} }
...@@ -181,7 +183,7 @@ namespace toku { ...@@ -181,7 +183,7 @@ namespace toku {
printf("memused: %" PRId64 "\n", maxrss); printf("memused: %" PRId64 "\n", maxrss);
} }
inline int intcmp(const int &a, const int &b) { static inline int intcmp(const int &a, const int &b) {
if (a < b) { if (a < b) {
return -1; return -1;
} }
...@@ -194,8 +196,8 @@ namespace toku { ...@@ -194,8 +196,8 @@ namespace toku {
typedef omt<int> int_omt_t; typedef omt<int> int_omt_t;
static int intiter_magic = 0xdeadbeef; static int intiter_magic = 0xdeadbeef;
int intiter(const int &value __attribute__((__unused__)), const uint32_t idx __attribute__((__unused__)), int &extra) { static int intiter(const int &value __attribute__((__unused__)), const uint32_t idx __attribute__((__unused__)), int *const extra) {
invariant(extra == intiter_magic); invariant(*extra == intiter_magic);
return 0; return 0;
} }
...@@ -203,17 +205,17 @@ namespace toku { ...@@ -203,17 +205,17 @@ namespace toku {
int count; int count;
int last; int last;
}; };
int intiter2(const int &value, const uint32_t idx __attribute__((__unused__)), struct intiter2extra &extra) { static int intiter2(const int &value, const uint32_t idx __attribute__((__unused__)), struct intiter2extra *const extra) {
extra.count++; extra->count++;
invariant(extra.last < value); invariant(extra->last < value);
extra.last = value; extra->last = value;
return 0; return 0;
} }
void unittest(void) { static void unittest(void) {
int_omt_t o; int_omt_t o;
int r; int r;
o.init(); o.create();
invariant(o.size() == 0); invariant(o.size() == 0);
r = o.insert<int, intcmp>(1, 1, nullptr); r = o.insert<int, intcmp>(1, 1, nullptr);
...@@ -234,11 +236,11 @@ namespace toku { ...@@ -234,11 +236,11 @@ namespace toku {
invariant(x == 2); invariant(x == 2);
r = o.iterate<int, intiter>(intiter_magic); r = o.iterate<int, intiter>(&intiter_magic);
invariant_zero(r); invariant_zero(r);
struct intiter2extra e = {0, 0}; struct intiter2extra e = {0, 0};
r = o.iterate_on_range<struct intiter2extra, intiter2>(0, 2, e); r = o.iterate_on_range<struct intiter2extra, intiter2>(0, 2, &e);
invariant_zero(r); invariant_zero(r);
invariant(e.count == 2); invariant(e.count == 2);
invariant(e.last == 2); invariant(e.last == 2);
...@@ -250,16 +252,16 @@ namespace toku { ...@@ -250,16 +252,16 @@ namespace toku {
invariant(o.size() == 2); invariant(o.size() == 2);
o.deinit(); o.destroy();
int *XMALLOC_N(4, intarray); int *XMALLOC_N(4, intarray);
for (int i = 0; i < 4; ++i) { for (int i = 0; i < 4; ++i) {
intarray[i] = i + 1; intarray[i] = i + 1;
} }
int_omt_t left, right; int_omt_t left, right;
left.init_steal_sorted_array(intarray, 4, 4); left.create_steal_sorted_array(&intarray, 4, 4);
invariant_null(intarray); invariant_null(intarray);
right.init(); right.create();
r = right.insert<int, intcmp>(8, 8, nullptr); r = right.insert<int, intcmp>(8, 8, nullptr);
invariant_zero(r); invariant_zero(r);
r = right.insert<int, intcmp>(7, 7, nullptr); r = right.insert<int, intcmp>(7, 7, nullptr);
...@@ -270,38 +272,25 @@ namespace toku { ...@@ -270,38 +272,25 @@ namespace toku {
invariant_zero(r); invariant_zero(r);
int_omt_t combined; int_omt_t combined;
combined.merge_init(left, right); combined.merge(&left, &right);
invariant(combined.size() == 8); invariant(combined.size() == 8);
invariant(left.size() == 0); invariant(left.size() == 0);
invariant(right.size() == 0); invariant(right.size() == 0);
struct intiter2extra e2 = {0, 0}; struct intiter2extra e2 = {0, 0};
r = combined.iterate<struct intiter2extra, intiter2>(e2); r = combined.iterate<struct intiter2extra, intiter2>(&e2);
invariant_zero(r); invariant_zero(r);
invariant(e2.count == 8); invariant(e2.count == 8);
invariant(e2.last == 8); invariant(e2.last == 8);
combined.deinit(); combined.destroy();
omt<int *> intptr_omt;
intptr_omt.init();
int *ptrs[3];
for (int i = 0; i < 3; ++i) {
XMALLOC(ptrs[i]);
*(ptrs[i]) = i;
intptr_omt.insert_at(ptrs[i], i);
}
omt<int *> intptr_omt2;
intptr_omt2.deep_clone_init(intptr_omt);
intptr_omt.free_items();
intptr_omt.deinit();
intptr_omt2.free_items();
intptr_omt2.deinit();
} }
}; } // end namespace test
} // end namespace toku
int main(void) { int main(void) {
toku::unittest(); toku::test::unittest();
toku::runit(); toku::test::perftest();
return 0; return 0;
} }
ft/tests/orthopush-flush.cc
View file @ 1c7e62ad
...@@ -616,15 +616,15 @@ flush_to_leaf(FT_HANDLE t, bool make_leaf_up_to_date, bool use_flush) { ...@@ -616,15 +616,15 @@ flush_to_leaf(FT_HANDLE t, bool make_leaf_up_to_date, bool use_flush) {
struct ancestors ancestors = { .node = parentnode, .childnum = 0, .next = NULL }; struct ancestors ancestors = { .node = parentnode, .childnum = 0, .next = NULL };
const struct pivot_bounds infinite_bounds = { .lower_bound_exclusive = NULL, .upper_bound_inclusive = NULL }; const struct pivot_bounds infinite_bounds = { .lower_bound_exclusive = NULL, .upper_bound_inclusive = NULL };
bool msgs_applied; bool msgs_applied;
maybe_apply_ancestors_messages_to_node(t, child, &ancestors, &infinite_bounds, &msgs_applied); toku_apply_ancestors_messages_to_node(t, child, &ancestors, &infinite_bounds, &msgs_applied);
FIFO_ITERATE(parent_bnc->buffer, key, keylen, val, vallen, type, msn, xids, is_fresh, FIFO_ITERATE(parent_bnc->buffer, key, keylen, val, vallen, type, msn, xids, is_fresh,
{ {
key = key; keylen = keylen; val = val; vallen = vallen; type = type; msn = msn; xids = xids; key = key; keylen = keylen; val = val; vallen = vallen; type = type; msn = msn; xids = xids;
assert(!is_fresh); assert(!is_fresh);
}); });
assert(parent_bnc->fresh_message_tree.size() == 0); invariant(parent_bnc->fresh_message_tree.size() + parent_bnc->stale_message_tree.size()
assert(parent_bnc->stale_message_tree.size() == (uint32_t) num_parent_messages); == (uint32_t) num_parent_messages);
toku_ftnode_free(&parentnode); toku_ftnode_free(&parentnode);
} }
...@@ -841,7 +841,7 @@ flush_to_leaf_with_keyrange(FT_HANDLE t, bool make_leaf_up_to_date) { ...@@ -841,7 +841,7 @@ flush_to_leaf_with_keyrange(FT_HANDLE t, bool make_leaf_up_to_date) {
.upper_bound_inclusive = toku_clone_dbt(&ubi, childkeys[7]) .upper_bound_inclusive = toku_clone_dbt(&ubi, childkeys[7])
}; };
bool msgs_applied; bool msgs_applied;
maybe_apply_ancestors_messages_to_node(t, child, &ancestors, &bounds, &msgs_applied); toku_apply_ancestors_messages_to_node(t, child, &ancestors, &bounds, &msgs_applied);
FIFO_ITERATE(parent_bnc->buffer, key, keylen, val, vallen, type, msn, xids, is_fresh, FIFO_ITERATE(parent_bnc->buffer, key, keylen, val, vallen, type, msn, xids, is_fresh,
{ {
...@@ -1024,15 +1024,15 @@ compare_apply_and_flush(FT_HANDLE t, bool make_leaf_up_to_date) { ...@@ -1024,15 +1024,15 @@ compare_apply_and_flush(FT_HANDLE t, bool make_leaf_up_to_date) {
struct ancestors ancestors = { .node = parentnode, .childnum = 0, .next = NULL }; struct ancestors ancestors = { .node = parentnode, .childnum = 0, .next = NULL };
const struct pivot_bounds infinite_bounds = { .lower_bound_exclusive = NULL, .upper_bound_inclusive = NULL }; const struct pivot_bounds infinite_bounds = { .lower_bound_exclusive = NULL, .upper_bound_inclusive = NULL };
bool msgs_applied; bool msgs_applied;
maybe_apply_ancestors_messages_to_node(t, child2, &ancestors, &infinite_bounds, &msgs_applied); toku_apply_ancestors_messages_to_node(t, child2, &ancestors, &infinite_bounds, &msgs_applied);
FIFO_ITERATE(parent_bnc->buffer, key, keylen, val, vallen, type, msn, xids, is_fresh, FIFO_ITERATE(parent_bnc->buffer, key, keylen, val, vallen, type, msn, xids, is_fresh,
{ {
key = key; keylen = keylen; val = val; vallen = vallen; type = type; msn = msn; xids = xids; key = key; keylen = keylen; val = val; vallen = vallen; type = type; msn = msn; xids = xids;
assert(!is_fresh); assert(!is_fresh);
}); });
assert(parent_bnc->fresh_message_tree.size() == 0); invariant(parent_bnc->fresh_message_tree.size() + parent_bnc->stale_message_tree.size()
assert(parent_bnc->stale_message_tree.size() == (uint32_t) num_parent_messages); == (uint32_t) num_parent_messages);
toku_ftnode_free(&parentnode); toku_ftnode_free(&parentnode);
......
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
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7