Signed-off-by: Jérémie Galarneau <jeremie.galarneau@efficios.com>
if (consumed_pos == stream->rotate_position) {
stream->rotate_ready = true;
}
- channel->nr_stream_rotate_pending++;
ret = consumer_flush_buffer(stream, 1);
if (ret < 0) {
bool streams_sent_to_relayd;
- /*
- * Account how many streams are waiting for their rotation to be
- * complete. When this number reaches 0, we inform the session
- * daemon that this channel has finished its rotation.
- */
- uint64_t nr_stream_rotate_pending;
-
/*
* The chunk id where we currently write the data. This value is sent
* to the relay when we add a stream and when a stream rotates. This