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
;
63 struct lttng_trace_archive_location
*location
;
67 /* lttng_waiter on which to wait for command reply (optional). */
68 struct lttng_waiter reply_waiter
;
69 enum lttng_error_code reply_code
;
72 enum lttng_error_code
notification_thread_command_register_trigger(
73 struct notification_thread_handle
*handle
,
74 struct lttng_trigger
*trigger
);
76 enum lttng_error_code
notification_thread_command_unregister_trigger(
77 struct notification_thread_handle
*handle
,
78 struct lttng_trigger
*trigger
);
80 enum lttng_error_code
notification_thread_command_add_channel(
81 struct notification_thread_handle
*handle
,
82 char *session_name
, uid_t session_uid
, gid_t session_gid
,
83 char *channel_name
, uint64_t key
,
84 enum lttng_domain_type domain
, uint64_t capacity
);
86 enum lttng_error_code
notification_thread_command_remove_channel(
87 struct notification_thread_handle
*handle
,
88 uint64_t key
, enum lttng_domain_type domain
);
90 enum lttng_error_code
notification_thread_command_session_rotation_ongoing(
91 struct notification_thread_handle
*handle
,
92 const char *session_name
, uid_t session_uid
, gid_t session_gid
,
93 uint64_t trace_archive_chunk_id
);
95 /* Ownership of location is transferred. */
96 enum lttng_error_code
notification_thread_command_session_rotation_completed(
97 struct notification_thread_handle
*handle
,
98 const char *session_name
, uid_t session_uid
, gid_t session_gid
,
99 uint64_t trace_archive_chunk_id
,
100 struct lttng_trace_archive_location
*location
);
102 void notification_thread_command_quit(
103 struct notification_thread_handle
*handle
);
105 #endif /* NOTIFICATION_THREAD_COMMANDS_H */