Lines Matching refs:log_buffer
29 bool* sfm_reserved_compact_space, LogBuffer* log_buffer) { in EnoughRoomForCompaction() argument
54 ROCKS_LOG_BUFFER(log_buffer, in EnoughRoomForCompaction()
63 LogBuffer* log_buffer) { in RequestCompactionToken() argument
72 ROCKS_LOG_BUFFER(log_buffer, in RequestCompactionToken()
143 SnapshotChecker* snapshot_checker, LogBuffer* log_buffer, in FlushMemTableToOutputFile() argument
153 snapshot_checker, job_context, log_buffer, directories_.GetDbDir(), in FlushMemTableToOutputFile()
205 ROCKS_LOG_BUFFER(log_buffer, "[%s] Level summary: %s\n", in FlushMemTableToOutputFile()
248 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri) { in FlushMemTablesToOutputFiles() argument
251 bg_flush_args, made_progress, job_context, log_buffer, thread_pri); in FlushMemTablesToOutputFiles()
266 snapshot_checker, log_buffer, thread_pri); in FlushMemTablesToOutputFiles()
290 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri) { in AtomicFlushMemTablesToOutputFiles() argument
344 snapshot_checker, job_context, log_buffer, directories_.GetDbDir(), in AtomicFlushMemTablesToOutputFiles()
526 &job_context->memtables_to_free, directories_.GetDbDir(), log_buffer); in AtomicFlushMemTablesToOutputFiles()
540 ROCKS_LOG_BUFFER(log_buffer, "[%s] Level summary: %s\n", in AtomicFlushMemTablesToOutputFiles()
876 LogBuffer log_buffer(InfoLogLevel::INFO_LEVEL, in CompactFiles()
895 &job_context, &log_buffer, compaction_job_info); in CompactFiles()
912 job_context.HaveSomethingToDelete() || !log_buffer.IsEmpty()) { in CompactFiles()
918 log_buffer.FlushBufferToLog(); in CompactFiles()
935 int output_path_id, JobContext* job_context, LogBuffer* log_buffer, in CompactFilesImpl() argument
989 cfd, input_files, &sfm_reserved_compact_space, log_buffer); in CompactFilesImpl()
1028 preserve_deletes_seqnum_.load(), log_buffer, directories_.GetDbDir(), in CompactFilesImpl()
1500 LogBuffer log_buffer(InfoLogLevel::INFO_LEVEL, in RunManualCompaction() local
1540 cfd, true, &ca->prepicked_compaction->task_token, &log_buffer)) { in RunManualCompaction()
1557 log_buffer.FlushBufferToLog(); in RunManualCompaction()
2087 std::unique_ptr<TaskLimiterToken>* token, LogBuffer* log_buffer) { in PickCompactionFromQueue() argument
2096 if (!RequestCompactionToken(first_cfd, false, token, log_buffer)) { in PickCompactionFromQueue()
2200 LogBuffer* log_buffer, FlushReason* reason, in BackgroundFlush() argument
2251 log_buffer, in BackgroundFlush()
2261 job_context, log_buffer, thread_pri); in BackgroundFlush()
2285 LogBuffer log_buffer(InfoLogLevel::INFO_LEVEL, in BackgroundCallFlush() local
2297 Status s = BackgroundFlush(&made_progress, &job_context, &log_buffer, in BackgroundCallFlush()
2313 log_buffer.FlushBufferToLog(); in BackgroundCallFlush()
2328 job_context.HaveSomethingToDelete() || !log_buffer.IsEmpty()) { in BackgroundCallFlush()
2336 log_buffer.FlushBufferToLog(); in BackgroundCallFlush()
2364 LogBuffer log_buffer(InfoLogLevel::INFO_LEVEL, in BackgroundCallCompaction() local
2382 Status s = BackgroundCompaction(&made_progress, &job_context, &log_buffer, in BackgroundCallCompaction()
2400 log_buffer.FlushBufferToLog(); in BackgroundCallCompaction()
2411 ROCKS_LOG_BUFFER(&log_buffer, "[%s] [JOB %d] Manual compaction paused", in BackgroundCallCompaction()
2427 job_context.HaveSomethingToDelete() || !log_buffer.IsEmpty()) { in BackgroundCallCompaction()
2434 log_buffer.FlushBufferToLog(); in BackgroundCallCompaction()
2477 LogBuffer* log_buffer, in BackgroundCompaction() argument
2548 ROCKS_LOG_BUFFER(log_buffer, in BackgroundCompaction()
2557 m->cfd, *(c->inputs()), &sfm_reserved_compact_space, log_buffer); in BackgroundCompaction()
2568 log_buffer, in BackgroundCompaction()
2590 auto cfd = PickCompactionFromQueue(&task_token, log_buffer); in BackgroundCompaction()
2620 c.reset(cfd->PickCompaction(*mutable_cf_options, log_buffer)); in BackgroundCompaction()
2625 cfd, *(c->inputs()), &sfm_reserved_compact_space, log_buffer); in BackgroundCompaction()
2672 ROCKS_LOG_BUFFER(log_buffer, "Compaction nothing to do"); in BackgroundCompaction()
2699 ROCKS_LOG_BUFFER(log_buffer, "[%s] Deleted %d files\n", in BackgroundCompaction()
2740 log_buffer, in BackgroundCompaction()
2763 event_logger_.LogToBuffer(log_buffer) in BackgroundCompaction()
2770 log_buffer, in BackgroundCompaction()
2819 preserve_deletes_seqnum_.load(), log_buffer, directories_.GetDbDir(), in BackgroundCompaction()