X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.h;h=790cb6b135d9b9983a9826e4713112ad586da247;hb=90e7d72ff2b93752b8c81c49e9251a83b01703c6;hp=1e378f04ea631ea4387a1940c407599d19a63966;hpb=a2361a610dc8201cc8e165a70682b2f6dc3e0aee;p=lttng-tools.git diff --git a/src/common/consumer.h b/src/common/consumer.h index 1e378f04e..790cb6b13 100644 --- a/src/common/consumer.h +++ b/src/common/consumer.h @@ -666,8 +666,9 @@ int consumer_send_status_channel(int sock, void notify_thread_del_channel(struct lttng_consumer_local_data *ctx, uint64_t key); void consumer_destroy_relayd(struct consumer_relayd_sock_pair *relayd); -unsigned long consumer_get_consumed_maxsize(unsigned long consumed_pos, - unsigned long produced_pos, uint64_t max_stream_size); +unsigned long consumer_get_consume_start_pos(unsigned long consumed_pos, + unsigned long produced_pos, uint64_t nb_packets_per_stream, + uint64_t max_sb_size); int consumer_add_data_stream(struct lttng_consumer_stream *stream); void consumer_del_stream_for_data(struct lttng_consumer_stream *stream); int consumer_add_metadata_stream(struct lttng_consumer_stream *stream);