X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fnotification-thread-commands.c;h=2908ccb76d3cdee0ade33cee9ccbd9b2c5d9e850;hp=a3b41f989e72d5de6e116af5f5730a03f8f05c33;hb=HEAD;hpb=ae0a823f9f7e1d3800479488a58efc2f92f27d89 diff --git a/src/bin/lttng-sessiond/notification-thread-commands.c b/src/bin/lttng-sessiond/notification-thread-commands.c deleted file mode 100644 index a3b41f989..000000000 --- a/src/bin/lttng-sessiond/notification-thread-commands.c +++ /dev/null @@ -1,282 +0,0 @@ -/* - * Copyright (C) 2017 Jérémie Galarneau - * - * SPDX-License-Identifier: GPL-2.0-only - * - */ - -#include -#include -#include "notification-thread.h" -#include "notification-thread-commands.h" -#include -#include -#include -#include - -static -void init_notification_thread_command(struct notification_thread_command *cmd) -{ - CDS_INIT_LIST_HEAD(&cmd->cmd_list_node); - lttng_waiter_init(&cmd->reply_waiter); -} - -static -int run_command_wait(struct notification_thread_handle *handle, - struct notification_thread_command *cmd) -{ - int ret; - uint64_t notification_counter = 1; - - pthread_mutex_lock(&handle->cmd_queue.lock); - /* Add to queue. */ - cds_list_add_tail(&cmd->cmd_list_node, - &handle->cmd_queue.list); - /* Wake-up thread. */ - ret = lttng_write(lttng_pipe_get_writefd(handle->cmd_queue.event_pipe), - ¬ification_counter, sizeof(notification_counter)); - if (ret != sizeof(notification_counter)) { - PERROR("write to notification thread's queue event fd"); - /* - * Remove the command from the list so the notification - * thread does not process it. - */ - cds_list_del(&cmd->cmd_list_node); - goto error_unlock_queue; - } - pthread_mutex_unlock(&handle->cmd_queue.lock); - - lttng_waiter_wait(&cmd->reply_waiter); - return 0; -error_unlock_queue: - pthread_mutex_unlock(&handle->cmd_queue.lock); - return -1; -} - -static -struct notification_thread_command *notification_thread_command_copy( - const struct notification_thread_command *original_cmd) -{ - struct notification_thread_command *new_cmd; - - new_cmd = zmalloc(sizeof(*new_cmd)); - if (!new_cmd) { - goto end; - } - - *new_cmd = *original_cmd; - init_notification_thread_command(new_cmd); -end: - return new_cmd; -} - -static -int run_command_no_wait(struct notification_thread_handle *handle, - const struct notification_thread_command *in_cmd) -{ - int ret; - uint64_t notification_counter = 1; - struct notification_thread_command *new_cmd = - notification_thread_command_copy(in_cmd); - - if (!new_cmd) { - goto error; - } - new_cmd->is_async = true; - - pthread_mutex_lock(&handle->cmd_queue.lock); - /* Add to queue. */ - cds_list_add_tail(&new_cmd->cmd_list_node, - &handle->cmd_queue.list); - /* Wake-up thread. */ - ret = lttng_write(lttng_pipe_get_writefd(handle->cmd_queue.event_pipe), - ¬ification_counter, sizeof(notification_counter)); - if (ret != sizeof(notification_counter)) { - PERROR("write to notification thread's queue event fd"); - /* - * Remove the command from the list so the notification - * thread does not process it. - */ - cds_list_del(&new_cmd->cmd_list_node); - goto error_unlock_queue; - } - pthread_mutex_unlock(&handle->cmd_queue.lock); - return 0; -error_unlock_queue: - free(new_cmd); - pthread_mutex_unlock(&handle->cmd_queue.lock); -error: - return -1; -} - -enum lttng_error_code notification_thread_command_register_trigger( - struct notification_thread_handle *handle, - struct lttng_trigger *trigger) -{ - int ret; - enum lttng_error_code ret_code; - struct notification_thread_command cmd = {}; - - init_notification_thread_command(&cmd); - - cmd.type = NOTIFICATION_COMMAND_TYPE_REGISTER_TRIGGER; - cmd.parameters.trigger = trigger; - - ret = run_command_wait(handle, &cmd); - if (ret) { - ret_code = LTTNG_ERR_UNK; - goto end; - } - ret_code = cmd.reply_code; -end: - return ret_code; -} - -enum lttng_error_code notification_thread_command_unregister_trigger( - struct notification_thread_handle *handle, - struct lttng_trigger *trigger) -{ - int ret; - enum lttng_error_code ret_code; - struct notification_thread_command cmd = {}; - - init_notification_thread_command(&cmd); - - cmd.type = NOTIFICATION_COMMAND_TYPE_UNREGISTER_TRIGGER; - cmd.parameters.trigger = trigger; - - ret = run_command_wait(handle, &cmd); - if (ret) { - ret_code = LTTNG_ERR_UNK; - goto end; - } - ret_code = cmd.reply_code; -end: - return ret_code; -} - -enum lttng_error_code notification_thread_command_add_channel( - struct notification_thread_handle *handle, - char *session_name, uid_t uid, gid_t gid, - char *channel_name, uint64_t key, - enum lttng_domain_type domain, uint64_t capacity) -{ - int ret; - enum lttng_error_code ret_code; - struct notification_thread_command cmd = {}; - - init_notification_thread_command(&cmd); - - cmd.type = NOTIFICATION_COMMAND_TYPE_ADD_CHANNEL; - cmd.parameters.add_channel.session.name = session_name; - cmd.parameters.add_channel.session.uid = uid; - cmd.parameters.add_channel.session.gid = gid; - cmd.parameters.add_channel.channel.name = channel_name; - cmd.parameters.add_channel.channel.key = key; - cmd.parameters.add_channel.channel.domain = domain; - cmd.parameters.add_channel.channel.capacity = capacity; - - ret = run_command_wait(handle, &cmd); - if (ret) { - ret_code = LTTNG_ERR_UNK; - goto end; - } - ret_code = cmd.reply_code; -end: - return ret_code; -} - -enum lttng_error_code notification_thread_command_remove_channel( - struct notification_thread_handle *handle, - uint64_t key, enum lttng_domain_type domain) -{ - int ret; - enum lttng_error_code ret_code; - struct notification_thread_command cmd = {}; - - init_notification_thread_command(&cmd); - - cmd.type = NOTIFICATION_COMMAND_TYPE_REMOVE_CHANNEL; - cmd.parameters.remove_channel.key = key; - cmd.parameters.remove_channel.domain = domain; - - ret = run_command_wait(handle, &cmd); - if (ret) { - ret_code = LTTNG_ERR_UNK; - goto end; - } - ret_code = cmd.reply_code; -end: - return ret_code; -} - -enum lttng_error_code notification_thread_command_session_rotation_ongoing( - struct notification_thread_handle *handle, - const char *session_name, uid_t uid, gid_t gid, - uint64_t trace_archive_chunk_id) -{ - int ret; - enum lttng_error_code ret_code; - struct notification_thread_command cmd = {}; - - init_notification_thread_command(&cmd); - - cmd.type = NOTIFICATION_COMMAND_TYPE_SESSION_ROTATION_ONGOING; - cmd.parameters.session_rotation.session_name = session_name; - cmd.parameters.session_rotation.uid = uid; - cmd.parameters.session_rotation.gid = gid; - cmd.parameters.session_rotation.trace_archive_chunk_id = - trace_archive_chunk_id; - - ret = run_command_wait(handle, &cmd); - if (ret) { - ret_code = LTTNG_ERR_UNK; - goto end; - } - ret_code = cmd.reply_code; -end: - return ret_code; -} - -enum lttng_error_code notification_thread_command_session_rotation_completed( - struct notification_thread_handle *handle, - const char *session_name, uid_t uid, gid_t gid, - uint64_t trace_archive_chunk_id, - struct lttng_trace_archive_location *location) -{ - int ret; - enum lttng_error_code ret_code; - struct notification_thread_command cmd = {}; - - init_notification_thread_command(&cmd); - - cmd.type = NOTIFICATION_COMMAND_TYPE_SESSION_ROTATION_COMPLETED; - cmd.parameters.session_rotation.session_name = session_name; - cmd.parameters.session_rotation.uid = uid; - cmd.parameters.session_rotation.gid = gid; - cmd.parameters.session_rotation.trace_archive_chunk_id = - trace_archive_chunk_id; - cmd.parameters.session_rotation.location = location; - - ret = run_command_wait(handle, &cmd); - if (ret) { - ret_code = LTTNG_ERR_UNK; - goto end; - } - ret_code = cmd.reply_code; -end: - return ret_code; -} - -void notification_thread_command_quit( - struct notification_thread_handle *handle) -{ - int ret; - struct notification_thread_command cmd = {}; - - init_notification_thread_command(&cmd); - - cmd.type = NOTIFICATION_COMMAND_TYPE_QUIT; - ret = run_command_wait(handle, &cmd); - assert(!ret && cmd.reply_code == LTTNG_OK); -}