ISAR/libmdbx
3
0
Fork 0
mirror of https://github.com/isar/libmdbx.git synced 2025-06-05 16:54:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

mdbx: обнуление информации о задержках для невалидных транзакций в mdbx_txn_commit_ex().

Browse Source
This commit is contained in:
Леонид Юрьев (Leonid Yuriev) 2022-12-21 20:55:11 +03:00
parent 85828f677a
commit 0498114469
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/core.c
View File

@ -11342,15 +11342,19 @@ int mdbx_txn_commit_ex(MDBX_txn *txn, MDBX_commit_latency *latency) {
uint64_t ts_1 = 0, ts_2 = 0, ts_3 = 0, ts_4 = 0, ts_5 = 0, gc_cputime = 0; uint64_t ts_1 = 0, ts_2 = 0, ts_3 = 0, ts_4 = 0, ts_5 = 0, gc_cputime = 0;
int rc = check_txn(txn, MDBX_TXN_FINISHED); int rc = check_txn(txn, MDBX_TXN_FINISHED);
if (unlikely(rc != MDBX_SUCCESS)) if (unlikely(rc != MDBX_SUCCESS)) {
goto provide_latency; if (latency)
memset(latency, 0, sizeof(*latency));
return rc;
}
MDBX_env *const env = txn->mt_env; MDBX_env *const env = txn->mt_env;
#if MDBX_ENV_CHECKPID #if MDBX_ENV_CHECKPID
if (unlikely(env->me_pid != osal_getpid())) { if (unlikely(env->me_pid != osal_getpid())) {
env->me_flags |= MDBX_FATAL_ERROR; env->me_flags |= MDBX_FATAL_ERROR;
rc = MDBX_PANIC; if (latency)
goto provide_latency; memset(latency, 0, sizeof(*latency));
return MDBX_PANIC;
} }
#endif /* MDBX_ENV_CHECKPID */ #endif /* MDBX_ENV_CHECKPID */