X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=c34f47c33f725252f2e598603653e9b1129fcafc;hp=526fbbf35c157f2bf545ef53b68dc0e45ef17365;hb=fb27f84c28e9d8ec7c8ce5ac1b541b0671a4569e;hpb=c585821bc78955b3d747fcd733aa1d2b81a3258e diff --git a/src/common/consumer.c b/src/common/consumer.c index 526fbbf35..c34f47c33 100644 --- a/src/common/consumer.c +++ b/src/common/consumer.c @@ -286,6 +286,17 @@ static void free_channel_rcu(struct rcu_head *head) struct lttng_consumer_channel *channel = caa_container_of(node, struct lttng_consumer_channel, node); + switch (consumer_data.type) { + case LTTNG_CONSUMER_KERNEL: + break; + case LTTNG_CONSUMER32_UST: + case LTTNG_CONSUMER64_UST: + lttng_ustconsumer_free_channel(channel); + break; + default: + ERR("Unknown consumer_data type"); + abort(); + } free(channel); } @@ -702,7 +713,7 @@ end: /* * Allocate and return a consumer relayd socket. */ -struct consumer_relayd_sock_pair *consumer_allocate_relayd_sock_pair( +static struct consumer_relayd_sock_pair *consumer_allocate_relayd_sock_pair( uint64_t net_seq_idx) { struct consumer_relayd_sock_pair *obj = NULL;