Home
last modified time | relevance | path

Searched refs:WriteThread (Results 1 – 13 of 13) sorted by relevance

/rocksdb-6.9/db/
Dwrite_thread.cc17 WriteThread::WriteThread(const ImmutableDBOptions& db_options) in WriteThread() function in ROCKSDB_NAMESPACE::WriteThread
257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
334 void WriteThread::BeginWriteStall() { in BeginWriteStall()
358 void WriteThread::EndWriteStall() { in EndWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
[all …]
Dwrite_callback_test.cc211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
215 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
218 WriteThread::State::STATE_INIT); in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F()
247 WriteThread::State::STATE_GROUP_LEADER); in TEST_F()
250 WriteThread::State::STATE_COMPLETED || in TEST_F()
253 WriteThread::State:: in TEST_F()
Dwrite_thread.h29 class WriteThread {
255 explicit WriteThread(const ImmutableDBOptions& db_options);
257 virtual ~WriteThread() = default;
Dwrite_batch_internal.h165 WriteThread::WriteGroup& write_group, SequenceNumber sequence,
183 static Status InsertInto(WriteThread::Writer* writer, SequenceNumber sequence,
Ddb_write_test.cc151 auto* w = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()
152 if (w->state == WriteThread::STATE_GROUP_LEADER) { in TEST_P()
Dwrite_batch.cc1968 WriteThread::WriteGroup& write_group, SequenceNumber sequence, in InsertInto()
2001 WriteThread::Writer* writer, SequenceNumber sequence, in InsertInto()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc198 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImpl()
216 WriteThread::WriteGroup write_group; in WriteImpl()
473 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
556 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
666 if (w.state == WriteThread::STATE_COMPLETED) { in WriteImplWALOnly()
694 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
701 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
1279 WriteThread::Writer nonmem_w; in SwitchWAL()
1356 WriteThread::Writer nonmem_w; in HandleWriteBufferFull()
1581 WriteThread::Writer nonmem_w; in ScheduleFlushes()
[all …]
Ddb_impl_debug.cc114 WriteThread::Writer nonmem_w; in TEST_SwitchMemtable()
183 auto w = new WriteThread::Writer(); in TEST_BeginWrite()
189 auto writer = reinterpret_cast<WriteThread::Writer*>(w); in TEST_EndWrite()
Ddb_impl.h1117 WriteThread* write_thread, const WriteOptions& options,
1500 WriteBatch* MergeBatch(const WriteThread::WriteGroup& write_group,
1507 IOStatus WriteToWAL(const WriteThread::WriteGroup& write_group,
1512 IOStatus ConcurrentWriteToWAL(const WriteThread::WriteGroup& write_group,
1874 WriteThread write_thread_;
1878 WriteThread nonmem_write_thread_;
Ddb_impl.cc1091 WriteThread::Writer w; in SetDBOptions()
2349 WriteThread::Writer w; in CreateColumnFamilyImpl()
2451 WriteThread::Writer w; in DropColumnFamilyImpl()
3654 WriteThread::Writer w; in WriteOptionsFile()
4093 WriteThread::Writer w; in IngestExternalFiles()
4095 WriteThread::Writer nonmem_w; in IngestExternalFiles()
4346 WriteThread::Writer w; in CreateColumnFamilyWithImport()
4348 WriteThread::Writer nonmem_w; in CreateColumnFamilyWithImport()
Ddb_impl_compaction_flush.cc1597 WriteThread::Writer w; in FlushMemTable()
1598 WriteThread::Writer nonmem_w; in FlushMemTable()
1720 WriteThread::Writer w; in AtomicFlushMemTables()
1721 WriteThread::Writer nonmem_w; in AtomicFlushMemTables()
/rocksdb-6.9/tools/
Dwrite_stress.cc156 void WriteThread() { in WriteThread() function in ROCKSDB_NAMESPACE::WriteStress
223 threads_.emplace_back([&]() { WriteThread(); }); in Run()
/rocksdb-6.9/utilities/transactions/
Dtransaction_test.cc1458 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_P()