struct consumer_socket *socket, struct ust_registry_session *registry)
{
int ret;
- struct ltt_session *session;
assert(ua_sess);
assert(ua_chan);
goto error;
}
- session = session_find_by_id(ua_sess->tracing_id);
- assert(session);
-
pthread_mutex_lock(socket->lock);
ret = ask_channel_creation(ua_sess, ua_chan, consumer, socket, registry);
pthread_mutex_unlock(socket->lock);
memset(&msg, 0, sizeof(msg));
msg.cmd_type = LTTNG_ERR_UND;
+ pthread_mutex_lock(socket->lock);
(void) consumer_send_msg(socket, &msg);
+ pthread_mutex_unlock(socket->lock);
/*
* This is possible since the session might have been destroyed
* during a consumer metadata request. So here, return gracefully