Home
last modified time | relevance | path

Searched refs:atomic_flush (Results 1 – 17 of 17) sorted by relevance

/rocksdb-6.9/db/
Ddb_flush_test.cc519 if (!atomic_flush) { in TEST_P()
526 options.atomic_flush = atomic_flush; in TEST_P()
565 if (!atomic_flush) { in TEST_P()
570 options.atomic_flush = atomic_flush; in TEST_P()
594 if (!atomic_flush) { in TEST_P()
599 options.atomic_flush = atomic_flush; in TEST_P()
646 if (!atomic_flush) { in TEST_P()
652 options.atomic_flush = atomic_flush; in TEST_P()
674 options.atomic_flush = atomic_flush; in TEST_P()
708 options.atomic_flush = atomic_flush; in TEST_P()
[all …]
Dmemtable_list.cc341 bool atomic_flush = false; in PickMemtablesToFlush() local
344 if (!atomic_flush && m->atomic_flush_seqno_ != kMaxSequenceNumber) { in PickMemtablesToFlush()
345 atomic_flush = true; in PickMemtablesToFlush()
360 if (!atomic_flush || num_flush_not_started_ == 0) { in PickMemtablesToFlush()
Ddb_filesnapshot.cc87 if (immutable_db_options_.atomic_flush) { in GetLiveFiles()
Dc.cc2749 unsigned char atomic_flush) { in rocksdb_options_set_atomic_flush() argument
2750 opt->rep.atomic_flush = atomic_flush; in rocksdb_options_set_atomic_flush()
/rocksdb-6.9/options/
Ddb_options.cc93 atomic_flush(options.atomic_flush), in ImmutableDBOptions()
239 ROCKS_LOG_HEADER(log, " Options.atomic_flush: %d", atomic_flush); in Dump()
Ddb_options.h85 bool atomic_flush; member
Doptions_helper.cc142 options.atomic_flush = immutable_db_options.atomic_flush; in BuildDBOptions()
1672 {offsetof(struct DBOptions, atomic_flush), OptionType::kBoolean,
1674 offsetof(struct ImmutableDBOptions, atomic_flush)}},
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc1209 assert(immutable_db_options_.atomic_flush); in AssignAtomicFlushSeq()
1266 if (immutable_db_options_.atomic_flush) { in SwitchWAL()
1297 if (immutable_db_options_.atomic_flush) { in SwitchWAL()
1330 if (immutable_db_options_.atomic_flush) { in HandleWriteBufferFull()
1376 if (immutable_db_options_.atomic_flush) { in HandleWriteBufferFull()
1567 if (immutable_db_options_.atomic_flush) { in ScheduleFlushes()
1603 if (immutable_db_options_.atomic_flush) { in ScheduleFlushes()
Ddb_impl_compaction_flush.cc249 if (immutable_db_options_.atomic_flush) { in FlushMemTablesToOutputFiles()
703 if (immutable_db_options_.atomic_flush) { in CompactRange()
1366 if (immutable_db_options_.atomic_flush) { in Flush()
1382 if (!immutable_db_options_.atomic_flush) { in Flush()
Ddb_impl_open.cc242 if (db_options.atomic_flush && db_options.enable_pipelined_write) { in ValidateOptions()
248 if (db_options.atomic_flush && db_options.best_efforts_recovery) { in ValidateOptions()
Ddb_impl.cc325 if (immutable_db_options_.atomic_flush) { in ResumeImpl()
415 if (immutable_db_options_.atomic_flush) { in CancelAllBackgroundWork()
4136 if (immutable_db_options_.atomic_flush) { in IngestExternalFiles()
/rocksdb-6.9/include/rocksdb/
Doptions.h1101 bool atomic_flush = false; member
/rocksdb-6.9/db_stress_tool/
Ddb_stress_gflags.cc82 DEFINE_bool(atomic_flush, false,
Ddb_stress_common.h92 DECLARE_bool(atomic_flush);
Ddb_stress_test_base.cc1817 options_.atomic_flush = FLAGS_atomic_flush; in Open()
/rocksdb-6.9/java/rocksjni/
Doptions.cc2077 opt->atomic_flush = jatomic_flush == JNI_TRUE; in Java_org_rocksdb_Options_setAtomicFlush()
2088 return static_cast<jboolean>(opt->atomic_flush); in Java_org_rocksdb_Options_atomicFlush()
6457 opt->atomic_flush = jatomic_flush == JNI_TRUE; in Java_org_rocksdb_DBOptions_setAtomicFlush()
6468 return static_cast<jboolean>(opt->atomic_flush); in Java_org_rocksdb_DBOptions_atomicFlush()
/rocksdb-6.9/
DHISTORY.md358 * Introduced DB option `atomic_flush`. If true, RocksDB supports flushing multiple column families …