Searched refs:WriteGroup (Results 1 – 6 of 6) sorted by relevance
| /rocksdb-6.9/db/ |
| D | write_thread.h | 77 struct WriteGroup { struct
128 WriteGroup* write_group; argument
285 size_t EnterAsBatchGroupLeader(Writer* leader, WriteGroup* write_group);
292 void ExitAsBatchGroupLeader(WriteGroup& write_group, Status status);
301 void EnterAsMemTableWriter(Writer* leader, WriteGroup* write_grup);
306 void ExitAsMemTableWriter(Writer* self, WriteGroup& write_group);
313 void LaunchParallelMemTableWriters(WriteGroup* write_group);
412 bool LinkGroup(WriteGroup& write_group, std::atomic<Writer*>* newest_writer);
424 void CompleteLeader(WriteGroup& write_group);
428 void CompleteFollower(Writer* w, WriteGroup& write_group);
|
| D | write_thread.cc | 257 bool WriteThread::LinkGroup(WriteGroup& write_group, in LinkGroup()
305 void WriteThread::CompleteLeader(WriteGroup& write_group) { in CompleteLeader()
320 void WriteThread::CompleteFollower(Writer* w, WriteGroup& write_group) { in CompleteFollower()
408 WriteGroup* write_group) { in EnterAsBatchGroupLeader()
487 WriteGroup* write_group) { in EnterAsMemTableWriter()
546 WriteGroup& write_group) { in ExitAsMemTableWriter()
577 void WriteThread::LaunchParallelMemTableWriters(WriteGroup* write_group) { in LaunchParallelMemTableWriters()
617 void WriteThread::ExitAsBatchGroupLeader(WriteGroup& write_group, in ExitAsBatchGroupLeader()
|
| D | write_batch_internal.h | 165 WriteThread::WriteGroup& write_group, SequenceNumber sequence,
|
| D | write_batch.cc | 1968 WriteThread::WriteGroup& write_group, SequenceNumber sequence, in InsertInto()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 216 WriteThread::WriteGroup write_group; in WriteImpl()
473 WriteThread::WriteGroup wal_write_group; in PipelinedWriteImpl()
556 WriteThread::WriteGroup memtable_write_group; in PipelinedWriteImpl()
694 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
701 WriteThread::WriteGroup write_group; in WriteImplWALOnly()
950 WriteBatch* DBImpl::MergeBatch(const WriteThread::WriteGroup& write_group, in MergeBatch()
1025 IOStatus DBImpl::WriteToWAL(const WriteThread::WriteGroup& write_group, in WriteToWAL()
1095 const WriteThread::WriteGroup& write_group, uint64_t* log_used, in ConcurrentWriteToWAL()
|
| D | db_impl.h | 1500 WriteBatch* MergeBatch(const WriteThread::WriteGroup& write_group,
1507 IOStatus WriteToWAL(const WriteThread::WriteGroup& write_group,
1512 IOStatus ConcurrentWriteToWAL(const WriteThread::WriteGroup& write_group,
|