[lttng-tools.git] / tests / regression / tools / notification / base_client.c

/*
 * base_client.c
 *
 * Base client application for testing of LTTng notification API
 *
 * Copyright 2017 Jonathan Rajotte <jonathan.rajotte-julien@efficios.com>
 *
 * SPDX-License-Identifier: MIT
 *
 */

#include <stdio.h>
#include <stdbool.h>
#include <string.h>
#include <unistd.h>
#include <inttypes.h>
#include <assert.h>

#include <lttng/action/action.h>
#include <lttng/action/notify.h>
#include <lttng/condition/buffer-usage.h>
#include <lttng/condition/condition.h>
#include <lttng/condition/evaluation.h>
#include <lttng/domain.h>
#include <lttng/endpoint.h>
#include <lttng/notification/channel.h>
#include <lttng/notification/notification.h>
#include <lttng/trigger/trigger.h>
#include <lttng/lttng-error.h>

static unsigned int nr_notifications = 0;
static unsigned int nr_expected_notifications = 0;
static const char *session_name = NULL;
static const char *channel_name = NULL;
static double threshold_ratio = 0.0;
static uint64_t threshold_bytes = 0;
static bool is_threshold_ratio = false;
static enum lttng_condition_type buffer_usage_type = LTTNG_CONDITION_TYPE_UNKNOWN;
static enum lttng_domain_type domain_type = LTTNG_DOMAIN_NONE;

int handle_condition(
		const struct lttng_condition *condition,
		const struct lttng_evaluation *condition_evaluation);

static
int parse_arguments(char **argv)
{
	const char *domain_type_string = NULL;
	const char *buffer_usage_type_string = NULL;
	const char *buffer_usage_threshold_type = NULL;
	const char *buffer_usage_threshold_value = NULL;
	const char *nr_expected_notifications_string = NULL;

	session_name = argv[1];
	channel_name = argv[2];
	domain_type_string = argv[3];
	buffer_usage_type_string = argv[4];
	buffer_usage_threshold_type = argv[5];
	buffer_usage_threshold_value = argv[6];
	nr_expected_notifications_string = argv[7];

	/* Parse arguments */
	/* Domain type */
	if (!strcasecmp("LTTNG_DOMAIN_UST", domain_type_string)) {
		domain_type = LTTNG_DOMAIN_UST;
	}
	if (!strcasecmp("LTTNG_DOMAIN_KERNEL", domain_type_string)) {
		domain_type = LTTNG_DOMAIN_KERNEL;
	}
	if (domain_type == LTTNG_DOMAIN_NONE) {
		printf("error: Unknown domain type\n");
		goto error;
	}

	/* Buffer usage condition type */
	if (!strcasecmp("low", buffer_usage_type_string)) {
		buffer_usage_type = LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW;
	}
	if (!strcasecmp("high", buffer_usage_type_string)) {
		buffer_usage_type = LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH;
	}
	if (buffer_usage_type == LTTNG_CONDITION_TYPE_UNKNOWN) {
		printf("error: Unknown condition type\n");
		goto error;
	}

	/* Ratio or bytes ? */
	if (!strcasecmp("bytes", buffer_usage_threshold_type)) {
		is_threshold_ratio = false;
		sscanf(buffer_usage_threshold_value, "%" SCNu64, &threshold_bytes);
	}

	if (!strcasecmp("ratio", buffer_usage_threshold_type)) {
		is_threshold_ratio = true;
		sscanf(buffer_usage_threshold_value, "%lf", &threshold_ratio);
	}

	/* Number of notification to expect */
	sscanf(nr_expected_notifications_string, "%d", &nr_expected_notifications);

	return 0;
error:
	return 1;
}

int main(int argc, char **argv)
{
	int ret = 0;
	enum lttng_condition_status condition_status;
	enum lttng_notification_channel_status nc_status;
	struct lttng_notification_channel *notification_channel = NULL;
	struct lttng_condition *condition = NULL;
	struct lttng_action *action = NULL;
	struct lttng_trigger *trigger = NULL;

	/*
	 * Disable buffering on stdout.
	 * Safety measure to prevent hang on the validation side since
	 * stdout is used for outside synchronization.
	 */
	setbuf(stdout, NULL);

	if (argc < 8) {
		printf("error: Missing arguments for tests\n");
		ret = 1;
		goto end;
	}

	ret = parse_arguments(argv);
	if (ret) {
		printf("error: Could not parse arguments\n");
		goto end;
	}

	/* Setup */
	notification_channel = lttng_notification_channel_create(
			lttng_session_daemon_notification_endpoint);
	if (!notification_channel) {
		printf("error: Could not create notification channel\n");
		ret = 1;
		goto end;
	}

	switch (buffer_usage_type) {
	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
		condition = lttng_condition_buffer_usage_low_create();
		break;
	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
		condition = lttng_condition_buffer_usage_high_create();
		break;
	default:
		printf("error: Invalid buffer_usage_type\n");
		ret = 1;
		goto end;
	}

	if (!condition) {
		printf("error: Could not create condition object\n");
		ret = 1;
		goto end;
	}

	if (is_threshold_ratio) {
		condition_status = lttng_condition_buffer_usage_set_threshold_ratio(
				condition, threshold_ratio);
	} else {
		condition_status = lttng_condition_buffer_usage_set_threshold(
				condition, threshold_bytes);
	}

	if (condition_status != LTTNG_CONDITION_STATUS_OK) {
		printf("error: Could not set threshold\n");
		ret = 1;
		goto end;
	}

	condition_status = lttng_condition_buffer_usage_set_session_name(
			condition, session_name);
	if (condition_status != LTTNG_CONDITION_STATUS_OK) {
		printf("error: Could not set session name\n");
		ret = 1;
		goto end;
	}
	condition_status = lttng_condition_buffer_usage_set_channel_name(
			condition, channel_name);
	if (condition_status != LTTNG_CONDITION_STATUS_OK) {
		printf("error: Could not set channel name\n");
		ret = 1;
		goto end;
	}
	condition_status = lttng_condition_buffer_usage_set_domain_type(
			condition, domain_type);
	if (condition_status != LTTNG_CONDITION_STATUS_OK) {
		printf("error: Could not set domain type\n");
		ret = 1;
		goto end;
	}

	action = lttng_action_notify_create();
	if (!action) {
		printf("error: Could not create action notify\n");
		ret = 1;
		goto end;
	}

	trigger = lttng_trigger_create(condition, action);
	if (!trigger) {
		printf("error: Could not create trigger\n");
		ret = 1;
		goto end;
	}

	ret = lttng_register_trigger(trigger);

	/*
	 * An equivalent trigger might already be registered if an other app
	 * registered an equivalent trigger.
	 */
	if (ret < 0 && ret != -LTTNG_ERR_TRIGGER_EXISTS) {
		printf("error: %s\n", lttng_strerror(ret));
		ret = 1;
		goto end;
	}

	nc_status = lttng_notification_channel_subscribe(notification_channel, condition);
	if (nc_status != LTTNG_NOTIFICATION_CHANNEL_STATUS_OK) {
		printf("error: Could not subscribe\n");
		ret = 1;
		goto end;
	}

	/* Tell outside process that the client is ready */
	printf("sync: ready\n");

	for (;;) {
		struct lttng_notification *notification;
		enum lttng_notification_channel_status status;
		const struct lttng_evaluation *notification_evaluation;
		const struct lttng_condition *notification_condition;

		if (nr_notifications == nr_expected_notifications) {
			ret = 0;
			goto end;
		}
		/* Receive the next notification. */
		status = lttng_notification_channel_get_next_notification(
				notification_channel,
				&notification);

		switch (status) {
		case LTTNG_NOTIFICATION_CHANNEL_STATUS_OK:
			break;
		case LTTNG_NOTIFICATION_CHANNEL_STATUS_NOTIFICATIONS_DROPPED:
			ret = 1;
			printf("error: No drop should be observed during this test app\n");
			goto end;
		case LTTNG_NOTIFICATION_CHANNEL_STATUS_CLOSED:
			/*
			 * The notification channel has been closed by the
			 * session daemon. This is typically caused by a session
			 * daemon shutting down (cleanly or because of a crash).
			 */
			printf("error: Notification channel was closed\n");
			ret = 1;
			goto end;
		default:
			/* Unhandled conditions / errors. */
			printf("error: Unknown notification channel status\n");
			ret = 1;
			goto end;
		}

		notification_condition = lttng_notification_get_condition(notification);
		notification_evaluation = lttng_notification_get_evaluation(notification);

		ret = handle_condition(notification_condition, notification_evaluation);
		nr_notifications++;

		lttng_notification_destroy(notification);
		if (ret != 0) {
			goto end;
		}
	}
end:
	if (trigger) {
		lttng_unregister_trigger(trigger);
	}
	if (lttng_notification_channel_unsubscribe(notification_channel, condition)) {
		printf("error: channel unsubscribe error\n");
	}
	lttng_trigger_destroy(trigger);
	lttng_condition_destroy(condition);
	lttng_action_destroy(action);
	lttng_notification_channel_destroy(notification_channel);
	printf("exit: %d\n", ret);
	return ret;
}

int handle_condition(
		const struct lttng_condition *condition,
		const struct lttng_evaluation *evaluation)
{
	int ret = 0;
	const char *string_low = "low";
	const char *string_high = "high";
	const char *string_condition_type = NULL;
	const char *condition_session_name = NULL;
	const char *condition_channel_name = NULL;
	enum lttng_condition_type condition_type;
	enum lttng_domain_type condition_domain_type;
	double buffer_usage_ratio;
	uint64_t buffer_usage_bytes;

	condition_type = lttng_condition_get_type(condition);

	if (condition_type != buffer_usage_type) {
		ret = 1;
		printf("error: condition type and buffer usage type are not the same\n");
		goto end;
	}

	/* Fetch info to test */
	ret = lttng_condition_buffer_usage_get_session_name(condition,
			&condition_session_name);
	if (ret) {
		printf("error: session name could not be fetched\n");
		ret = 1;
		goto end;
	}
	ret = lttng_condition_buffer_usage_get_channel_name(condition,
			&condition_channel_name);
	if (ret) {
		printf("error: channel name could not be fetched\n");
		ret = 1;
		goto end;
	}
	ret = lttng_condition_buffer_usage_get_domain_type(condition,
			&condition_domain_type);
	if (ret) {
		printf("error: domain type could not be fetched\n");
		ret = 1;
		goto end;
	}

	if (strcmp(condition_session_name, session_name) != 0) {
		printf("error: session name differs\n");
		ret = 1;
		goto end;
	}

	if (strcmp(condition_channel_name, channel_name) != 0) {
		printf("error: channel name differs\n");
		ret = 1;
		goto end;
	}

	if (condition_domain_type != domain_type) {
		printf("error: domain type differs\n");
		ret = 1;
		goto end;
	}

	if (is_threshold_ratio) {
		lttng_evaluation_buffer_usage_get_usage_ratio(
				evaluation, &buffer_usage_ratio);
		switch (condition_type) {
		case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
			if (buffer_usage_ratio > threshold_ratio) {
				printf("error: buffer usage ratio is bigger than set threshold ratio\n");
				ret = 1;
				goto end;
			}
			break;
		case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
			if (buffer_usage_ratio < threshold_ratio) {
				printf("error: buffer usage ratio is lower than set threshold ratio\n");
				ret = 1;
				goto end;
			}
			break;
		default:
			printf("error: Unknown condition type\n");
			ret = 1;
			goto end;
		}
	} else {
		lttng_evaluation_buffer_usage_get_usage(
				evaluation, &buffer_usage_bytes);
		switch (condition_type) {
		case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
			if (buffer_usage_bytes > threshold_bytes) {
				printf("error: buffer usage ratio is bigger than set threshold bytes\n");
				ret = 1;
				goto end;
			}
			break;
		case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
			if (buffer_usage_bytes < threshold_bytes) {
				printf("error: buffer usage ratio is lower than set threshold bytes\n");
				ret = 1;
				goto end;
			}
			break;
		default:
			printf("error: Unknown condition type\n");
			ret = 1;
			goto end;
		}
	}

	switch (condition_type) {
	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
		string_condition_type = string_low;
		break;
	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
		string_condition_type = string_high;
		break;
	default:
		printf("error: Unknown condition type\n");
		ret = 1;
		goto end;
	}

	printf("notification: %s %d\n", string_condition_type, nr_notifications);
end:
	return ret;
}
Commit	Line	Data
434f8068 JR	1	/*
	2	* base_client.c
	3	*
	4	* Base client application for testing of LTTng notification API
	5	*
	6	* Copyright 2017 Jonathan Rajotte <jonathan.rajotte-julien@efficios.com>
	7	*
9d16b343	8	* SPDX-License-Identifier: MIT
434f8068	9	*
434f8068 JR	10	*/
	11
	12	#include <stdio.h>
	13	#include <stdbool.h>
	14	#include <string.h>
	15	#include <unistd.h>
	16	#include <inttypes.h>
	17	#include <assert.h>
	18
	19	#include <lttng/action/action.h>
	20	#include <lttng/action/notify.h>
	21	#include <lttng/condition/buffer-usage.h>
	22	#include <lttng/condition/condition.h>
	23	#include <lttng/condition/evaluation.h>
	24	#include <lttng/domain.h>
	25	#include <lttng/endpoint.h>
	26	#include <lttng/notification/channel.h>
	27	#include <lttng/notification/notification.h>
	28	#include <lttng/trigger/trigger.h>
25040abc	29	#include <lttng/lttng-error.h>
434f8068 JR	30
	31	static unsigned int nr_notifications = 0;
	32	static unsigned int nr_expected_notifications = 0;
	33	static const char *session_name = NULL;
	34	static const char *channel_name = NULL;
	35	static double threshold_ratio = 0.0;
	36	static uint64_t threshold_bytes = 0;
	37	static bool is_threshold_ratio = false;
	38	static enum lttng_condition_type buffer_usage_type = LTTNG_CONDITION_TYPE_UNKNOWN;
	39	static enum lttng_domain_type domain_type = LTTNG_DOMAIN_NONE;
	40
	41	int handle_condition(
	42	const struct lttng_condition *condition,
	43	const struct lttng_evaluation *condition_evaluation);
	44
53089c7c SM	45	static
	46	int parse_arguments(char **argv)
	47	{
434f8068 JR	48	const char *domain_type_string = NULL;
	49	const char *buffer_usage_type_string = NULL;
	50	const char *buffer_usage_threshold_type = NULL;
	51	const char *buffer_usage_threshold_value = NULL;
	52	const char *nr_expected_notifications_string = NULL;
	53
	54	session_name = argv[1];
	55	channel_name = argv[2];
	56	domain_type_string = argv[3];
	57	buffer_usage_type_string = argv[4];
	58	buffer_usage_threshold_type = argv[5];
	59	buffer_usage_threshold_value = argv[6];
	60	nr_expected_notifications_string = argv[7];
	61
	62	/* Parse arguments */
	63	/* Domain type */
	64	if (!strcasecmp("LTTNG_DOMAIN_UST", domain_type_string)) {
	65	domain_type = LTTNG_DOMAIN_UST;
	66	}
	67	if (!strcasecmp("LTTNG_DOMAIN_KERNEL", domain_type_string)) {
	68	domain_type = LTTNG_DOMAIN_KERNEL;
	69	}
	70	if (domain_type == LTTNG_DOMAIN_NONE) {
	71	printf("error: Unknown domain type\n");
	72	goto error;
	73	}
	74
	75	/* Buffer usage condition type */
	76	if (!strcasecmp("low", buffer_usage_type_string)) {
	77	buffer_usage_type = LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW;
	78	}
	79	if (!strcasecmp("high", buffer_usage_type_string)) {
	80	buffer_usage_type = LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH;
	81	}
	82	if (buffer_usage_type == LTTNG_CONDITION_TYPE_UNKNOWN) {
	83	printf("error: Unknown condition type\n");
	84	goto error;
	85	}
	86
	87	/* Ratio or bytes ? */
	88	if (!strcasecmp("bytes", buffer_usage_threshold_type)) {
	89	is_threshold_ratio = false;
	90	sscanf(buffer_usage_threshold_value, "%" SCNu64, &threshold_bytes);
	91	}
	92
	93	if (!strcasecmp("ratio", buffer_usage_threshold_type)) {
	94	is_threshold_ratio = true;
	95	sscanf(buffer_usage_threshold_value, "%lf", &threshold_ratio);
	96	}
	97
	98	/* Number of notification to expect */
	99	sscanf(nr_expected_notifications_string, "%d", &nr_expected_notifications);
	100
	101	return 0;
	102	error:
	103	return 1;
	104	}
	105
	106	int main(int argc, char **argv)
	107	{
	108	int ret = 0;
	109	enum lttng_condition_status condition_status;
	110	enum lttng_notification_channel_status nc_status;
	111	struct lttng_notification_channel *notification_channel = NULL;
112	struct lttng_condition *condition = NULL;
113	struct lttng_action *action = NULL;
114	struct lttng_trigger *trigger = NULL;
115
116	/*
117	* Disable buffering on stdout.
118	* Safety measure to prevent hang on the validation side since
119	* stdout is used for outside synchronization.
120	*/
121	setbuf(stdout, NULL);
122
123	if (argc < 8) {
124	printf("error: Missing arguments for tests\n");
125	ret = 1;
126	goto end;
127	}
128
129	ret = parse_arguments(argv);
130	if (ret) {
131	printf("error: Could not parse arguments\n");
132	goto end;
133	}
134
135	/* Setup */
136	notification_channel = lttng_notification_channel_create(
137	lttng_session_daemon_notification_endpoint);
138	if (!notification_channel) {
139	printf("error: Could not create notification channel\n");
140	ret = 1;
141	goto end;
142	}
143
144	switch (buffer_usage_type) {
145	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
146	condition = lttng_condition_buffer_usage_low_create();
147	break;
148	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
149	condition = lttng_condition_buffer_usage_high_create();
150	break;
151	default:
152	printf("error: Invalid buffer_usage_type\n");
153	ret = 1;
154	goto end;
155	}
156
157	if (!condition) {
158	printf("error: Could not create condition object\n");
159	ret = 1;
160	goto end;
161	}
162
163	if (is_threshold_ratio) {
164	condition_status = lttng_condition_buffer_usage_set_threshold_ratio(
165	condition, threshold_ratio);
166	} else {
167	condition_status = lttng_condition_buffer_usage_set_threshold(
168	condition, threshold_bytes);
169	}
170
171	if (condition_status != LTTNG_CONDITION_STATUS_OK) {
172	printf("error: Could not set threshold\n");
173	ret = 1;
174	goto end;
175	}
176
177	condition_status = lttng_condition_buffer_usage_set_session_name(
178	condition, session_name);
179	if (condition_status != LTTNG_CONDITION_STATUS_OK) {
180	printf("error: Could not set session name\n");
181	ret = 1;
182	goto end;
183	}
184	condition_status = lttng_condition_buffer_usage_set_channel_name(
185	condition, channel_name);
186	if (condition_status != LTTNG_CONDITION_STATUS_OK) {
187	printf("error: Could not set channel name\n");
188	ret = 1;
189	goto end;
190	}
191	condition_status = lttng_condition_buffer_usage_set_domain_type(
854382b8	192	condition, domain_type);
434f8068 JR	193	if (condition_status != LTTNG_CONDITION_STATUS_OK) {
	194	printf("error: Could not set domain type\n");
	195	ret = 1;
	196	goto end;
	197	}
	198
	199	action = lttng_action_notify_create();
	200	if (!action) {
	201	printf("error: Could not create action notify\n");
	202	ret = 1;
	203	goto end;
	204	}
	205
	206	trigger = lttng_trigger_create(condition, action);
	207	if (!trigger) {
	208	printf("error: Could not create trigger\n");
	209	ret = 1;
	210	goto end;
	211	}
	212
	213	ret = lttng_register_trigger(trigger);
	214
	215	/*
	216	* An equivalent trigger might already be registered if an other app
	217	* registered an equivalent trigger.
	218	*/
	219	if (ret < 0 && ret != -LTTNG_ERR_TRIGGER_EXISTS) {
	220	printf("error: %s\n", lttng_strerror(ret));
	221	ret = 1;
	222	goto end;
	223	}
	224
	225	nc_status = lttng_notification_channel_subscribe(notification_channel, condition);
	226	if (nc_status != LTTNG_NOTIFICATION_CHANNEL_STATUS_OK) {
	227	printf("error: Could not subscribe\n");
	228	ret = 1;
	229	goto end;
	230	}
	231
	232	/* Tell outside process that the client is ready */
	233	printf("sync: ready\n");
	234
	235	for (;;) {
	236	struct lttng_notification *notification;
	237	enum lttng_notification_channel_status status;
	238	const struct lttng_evaluation *notification_evaluation;
	239	const struct lttng_condition *notification_condition;
	240
	241	if (nr_notifications == nr_expected_notifications) {
	242	ret = 0;
	243	goto end;
	244	}
	245	/* Receive the next notification. */
	246	status = lttng_notification_channel_get_next_notification(
	247	notification_channel,
	248	&notification);
	249
	250	switch (status) {
	251	case LTTNG_NOTIFICATION_CHANNEL_STATUS_OK:
	252	break;
	253	case LTTNG_NOTIFICATION_CHANNEL_STATUS_NOTIFICATIONS_DROPPED:
	254	ret = 1;
	255	printf("error: No drop should be observed during this test app\n");
	256	goto end;
257	case LTTNG_NOTIFICATION_CHANNEL_STATUS_CLOSED:
258	/*
259	* The notification channel has been closed by the
260	* session daemon. This is typically caused by a session
261	* daemon shutting down (cleanly or because of a crash).
262	*/
263	printf("error: Notification channel was closed\n");
264	ret = 1;
265	goto end;
266	default:
267	/* Unhandled conditions / errors. */
268	printf("error: Unknown notification channel status\n");
269	ret = 1;
270	goto end;
271	}
272
273	notification_condition = lttng_notification_get_condition(notification);
274	notification_evaluation = lttng_notification_get_evaluation(notification);
275
276	ret = handle_condition(notification_condition, notification_evaluation);
277	nr_notifications++;
278
279	lttng_notification_destroy(notification);
280	if (ret != 0) {
281	goto end;
282	}
283	}
284	end:
285	if (trigger) {
286	lttng_unregister_trigger(trigger);
287	}
eff748d0 JR	288	if (lttng_notification_channel_unsubscribe(notification_channel, condition)) {
	289	printf("error: channel unsubscribe error\n");
	290	}
434f8068 JR	291	lttng_trigger_destroy(trigger);
	292	lttng_condition_destroy(condition);
	293	lttng_action_destroy(action);
	294	lttng_notification_channel_destroy(notification_channel);
	295	printf("exit: %d\n", ret);
	296	return ret;
	297	}
	298
	299	int handle_condition(
	300	const struct lttng_condition *condition,
	301	const struct lttng_evaluation *evaluation)
	302	{
	303	int ret = 0;
	304	const char *string_low = "low";
	305	const char *string_high = "high";
	306	const char *string_condition_type = NULL;
	307	const char *condition_session_name = NULL;
	308	const char *condition_channel_name = NULL;
	309	enum lttng_condition_type condition_type;
	310	enum lttng_domain_type condition_domain_type;
	311	double buffer_usage_ratio;
	312	uint64_t buffer_usage_bytes;
	313
	314	condition_type = lttng_condition_get_type(condition);
	315
	316	if (condition_type != buffer_usage_type) {
	317	ret = 1;
	318	printf("error: condition type and buffer usage type are not the same\n");
	319	goto end;
	320	}
	321
	322	/* Fetch info to test */
eff748d0	323	ret = lttng_condition_buffer_usage_get_session_name(condition,
434f8068	324	&condition_session_name);
eff748d0 JR	325	if (ret) {
	326	printf("error: session name could not be fetched\n");
	327	ret = 1;
	328	goto end;
	329	}
	330	ret = lttng_condition_buffer_usage_get_channel_name(condition,
434f8068	331	&condition_channel_name);
eff748d0 JR	332	if (ret) {
	333	printf("error: channel name could not be fetched\n");
	334	ret = 1;
	335	goto end;
	336	}
	337	ret = lttng_condition_buffer_usage_get_domain_type(condition,
434f8068	338	&condition_domain_type);
eff748d0 JR	339	if (ret) {
	340	printf("error: domain type could not be fetched\n");
	341	ret = 1;
	342	goto end;
	343	}
434f8068 JR	344
	345	if (strcmp(condition_session_name, session_name) != 0) {
	346	printf("error: session name differs\n");
	347	ret = 1;
	348	goto end;
	349	}
	350
	351	if (strcmp(condition_channel_name, channel_name) != 0) {
	352	printf("error: channel name differs\n");
	353	ret = 1;
	354	goto end;
	355	}
	356
	357	if (condition_domain_type != domain_type) {
	358	printf("error: domain type differs\n");
	359	ret = 1;
	360	goto end;
	361	}
	362
	363	if (is_threshold_ratio) {
	364	lttng_evaluation_buffer_usage_get_usage_ratio(
	365	evaluation, &buffer_usage_ratio);
	366	switch (condition_type) {
	367	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
	368	if (buffer_usage_ratio > threshold_ratio) {
	369	printf("error: buffer usage ratio is bigger than set threshold ratio\n");
	370	ret = 1;
	371	goto end;
	372	}
	373	break;
	374	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
	375	if (buffer_usage_ratio < threshold_ratio) {
	376	printf("error: buffer usage ratio is lower than set threshold ratio\n");
	377	ret = 1;
	378	goto end;
	379	}
	380	break;
	381	default:
	382	printf("error: Unknown condition type\n");
	383	ret = 1;
	384	goto end;
	385	}
	386	} else {
	387	lttng_evaluation_buffer_usage_get_usage(
	388	evaluation, &buffer_usage_bytes);
	389	switch (condition_type) {
	390	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
	391	if (buffer_usage_bytes > threshold_bytes) {
	392	printf("error: buffer usage ratio is bigger than set threshold bytes\n");
	393	ret = 1;
	394	goto end;
	395	}
	396	break;
	397	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
	398	if (buffer_usage_bytes < threshold_bytes) {
	399	printf("error: buffer usage ratio is lower than set threshold bytes\n");
	400	ret = 1;
	401	goto end;
	402	}
	403	break;
	404	default:
	405	printf("error: Unknown condition type\n");
	406	ret = 1;
	407	goto end;
408	}
409	}
410
411	switch (condition_type) {
412	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_LOW:
413	string_condition_type = string_low;
414	break;
415	case LTTNG_CONDITION_TYPE_BUFFER_USAGE_HIGH:
416	string_condition_type = string_high;
417	break;
418	default:
419	printf("error: Unknown condition type\n");
420	ret = 1;
421	goto end;
422	}
423
424	printf("notification: %s %d\n", string_condition_type, nr_notifications);
425	end:
426	return ret;
427	}