Home
last modified time | relevance | path

Searched refs:FlushReason (Results 1 – 11 of 11) sorted by relevance

/rocksdb-6.9/db/
Dflush_job.cc56 case FlushReason::kOthers: in GetFlushReasonString()
58 case FlushReason::kGetLiveFiles: in GetFlushReasonString()
60 case FlushReason::kShutDown: in GetFlushReasonString()
64 case FlushReason::kManualCompaction: in GetFlushReasonString()
66 case FlushReason::kWriteBufferManager: in GetFlushReasonString()
68 case FlushReason::kWriteBufferFull: in GetFlushReasonString()
70 case FlushReason::kTest: in GetFlushReasonString()
72 case FlushReason::kDeleteFiles: in GetFlushReasonString()
74 case FlushReason::kAutoCompaction: in GetFlushReasonString()
76 case FlushReason::kManualFlush: in GetFlushReasonString()
[all …]
Ddb_filesnapshot.cc92 FlushReason::kGetLiveFiles); in GetLiveFiles()
101 status = FlushMemTable(cfd, FlushOptions(), FlushReason::kGetLiveFiles); in GetLiveFiles()
Dcolumn_family.h322 void SetFlushReason(FlushReason flush_reason) { in SetFlushReason()
325 FlushReason GetFlushReason() const { return flush_reason_; } in GetFlushReason()
572 std::atomic<FlushReason> flush_reason_;
Dcolumn_family.cc515 flush_reason_(FlushReason::kOthers), in ColumnFamilyData()
Ddb_wal_test.cc1474 assert(FlushReason::kWriteBufferManager == flush_job_info.flush_reason); in TEST_F()
/rocksdb-6.9/db/db_impl/
Ddb_impl_debug.cc137 return FlushMemTable(cfd, fo, FlushReason::kTest); in TEST_FlushMemTable()
142 return FlushMemTable(cfd, flush_opts, FlushReason::kTest); in TEST_FlushMemTable()
147 return AtomicFlushMemTables(cfds, flush_opts, FlushReason::kTest); in TEST_AtomicFlushMemTables()
Ddb_impl_compaction_flush.cc708 s = AtomicFlushMemTables(cfds, fo, FlushReason::kManualCompaction, in CompactRange()
711 s = FlushMemTable(cfd, fo, FlushReason::kManualCompaction, in CompactRange()
1368 FlushReason::kManualFlush); in Flush()
1370 s = FlushMemTable(cfh->cfd(), flush_options, FlushReason::kManualFlush); in Flush()
1406 s = AtomicFlushMemTables(cfds, flush_options, FlushReason::kManualFlush); in Flush()
1696 const FlushOptions& flush_options, FlushReason flush_reason, in AtomicFlushMemTables()
2113 FlushReason flush_reason) { in SchedulePendingFlush()
2200 LogBuffer* log_buffer, FlushReason* reason, in BackgroundFlush()
2205 *reason = FlushReason::kOthers; in BackgroundFlush()
2295 FlushReason reason; in BackgroundCallFlush()
[all …]
Ddb_impl.h1431 FlushReason flush_reason, bool writes_stopped = false);
1435 const FlushOptions& options, FlushReason flush_reason,
1561 void SchedulePendingFlush(const FlushRequest& req, FlushReason flush_reason);
1583 LogBuffer* log_buffer, FlushReason* reason,
Ddb_impl_write.cc1305 SchedulePendingFlush(flush_req, FlushReason::kWriteBufferManager); in SwitchWAL()
1384 SchedulePendingFlush(flush_req, FlushReason::kWriteBufferFull); in HandleWriteBufferFull()
1608 SchedulePendingFlush(flush_req, FlushReason::kWriteBufferFull); in ScheduleFlushes()
Ddb_impl.cc329 s = AtomicFlushMemTables(cfds, flush_opts, FlushReason::kErrorRecovery); in ResumeImpl()
338 s = FlushMemTable(cfd, flush_opts, FlushReason::kErrorRecovery); in ResumeImpl()
419 AtomicFlushMemTables(cfds, FlushOptions(), FlushReason::kShutDown); in CancelAllBackgroundWork()
426 FlushMemTable(cfd, FlushOptions(), FlushReason::kShutDown); in CancelAllBackgroundWork()
4141 FlushReason::kExternalFileIngestion, in IngestExternalFiles()
4152 FlushReason::kExternalFileIngestion, in IngestExternalFiles()
/rocksdb-6.9/include/rocksdb/
Dlistener.h100 enum class FlushReason : int { enum
198 FlushReason flush_reason;