Lines Matching refs:Writer

34 uint8_t WriteThread::BlockingAwaitState(Writer* w, uint8_t goal_mask) {  in BlockingAwaitState()
62 uint8_t WriteThread::AwaitState(Writer* w, uint8_t goal_mask, in AwaitState()
210 void WriteThread::SetState(Writer* w, uint8_t new_state) { in SetState()
223 bool WriteThread::LinkOne(Writer* w, std::atomic<Writer*>* newest_writer) { in LinkOne()
226 Writer* writers = newest_writer->load(std::memory_order_relaxed); in LinkOne()
258 std::atomic<Writer*>* newest_writer) { in LinkGroup()
260 Writer* leader = write_group.leader; in LinkGroup()
261 Writer* last_writer = write_group.last_writer; in LinkGroup()
262 Writer* w = last_writer; in LinkGroup()
273 Writer* newest = newest_writer->load(std::memory_order_relaxed); in LinkGroup()
282 void WriteThread::CreateMissingNewerLinks(Writer* head) { in CreateMissingNewerLinks()
284 Writer* next = head->link_older; in CreateMissingNewerLinks()
294 WriteThread::Writer* WriteThread::FindNextLeader(Writer* from, in FindNextLeader()
295 Writer* boundary) { in FindNextLeader()
297 Writer* current = from; in FindNextLeader()
307 Writer* leader = write_group.leader; in CompleteLeader()
320 void WriteThread::CompleteFollower(Writer* w, WriteGroup& write_group) { in CompleteFollower()
340 Writer* w = write_stall_dummy_.link_older; in BeginWriteStall()
341 Writer* prev = &write_stall_dummy_; in BeginWriteStall()
373 void WriteThread::JoinBatchGroup(Writer* w) { in JoinBatchGroup()
407 size_t WriteThread::EnterAsBatchGroupLeader(Writer* leader, in EnterAsBatchGroupLeader()
428 Writer* newest_writer = newest_writer_.load(std::memory_order_acquire); in EnterAsBatchGroupLeader()
439 Writer* w = leader; in EnterAsBatchGroupLeader()
486 void WriteThread::EnterAsMemTableWriter(Writer* leader, in EnterAsMemTableWriter()
507 Writer* last_writer = leader; in EnterAsMemTableWriter()
510 Writer* newest_writer = newest_memtable_writer_.load(); in EnterAsMemTableWriter()
513 Writer* w = leader; in EnterAsMemTableWriter()
545 void WriteThread::ExitAsMemTableWriter(Writer* /*self*/, in ExitAsMemTableWriter() argument
547 Writer* leader = write_group.leader; in ExitAsMemTableWriter()
548 Writer* last_writer = write_group.last_writer; in ExitAsMemTableWriter()
550 Writer* newest_writer = last_writer; in ExitAsMemTableWriter()
554 Writer* next_leader = last_writer->link_newer; in ExitAsMemTableWriter()
559 Writer* w = leader; in ExitAsMemTableWriter()
564 Writer* next = w->link_newer; in ExitAsMemTableWriter()
587 bool WriteThread::CompleteParallelMemTableWriter(Writer* w) { in CompleteParallelMemTableWriter()
605 void WriteThread::ExitAsBatchGroupFollower(Writer* w) { in ExitAsBatchGroupFollower()
619 Writer* leader = write_group.leader; in ExitAsBatchGroupLeader()
620 Writer* last_writer = write_group.last_writer; in ExitAsBatchGroupLeader()
630 for (Writer* w = last_writer; w != leader;) { in ExitAsBatchGroupLeader()
631 Writer* next = w->link_older; in ExitAsBatchGroupLeader()
642 Writer* next_leader = nullptr; in ExitAsBatchGroupLeader()
647 Writer dummy; in ExitAsBatchGroupLeader()
648 Writer* expected = last_writer; in ExitAsBatchGroupLeader()
691 Writer* head = newest_writer_.load(std::memory_order_acquire); in ExitAsBatchGroupLeader()
737 void WriteThread::EnterUnbatched(Writer* w, InstrumentedMutex* mu) { in EnterUnbatched()
752 void WriteThread::ExitUnbatched(Writer* w) { in ExitUnbatched()
754 Writer* newest_writer = w; in ExitUnbatched()
757 Writer* next_leader = w->link_newer; in ExitUnbatched()
770 Writer w; in WaitForMemTableWriters()