Home
last modified time | relevance | path

Searched refs:flush_options (Results 1 – 7 of 7) sorted by relevance

/rocksdb-6.9/db/
Dfault_injection_test.cc277 FlushOptions flush_options; in DeleteAllData() local
278 flush_options.wait = true; in DeleteAllData()
279 db_->Flush(flush_options); in DeleteAllData()
405 FlushOptions flush_options; in TEST_P() local
406 flush_options.wait = false; in TEST_P()
407 ASSERT_OK(db_->Flush(flush_options)); in TEST_P()
450 FlushOptions flush_options; in TEST_P() local
451 flush_options.wait = true; in TEST_P()
452 db_->Flush(flush_options); in TEST_P()
491 FlushOptions flush_options; in TEST_P() local
[all …]
Ddb_flush_test.cc94 FlushOptions flush_options; in TEST_F() local
95 flush_options.wait = false; in TEST_F()
96 ASSERT_OK(dbfull()->Flush(flush_options)); in TEST_F()
130 FlushOptions flush_options; in TEST_F() local
131 flush_options.wait = false; in TEST_F()
132 ASSERT_OK(dbfull()->Flush(flush_options)); in TEST_F()
256 FlushOptions flush_options; in TEST_P() local
257 flush_options.wait = true; in TEST_P()
258 ASSERT_OK(dbfull()->Flush(flush_options)); in TEST_P()
Ddb_log_iter_test.cc130 FlushOptions flush_options; in TEST_F() local
131 flush_options.wait = false; in TEST_F()
132 dbfull()->Flush(flush_options); in TEST_F()
Dc_test.c1239 rocksdb_flushoptions_t *flush_options = rocksdb_flushoptions_create(); in main() local
1240 rocksdb_flushoptions_set_wait(flush_options, 1); in main()
1241 rocksdb_flush_cf(db, flush_options, handles[1], &err); in main()
1243 rocksdb_flushoptions_destroy(flush_options); in main()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc1360 Status DBImpl::Flush(const FlushOptions& flush_options, in Flush() argument
1367 s = AtomicFlushMemTables({cfh->cfd()}, flush_options, in Flush()
1379 Status DBImpl::Flush(const FlushOptions& flush_options, in Flush() argument
1384 s = Flush(flush_options, cfh); in Flush()
1580 const FlushOptions& flush_options, in FlushMemTable() argument
1584 if (!flush_options.allow_write_stall) { in FlushMemTable()
1655 if (flush_options.wait) { in FlushMemTable()
1674 if (s.ok() && flush_options.wait) { in FlushMemTable()
1699 if (!flush_options.allow_write_stall) { in AtomicFlushMemTables()
1759 if (flush_options.wait) { in AtomicFlushMemTables()
[all …]
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc1326 FlushOptions flush_options; in TEST_F() local
1332 ASSERT_OK(db->Flush(flush_options, db->DefaultColumnFamily())); in TEST_F()
/rocksdb-6.9/java/rocksjni/
Doptions.cc7213 auto* flush_options = in Java_org_rocksdb_FlushOptions_setAllowWriteStall() local
7215 flush_options->allow_write_stall = jallow_write_stall == JNI_TRUE; in Java_org_rocksdb_FlushOptions_setAllowWriteStall()
7225 auto* flush_options = in Java_org_rocksdb_FlushOptions_allowWriteStall() local
7227 return static_cast<jboolean>(flush_options->allow_write_stall); in Java_org_rocksdb_FlushOptions_allowWriteStall()