X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=tests%2Funit%2Ftest_action.cpp;h=ad323e9acc169592c68de995f4344fe6d6e0e997;hp=c54b0278dbc4d92b9570160bda86384b954e5248;hb=HEAD;hpb=cd9adb8b829564212158943a0d279bb35322ab30

diff --git a/tests/unit/test_action.cpp b/tests/unit/test_action.cpp
index c54b0278d..52f6d26ca 100644
--- a/tests/unit/test_action.cpp
+++ b/tests/unit/test_action.cpp
@@ -9,11 +9,13 @@
  *
  */
 
+#include <common/error.hpp>
 #include <common/payload-view.hpp>
 #include <common/payload.hpp>
 
 #include <lttng/action/action-internal.hpp>
 #include <lttng/action/action.h>
+#include <lttng/action/list-internal.hpp>
 #include <lttng/action/notify.h>
 #include <lttng/action/rate-policy-internal.hpp>
 #include <lttng/action/rate-policy.h>
@@ -33,7 +35,7 @@ int lttng_opt_quiet = 1;
 int lttng_opt_verbose;
 int lttng_opt_mi;
 
-#define NUM_TESTS 60
+#define NUM_TESTS 71
 
 static void test_action_notify()
 {
@@ -98,7 +100,93 @@ static void test_action_notify()
 	lttng_payload_reset(&payload);
 }
 
-static void test_action_rotate_session()
+static void test_action_list(void)
+{
+	int ret, action_idx;
+	struct lttng_action *list_action = NULL, *list_action_from_buffer = NULL,
+			    *stop_session_action = NULL, *notify_action = NULL,
+			    *start_session_action = NULL;
+	struct lttng_payload payload;
+
+	lttng_payload_init(&payload);
+
+	list_action = lttng_action_list_create();
+	ok(list_action, "Create list action");
+	ok(lttng_action_get_type(list_action) == LTTNG_ACTION_TYPE_LIST,
+	   "Action has type LTTNG_ACTION_TYPE_LIST");
+
+	start_session_action = lttng_action_start_session_create();
+	(void) lttng_action_start_session_set_session_name(start_session_action, "une-session");
+
+	stop_session_action = lttng_action_stop_session_create();
+	(void) lttng_action_stop_session_set_session_name(stop_session_action, "une-autre-session");
+	notify_action = lttng_action_notify_create();
+
+	lttng_action_list_add_action(list_action, start_session_action);
+	lttng_action_list_add_action(list_action, stop_session_action);
+	lttng_action_list_add_action(list_action, notify_action);
+
+	ret = lttng_action_serialize(list_action, &payload);
+	ok(ret == 0, "Action list serialized");
+
+	{
+		struct lttng_payload_view view = lttng_payload_view_from_payload(&payload, 0, -1);
+		(void) lttng_action_create_from_payload(&view, &list_action_from_buffer);
+	}
+	ok(list_action_from_buffer, "Notify action created from payload is non-null");
+
+	ok(lttng_action_is_equal(list_action, list_action_from_buffer),
+	   "Serialized and de-serialized list action are equal");
+
+	action_idx = 0;
+	for (auto action : lttng::ctl::const_action_list_view(list_action)) {
+		enum lttng_action_type inner_action_type = lttng_action_get_type(action);
+		switch (action_idx) {
+		case 0:
+			ok(inner_action_type == LTTNG_ACTION_TYPE_START_SESSION,
+			   "First inner action of action list is `start-session` action");
+			break;
+		case 1:
+			ok(inner_action_type == LTTNG_ACTION_TYPE_STOP_SESSION,
+			   "Second inner action of action list is `stop-session` action");
+			break;
+		case 2:
+			ok(inner_action_type == LTTNG_ACTION_TYPE_NOTIFY,
+			   "Third inner action of action list is `notify` action");
+			break;
+		}
+		action_idx++;
+	}
+
+	action_idx = 0;
+	for (auto action : lttng::ctl::action_list_view(list_action)) {
+		enum lttng_action_type inner_action_type = lttng_action_get_type(action);
+		switch (action_idx) {
+		case 0:
+			ok(inner_action_type == LTTNG_ACTION_TYPE_START_SESSION,
+			   "First inner action of action list is `start-session` action");
+			break;
+		case 1:
+			ok(inner_action_type == LTTNG_ACTION_TYPE_STOP_SESSION,
+			   "Second inner action of action list is `stop-session` action");
+			break;
+		case 2:
+			ok(inner_action_type == LTTNG_ACTION_TYPE_NOTIFY,
+			   "Third inner action of action list is `notify` action");
+			break;
+		}
+		action_idx++;
+	}
+
+	lttng_action_destroy(list_action);
+	lttng_action_destroy(list_action_from_buffer);
+	lttng_action_destroy(start_session_action);
+	lttng_action_destroy(stop_session_action);
+	lttng_action_destroy(notify_action);
+	lttng_payload_reset(&payload);
+}
+
+static void test_action_rotate_session(void)
 {
 	int ret;
 	enum lttng_action_status status;
@@ -454,13 +542,24 @@ static void test_action_snapshot_session()
 	lttng_payload_reset(&payload);
 }
 
-int main()
+static int _main()
 {
 	plan_tests(NUM_TESTS);
 	test_action_notify();
+	test_action_list();
 	test_action_rotate_session();
 	test_action_start_session();
 	test_action_stop_session();
 	test_action_snapshot_session();
 	return exit_status();
 }
+
+int main()
+{
+	try {
+		return _main();
+	} catch (const std::exception& e) {
+		ERR_FMT("Unhandled exception caught by action unit test: {}", e.what());
+		abort();
+	}
+}