diff --git a/src/box/vy_tx.c b/src/box/vy_tx.c index c44455054427d38471bf12b5c07b90238fd23338..33d153a4bf47632ea9b17da47f271fc4877a5994 100644 --- a/src/box/vy_tx.c +++ b/src/box/vy_tx.c @@ -248,6 +248,30 @@ txv_delete(struct txv *v) mempool_free(&xm->txv_mempool, v); } +/** + * Account a read interval in transaction manager stats. + */ +static void +vy_read_interval_acct(struct vy_read_interval *interval) +{ + struct tx_manager *xm = interval->tx->xm; + xm->read_set_size += tuple_size(interval->left); + if (interval->left != interval->right) + xm->read_set_size += tuple_size(interval->right); +} + +/** + * Unaccount a read interval in transaction manager stats. + */ +static void +vy_read_interval_unacct(struct vy_read_interval *interval) +{ + struct tx_manager *xm = interval->tx->xm; + xm->read_set_size -= tuple_size(interval->left); + if (interval->left != interval->right) + xm->read_set_size -= tuple_size(interval->right); +} + static struct vy_read_interval * vy_read_interval_new(struct vy_tx *tx, struct vy_lsm *lsm, struct tuple *left, bool left_belongs, @@ -271,9 +295,7 @@ vy_read_interval_new(struct vy_tx *tx, struct vy_lsm *lsm, interval->right = right; interval->right_belongs = right_belongs; interval->subtree_last = NULL; - xm->read_set_size += tuple_size(left); - if (left != right) - xm->read_set_size += tuple_size(right); + vy_read_interval_acct(interval); return interval; } @@ -281,9 +303,7 @@ static void vy_read_interval_delete(struct vy_read_interval *interval) { struct tx_manager *xm = interval->tx->xm; - xm->read_set_size -= tuple_size(interval->left); - if (interval->left != interval->right) - xm->read_set_size -= tuple_size(interval->right); + vy_read_interval_unacct(interval); vy_lsm_unref(interval->lsm); tuple_unref(interval->left); tuple_unref(interval->right); @@ -926,6 +946,7 @@ vy_tx_track(struct vy_tx *tx, struct vy_lsm *lsm, * remove them from the transaction and LSM tree read sets. */ if (!stailq_empty(&merge)) { + vy_read_interval_unacct(new_interval); interval = stailq_first_entry(&merge, struct vy_read_interval, in_merge); if (vy_read_interval_cmpl(new_interval, interval) > 0) { @@ -949,6 +970,7 @@ vy_tx_track(struct vy_tx *tx, struct vy_lsm *lsm, vy_lsm_read_set_remove(&lsm->read_set, interval); vy_read_interval_delete(interval); } + vy_read_interval_acct(new_interval); } vy_tx_read_set_insert(&tx->read_set, new_interval); diff --git a/test/vinyl/tx_gap_lock.result b/test/vinyl/tx_gap_lock.result index a456c017e7e1a364309898cf5008dbe9587724e2..6270f42970243eb7b5a48ef1f8a8d6f72bcb04f4 100644 --- a/test/vinyl/tx_gap_lock.result +++ b/test/vinyl/tx_gap_lock.result @@ -1416,6 +1416,33 @@ test_run:cmd("setopt delimiter ''"); - true ... ---------------------------------------------------------------- +-- Check vinyl stats after all transactions have completed. +-- Should be all zeros. See gh-4071. +---------------------------------------------------------------- +stat = box.stat.vinyl() +--- +... +stat.memory.tx +--- +- 0 +... +stat.tx.statements +--- +- 0 +... +stat.tx.transactions +--- +- 0 +... +stat.tx.gap_locks +--- +- 0 +... +stat.tx.read_views +--- +- 0 +... +---------------------------------------------------------------- c = nil --- ... diff --git a/test/vinyl/tx_gap_lock.test.lua b/test/vinyl/tx_gap_lock.test.lua index 4ad558608f06620155f0e841e739853f7945974f..ddc5bce420f04f32814b9d1bdbf7a8d22d69862e 100644 --- a/test/vinyl/tx_gap_lock.test.lua +++ b/test/vinyl/tx_gap_lock.test.lua @@ -526,6 +526,16 @@ s:drop(); test_run:cmd("setopt delimiter ''"); ---------------------------------------------------------------- +-- Check vinyl stats after all transactions have completed. +-- Should be all zeros. See gh-4071. +---------------------------------------------------------------- +stat = box.stat.vinyl() +stat.memory.tx +stat.tx.statements +stat.tx.transactions +stat.tx.gap_locks +stat.tx.read_views +---------------------------------------------------------------- c = nil c1 = nil