42 void SerializedFlushToState::CreateLogPosition(log_id_t log_id) {  in CreateLogPosition()  argument
43     CHECK(!logs_[log_id].empty());  in CreateLogPosition()
45     auto it = logs_[log_id].begin();  in CreateLogPosition()
46     while (it != logs_[log_id].end() && start() > it->highest_sequence_number()) {  in CreateLogPosition()
49     if (it == logs_[log_id].end()) {  in CreateLogPosition()
66     log_positions_[log_id].emplace(log_position);  in CreateLogPosition()
69 void SerializedFlushToState::UpdateLogsNeeded(log_id_t log_id) {  in UpdateLogsNeeded()  argument
70     auto& buffer_it = log_positions_[log_id]->buffer_it;  in UpdateLogsNeeded()
71     auto read_offset = log_positions_[log_id]->read_offset;  in UpdateLogsNeeded()
75         logs_needed_from_next_position_[log_id] = false;  in UpdateLogsNeeded()
79         if (buffer_it == std::prev(logs_[log_id].end())) {  in UpdateLogsNeeded()
80             logs_needed_from_next_position_[log_id] = true;  in UpdateLogsNeeded()
86             log_positions_[log_id]->read_offset = 0;  in UpdateLogsNeeded()
88                 logs_needed_from_next_position_[log_id] = true;  in UpdateLogsNeeded()
90                 logs_needed_from_next_position_[log_id] = false;  in UpdateLogsNeeded()
127     log_id_t log_id;  in PopNextUnreadLog()  local
134             log_id = i;  in PopNextUnreadLog()
141     log_positions_[log_id]->read_offset += entry->total_len();  in PopNextUnreadLog()
143     logs_needed_from_next_position_[log_id] = true;  in PopNextUnreadLog()
145     return {log_id, entry};  in PopNextUnreadLog()
148 void SerializedFlushToState::Prune(log_id_t log_id) {  in Prune()  argument
149     CHECK(log_positions_[log_id].has_value());  in Prune()
152     log_positions_[log_id]->buffer_it->DetachReader(this);  in Prune()
155     log_positions_[log_id].reset();  in Prune()
159     logs_needed_from_next_position_[log_id] = true;  in Prune()