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

mdbx: toggle of readers-refresh after wipe steady-point.

Browse Source 
Change-Id: I43985fb667b727a8b41dcd5c33e6012160dee16e
This commit is contained in:
Leonid Yuriev 2019-12-19 22:52:29 +03:00
parent c554b5c45d
commit cddf9ca8a2
1 changed files with 19 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/elements/core.c
View File

@ -3912,21 +3912,27 @@ __cold static int mdbx_wipe_steady(MDBX_env *env, const txnid_t last_steady) {
if (env->me_flags & MDBX_WRITEMAP) { if (env->me_flags & MDBX_WRITEMAP) {
mdbx_flush_incoherent_cpu_writeback(); mdbx_flush_incoherent_cpu_writeback();
return mdbx_msync(&env->me_dxb_mmap, 0, pgno_align2os_bytes(env, NUM_METAS), err = mdbx_msync(&env->me_dxb_mmap, 0, pgno_align2os_bytes(env, NUM_METAS),
false); false);
if (unlikely(err != MDBX_SUCCESS))
return err;
} else {
#if defined(__linux__) || defined(__gnu_linux__)
if (sync_file_range(env->me_lazy_fd, 0, pgno2bytes(env, NUM_METAS),
SYNC_FILE_RANGE_WRITE | SYNC_FILE_RANGE_WAIT_AFTER))
err = errno;
#else
err = mdbx_filesync(env->me_lazy_fd, MDBX_SYNC_DATA);
#endif
if (unlikely(err != MDBX_SUCCESS))
return err;
mdbx_flush_incoherent_mmap(env->me_map, pgno2bytes(env, NUM_METAS),
env->me_os_psize);
} }
#if defined(__linux__) || defined(__gnu_linux__) if (likely(env->me_lck))
if (sync_file_range(env->me_lazy_fd, 0, pgno2bytes(env, NUM_METAS), /* force oldest refresh */
SYNC_FILE_RANGE_WRITE | SYNC_FILE_RANGE_WAIT_AFTER)) env->me_lck->mti_readers_refresh_flag = true;
err = errno;
#else
err = mdbx_filesync(env->me_lazy_fd, MDBX_SYNC_DATA);
#endif
if (unlikely(err != MDBX_SUCCESS))
return err;
mdbx_flush_incoherent_mmap(env->me_map, pgno2bytes(env, NUM_METAS),
env->me_os_psize);
return MDBX_SUCCESS; return MDBX_SUCCESS;
} }