struct consumer_output *consumer)
{
int ret;
- int32_t ret_code;
+ int32_t ret_code = 1; /* Default is that the data is available */
struct consumer_socket *socket;
struct lttng_ht_iter iter;
struct lttcomm_consumer_msg msg;
DBG3("Consumer data available for id %u", id);
+ /* Send command for each consumer */
cds_lfht_for_each_entry(consumer->socks->ht, &iter.iter, socket,
node.node) {
/* Code flow error */