X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fnotification-thread-events.c;h=6ba6c415b65b74bf2c6571fb6261d6f3f3a34f80;hp=3f8cb4804ddd0800061f634afb3d6e92022e8103;hb=97a71ea68e8e05a20f44903db11e9e57dbbd29af;hpb=0ab399e0bcf4e99492845f02e3e5b405155dea92

diff --git a/src/bin/lttng-sessiond/notification-thread-events.c b/src/bin/lttng-sessiond/notification-thread-events.c
index 3f8cb4804..6ba6c415b 100644
--- a/src/bin/lttng-sessiond/notification-thread-events.c
+++ b/src/bin/lttng-sessiond/notification-thread-events.c
@@ -2412,6 +2412,8 @@ int handle_notification_thread_command(
 	pthread_mutex_lock(&handle->cmd_queue.lock);
 	cmd = cds_list_first_entry(&handle->cmd_queue.list,
 			struct notification_thread_command, cmd_list_node);
+	cds_list_del(&cmd->cmd_list_node);
+	pthread_mutex_unlock(&handle->cmd_queue.lock);
 	switch (cmd->type) {
 	case NOTIFICATION_COMMAND_TYPE_REGISTER_TRIGGER:
 		DBG("[notification-thread] Received register trigger command");
@@ -2474,19 +2476,16 @@ int handle_notification_thread_command(
 		goto error_unlock;
 	}
 end:
-	cds_list_del(&cmd->cmd_list_node);
 	if (cmd->is_async) {
 		free(cmd);
 		cmd = NULL;
 	} else {
 		lttng_waiter_wake_up(&cmd->reply_waiter);
 	}
-	pthread_mutex_unlock(&handle->cmd_queue.lock);
 	return ret;
 error_unlock:
 	/* Wake-up and return a fatal error to the calling thread. */
 	lttng_waiter_wake_up(&cmd->reply_waiter);
-	pthread_mutex_unlock(&handle->cmd_queue.lock);
 	cmd->reply_code = LTTNG_ERR_FATAL;
 error:
 	/* Indicate a fatal error to the caller. */