unsigned int i;
uint16_t x;
int rc, new_notls = 0;
- pgno_t lastpg2;
/* Setup db info */
txn->mt_numdbs = env->me_numdbs;
txn->mt_u.reader = r;
}
txn->mt_toggle = txn->mt_txnid & 1;
- txn->mt_next_pgno = env->me_metas[txn->mt_toggle]->mm_last_pg+1;
} else {
LOCK_MUTEX_W(env);
txn->mt_txnid = env->me_txns->mti_txnid;
txn->mt_toggle = txn->mt_txnid & 1;
- txn->mt_next_pgno = env->me_metas[txn->mt_toggle]->mm_last_pg+1;
txn->mt_txnid++;
#if MDB_DEBUG
if (txn->mt_txnid == mdb_debug_start)
/* Copy the DB info and flags */
memcpy(txn->mt_dbs, env->me_metas[txn->mt_toggle]->mm_dbs, 2 * sizeof(MDB_db));
- /* In a read txn, there is a data race here. Make sure our
- * last_pg/next_pg are up to date.
- */
- lastpg2 = env->me_metas[txn->mt_toggle]->mm_last_pg+1;
- if (lastpg2 != txn->mt_next_pgno) {
- txn->mt_next_pgno = lastpg2;
- /* When this situation occurs, the txnid will certainly also
- * be out of date. But as noted before, we don't care about having
- * up to date read txn IDs.
- */
- }
+
+ /* Moved to here to avoid a data race in read TXNs */
+ txn->mt_next_pgno = env->me_metas[txn->mt_toggle]->mm_last_pg+1;
+
for (i=2; i<txn->mt_numdbs; i++) {
x = env->me_dbflags[i];
txn->mt_dbs[i].md_flags = x & PERSISTENT_FLAGS;