2 * Copyright (C) 2019 Simon Marchi <simon.marchi@efficios.com>
4 * SPDX-License-Identifier: LGPL-2.1-only
9 #include <common/error.h>
10 #include <common/macros.h>
11 #include <lttng/action/action-internal.h>
12 #include <lttng/action/firing-policy-internal.h>
13 #include <lttng/action/firing-policy.h>
14 #include <lttng/action/stop-session-internal.h>
15 #include <lttng/action/stop-session.h>
17 #define IS_STOP_SESSION_ACTION(action) \
18 (lttng_action_get_type(action) == LTTNG_ACTION_TYPE_STOP_SESSION)
20 struct lttng_action_stop_session
{
21 struct lttng_action parent
;
25 struct lttng_firing_policy
*policy
;
28 struct lttng_action_stop_session_comm
{
29 /* Includes the trailing \0. */
30 uint32_t session_name_len
;
35 * - session name (null terminated)
41 static const struct lttng_firing_policy
*
42 lttng_action_stop_session_internal_get_firing_policy(
43 const struct lttng_action
*action
);
45 static struct lttng_action_stop_session
*action_stop_session_from_action(
46 struct lttng_action
*action
)
50 return container_of(action
, struct lttng_action_stop_session
, parent
);
53 static const struct lttng_action_stop_session
*
54 action_stop_session_from_action_const(const struct lttng_action
*action
)
58 return container_of(action
, struct lttng_action_stop_session
, parent
);
61 static bool lttng_action_stop_session_validate(struct lttng_action
*action
)
64 struct lttng_action_stop_session
*action_stop_session
;
71 action_stop_session
= action_stop_session_from_action(action
);
73 /* A non-empty session name is mandatory. */
74 if (!action_stop_session
->session_name
||
75 strlen(action_stop_session
->session_name
) == 0) {
85 static bool lttng_action_stop_session_is_equal(
86 const struct lttng_action
*_a
, const struct lttng_action
*_b
)
88 bool is_equal
= false;
89 const struct lttng_action_stop_session
*a
, *b
;
91 a
= action_stop_session_from_action_const(_a
);
92 b
= action_stop_session_from_action_const(_b
);
94 /* Action is not valid if this is not true. */
95 assert(a
->session_name
);
96 assert(b
->session_name
);
97 if (strcmp(a
->session_name
, b
->session_name
)) {
101 is_equal
= lttng_firing_policy_is_equal(a
->policy
, b
->policy
);
106 static int lttng_action_stop_session_serialize(
107 struct lttng_action
*action
, struct lttng_payload
*payload
)
109 struct lttng_action_stop_session
*action_stop_session
;
110 struct lttng_action_stop_session_comm comm
;
111 size_t session_name_len
;
117 action_stop_session
= action_stop_session_from_action(action
);
119 assert(action_stop_session
->session_name
);
121 DBG("Serializing stop session action: session-name: %s",
122 action_stop_session
->session_name
);
124 session_name_len
= strlen(action_stop_session
->session_name
) + 1;
125 comm
.session_name_len
= session_name_len
;
127 ret
= lttng_dynamic_buffer_append(
128 &payload
->buffer
, &comm
, sizeof(comm
));
134 ret
= lttng_dynamic_buffer_append(&payload
->buffer
,
135 action_stop_session
->session_name
, session_name_len
);
141 ret
= lttng_firing_policy_serialize(
142 action_stop_session
->policy
, payload
);
153 static void lttng_action_stop_session_destroy(struct lttng_action
*action
)
155 struct lttng_action_stop_session
*action_stop_session
;
161 action_stop_session
= action_stop_session_from_action(action
);
163 lttng_firing_policy_destroy(action_stop_session
->policy
);
164 free(action_stop_session
->session_name
);
165 free(action_stop_session
);
171 ssize_t
lttng_action_stop_session_create_from_payload(
172 struct lttng_payload_view
*view
,
173 struct lttng_action
**p_action
)
175 ssize_t consumed_len
, ret
;
176 const struct lttng_action_stop_session_comm
*comm
;
177 const char *session_name
;
178 struct lttng_action
*action
= NULL
;
179 enum lttng_action_status status
;
180 struct lttng_firing_policy
*policy
= NULL
;
182 comm
= (typeof(comm
)) view
->buffer
.data
;
183 session_name
= (const char *) &comm
->data
;
186 if (!lttng_buffer_view_contains_string(
187 &view
->buffer
, session_name
, comm
->session_name_len
)) {
191 consumed_len
= sizeof(*comm
) + comm
->session_name_len
;
195 struct lttng_payload_view policy_view
=
196 lttng_payload_view_from_view(
197 view
, consumed_len
, -1);
198 ret
= lttng_firing_policy_create_from_payload(
199 &policy_view
, &policy
);
207 action
= lttng_action_stop_session_create();
213 status
= lttng_action_stop_session_set_session_name(
214 action
, session_name
);
215 if (status
!= LTTNG_ACTION_STATUS_OK
) {
221 status
= lttng_action_stop_session_set_firing_policy(action
, policy
);
222 if (status
!= LTTNG_ACTION_STATUS_OK
) {
231 lttng_firing_policy_destroy(policy
);
232 lttng_action_stop_session_destroy(action
);
237 struct lttng_action
*lttng_action_stop_session_create(void)
239 struct lttng_action
*action
= NULL
;
240 struct lttng_firing_policy
*policy
= NULL
;
241 enum lttng_action_status status
;
243 /* Create a every N = 1 firing policy. */
244 policy
= lttng_firing_policy_every_n_create(1);
249 action
= zmalloc(sizeof(struct lttng_action_stop_session
));
254 lttng_action_init(action
, LTTNG_ACTION_TYPE_STOP_SESSION
,
255 lttng_action_stop_session_validate
,
256 lttng_action_stop_session_serialize
,
257 lttng_action_stop_session_is_equal
,
258 lttng_action_stop_session_destroy
,
259 lttng_action_stop_session_internal_get_firing_policy
);
261 status
= lttng_action_stop_session_set_firing_policy(action
, policy
);
262 if (status
!= LTTNG_ACTION_STATUS_OK
) {
269 lttng_firing_policy_destroy(policy
);
273 enum lttng_action_status
lttng_action_stop_session_set_session_name(
274 struct lttng_action
*action
, const char *session_name
)
276 struct lttng_action_stop_session
*action_stop_session
;
277 enum lttng_action_status status
;
279 if (!action
|| !IS_STOP_SESSION_ACTION(action
) || !session_name
||
280 strlen(session_name
) == 0) {
281 status
= LTTNG_ACTION_STATUS_INVALID
;
285 action_stop_session
= action_stop_session_from_action(action
);
287 free(action_stop_session
->session_name
);
289 action_stop_session
->session_name
= strdup(session_name
);
290 if (!action_stop_session
->session_name
) {
291 status
= LTTNG_ACTION_STATUS_ERROR
;
295 status
= LTTNG_ACTION_STATUS_OK
;
300 enum lttng_action_status
lttng_action_stop_session_get_session_name(
301 const struct lttng_action
*action
, const char **session_name
)
303 const struct lttng_action_stop_session
*action_stop_session
;
304 enum lttng_action_status status
;
306 if (!action
|| !IS_STOP_SESSION_ACTION(action
) || !session_name
) {
307 status
= LTTNG_ACTION_STATUS_INVALID
;
311 action_stop_session
= action_stop_session_from_action_const(action
);
313 *session_name
= action_stop_session
->session_name
;
315 status
= LTTNG_ACTION_STATUS_OK
;
320 enum lttng_action_status
lttng_action_stop_session_set_firing_policy(
321 struct lttng_action
*action
,
322 const struct lttng_firing_policy
*policy
)
324 enum lttng_action_status status
;
325 struct lttng_action_stop_session
*stop_session_action
;
326 struct lttng_firing_policy
*copy
= NULL
;
328 if (!action
|| !policy
|| !IS_STOP_SESSION_ACTION(action
)) {
329 status
= LTTNG_ACTION_STATUS_INVALID
;
333 copy
= lttng_firing_policy_copy(policy
);
335 status
= LTTNG_ACTION_STATUS_ERROR
;
338 stop_session_action
= action_stop_session_from_action(action
);
340 /* Free the previous firing policy .*/
341 lttng_firing_policy_destroy(stop_session_action
->policy
);
343 stop_session_action
->policy
= copy
;
344 status
= LTTNG_ACTION_STATUS_OK
;
348 lttng_firing_policy_destroy(copy
);
352 enum lttng_action_status
lttng_action_stop_session_get_firing_policy(
353 const struct lttng_action
*action
,
354 const struct lttng_firing_policy
**policy
)
356 enum lttng_action_status status
;
357 const struct lttng_action_stop_session
*stop_session_action
;
359 if (!action
|| !policy
|| !IS_STOP_SESSION_ACTION(action
)) {
360 status
= LTTNG_ACTION_STATUS_INVALID
;
364 stop_session_action
= action_stop_session_from_action_const(action
);
366 *policy
= stop_session_action
->policy
;
367 status
= LTTNG_ACTION_STATUS_OK
;
372 static const struct lttng_firing_policy
*
373 lttng_action_stop_session_internal_get_firing_policy(
374 const struct lttng_action
*action
)
376 const struct lttng_action_stop_session
*_action
;
377 _action
= action_stop_session_from_action_const(action
);
379 return _action
->policy
;