Searched refs:expected_seq (Results 1 – 4 of 4) sorted by relevance
| /rocksdb-6.9/db/ |
| D | transaction_log_impl.cc | 208 const WriteBatch* batch, const SequenceNumber expected_seq) { in IsBatchExpected() argument
211 if (batchSeq != expected_seq) { in IsBatchExpected()
217 batchSeq, expected_seq, versions_->LastSequence()); in IsBatchExpected()
228 SequenceNumber expected_seq = current_last_seq_ + 1; in UpdateCurrentWriteBatch() local
230 if (started_ && !IsBatchExpected(batch.get(), expected_seq)) { in UpdateCurrentWriteBatch()
232 if (expected_seq < files_->at(current_file_index_)->StartSequence()) { in UpdateCurrentWriteBatch()
239 starting_sequence_number_ = expected_seq; in UpdateCurrentWriteBatch()
|
| D | db_with_timestamp_basic_test.cc | 147 SequenceNumber expected_seq, ValueType expected_val_type, in CheckIterEntry() argument
154 ParsedInternalKey parsed_ikey(ukey_and_ts, expected_seq, expected_val_type); in CheckIterEntry()
284 SequenceNumber expected_seq = start_seqs[i] + 1; in TEST_F() local
287 CheckIterEntry(iter.get(), Key1(key), expected_seq, kTypeValue, in TEST_F()
290 ++expected_seq; in TEST_F()
|
| D | transaction_log_impl.h | 121 bool IsBatchExpected(const WriteBatch* batch, SequenceNumber expected_seq);
|
| /rocksdb-6.9/utilities/transactions/ |
| D | write_prepared_transaction_test.cc | 2383 SequenceNumber expected_seq = 0; in TEST_P() local
2387 expected_seq++; in TEST_P()
2471 SequenceNumber expected_seq = 0; in TEST_P() local
2497 expected_seq++; // 1 for write in TEST_P()
2498 SequenceNumber seq1 = expected_seq; in TEST_P()
2500 expected_seq++; // 1 for commit in TEST_P()
2504 expected_seq++; // 1 for write in TEST_P()
2505 SequenceNumber seq2 = expected_seq; in TEST_P()
2507 expected_seq++; // 1 for commit in TEST_P()
2876 SequenceNumber expected_seq = 0; in TEST_P() local
[all …]
|