diff --git a/src/api-env.c b/src/api-env.c index 2bfbdeb2..bd3702e9 100644 --- a/src/api-env.c +++ b/src/api-env.c @@ -648,7 +648,7 @@ __cold int mdbx_env_close_ex(MDBX_env *env, bool dont_sync) { #endif /* Windows */ } - if (env->basal_txn && env->basal_txn->owner == osal_thread_self()) + if (env->basal_txn && (MDBX_TXN_CHECKOWNER ? env->basal_txn->owner == osal_thread_self() : !!env->basal_txn->owner)) lck_txn_unlock(env); eASSERT(env, env->signature.weak == 0); diff --git a/src/api-extra.c b/src/api-extra.c index 61b0fac9..32ad4bfd 100644 --- a/src/api-extra.c +++ b/src/api-extra.c @@ -117,7 +117,6 @@ __cold int mdbx_thread_unregister(const MDBX_env *env) { return MDBX_RESULT_TRUE /* not registered */; eASSERT(env, r->pid.weak == env->pid); - eASSERT(env, r->tid.weak == osal_thread_self()); if (unlikely(r->pid.weak != env->pid || r->tid.weak != osal_thread_self())) return LOG_IFERR(MDBX_BAD_RSLOT); @@ -154,8 +153,10 @@ int mdbx_txn_unlock(MDBX_env *env) { if (unlikely(env->flags & MDBX_RDONLY)) return LOG_IFERR(MDBX_EACCESS); +#if MDBX_TXN_CHECKOWNER if (unlikely(env->basal_txn->owner != osal_thread_self())) return LOG_IFERR(MDBX_THREAD_MISMATCH); +#endif /* MDBX_TXN_CHECKOWNER */ if (unlikely((env->basal_txn->flags & MDBX_TXN_FINISHED) == 0)) return LOG_IFERR(MDBX_BUSY); diff --git a/src/api-txn.c b/src/api-txn.c index 1f24c930..2fe01a4e 100644 --- a/src/api-txn.c +++ b/src/api-txn.c @@ -101,11 +101,13 @@ int mdbx_txn_abort(MDBX_txn *txn) { if (unlikely(rc != MDBX_SUCCESS)) return LOG_IFERR(rc); +#if MDBX_TXN_CHECKOWNER if ((txn->flags & (MDBX_TXN_RDONLY | MDBX_NOSTICKYTHREADS)) == MDBX_NOSTICKYTHREADS && unlikely(txn->owner != osal_thread_self())) { mdbx_txn_break(txn); return LOG_IFERR(MDBX_THREAD_MISMATCH); } +#endif /* MDBX_TXN_CHECKOWNER */ return LOG_IFERR(txn_abort(txn)); } @@ -420,11 +422,13 @@ int mdbx_txn_commit_ex(MDBX_txn *txn, MDBX_commit_latency *latency) { goto done; } +#if MDBX_TXN_CHECKOWNER if (!txn->parent && (txn->flags & MDBX_NOSTICKYTHREADS) && unlikely(txn->owner != osal_thread_self())) { txn->flags |= MDBX_TXN_ERROR; rc = MDBX_THREAD_MISMATCH; return LOG_IFERR(rc); } +#endif /* MDBX_TXN_CHECKOWNER */ if (unlikely(txn->flags & MDBX_TXN_ERROR)) { rc = MDBX_RESULT_TRUE; diff --git a/test/extra/txn.c++ b/test/extra/txn.c++ index d817cc7e..3a616015 100644 --- a/test/extra/txn.c++ +++ b/test/extra/txn.c++ @@ -131,6 +131,7 @@ int main(int argc, const char *argv[]) { std::thread t([&]() { s.wait(); +#if MDBX_TXN_CHECKOWNER err = mdbx_txn_reset(c_txn); assert(err == MDBX_THREAD_MISMATCH); ok = ok && err == MDBX_THREAD_MISMATCH; @@ -143,6 +144,7 @@ int main(int argc, const char *argv[]) { err = mdbx_txn_abort(c_txn); assert(err == MDBX_THREAD_MISMATCH); ok = ok && err == MDBX_THREAD_MISMATCH; +#endif /* MDBX_TXN_CHECKOWNER */ err = mdbx_txn_begin(env, txn, MDBX_TXN_READWRITE, &c_txn); assert(err == MDBX_BAD_TXN); ok = ok && err == MDBX_BAD_TXN;