X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fkernel-consumer.cpp;h=ece50de117456feddd7d653c27a8693283dbd919;hb=3130a40c184a9315f0a4ca9a235273277fdcabde;hp=d224b4cb741545daabcb653cd9944893620dbf6e;hpb=f46376a14da2eb796690cb4e718e8b213839d6ea;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/kernel-consumer.cpp b/src/bin/lttng-sessiond/kernel-consumer.cpp index d224b4cb7..ece50de11 100644 --- a/src/bin/lttng-sessiond/kernel-consumer.cpp +++ b/src/bin/lttng-sessiond/kernel-consumer.cpp @@ -12,16 +12,16 @@ #include #include -#include -#include -#include +#include +#include +#include -#include "consumer.h" -#include "health-sessiond.h" -#include "kernel-consumer.h" -#include "notification-thread-commands.h" -#include "session.h" -#include "lttng-sessiond.h" +#include "consumer.hpp" +#include "health-sessiond.hpp" +#include "kernel-consumer.hpp" +#include "notification-thread-commands.hpp" +#include "session.hpp" +#include "lttng-sessiond.hpp" static char *create_channel_path(struct consumer_output *consumer, size_t *consumer_path_offset) @@ -169,8 +169,8 @@ int kernel_consumer_add_channel(struct consumer_socket *sock, rcu_read_lock(); session = session_find_by_id(ksession->id); LTTNG_ASSERT(session); - LTTNG_ASSERT(pthread_mutex_trylock(&session->lock)); - LTTNG_ASSERT(session_trylock_list()); + ASSERT_LOCKED(session->lock); + ASSERT_SESSION_LIST_LOCKED(); status = notification_thread_command_add_channel( the_notification_thread_handle, session->name,