Lines Matching refs:sequence
41 auto sequence_to_log_id = [&](uint64_t sequence) -> int { in TestReport() argument
43 if (std::find(sequences.begin(), sequences.end(), sequence) != sequences.end()) { in TestReport()
54 for (uint64_t sequence : missing_expected) { in TestReport() local
55 int log_id = sequence_to_log_id(sequence); in TestReport()
56 missing_sequences[log_id].emplace_back(sequence); in TestReport()
63 for (uint64_t sequence : extra_read) { in TestReport() local
64 int log_id = sequence_to_log_id(sequence); in TestReport()
65 extra_sequences[log_id].emplace_back(sequence); in TestReport()
88 for (uint64_t sequence = 0; sequence < max_sequence; ++sequence) { in TestAllReading() local
90 auto state = SerializedFlushToState{sequence, mask}; in TestAllReading()
92 TestReading(sequence, mask, state); in TestAllReading()
104 for (uint64_t sequence = 1; sequence < max_sequence; ++sequence) { in TestAllReadingWithFutureMessages() local
107 auto state = SerializedFlushToState{sequence, mask}; in TestAllReadingWithFutureMessages()
111 TestReading(sequence, mask, state); in TestAllReadingWithFutureMessages()
124 for (const auto& sequence : sequence_numbers_per_buffer_[i]) { in TestReading() local
125 if (sequence >= start) { in TestReading()
126 expected_sequence.emplace_back(sequence); in TestReading()
136 read_sequence.emplace_back(top.entry->sequence()); in TestReading()
154 auto sequence = sequence_++; in AddChunkWithMessages() local
155 sequence_numbers_per_buffer_[buffer].emplace_back(sequence); in AddChunkWithMessages()
157 chunk.Log(sequence, log_time(), 0, 1, 1, message.c_str(), message.size() + 1); in AddChunkWithMessages()