Lines Matching refs:need_log_sync
222 bool need_log_sync = write_options.sync; in WriteImpl() local
223 bool need_log_dir_sync = need_log_sync && !log_dir_synced_; in WriteImpl()
232 status = PreprocessWrite(write_options, &need_log_sync, &write_context); in WriteImpl()
326 io_s = WriteToWAL(write_group, log_writer, log_used, need_log_sync, in WriteImpl()
423 if (need_log_sync) { in WriteImpl()
478 bool need_log_sync = !write_options.disableWAL && write_options.sync; in PipelinedWriteImpl() local
479 bool need_log_dir_sync = need_log_sync && !log_dir_synced_; in PipelinedWriteImpl()
482 w.status = PreprocessWrite(write_options, &need_log_sync, &write_context); in PipelinedWriteImpl()
534 io_s = WriteToWAL(wal_write_group, log_writer, log_used, need_log_sync, in PipelinedWriteImpl()
547 if (need_log_sync) { in PipelinedWriteImpl()
689 bool need_log_sync = false; in WriteImplWALOnly() local
690 status = PreprocessWrite(write_options, &need_log_sync, &write_context); in WriteImplWALOnly()
869 bool* need_log_sync, in PreprocessWrite() argument
872 assert(write_context != nullptr && need_log_sync != nullptr); in PreprocessWrite()
923 if (status.ok() && *need_log_sync) { in PreprocessWrite()
944 *need_log_sync = false; in PreprocessWrite()
1027 bool need_log_sync, bool need_log_dir_sync, in WriteToWAL() argument
1053 if (io_s.ok() && need_log_sync) { in WriteToWAL()
1082 if (need_log_sync) { in WriteToWAL()