struct lttcomm_consumer_msg lkm;
struct consumer_output *consumer;
enum lttng_error_code status;
- struct ltt_session *session;
+ struct ltt_session *session = NULL;
struct lttng_channel_extended *channel_attr_extended;
/* Safety net */
channel->published_to_notification_thread = true;
error:
+ if (session) {
+ session_put(session);
+ }
free(pathname);
return ret;
}
char *pathname;
struct lttcomm_consumer_msg lkm;
struct consumer_output *consumer;
- struct ltt_session *session;
+ struct ltt_session *session = NULL;
rcu_read_lock();
error:
rcu_read_unlock();
free(pathname);
+ if (session) {
+ session_put(session);
+ }
return ret;
}
{
int ret = LTTNG_OK;
struct ltt_kernel_stream *stream;
- struct ltt_session *session;
+ struct ltt_session *session = NULL;
/* Safety net */
assert(channel);
error:
rcu_read_unlock();
+ if (session) {
+ session_put(session);
+ }
return ret;
}