Lines Matching refs:sequence
176 &w, w.sequence, &column_family_memtables, &flush_scheduler_, in WriteImpl()
203 *seq_used = w.sequence; in WriteImpl()
358 writer->sequence = next_sequence; in WriteImpl()
361 writer->sequence, disable_memtable, writer->log_used, index++, in WriteImpl()
398 assert(w.sequence == current_sequence); in WriteImpl()
400 &w, w.sequence, &column_family_memtables, &flush_scheduler_, in WriteImpl()
409 *seq_used = w.sequence; in WriteImpl()
500 writer->sequence = next_sequence; in PipelinedWriteImpl()
566 memtable_write_group, w.sequence, column_family_memtables_.get(), in PipelinedWriteImpl()
580 &w, w.sequence, &column_family_memtables, &flush_scheduler_, in PipelinedWriteImpl()
592 *seq_used = w.sequence; in PipelinedWriteImpl()
611 w.sequence = seq; in UnorderedWriteMemtable()
620 &w, w.sequence, &column_family_memtables, &flush_scheduler_, in UnorderedWriteMemtable()
671 *seq_used = w.sequence; in WriteImplWALOnly()
770 writer->sequence = curr_seq; in WriteImplWALOnly()
803 assert(writer->sequence != kMaxSequenceNumber); in WriteImplWALOnly()
805 writer->sequence, disable_memtable, writer->log_used, index++, in WriteImplWALOnly()
827 *seq_used = w.sequence; in WriteImplWALOnly()
1028 SequenceNumber sequence) { in WriteToWAL() argument
1044 WriteBatchInternal::SetSequence(merged_batch, sequence); in WriteToWAL()
1118 auto sequence = *last_sequence + 1; in ConcurrentWriteToWAL() local
1119 WriteBatchInternal::SetSequence(merged_batch, sequence); in ConcurrentWriteToWAL()