[lttng-tools.git] / src / common / actions / start-session.cpp

/*
 * Copyright (C) 2019 Simon Marchi <simon.marchi@efficios.com>
 *
 * SPDX-License-Identifier: LGPL-2.1-only
 *
 */

#include <common/error.hpp>
#include <common/macros.hpp>
#include <common/mi-lttng.hpp>
#include <lttng/action/action-internal.hpp>
#include <lttng/action/rate-policy-internal.hpp>
#include <lttng/action/rate-policy.h>
#include <lttng/action/start-session-internal.hpp>
#include <lttng/action/start-session.h>

#define IS_START_SESSION_ACTION(action) \
	(lttng_action_get_type(action) == LTTNG_ACTION_TYPE_START_SESSION)

namespace {
struct lttng_action_start_session {
	struct lttng_action parent;

	/* Owned by this. */
	char *session_name;
	struct lttng_rate_policy *policy;
};

struct lttng_action_start_session_comm {
	/* Includes the trailing \0. */
	uint32_t session_name_len;

	/*
	 * Variable data:
	 *
	 *  - session name (null terminated)
	 *  - policy
	 */
	char data[];
} LTTNG_PACKED;
} /* namespace */

static const struct lttng_rate_policy *
lttng_action_start_session_internal_get_rate_policy(
		const struct lttng_action *action);

static struct lttng_action_start_session *action_start_session_from_action(
		struct lttng_action *action)
{
	LTTNG_ASSERT(action);

	return container_of(action, struct lttng_action_start_session, parent);
}

static const struct lttng_action_start_session *
action_start_session_from_action_const(const struct lttng_action *action)
{
	LTTNG_ASSERT(action);

	return container_of(action, struct lttng_action_start_session, parent);
}

static bool lttng_action_start_session_validate(struct lttng_action *action)
{
	bool valid;
	struct lttng_action_start_session *action_start_session;

	if (!action) {
		valid = false;
		goto end;
	}

	action_start_session = action_start_session_from_action(action);

	/* A non-empty session name is mandatory. */
	if (!action_start_session->session_name ||
			strlen(action_start_session->session_name) == 0) {
		valid = false;
		goto end;
	}

	valid = true;
end:
	return valid;
}

static bool lttng_action_start_session_is_equal(
		const struct lttng_action *_a, const struct lttng_action *_b)
{
	bool is_equal = false;
	struct lttng_action_start_session *a, *b;

	a = container_of(_a, struct lttng_action_start_session, parent);
	b = container_of(_b, struct lttng_action_start_session, parent);

	/* Action is not valid if this is not true. */
	LTTNG_ASSERT(a->session_name);
	LTTNG_ASSERT(b->session_name);
	if (strcmp(a->session_name, b->session_name)) {
		goto end;
	}

	is_equal = lttng_rate_policy_is_equal(a->policy, b->policy);
end:
	return is_equal;
}

static int lttng_action_start_session_serialize(
		struct lttng_action *action, struct lttng_payload *payload)
{
	struct lttng_action_start_session *action_start_session;
	struct lttng_action_start_session_comm comm;
	size_t session_name_len;
	int ret;

	LTTNG_ASSERT(action);
	LTTNG_ASSERT(payload);

	action_start_session = action_start_session_from_action(action);

	LTTNG_ASSERT(action_start_session->session_name);

	DBG("Serializing start session action: session-name: %s",
			action_start_session->session_name);

	session_name_len = strlen(action_start_session->session_name) + 1;
	comm.session_name_len = session_name_len;

	ret = lttng_dynamic_buffer_append(&payload->buffer, &comm, sizeof(comm));
	if (ret) {
		ret = -1;
		goto end;
	}

	ret = lttng_dynamic_buffer_append(&payload->buffer,
			action_start_session->session_name, session_name_len);
	if (ret) {
		ret = -1;
		goto end;
	}

	ret = lttng_rate_policy_serialize(
			action_start_session->policy, payload);
	if (ret) {
		ret = -1;
		goto end;
	}

	ret = 0;
end:
	return ret;
}

static void lttng_action_start_session_destroy(struct lttng_action *action)
{
	struct lttng_action_start_session *action_start_session;

	if (!action) {
		goto end;
	}

	action_start_session = action_start_session_from_action(action);

	lttng_rate_policy_destroy(action_start_session->policy);
	free(action_start_session->session_name);
	free(action_start_session);

end:
	return;
}

ssize_t lttng_action_start_session_create_from_payload(
		struct lttng_payload_view *view,
		struct lttng_action **p_action)
{
	ssize_t consumed_len, ret;
	const struct lttng_action_start_session_comm *comm;
	const char *session_name;
	struct lttng_action *action = NULL;
	enum lttng_action_status status;
	struct lttng_rate_policy *policy = NULL;

	comm = (typeof(comm)) view->buffer.data;
	session_name = (const char *) &comm->data;

	/* Session name */
	if (!lttng_buffer_view_contains_string(&view->buffer, session_name,
			    comm->session_name_len)) {
		consumed_len = -1;
		goto end;
	}
	consumed_len = sizeof(*comm) + comm->session_name_len;

	/* Rate policy. */
	{
		struct lttng_payload_view policy_view =
				lttng_payload_view_from_view(
						view, consumed_len, -1);
		ret = lttng_rate_policy_create_from_payload(
				&policy_view, &policy);
		if (ret < 0) {
			consumed_len = -1;
			goto end;
		}
		consumed_len += ret;
	}

	action = lttng_action_start_session_create();
	if (!action) {
		consumed_len = -1;
		goto end;
	}

	status = lttng_action_start_session_set_session_name(
			action, session_name);
	if (status != LTTNG_ACTION_STATUS_OK) {
		consumed_len = -1;
		goto end;
	}

	LTTNG_ASSERT(policy);
	status = lttng_action_start_session_set_rate_policy(action, policy);
	if (status != LTTNG_ACTION_STATUS_OK) {
		consumed_len = -1;
		goto end;
	}

	*p_action = action;
	action = NULL;

end:
	lttng_rate_policy_destroy(policy);
	lttng_action_start_session_destroy(action);

	return consumed_len;
}

static enum lttng_error_code lttng_action_start_session_mi_serialize(
		const struct lttng_action *action, struct mi_writer *writer)
{
	int ret;
	enum lttng_error_code ret_code;
	enum lttng_action_status status;
	const char *session_name = NULL;
	const struct lttng_rate_policy *policy = NULL;

	LTTNG_ASSERT(action);
	LTTNG_ASSERT(IS_START_SESSION_ACTION(action));

	status = lttng_action_start_session_get_session_name(
			action, &session_name);
	LTTNG_ASSERT(status == LTTNG_ACTION_STATUS_OK);
	LTTNG_ASSERT(session_name != NULL);

	status = lttng_action_start_session_get_rate_policy(action, &policy);
	LTTNG_ASSERT(status == LTTNG_ACTION_STATUS_OK);
	LTTNG_ASSERT(policy != NULL);

	/* Open action start session element. */
	ret = mi_lttng_writer_open_element(
			writer, mi_lttng_element_action_start_session);
	if (ret) {
		goto mi_error;
	}

	/* Session name. */
	ret = mi_lttng_writer_write_element_string(
			writer, mi_lttng_element_session_name, session_name);
	if (ret) {
		goto mi_error;
	}

	/* Rate policy. */
	ret_code = lttng_rate_policy_mi_serialize(policy, writer);
	if (ret_code != LTTNG_OK) {
		goto end;
	}

	/* Close action start session element. */
	ret = mi_lttng_writer_close_element(writer);
	if (ret) {
		goto mi_error;
	}

	ret_code = LTTNG_OK;
	goto end;

mi_error:
	ret_code = LTTNG_ERR_MI_IO_FAIL;
end:
	return ret_code;
}

struct lttng_action *lttng_action_start_session_create(void)
{
	struct lttng_action_start_session *action_start = NULL;
	struct lttng_rate_policy *policy = NULL;
	enum lttng_action_status status;

	/* Create a every N = 1 rate policy. */
	policy = lttng_rate_policy_every_n_create(1);
	if (!policy) {
		goto end;
	}

	action_start = zmalloc<lttng_action_start_session>();
	if (!action_start) {
		goto end;
	}

	lttng_action_init(&action_start->parent,
			LTTNG_ACTION_TYPE_START_SESSION,
			lttng_action_start_session_validate,
			lttng_action_start_session_serialize,
			lttng_action_start_session_is_equal,
			lttng_action_start_session_destroy,
			lttng_action_start_session_internal_get_rate_policy,
			lttng_action_generic_add_error_query_results,
			lttng_action_start_session_mi_serialize);

	status = lttng_action_start_session_set_rate_policy(
			&action_start->parent, policy);
	if (status != LTTNG_ACTION_STATUS_OK) {
		lttng_action_destroy(&action_start->parent);
		action_start = NULL;
		goto end;
	}

end:
	lttng_rate_policy_destroy(policy);
	return &action_start->parent;
}

enum lttng_action_status lttng_action_start_session_set_session_name(
		struct lttng_action *action, const char *session_name)
{
	struct lttng_action_start_session *action_start_session;
	enum lttng_action_status status;

	if (!action || !IS_START_SESSION_ACTION(action) || !session_name ||
			strlen(session_name) == 0) {
		status = LTTNG_ACTION_STATUS_INVALID;
		goto end;
	}

	action_start_session = action_start_session_from_action(action);

	free(action_start_session->session_name);

	action_start_session->session_name = strdup(session_name);
	if (!action_start_session->session_name) {
		status = LTTNG_ACTION_STATUS_ERROR;
		goto end;
	}

	status = LTTNG_ACTION_STATUS_OK;
end:
	return status;
}

enum lttng_action_status lttng_action_start_session_get_session_name(
		const struct lttng_action *action, const char **session_name)
{
	const struct lttng_action_start_session *action_start_session;
	enum lttng_action_status status;

	if (!action || !IS_START_SESSION_ACTION(action) || !session_name) {
		status = LTTNG_ACTION_STATUS_INVALID;
		goto end;
	}

	action_start_session = action_start_session_from_action_const(action);

	*session_name = action_start_session->session_name;

	status = LTTNG_ACTION_STATUS_OK;
end:
	return status;
}

enum lttng_action_status lttng_action_start_session_set_rate_policy(
		struct lttng_action *action,
		const struct lttng_rate_policy *policy)
{
	enum lttng_action_status status;
	struct lttng_action_start_session *start_session_action;
	struct lttng_rate_policy *copy = NULL;

	if (!action || !policy || !IS_START_SESSION_ACTION(action)) {
		status = LTTNG_ACTION_STATUS_INVALID;
		goto end;
	}

	copy = lttng_rate_policy_copy(policy);
	if (!copy) {
		status = LTTNG_ACTION_STATUS_ERROR;
		goto end;
	}

	start_session_action = action_start_session_from_action(action);

	/* Release the previous rate policy .*/
	lttng_rate_policy_destroy(start_session_action->policy);

	/* Assign the policy. */
	start_session_action->policy = copy;
	status = LTTNG_ACTION_STATUS_OK;
	copy = NULL;

end:
	lttng_rate_policy_destroy(copy);
	return status;
}

enum lttng_action_status lttng_action_start_session_get_rate_policy(
		const struct lttng_action *action,
		const struct lttng_rate_policy **policy)
{
	enum lttng_action_status status;
	const struct lttng_action_start_session *start_session_action;

	if (!action || !policy || !IS_START_SESSION_ACTION(action)) {
		status = LTTNG_ACTION_STATUS_INVALID;
		goto end;
	}

	start_session_action = action_start_session_from_action_const(action);

	*policy = start_session_action->policy;
	status = LTTNG_ACTION_STATUS_OK;
end:
	return status;
}

static const struct lttng_rate_policy *
lttng_action_start_session_internal_get_rate_policy(
		const struct lttng_action *action)
{
	const struct lttng_action_start_session *_action;
	_action = action_start_session_from_action_const(action);

	return _action->policy;
}
Commit	Line	Data
58397d0d SM	1	/*
	2	* Copyright (C) 2019 Simon Marchi <simon.marchi@efficios.com>
	3	*
	4	* SPDX-License-Identifier: LGPL-2.1-only
	5	*
	6	*/
	7
c9e313bc SM	8	#include <common/error.hpp>
	9	#include <common/macros.hpp>
	10	#include <common/mi-lttng.hpp>
	11	#include <lttng/action/action-internal.hpp>
	12	#include <lttng/action/rate-policy-internal.hpp>
7f4d5b07	13	#include <lttng/action/rate-policy.h>
c9e313bc	14	#include <lttng/action/start-session-internal.hpp>
58397d0d SM	15	#include <lttng/action/start-session.h>
	16
	17	#define IS_START_SESSION_ACTION(action) \
17182cfd	18	(lttng_action_get_type(action) == LTTNG_ACTION_TYPE_START_SESSION)
58397d0d	19
f1494934	20	namespace {
58397d0d SM	21	struct lttng_action_start_session {
	22	struct lttng_action parent;
	23
	24	/* Owned by this. */
	25	char *session_name;
7f4d5b07	26	struct lttng_rate_policy *policy;
58397d0d SM	27	};
	28
	29	struct lttng_action_start_session_comm {
	30	/* Includes the trailing \0. */
	31	uint32_t session_name_len;
	32
	33	/*
	34	* Variable data:
	35	*
	36	* - session name (null terminated)
1345b16b	37	* - policy
58397d0d SM	38	*/
	39	char data[];
	40	} LTTNG_PACKED;
f1494934	41	} /* namespace */
58397d0d	42
7f4d5b07 JR	43	static const struct lttng_rate_policy *
7f4d5b07 JR	44	lttng_action_start_session_internal_get_rate_policy(
2d57482c JR	45	const struct lttng_action *action);
2d57482c JR	46
58397d0d SM	47	static struct lttng_action_start_session *action_start_session_from_action(
	48	struct lttng_action *action)
	49	{
a0377dfe	50	LTTNG_ASSERT(action);
58397d0d SM	51
	52	return container_of(action, struct lttng_action_start_session, parent);
	53	}
	54
	55	static const struct lttng_action_start_session *
	56	action_start_session_from_action_const(const struct lttng_action *action)
	57	{
a0377dfe	58	LTTNG_ASSERT(action);
58397d0d SM	59
	60	return container_of(action, struct lttng_action_start_session, parent);
	61	}
	62
	63	static bool lttng_action_start_session_validate(struct lttng_action *action)
	64	{
	65	bool valid;
	66	struct lttng_action_start_session *action_start_session;
	67
	68	if (!action) {
	69	valid = false;
	70	goto end;
	71	}
	72
	73	action_start_session = action_start_session_from_action(action);
	74
	75	/* A non-empty session name is mandatory. */
	76	if (!action_start_session->session_name \|\|
	77	strlen(action_start_session->session_name) == 0) {
	78	valid = false;
	79	goto end;
	80	}
	81
	82	valid = true;
	83	end:
	84	return valid;
	85	}
	86
	87	static bool lttng_action_start_session_is_equal(
	88	const struct lttng_action _a, const struct lttng_action _b)
	89	{
	90	bool is_equal = false;
	91	struct lttng_action_start_session a, b;
	92
	93	a = container_of(_a, struct lttng_action_start_session, parent);
	94	b = container_of(_b, struct lttng_action_start_session, parent);
	95
	96	/* Action is not valid if this is not true. */
a0377dfe FD	97	LTTNG_ASSERT(a->session_name);
a0377dfe FD	98	LTTNG_ASSERT(b->session_name);
58397d0d SM	99	if (strcmp(a->session_name, b->session_name)) {
	100	goto end;
	101	}
	102
7f4d5b07	103	is_equal = lttng_rate_policy_is_equal(a->policy, b->policy);
58397d0d SM	104	end:
	105	return is_equal;
	106	}
	107
	108	static int lttng_action_start_session_serialize(
c0a66c84	109	struct lttng_action action, struct lttng_payload payload)
58397d0d SM	110	{
	111	struct lttng_action_start_session *action_start_session;
	112	struct lttng_action_start_session_comm comm;
	113	size_t session_name_len;
	114	int ret;
	115
a0377dfe FD	116	LTTNG_ASSERT(action);
a0377dfe FD	117	LTTNG_ASSERT(payload);
58397d0d SM	118
	119	action_start_session = action_start_session_from_action(action);
	120
a0377dfe	121	LTTNG_ASSERT(action_start_session->session_name);
58397d0d SM	122
	123	DBG("Serializing start session action: session-name: %s",
	124	action_start_session->session_name);
	125
	126	session_name_len = strlen(action_start_session->session_name) + 1;
	127	comm.session_name_len = session_name_len;
	128
c0a66c84	129	ret = lttng_dynamic_buffer_append(&payload->buffer, &comm, sizeof(comm));
58397d0d SM	130	if (ret) {
	131	ret = -1;
	132	goto end;
	133	}
	134
c0a66c84	135	ret = lttng_dynamic_buffer_append(&payload->buffer,
58397d0d SM	136	action_start_session->session_name, session_name_len);
	137	if (ret) {
	138	ret = -1;
	139	goto end;
	140	}
	141
7f4d5b07	142	ret = lttng_rate_policy_serialize(
1345b16b JR	143	action_start_session->policy, payload);
	144	if (ret) {
	145	ret = -1;
	146	goto end;
	147	}
	148
58397d0d SM	149	ret = 0;
	150	end:
	151	return ret;
	152	}
	153
	154	static void lttng_action_start_session_destroy(struct lttng_action *action)
	155	{
	156	struct lttng_action_start_session *action_start_session;
	157
	158	if (!action) {
	159	goto end;
	160	}
	161
	162	action_start_session = action_start_session_from_action(action);
	163
7f4d5b07	164	lttng_rate_policy_destroy(action_start_session->policy);
58397d0d SM	165	free(action_start_session->session_name);
	166	free(action_start_session);
	167
	168	end:
	169	return;
	170	}
	171
c0a66c84 JG	172	ssize_t lttng_action_start_session_create_from_payload(
c0a66c84 JG	173	struct lttng_payload_view *view,
58397d0d SM	174	struct lttng_action **p_action)
58397d0d SM	175	{
1345b16b	176	ssize_t consumed_len, ret;
58397d0d SM	177	const struct lttng_action_start_session_comm *comm;
58397d0d SM	178	const char *session_name;
1345b16b	179	struct lttng_action *action = NULL;
58397d0d	180	enum lttng_action_status status;
7f4d5b07	181	struct lttng_rate_policy *policy = NULL;
58397d0d	182
c0a66c84	183	comm = (typeof(comm)) view->buffer.data;
58397d0d SM	184	session_name = (const char *) &comm->data;
58397d0d SM	185
1345b16b	186	/* Session name */
c0a66c84 JG	187	if (!lttng_buffer_view_contains_string(&view->buffer, session_name,
c0a66c84 JG	188	comm->session_name_len)) {
58397d0d SM	189	consumed_len = -1;
	190	goto end;
	191	}
1345b16b JR	192	consumed_len = sizeof(*comm) + comm->session_name_len;
1345b16b JR	193
7f4d5b07	194	/* Rate policy. */
1345b16b JR	195	{
	196	struct lttng_payload_view policy_view =
	197	lttng_payload_view_from_view(
	198	view, consumed_len, -1);
7f4d5b07	199	ret = lttng_rate_policy_create_from_payload(
1345b16b JR	200	&policy_view, &policy);
	201	if (ret < 0) {
	202	consumed_len = -1;
	203	goto end;
	204	}
	205	consumed_len += ret;
	206	}
	207
	208	action = lttng_action_start_session_create();
	209	if (!action) {
	210	consumed_len = -1;
	211	goto end;
	212	}
58397d0d SM	213
	214	status = lttng_action_start_session_set_session_name(
	215	action, session_name);
	216	if (status != LTTNG_ACTION_STATUS_OK) {
	217	consumed_len = -1;
	218	goto end;
	219	}
	220
a0377dfe	221	LTTNG_ASSERT(policy);
7f4d5b07	222	status = lttng_action_start_session_set_rate_policy(action, policy);
1345b16b JR	223	if (status != LTTNG_ACTION_STATUS_OK) {
	224	consumed_len = -1;
	225	goto end;
	226	}
	227
58397d0d SM	228	*p_action = action;
	229	action = NULL;
	230
	231	end:
7f4d5b07	232	lttng_rate_policy_destroy(policy);
58397d0d SM	233	lttng_action_start_session_destroy(action);
	234
	235	return consumed_len;
	236	}
	237
6a751b95 JR	238	static enum lttng_error_code lttng_action_start_session_mi_serialize(
	239	const struct lttng_action action, struct mi_writer writer)
	240	{
	241	int ret;
	242	enum lttng_error_code ret_code;
	243	enum lttng_action_status status;
	244	const char *session_name = NULL;
	245	const struct lttng_rate_policy *policy = NULL;
	246
a0377dfe FD	247	LTTNG_ASSERT(action);
a0377dfe FD	248	LTTNG_ASSERT(IS_START_SESSION_ACTION(action));
6a751b95 JR	249
	250	status = lttng_action_start_session_get_session_name(
	251	action, &session_name);
a0377dfe FD	252	LTTNG_ASSERT(status == LTTNG_ACTION_STATUS_OK);
a0377dfe FD	253	LTTNG_ASSERT(session_name != NULL);
6a751b95 JR	254
6a751b95 JR	255	status = lttng_action_start_session_get_rate_policy(action, &policy);
a0377dfe FD	256	LTTNG_ASSERT(status == LTTNG_ACTION_STATUS_OK);
a0377dfe FD	257	LTTNG_ASSERT(policy != NULL);
6a751b95 JR	258
	259	/* Open action start session element. */
	260	ret = mi_lttng_writer_open_element(
	261	writer, mi_lttng_element_action_start_session);
	262	if (ret) {
	263	goto mi_error;
	264	}
	265
	266	/* Session name. */
	267	ret = mi_lttng_writer_write_element_string(
	268	writer, mi_lttng_element_session_name, session_name);
	269	if (ret) {
	270	goto mi_error;
	271	}
	272
	273	/* Rate policy. */
	274	ret_code = lttng_rate_policy_mi_serialize(policy, writer);
	275	if (ret_code != LTTNG_OK) {
	276	goto end;
	277	}
	278
	279	/* Close action start session element. */
	280	ret = mi_lttng_writer_close_element(writer);
	281	if (ret) {
	282	goto mi_error;
	283	}
	284
	285	ret_code = LTTNG_OK;
	286	goto end;
	287
	288	mi_error:
	289	ret_code = LTTNG_ERR_MI_IO_FAIL;
	290	end:
	291	return ret_code;
	292	}
	293
58397d0d SM	294	struct lttng_action *lttng_action_start_session_create(void)
58397d0d SM	295	{
64803277	296	struct lttng_action_start_session *action_start = NULL;
7f4d5b07	297	struct lttng_rate_policy *policy = NULL;
1345b16b JR	298	enum lttng_action_status status;
1345b16b JR	299
7f4d5b07 JR	300	/* Create a every N = 1 rate policy. */
7f4d5b07 JR	301	policy = lttng_rate_policy_every_n_create(1);
1345b16b JR	302	if (!policy) {
	303	goto end;
	304	}
58397d0d	305
64803277 SM	306	action_start = zmalloc<lttng_action_start_session>();
64803277 SM	307	if (!action_start) {
58397d0d SM	308	goto end;
	309	}
	310
64803277 SM	311	lttng_action_init(&action_start->parent,
64803277 SM	312	LTTNG_ACTION_TYPE_START_SESSION,
58397d0d SM	313	lttng_action_start_session_validate,
	314	lttng_action_start_session_serialize,
	315	lttng_action_start_session_is_equal,
2d57482c	316	lttng_action_start_session_destroy,
588c4b0d	317	lttng_action_start_session_internal_get_rate_policy,
6a751b95 JR	318	lttng_action_generic_add_error_query_results,
6a751b95 JR	319	lttng_action_start_session_mi_serialize);
58397d0d	320
64803277 SM	321	status = lttng_action_start_session_set_rate_policy(
64803277 SM	322	&action_start->parent, policy);
1345b16b	323	if (status != LTTNG_ACTION_STATUS_OK) {
64803277 SM	324	lttng_action_destroy(&action_start->parent);
64803277 SM	325	action_start = NULL;
1345b16b JR	326	goto end;
	327	}
	328
58397d0d	329	end:
7f4d5b07	330	lttng_rate_policy_destroy(policy);
64803277	331	return &action_start->parent;
58397d0d SM	332	}
	333
	334	enum lttng_action_status lttng_action_start_session_set_session_name(
	335	struct lttng_action action, const char session_name)
	336	{
	337	struct lttng_action_start_session *action_start_session;
	338	enum lttng_action_status status;
	339
	340	if (!action \|\| !IS_START_SESSION_ACTION(action) \|\| !session_name \|\|
	341	strlen(session_name) == 0) {
	342	status = LTTNG_ACTION_STATUS_INVALID;
	343	goto end;
	344	}
	345
	346	action_start_session = action_start_session_from_action(action);
	347
	348	free(action_start_session->session_name);
	349
	350	action_start_session->session_name = strdup(session_name);
	351	if (!action_start_session->session_name) {
	352	status = LTTNG_ACTION_STATUS_ERROR;
	353	goto end;
	354	}
	355
	356	status = LTTNG_ACTION_STATUS_OK;
	357	end:
	358	return status;
	359	}
	360
	361	enum lttng_action_status lttng_action_start_session_get_session_name(
	362	const struct lttng_action action, const char *session_name)
	363	{
	364	const struct lttng_action_start_session *action_start_session;
	365	enum lttng_action_status status;
	366
	367	if (!action \|\| !IS_START_SESSION_ACTION(action) \|\| !session_name) {
	368	status = LTTNG_ACTION_STATUS_INVALID;
	369	goto end;
	370	}
	371
	372	action_start_session = action_start_session_from_action_const(action);
	373
	374	*session_name = action_start_session->session_name;
	375
	376	status = LTTNG_ACTION_STATUS_OK;
	377	end:
	378	return status;
	379	}
1345b16b	380
7f4d5b07	381	enum lttng_action_status lttng_action_start_session_set_rate_policy(
1345b16b	382	struct lttng_action *action,
7f4d5b07	383	const struct lttng_rate_policy *policy)
1345b16b JR	384	{
	385	enum lttng_action_status status;
	386	struct lttng_action_start_session *start_session_action;
7f4d5b07	387	struct lttng_rate_policy *copy = NULL;
1345b16b JR	388
	389	if (!action \|\| !policy \|\| !IS_START_SESSION_ACTION(action)) {
	390	status = LTTNG_ACTION_STATUS_INVALID;
	391	goto end;
	392	}
	393
7f4d5b07	394	copy = lttng_rate_policy_copy(policy);
1345b16b JR	395	if (!copy) {
	396	status = LTTNG_ACTION_STATUS_ERROR;
	397	goto end;
	398	}
	399
	400	start_session_action = action_start_session_from_action(action);
	401
7f4d5b07 JR	402	/* Release the previous rate policy .*/
7f4d5b07 JR	403	lttng_rate_policy_destroy(start_session_action->policy);
1345b16b JR	404
	405	/* Assign the policy. */
	406	start_session_action->policy = copy;
	407	status = LTTNG_ACTION_STATUS_OK;
	408	copy = NULL;
	409
	410	end:
7f4d5b07	411	lttng_rate_policy_destroy(copy);
1345b16b JR	412	return status;
	413	}
	414
7f4d5b07	415	enum lttng_action_status lttng_action_start_session_get_rate_policy(
1345b16b	416	const struct lttng_action *action,
7f4d5b07	417	const struct lttng_rate_policy **policy)
1345b16b JR	418	{
	419	enum lttng_action_status status;
	420	const struct lttng_action_start_session *start_session_action;
	421
	422	if (!action \|\| !policy \|\| !IS_START_SESSION_ACTION(action)) {
	423	status = LTTNG_ACTION_STATUS_INVALID;
	424	goto end;
	425	}
	426
	427	start_session_action = action_start_session_from_action_const(action);
	428
	429	*policy = start_session_action->policy;
	430	status = LTTNG_ACTION_STATUS_OK;
	431	end:
	432	return status;
	433	}
2d57482c	434
7f4d5b07 JR	435	static const struct lttng_rate_policy *
7f4d5b07 JR	436	lttng_action_start_session_internal_get_rate_policy(
2d57482c JR	437	const struct lttng_action *action)
	438	{
	439	const struct lttng_action_start_session *_action;
	440	_action = action_start_session_from_action_const(action);
	441
	442	return _action->policy;
	443	}