consumer_stream_destroy(stream, metadata_ht);
}
-struct lttng_consumer_stream *consumer_allocate_stream(uint64_t channel_key,
+struct lttng_consumer_stream *consumer_allocate_stream(
+ struct lttng_consumer_channel *channel,
+ uint64_t channel_key,
uint64_t stream_key,
enum lttng_consumer_stream_state state,
const char *channel_name,
}
rcu_read_lock();
-
+ stream->chan = channel;
stream->key = stream_key;
stream->out_fd = -1;
stream->out_fd_offset = 0;