Commit 6ae91567 authored by Yoni Fogel's avatar Yoni Fogel

[t:2440] Add commit progress to local checkpoint

git-svn-id: file:///svn/toku/tokudb@19461 c7de825b-a66e-492c-adef-691d508d4ae1
parent 54ae26e4
...@@ -132,6 +132,7 @@ local_checkpoints_and_log_xcommit(void *thunk) { ...@@ -132,6 +132,7 @@ local_checkpoints_and_log_xcommit(void *thunk) {
TOKUTXN txn = info->txn; TOKUTXN txn = info->txn;
if (!txn->parent && !toku_list_empty(&txn->checkpoint_before_commit)) { if (!txn->parent && !toku_list_empty(&txn->checkpoint_before_commit)) {
toku_poll_txn_progress_function(txn, TRUE, TRUE);
//Do local checkpoints that must happen BEFORE logging xcommit //Do local checkpoints that must happen BEFORE logging xcommit
uint32_t num_cachefiles = 0; uint32_t num_cachefiles = 0;
uint32_t list_size = 16; uint32_t list_size = 16;
...@@ -153,6 +154,7 @@ local_checkpoints_and_log_xcommit(void *thunk) { ...@@ -153,6 +154,7 @@ local_checkpoints_and_log_xcommit(void *thunk) {
int r = toku_cachetable_local_checkpoint_for_commit(ct, txn, num_cachefiles, cachefiles); int r = toku_cachetable_local_checkpoint_for_commit(ct, txn, num_cachefiles, cachefiles);
assert(r==0); assert(r==0);
toku_poll_txn_progress_function(txn, TRUE, FALSE);
} }
info->r = toku_log_xcommit(txn->logger, (LSN*)0, info->do_fsync, txn->txnid64); // exits holding neither of the tokulogger locks. info->r = toku_log_xcommit(txn->logger, (LSN*)0, info->do_fsync, txn->txnid64); // exits holding neither of the tokulogger locks.
......
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