Home
last modified time | relevance | path

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

/rocksdb-6.9/db/
Dwrite_thread.cc316 write_group.size -= 1; in CompleteLeader()
330 write_group.size -= 1; in CompleteFollower()
424 leader->write_group = write_group; in EnterAsBatchGroupLeader()
427 write_group->size = 1; in EnterAsBatchGroupLeader()
477 w->write_group = write_group; in EnterAsBatchGroupLeader()
504 leader->write_group = write_group; in EnterAsMemTableWriter()
534 w->write_group = write_group; in EnterAsMemTableWriter()
579 write_group->running.store(write_group->size); in LaunchParallelMemTableWriters()
589 auto* write_group = w->write_group; in CompleteParallelMemTableWriter() local
606 auto* write_group = w->write_group; in ExitAsBatchGroupFollower() local
[all …]
Dwrite_thread.h128 WriteGroup* write_group; member
151 write_group(nullptr), in Writer()
172 write_group(nullptr), in batch()
285 size_t EnterAsBatchGroupLeader(Writer* leader, WriteGroup* write_group);
292 void ExitAsBatchGroupLeader(WriteGroup& write_group, Status status);
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);
Dwrite_callback_test.cc134 for (auto& write_group : write_scenarios) { in TEST_F() local
208 is_last = (cur_threads_linked == write_group.size() - 1); in TEST_F()
226 !write_group.front().callback_.should_fail_); in TEST_F()
229 !write_group.back().callback_.should_fail_); in TEST_F()
235 while (threads_verified.load() < write_group.size()) { in TEST_F()
272 while (i == write_group.size() - 1 && in TEST_F()
273 threads_verified.load() < write_group.size() - 1) { in TEST_F()
276 auto& write_op = write_group.at(i); in TEST_F()
337 for (uint32_t i = 0; i < write_group.size(); i++) { in TEST_F()
348 for (auto& w : write_group) { in TEST_F()
Dwrite_batch_internal.h165 WriteThread::WriteGroup& write_group, SequenceNumber sequence,
Dwrite_batch.cc1968 WriteThread::WriteGroup& write_group, SequenceNumber sequence, in InsertInto() argument
1978 for (auto w : write_group) { in InsertInto()
/rocksdb-6.9/db/db_impl/
Ddb_impl_write.cc216 WriteThread::WriteGroup write_group; in WriteImpl() local
272 for (auto* writer : write_group) { in WriteImpl()
701 WriteThread::WriteGroup write_group; in WriteImplWALOnly() local
709 for (auto* writer : write_group) { in WriteImplWALOnly()
747 for (auto* writer : write_group) { in WriteImplWALOnly()
766 for (auto* writer : write_group) { in WriteImplWALOnly()
801 for (auto* writer : write_group) { in WriteImplWALOnly()
958 auto* leader = write_group.leader; in MergeBatch()
975 for (auto writer : write_group) { in MergeBatch()
1039 for (auto writer : write_group) { in WriteToWAL()
[all …]
Ddb_impl.h1500 WriteBatch* MergeBatch(const WriteThread::WriteGroup& write_group,
1507 IOStatus WriteToWAL(const WriteThread::WriteGroup& write_group,
1512 IOStatus ConcurrentWriteToWAL(const WriteThread::WriteGroup& write_group,