2 * Copyright (C) 2017 Jérémie Galarneau <jeremie.galarneau@efficios.com>
4 * SPDX-License-Identifier: GPL-2.0-only
8 #ifndef NOTIFICATION_THREAD_COMMANDS_H
9 #define NOTIFICATION_THREAD_COMMANDS_H
11 #include <lttng/domain.h>
12 #include <lttng/lttng-error.h>
13 #include <urcu/rculfhash.h>
14 #include "notification-thread.h"
15 #include "notification-thread-internal.h"
16 #include "notification-thread-events.h"
17 #include <common/waiter.h>
19 struct notification_thread_data
;
22 enum notification_thread_command_type
{
23 NOTIFICATION_COMMAND_TYPE_REGISTER_TRIGGER
,
24 NOTIFICATION_COMMAND_TYPE_UNREGISTER_TRIGGER
,
25 NOTIFICATION_COMMAND_TYPE_ADD_CHANNEL
,
26 NOTIFICATION_COMMAND_TYPE_REMOVE_CHANNEL
,
27 NOTIFICATION_COMMAND_TYPE_SESSION_ROTATION_ONGOING
,
28 NOTIFICATION_COMMAND_TYPE_SESSION_ROTATION_COMPLETED
,
29 NOTIFICATION_COMMAND_TYPE_QUIT
,
32 struct notification_thread_command
{
33 struct cds_list_head cmd_list_node
;
35 enum notification_thread_command_type type
;
37 /* Register/Unregister trigger. */
38 struct lttng_trigger
*trigger
;
48 enum lttng_domain_type domain
;
56 enum lttng_domain_type domain
;
59 const char *session_name
;
62 uint64_t trace_archive_chunk_id
;
64 struct lttng_trace_archive_location
*location
;
68 /* lttng_waiter on which to wait for command reply (optional). */
69 struct lttng_waiter reply_waiter
;
70 enum lttng_error_code reply_code
;
73 enum lttng_error_code
notification_thread_command_register_trigger(
74 struct notification_thread_handle
*handle
,
75 struct lttng_trigger
*trigger
);
77 enum lttng_error_code
notification_thread_command_unregister_trigger(
78 struct notification_thread_handle
*handle
,
79 struct lttng_trigger
*trigger
);
81 enum lttng_error_code
notification_thread_command_add_channel(
82 struct notification_thread_handle
*handle
,
83 char *session_name
, uid_t session_uid
, gid_t session_gid
,
84 char *channel_name
, uint64_t key
,
85 enum lttng_domain_type domain
, uint64_t capacity
);
87 enum lttng_error_code
notification_thread_command_remove_channel(
88 struct notification_thread_handle
*handle
,
89 uint64_t key
, enum lttng_domain_type domain
);
91 enum lttng_error_code
notification_thread_command_session_rotation_ongoing(
92 struct notification_thread_handle
*handle
,
93 const char *session_name
, uid_t session_uid
, gid_t session_gid
,
94 uint64_t trace_archive_chunk_id
);
96 /* Ownership of location is transferred. */
97 enum lttng_error_code
notification_thread_command_session_rotation_completed(
98 struct notification_thread_handle
*handle
,
99 const char *session_name
, uid_t session_uid
, gid_t session_gid
,
100 uint64_t trace_archive_chunk_id
,
101 struct lttng_trace_archive_location
*location
);
103 void notification_thread_command_quit(
104 struct notification_thread_handle
*handle
);
106 #endif /* NOTIFICATION_THREAD_COMMANDS_H */