Home
last modified time | relevance | path

Searched refs:log_buffer (Results 1 – 25 of 403) sorted by relevance

12345678910>>...17

/rocksdb-6.9/db/compaction/
Dcompaction_picker_fifo.cc39 VersionStorageInfo* vstorage, LogBuffer* log_buffer) { in PickTTLCompaction() argument
49 ROCKS_LOG_BUFFER(log_buffer, in PickTTLCompaction()
59 log_buffer, in PickTTLCompaction()
95 ROCKS_LOG_BUFFER(log_buffer, in PickTTLCompaction()
112 VersionStorageInfo* vstorage, LogBuffer* log_buffer) { in PickSizeCompaction() argument
154 log_buffer, in PickSizeCompaction()
164 log_buffer, in PickSizeCompaction()
181 ROCKS_LOG_BUFFER(log_buffer, in PickSizeCompaction()
201 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction() argument
230 LogBuffer log_buffer(InfoLogLevel::INFO_LEVEL, ioptions_.info_log); in CompactRange() local
[all …]
Dcompaction_picker_fifo.h24 VersionStorageInfo* version, LogBuffer* log_buffer,
45 LogBuffer* log_buffer);
50 LogBuffer* log_buffer);
Dcompaction_picker_level.cc50 LogBuffer* log_buffer, in LevelCompactionBuilder() argument
57 log_buffer_(log_buffer), in LevelCompactionBuilder()
552 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction() argument
555 log_buffer, mutable_cf_options, ioptions_); in PickCompaction()
Dcompaction_picker_level.h25 VersionStorageInfo* vstorage, LogBuffer* log_buffer,
Dcompaction_picker_universal.cc40 LogBuffer* log_buffer) in UniversalCompactionBuilder() argument
47 log_buffer_(log_buffer) {} in UniversalCompactionBuilder()
281 VersionStorageInfo* vstorage, LogBuffer* log_buffer, in PickCompaction() argument
285 log_buffer); in PickCompaction()
Dcompaction_picker_universal.h23 VersionStorageInfo* vstorage, LogBuffer* log_buffer,
Dcompaction_job.h70 LogBuffer* log_buffer, FSDirectory* db_directory,
/rocksdb-6.9/logging/
Dlog_buffer.cc73 void LogToBuffer(LogBuffer* log_buffer, size_t max_log_size, const char* format, in LogToBuffer() argument
75 if (log_buffer != nullptr) { in LogToBuffer()
78 log_buffer->AddLogToBuffer(max_log_size, format, ap); in LogToBuffer()
83 void LogToBuffer(LogBuffer* log_buffer, const char* format, ...) { in LogToBuffer() argument
84 if (log_buffer != nullptr) { in LogToBuffer()
87 log_buffer->AddLogToBuffer(LogBuffer::kDefaultMaxLogSize, format, ap); in LogToBuffer()
Devent_logger.cc24 EventLoggerStream::EventLoggerStream(LogBuffer* log_buffer, in EventLoggerStream() argument
27 log_buffer_(log_buffer), in EventLoggerStream()
60 void EventLogger::LogToBuffer(LogBuffer* log_buffer, const JSONWriter& jwriter, in LogToBuffer() argument
65 assert(log_buffer); in LogToBuffer()
66 ROCKSDB_NAMESPACE::LogToBuffer(log_buffer, max_log_size, "%s %s", Prefix(), in LogToBuffer()
Devent_logger.h165 explicit EventLoggerStream(LogBuffer* log_buffer, const size_t max_log_size);
186 EventLoggerStream LogToBuffer(LogBuffer* log_buffer) { in LogToBuffer() argument
187 return EventLoggerStream(log_buffer, LogBuffer::kDefaultMaxLogSize); in LogToBuffer()
189 EventLoggerStream LogToBuffer(LogBuffer* log_buffer, in LogToBuffer() argument
191 return EventLoggerStream(log_buffer, max_log_size); in LogToBuffer()
196 LogBuffer* log_buffer, const JSONWriter& jwriter,
Dlog_buffer.cc.d1 logging/log_buffer.cc.d logging/log_buffer.o: logging/log_buffer.cc \
2 logging/log_buffer.h memory/arena.h memory/allocator.h \
Dlog_buffer.h51 extern void LogToBuffer(LogBuffer* log_buffer, size_t max_log_size,
54 extern void LogToBuffer(LogBuffer* log_buffer, const char* format, ...);
Devent_logger_test.cc.d3 logging/log_buffer.h memory/arena.h memory/allocator.h \
Devent_logger.cc.d2 logging/event_logger.h logging/log_buffer.h memory/arena.h \
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc54 ROCKS_LOG_BUFFER(log_buffer, in EnoughRoomForCompaction()
72 ROCKS_LOG_BUFFER(log_buffer, in RequestCompactionToken()
918 log_buffer.FlushBufferToLog(); in CompactFiles()
1557 log_buffer.FlushBufferToLog(); in RunManualCompaction()
2251 log_buffer, in BackgroundFlush()
2313 log_buffer.FlushBufferToLog(); in BackgroundCallFlush()
2336 log_buffer.FlushBufferToLog(); in BackgroundCallFlush()
2548 ROCKS_LOG_BUFFER(log_buffer, in BackgroundCompaction()
2568 log_buffer, in BackgroundCompaction()
2740 log_buffer, in BackgroundCompaction()
[all …]
Ddb_impl.h1378 SnapshotChecker* snapshot_checker, LogBuffer* log_buffer,
1385 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri);
1389 JobContext* job_context, LogBuffer* log_buffer, Env::Priority thread_pri);
1533 JobContext* job_context, LogBuffer* log_buffer,
1579 LogBuffer* log_buffer,
1583 LogBuffer* log_buffer, FlushReason* reason,
1588 bool* sfm_bookkeeping, LogBuffer* log_buffer);
1594 LogBuffer* log_buffer);
1627 std::unique_ptr<TaskLimiterToken>* token, LogBuffer* log_buffer);
/rocksdb-6.9/db/
Dmemtable_list.h144 LogBuffer* log_buffer);
268 LogBuffer* log_buffer,
384 LogBuffer* log_buffer);
426 LogBuffer* log_buffer);
Dmemtable_list.cc392 LogBuffer* log_buffer, in TryInstallMemtableFlushResults() argument
447 ROCKS_LOG_BUFFER(log_buffer, in TryInstallMemtableFlushResults()
505 ROCKS_LOG_BUFFER(log_buffer, "[%s] Level-0 commit table #%" PRIu64 in TryInstallMemtableFlushResults()
518 ROCKS_LOG_BUFFER(log_buffer, "Level-0 commit table #%" PRIu64 in TryInstallMemtableFlushResults()
649 LogBuffer* log_buffer) { in InstallMemtableAtomicFlushResults() argument
715 ROCKS_LOG_BUFFER(log_buffer, in InstallMemtableAtomicFlushResults()
730 ROCKS_LOG_BUFFER(log_buffer, in InstallMemtableAtomicFlushResults()
Dflush_job.cc95 LogBuffer* log_buffer, FSDirectory* db_directory, in FlushJob() argument
114 log_buffer_(log_buffer), in FlushJob()
Dmemtable_list_test.cc90 LogBuffer log_buffer(DEBUG_LEVEL, &logger); in Mock_InstallMemtableFlushResults() local
124 file_num, to_delete, nullptr, &log_buffer, &flush_jobs_info, &io_s); in Mock_InstallMemtableFlushResults()
137 LogBuffer log_buffer(DEBUG_LEVEL, &logger); in Mock_InstallMemtableAtomicFlushResults() local
184 file_meta_ptrs, to_delete, nullptr, &log_buffer); in Mock_InstallMemtableAtomicFlushResults()
Dflush_job.h70 LogBuffer* log_buffer, FSDirectory* db_directory,
/rocksdb-6.9/env/
Denv_test.cc1400 LogBuffer log_buffer(InfoLogLevel::INFO_LEVEL, &test_logger); in TEST_P() local
1413 ROCKS_LOG_BUFFER(&log_buffer, "x%sx", bytes200); in TEST_P()
1414 ROCKS_LOG_BUFFER(&log_buffer, "x%sx", bytes600); in TEST_P()
1415 ROCKS_LOG_BUFFER(&log_buffer, "x%sx%sx%sx", bytes200, bytes200, bytes200); in TEST_P()
1416 ROCKS_LOG_BUFFER(&log_buffer, "x%sx%sx", bytes200, bytes600); in TEST_P()
1417 ROCKS_LOG_BUFFER(&log_buffer, "x%sx%sx", bytes600, bytes9000); in TEST_P()
1425 log_buffer.FlushBufferToLog(); in TEST_P()
1462 LogBuffer log_buffer(InfoLogLevel::INFO_LEVEL, &test_logger); in TEST_P() local
1463 ROCKS_LOG_BUFFER_MAX_SZ(&log_buffer, max_log_size, "%s", bytes9000); in TEST_P()
1464 log_buffer.FlushBufferToLog(); in TEST_P()
/rocksdb-6.9/db/blob/
Dblob_file_garbage.cc.d4 logging/event_logger.h logging/log_buffer.h memory/arena.h \
Dblob_file_addition.cc.d4 logging/event_logger.h logging/log_buffer.h memory/arena.h \
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader.cc.d43 logging/log_buffer.h port/sys_time.h table/scoped_arena_iterator.h \

12345678910>>...17