Lines Matching refs:batch_edits
3646 autovector<VersionEdit*> batch_edits; in ProcessManifestWrites() local
3654 batch_edits.push_back(first_writer.edit_list.front()); in ProcessManifestWrites()
3674 if (!batch_edits.empty()) { in ProcessManifestWrites()
3675 if (batch_edits.back()->is_in_atomic_group_ && in ProcessManifestWrites()
3676 batch_edits.back()->remaining_entries_ > 0) { in ProcessManifestWrites()
3677 assert(group_start < batch_edits.size()); in ProcessManifestWrites()
3689 for (auto i = group_start; i < batch_edits.size(); ++i) { in ProcessManifestWrites()
3691 batch_edits.back()->remaining_entries_); in ProcessManifestWrites()
3692 batch_edits[i]->remaining_entries_ -= static_cast<uint32_t>(k); in ProcessManifestWrites()
3727 if (batch_edits.empty() || !batch_edits.back()->is_in_atomic_group_ || in ProcessManifestWrites()
3728 (batch_edits.back()->is_in_atomic_group_ && in ProcessManifestWrites()
3729 batch_edits.back()->remaining_entries_ == 0)) { in ProcessManifestWrites()
3730 group_start = batch_edits.size(); in ProcessManifestWrites()
3743 batch_edits.push_back(e); in ProcessManifestWrites()
3765 while (k < batch_edits.size()) { in ProcessManifestWrites()
3766 while (k < batch_edits.size() && !batch_edits[k]->is_in_atomic_group_) { in ProcessManifestWrites()
3769 if (k == batch_edits.size()) { in ProcessManifestWrites()
3773 while (i < batch_edits.size()) { in ProcessManifestWrites()
3774 if (!batch_edits[i]->is_in_atomic_group_) { in ProcessManifestWrites()
3777 assert(i - k + batch_edits[i]->remaining_entries_ == in ProcessManifestWrites()
3778 batch_edits[k]->remaining_entries_); in ProcessManifestWrites()
3779 if (batch_edits[i]->remaining_entries_ == 0) { in ProcessManifestWrites()
3785 assert(batch_edits[i - 1]->is_in_atomic_group_); in ProcessManifestWrites()
3786 assert(0 == batch_edits[i - 1]->remaining_entries_); in ProcessManifestWrites()
3789 tmp.emplace_back(batch_edits[j]); in ProcessManifestWrites()
3816 batch_edits.back()->SetNextFile(next_file_number_.load()); in ProcessManifestWrites()
3891 for (auto& e : batch_edits) { in ProcessManifestWrites()
3901 if (batch_edits.size() > 1 && batch_edits.size() - 1 == idx) { in ProcessManifestWrites()
3966 assert(batch_edits.size() == 1); in ProcessManifestWrites()
3970 assert(batch_edits.size() == 1); in ProcessManifestWrites()
3980 for (const auto& e : batch_edits) { in ProcessManifestWrites()
3993 for (auto& e : batch_edits) { in ProcessManifestWrites()
4015 for (auto& e : batch_edits) { in ProcessManifestWrites()