Searched refs:next_sequence (Results 1 – 5 of 5) sorted by relevance
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_secondary.cc | 86 SequenceNumber next_sequence(kMaxSequenceNumber); in FindAndRecoverLogFiles() local
87 s = RecoverLogFiles(logs, &next_sequence, cfds_changed, job_context); in FindAndRecoverLogFiles()
175 const std::vector<uint64_t>& log_numbers, SequenceNumber* next_sequence, in RecoverLogFiles() argument
260 next_sequence, &has_valid_writes, seq_per_batch_, batch_per_txn_); in RecoverLogFiles()
284 auto last_sequence = *next_sequence - 1; in RecoverLogFiles()
285 if ((*next_sequence != kMaxSequenceNumber) && in RecoverLogFiles()
|
| D | db_impl_open.cc | 493 SequenceNumber next_sequence(kMaxSequenceNumber); in Recover() local
561 s = RecoverLogFiles(logs, &next_sequence, read_only, in Recover()
564 *recovered_seq = next_sequence; in Recover()
695 SequenceNumber* next_sequence, bool read_only, in RecoverLogFiles() argument
848 if (sequence == *next_sequence) { in RecoverLogFiles()
944 false /* concurrent_memtable_writes */, next_sequence, in RecoverLogFiles()
976 *next_sequence); in RecoverLogFiles()
1004 log_number, *next_sequence); in RecoverLogFiles()
1016 auto last_sequence = *next_sequence - 1; in RecoverLogFiles()
1017 if ((*next_sequence != kMaxSequenceNumber) && in RecoverLogFiles()
|
| D | db_impl_write.cc | 348 SequenceNumber next_sequence = current_sequence; in WriteImpl() local
358 writer->sequence = next_sequence; in WriteImpl()
370 next_sequence += writer->batch_cnt; in WriteImpl()
372 next_sequence += WriteBatchInternal::Count(writer->batch); in WriteImpl()
496 SequenceNumber next_sequence = current_sequence; in PipelinedWriteImpl() local
500 writer->sequence = next_sequence; in PipelinedWriteImpl()
502 next_sequence += count; in PipelinedWriteImpl()
|
| D | db_impl_secondary.h | 315 SequenceNumber* next_sequence,
|
| D | db_impl.h | 1394 SequenceNumber* next_sequence, bool read_only,
|