Lines Matching refs:merged_batch
956 WriteBatch* merged_batch = nullptr; in MergeBatch() local
965 merged_batch = leader->batch; in MergeBatch()
966 if (WriteBatchInternal::IsLatestPersistentState(merged_batch)) { in MergeBatch()
967 *to_be_cached_state = merged_batch; in MergeBatch()
974 merged_batch = tmp_batch; in MergeBatch()
977 WriteBatchInternal::Append(merged_batch, writer->batch, in MergeBatch()
987 return merged_batch; in MergeBatch()
992 IOStatus DBImpl::WriteToWAL(const WriteBatch& merged_batch, in WriteToWAL() argument
996 Slice log_entry = WriteBatchInternal::Contents(&merged_batch); in WriteToWAL()
1034 WriteBatch* merged_batch = MergeBatch(write_group, &tmp_batch_, in WriteToWAL() local
1036 if (merged_batch == write_group.leader->batch) { in WriteToWAL()
1044 WriteBatchInternal::SetSequence(merged_batch, sequence); in WriteToWAL()
1047 io_s = WriteToWAL(*merged_batch, log_writer, log_used, &log_size); in WriteToWAL()
1077 if (merged_batch == &tmp_batch_) { in WriteToWAL()
1104 WriteBatch* merged_batch = in ConcurrentWriteToWAL() local
1110 if (merged_batch == write_group.leader->batch) { in ConcurrentWriteToWAL()
1119 WriteBatchInternal::SetSequence(merged_batch, sequence); in ConcurrentWriteToWAL()
1123 io_s = WriteToWAL(*merged_batch, log_writer, log_used, &log_size); in ConcurrentWriteToWAL()