2 * Copyright (C) 2019 Jonathan Rajotte <jonathan.rajotte-julien@efficios.com>
4 * SPDX-License-Identifier: GPL-2.0-only
12 #include "session.hpp"
13 #include "ust-app.hpp"
15 #include <common/defaults.hpp>
16 #include <common/error.hpp>
17 #include <common/utils.hpp>
24 struct cmd_clear_session_reply_context
{
29 static void cmd_clear_session_reply(const ltt_session::locked_ref
& session
, void *_reply_context
)
33 const struct cmd_clear_session_reply_context
*reply_context
=
34 (cmd_clear_session_reply_context
*) _reply_context
;
35 struct lttcomm_lttng_msg llm
= {
36 .cmd_type
= LTTCOMM_SESSIOND_COMMAND_CLEAR_SESSION
,
44 DBG("End of clear command: replying to client");
45 comm_ret
= lttcomm_send_unix_sock(reply_context
->reply_sock_fd
, &llm
, sizeof(llm
));
46 if (comm_ret
!= (ssize_t
) sizeof(llm
)) {
47 ERR("Failed to send result of session \"%s\" clear to client", session
->name
);
49 ret
= close(reply_context
->reply_sock_fd
);
51 PERROR("Failed to close client socket in deferred session clear reply");
56 int cmd_clear_session(const ltt_session::locked_ref
& session
, int *sock_fd
)
59 struct cmd_clear_session_reply_context
*reply_context
= nullptr;
60 bool session_was_active
= false;
61 struct ltt_kernel_session
*ksession
;
62 struct ltt_ust_session
*usess
;
64 ksession
= session
->kernel_session
;
65 usess
= session
->ust_session
;
68 reply_context
= zmalloc
<cmd_clear_session_reply_context
>();
70 ret
= LTTNG_ERR_NOMEM
;
73 reply_context
->reply_sock_fd
= *sock_fd
;
76 if (!session
->has_been_started
) {
78 * Nothing to be cleared, this is not an error: there is
79 * indeed nothing to do, and there is no reason why we
80 * should return an error to the user.
85 /* Unsupported feature in lttng-relayd before 2.11. */
86 if (session
->consumer
->type
== CONSUMER_DST_NET
&&
87 (session
->consumer
->relay_major_version
== 2 &&
88 session
->consumer
->relay_minor_version
< 12)) {
89 ret
= LTTNG_ERR_CLEAR_NOT_AVAILABLE_RELAY
;
92 if (session
->consumer
->type
== CONSUMER_DST_NET
&& !session
->consumer
->relay_allows_clear
) {
93 ret
= LTTNG_ERR_CLEAR_NOT_AVAILABLE_RELAY
;
98 * After a stop followed by a clear, all subsequent clear are
99 * effect-less until start is performed.
101 if (session
->cleared_after_last_stop
) {
107 * After a stop followed by a rotation, all subsequent clear are effect-less
108 * until start is performed.
110 if (session
->rotated_after_last_stop
) {
115 session_was_active
= session
->active
;
116 if (session_was_active
) {
117 ret
= stop_kernel_session(ksession
);
118 if (ret
!= LTTNG_OK
) {
121 if (usess
&& usess
->active
) {
122 ret
= ust_app_stop_trace_all(usess
);
124 ret
= LTTNG_ERR_UST_STOP_FAIL
;
131 * Clear active kernel and UST session buffers.
133 if (session
->kernel_session
) {
134 ret
= kernel_clear_session(session
);
135 if (ret
!= LTTNG_OK
) {
139 if (session
->ust_session
) {
140 ret
= ust_app_clear_session(session
);
141 if (ret
!= LTTNG_OK
) {
146 if (session
->output_traces
) {
148 * Use rotation to delete local and remote stream files.
151 ret
= session_add_clear_notifier(
152 session
, cmd_clear_session_reply
, (void *) reply_context
);
154 ret
= LTTNG_ERR_FATAL
;
158 * On success, ownership of reply_context has been
159 * passed to session_add_clear_notifier().
161 reply_context
= nullptr;
164 ret
= cmd_rotate_session(
165 session
, nullptr, true, LTTNG_TRACE_CHUNK_COMMAND_TYPE_DELETE
);
166 if (ret
!= LTTNG_OK
) {
170 if (!session
->active
) {
171 session
->cleared_after_last_stop
= true;
173 if (session_was_active
) {
175 if (ksession
!= nullptr) {
176 DBG("Start kernel tracing session \"%s\"", session
->name
);
177 ret
= start_kernel_session(ksession
);
178 if (ret
!= LTTNG_OK
) {
183 /* Flag session that trace should start automatically */
185 int int_ret
= ust_app_start_trace_all(usess
);
188 ret
= LTTNG_ERR_UST_START_FAIL
;
194 * Open a packet in every stream of the session to ensure that
195 * viewers can correctly identify the boundaries of the periods
196 * during which tracing was active for this session.
198 ret
= session_open_packets(session
);
199 if (ret
!= LTTNG_OK
) {