X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=c74d1f7ae3cbded46415430ca20054c8686de416;hp=af99333c8d2ae1bacc73f7f4af5fcd231e79e104;hb=ad7051c0f2e1eb584c623794bf4b83548e3ccadc;hpb=beaad64cecee395058e37c8b33dc50af99d771a4 diff --git a/src/common/consumer.c b/src/common/consumer.c index af99333c8..c74d1f7ae 100644 --- a/src/common/consumer.c +++ b/src/common/consumer.c @@ -3006,7 +3006,8 @@ int consumer_data_pending(uint64_t id) if (relayd) { pthread_mutex_lock(&relayd->ctrl_sock_mutex); if (stream->metadata_flag) { - ret = relayd_quiescent_control(&relayd->control_sock); + ret = relayd_quiescent_control(&relayd->control_sock, + stream->relayd_stream_id); } else { ret = relayd_data_pending(&relayd->control_sock, stream->relayd_stream_id, stream->next_net_seq_num);