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

mdbx: refile rollback-writes inside mdbx_setup_dxb().

Browse Source
This commit is contained in:
Leonid Yuriev 2021-05-12 13:55:33 +03:00
parent 7d8099fc77
commit 137f80e177
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/core.c
View File

@ -11672,8 +11672,13 @@ static __cold int mdbx_setup_dxb(MDBX_env *env, const int lck_rc) {
MDBX_meta rollback = *head; MDBX_meta rollback = *head;
mdbx_meta_set_txnid(env, &rollback, undo_txnid); mdbx_meta_set_txnid(env, &rollback, undo_txnid);
unaligned_poke_u64(4, rollback.mm_datasync_sign, MDBX_DATASIGN_WEAK); unaligned_poke_u64(4, rollback.mm_datasync_sign, MDBX_DATASIGN_WEAK);
err = mdbx_pwrite(env->me_lazy_fd, &rollback, sizeof(MDBX_meta), const mdbx_filehandle_t fd = (env->me_dsync_fd != INVALID_HANDLE_VALUE)
? env->me_dsync_fd
: env->me_lazy_fd;
err = mdbx_pwrite(fd, &rollback, sizeof(MDBX_meta),
(uint8_t *)head - (uint8_t *)env->me_map); (uint8_t *)head - (uint8_t *)env->me_map);
if (err == MDBX_SUCCESS && fd == env->me_lazy_fd)
err = mdbx_fsync(env->me_lazy_fd, MDBX_SYNC_DATA | MDBX_SYNC_IODQ);
} }
if (err) { if (err) {
mdbx_error("error %d rollback from %" PRIaTXN ", to %" PRIaTXN mdbx_error("error %d rollback from %" PRIaTXN ", to %" PRIaTXN