Searched refs:next_message_end_offset (Results 1 – 4 of 4) sorted by relevance
505 int64_t next_message_end_offset; member
1292 int64_t notify_offset = s->next_message_end_offset; in continue_fetching_send_locked()1528 s->next_message_end_offset = in perform_stream_op_locked()1533 s->next_message_end_offset -= t->write_buffer_size; in perform_stream_op_locked()
548 int64_t next_message_end_offset; member
1256 int64_t notify_offset = s->next_message_end_offset; in continue_fetching_send_locked()1475 s->next_message_end_offset = in perform_stream_op_locked()1480 s->next_message_end_offset -= t->write_buffer_size; in perform_stream_op_locked()