Home
last modified time | relevance | path

Searched refs:flush_needed (Results 1 – 4 of 4) sorted by relevance

/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc688 bool flush_needed = true; in CompactRange() local
700 if (flush_needed) { in CompactRange()
1585 bool flush_needed = true; in FlushMemTable() local
1586 s = WaitUntilFlushWouldNotStallWrites(cfd, &flush_needed); in FlushMemTable()
1588 if (!s.ok() || !flush_needed) { in FlushMemTable()
1702 bool flush_needed = true; in AtomicFlushMemTables() local
1703 s = WaitUntilFlushWouldNotStallWrites(cfd, &flush_needed); in AtomicFlushMemTables()
1706 } else if (flush_needed) { in AtomicFlushMemTables()
1800 bool* flush_needed) { in WaitUntilFlushWouldNotStallWrites() argument
1802 *flush_needed = true; in WaitUntilFlushWouldNotStallWrites()
[all …]
Ddb_impl.h1440 bool* flush_needed);
/rocksdb-6.9/db/
Dexternal_sst_file_ingestion_job.cc182 Status ExternalSstFileIngestionJob::NeedsFlush(bool* flush_needed, in NeedsFlush() argument
190 cfd_->RangesOverlapWithMemtables(ranges, super_version, flush_needed); in NeedsFlush()
191 if (status.ok() && *flush_needed && in NeedsFlush()
Dexternal_sst_file_ingestion_job.h103 Status NeedsFlush(bool* flush_needed, SuperVersion* super_version);