Lines Matching refs:read_offset
56 int read_offset = 0; in CreateLogPosition() local
57 while (read_offset < it->write_offset()) { in CreateLogPosition()
58 const auto* entry = it->log_entry(read_offset); in CreateLogPosition()
62 read_offset += entry->total_len(); in CreateLogPosition()
64 log_position.read_offset = read_offset; in CreateLogPosition()
71 auto read_offset = log_positions_[log_id]->read_offset; in UpdateLogsNeeded() local
74 if (read_offset < buffer_it->write_offset()) { in UpdateLogsNeeded()
76 } else if (read_offset == buffer_it->write_offset()) { in UpdateLogsNeeded()
86 log_positions_[log_id]->read_offset = 0; in UpdateLogsNeeded()
95 LOG(FATAL) << "read_offset (" << read_offset << ") > buffer_it->write_offset() (" in UpdateLogsNeeded()
141 log_positions_[log_id]->read_offset += entry->total_len(); in PopNextUnreadLog()