Searched refs:leader (Results 1 – 4 of 4) sorted by relevance
260 Writer* leader = write_group.leader; in LinkGroup() local268 if (w == leader) { in LinkGroup()307 Writer* leader = write_group.leader; in CompleteLeader() local314 write_group.leader = leader->link_newer; in CompleteLeader()425 write_group->leader = leader; in EnterAsBatchGroupLeader()439 Writer* w = leader; in EnterAsBatchGroupLeader()505 write_group->leader = leader; in EnterAsMemTableWriter()547 Writer* leader = write_group.leader; in ExitAsMemTableWriter() local559 Writer* w = leader; in ExitAsMemTableWriter()565 if (w != leader) { in ExitAsMemTableWriter()[all …]
78 Writer* leader = nullptr; member110 Iterator begin() const { return Iterator(leader, last_writer); } in begin()285 size_t EnterAsBatchGroupLeader(Writer* leader, WriteGroup* write_group);301 void EnterAsMemTableWriter(Writer* leader, WriteGroup* write_grup);
958 auto* leader = write_group.leader; in MergeBatch() local959 assert(!leader->disable_wal); // Same holds for all in the batch group in MergeBatch()960 if (write_group.size == 1 && !leader->CallbackFailed() && in MergeBatch()961 leader->batch->GetWalTerminationPoint().is_cleared()) { in MergeBatch()965 merged_batch = leader->batch; in MergeBatch()1030 assert(!write_group.leader->disable_wal); in WriteToWAL()1036 if (merged_batch == write_group.leader->batch) { in WriteToWAL()1037 write_group.leader->log_used = logfile_number_; in WriteToWAL()1099 assert(!write_group.leader->disable_wal); in ConcurrentWriteToWAL()1110 if (merged_batch == write_group.leader->batch) { in ConcurrentWriteToWAL()[all …]
163 …tten in a single batch of WAL or memtable write. It is followed when the leader write size is larg…370 * Fix corner case where a write group leader blocked due to write stall blocks other writers in que…