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>
20 struct notification_thread_data
;
23 enum notification_thread_command_type
{
24 NOTIFICATION_COMMAND_TYPE_REGISTER_TRIGGER
,
25 NOTIFICATION_COMMAND_TYPE_UNREGISTER_TRIGGER
,
26 NOTIFICATION_COMMAND_TYPE_ADD_CHANNEL
,
27 NOTIFICATION_COMMAND_TYPE_REMOVE_CHANNEL
,
28 NOTIFICATION_COMMAND_TYPE_SESSION_ROTATION_ONGOING
,
29 NOTIFICATION_COMMAND_TYPE_SESSION_ROTATION_COMPLETED
,
30 NOTIFICATION_COMMAND_TYPE_ADD_TRACER_EVENT_SOURCE
,
31 NOTIFICATION_COMMAND_TYPE_REMOVE_TRACER_EVENT_SOURCE
,
32 NOTIFICATION_COMMAND_TYPE_LIST_TRIGGERS
,
33 NOTIFICATION_COMMAND_TYPE_QUIT
,
34 NOTIFICATION_COMMAND_TYPE_CLIENT_COMMUNICATION_UPDATE
,
35 NOTIFICATION_COMMAND_TYPE_GET_TRIGGER
,
38 struct notification_thread_command
{
39 struct cds_list_head cmd_list_node
;
41 enum notification_thread_command_type type
;
43 /* Register trigger. */
45 struct lttng_trigger
*trigger
;
46 bool is_trigger_anonymous
;
48 /* Unregister trigger. */
50 const struct lttng_trigger
*trigger
;
61 enum lttng_domain_type domain
;
69 enum lttng_domain_type domain
;
72 const char *session_name
;
75 uint64_t trace_archive_chunk_id
;
76 struct lttng_trace_archive_location
*location
;
78 /* Add/Remove tracer event source fd. */
80 int tracer_event_source_fd
;
81 enum lttng_domain_type domain
;
82 } tracer_event_source
;
85 /* Credentials of the requesting user. */
88 /* Client communication update. */
90 notification_client_id id
;
91 enum client_transmission_status status
;
92 } client_communication_update
;
95 const struct lttng_trigger
*trigger
;
102 struct lttng_triggers
*triggers
;
105 struct lttng_trigger
*trigger
;
108 /* lttng_waiter on which to wait for command reply (optional). */
109 struct lttng_waiter reply_waiter
;
110 enum lttng_error_code reply_code
;
114 enum lttng_error_code
notification_thread_command_register_trigger(
115 struct notification_thread_handle
*handle
,
116 struct lttng_trigger
*trigger
,
117 bool is_anonymous_trigger
);
119 enum lttng_error_code
notification_thread_command_unregister_trigger(
120 struct notification_thread_handle
*handle
,
121 const struct lttng_trigger
*trigger
);
123 enum lttng_error_code
notification_thread_command_add_channel(
124 struct notification_thread_handle
*handle
,
125 char *session_name
, uid_t session_uid
, gid_t session_gid
,
126 char *channel_name
, uint64_t key
,
127 enum lttng_domain_type domain
, uint64_t capacity
);
129 enum lttng_error_code
notification_thread_command_remove_channel(
130 struct notification_thread_handle
*handle
,
131 uint64_t key
, enum lttng_domain_type domain
);
133 enum lttng_error_code
notification_thread_command_session_rotation_ongoing(
134 struct notification_thread_handle
*handle
,
135 const char *session_name
, uid_t session_uid
, gid_t session_gid
,
136 uint64_t trace_archive_chunk_id
);
138 /* Ownership of location is transferred. */
139 enum lttng_error_code
notification_thread_command_session_rotation_completed(
140 struct notification_thread_handle
*handle
,
141 const char *session_name
, uid_t session_uid
, gid_t session_gid
,
142 uint64_t trace_archive_chunk_id
,
143 struct lttng_trace_archive_location
*location
);
146 * Return the set of triggers visible to a given client.
148 * The trigger objects contained in the set are the actual trigger instances
149 * used by the notification subsystem (i.e. not a copy). Given that the command
150 * is only used to serialize the triggers, this is fine: the properties that
151 * are serialized are immutable over the lifetime of the triggers.
153 * Moreover, the lifetime of the trigger instances is protected through
154 * reference counting (references are held by the trigger set).
156 * The caller has the exclusive ownership of the returned trigger set.
158 enum lttng_error_code
notification_thread_command_list_triggers(
159 struct notification_thread_handle
*handle
,
161 struct lttng_triggers
**triggers
);
164 * The ownership of trigger_event_application_pipe is _not_ transferred to
165 * the notification thread.
167 enum lttng_error_code
notification_thread_command_add_tracer_event_source(
168 struct notification_thread_handle
*handle
,
169 int tracer_event_source_fd
,
170 enum lttng_domain_type domain
);
172 enum lttng_error_code
notification_thread_command_remove_tracer_event_source(
173 struct notification_thread_handle
*handle
,
174 int tracer_event_source_fd
);
176 void notification_thread_command_quit(
177 struct notification_thread_handle
*handle
);
179 enum lttng_error_code
notification_thread_command_get_trigger(
180 struct notification_thread_handle
*handle
,
181 const struct lttng_trigger
*trigger
,
182 struct lttng_trigger
**real_trigger
);
184 #endif /* NOTIFICATION_THREAD_COMMANDS_H */