--- /dev/null
+/*
+ * Copyright (c) - 2019 Jonathan Rajotte-Julien
+ * <jonathan.rajotte-julien@efficios.com>
+ *
+ * This program is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU General Public License as published by as
+ * published by the Free Software Foundation; only version 2 of the License.
+ *
+ * This program is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
+ * more details.
+ *
+ * You should have received a copy of the GNU General Public License along with
+ * this program; if not, write to the Free Software Foundation, Inc., 51
+ * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ */
+
+#include <assert.h>
+#include <stdbool.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <tap/tap.h>
+
+#include "backward-compatibility-group-by.h"
+
+/* Number of TAP tests in this file */
+#define NUM_TESTS_PER_TEST 1
+
+struct test {
+ char *stream_path;
+ char *session_name;
+ char *hostname;
+ char *creation_time;
+ char *extra_path;
+ char *leftover;
+ bool is_valid;
+};
+
+int lttng_opt_quiet;
+int lttng_opt_mi;
+int lttng_opt_verbose;
+
+struct test tests[] = {
+ /* Default name session streaming. */
+ {"hostname/auto-20190918-164429/ust/uid/1000/64-bit",
+ "auto-20190918-164429", "hostname",
+ "20190918-164429", "", "ust/uid/1000/64-bit",
+ true},
+ /* Custom default name session */
+ {"hostname/custom_auto-20190319-120000/ust/uid/1000/64-bit",
+ "custom_auto-20190319-120000", "hostname",
+ "20190319-120000", "", "ust/uid/1000/64-bit",
+ true},
+ /* Named session streaming */
+ {"hostname/test-20190918-164709/ust/uid/1000/64-bit", "test",
+ "hostname", "20190918-164709", "",
+ "ust/uid/1000/64-bit", true},
+ /* Default session snapshot streaming */
+ {"hostname//snapshot-1-20190918-164829-0/ust//uid/1000/64-bit",
+ "my_session", "hostname", "", "",
+ "snapshot-1-20190918-164829-0/ust//uid/1000/64-bit",
+ true},
+ /* Named session snapshot streaming */
+ {"hostname//snapshot-1-20190918-175919-0/ust//uid/1000/64-bit",
+ "my_session", "hostname", "", "",
+ "snapshot-1-20190918-175919-0/ust//uid/1000/64-bit",
+ true},
+ /* Default name session, live */
+ {"hostname//auto-20190918-171641/ust/uid/1000/64-bit",
+ "auto-20190918-171641", "hostname",
+ "20190918-171641", "", "ust/uid/1000/64-bit",
+ true},
+ /* Named session, live */
+ {"hostname//test-20190918-180333//ust/uid/1000/64-bit",
+ "test-20190918-180333", "hostname",
+ "20190918-180333", "", "/ust/uid/1000/64-bit",
+ true},
+ /* Default name session, streaming & live , extra path */
+ {"hostname/extra/path/ust/uid/1000/64-bit",
+ "auto-20190919-122110", "hostname",
+ "20190919-122110", "extra",
+ "path/ust/uid/1000/64-bit", true},
+ /* Named session, live, extra path */
+ {"hostname/extra/path/ust/uid/1000/64-bit", "test", "hostname",
+ "", "extra", "path/ust/uid/1000/64-bit", true},
+ /* Named session, snapshot, extra path */
+ {"hostname/extra/path/snapshot-1-20190919-140702-0/ust//uid/1000/64-bit",
+ "test", "hostname", "", "extra",
+ "path/snapshot-1-20190919-140702-0/ust//uid/1000/64-bit",
+ true},
+ /* Corner cases*/
+ /* Named session with valid datetime in it */
+ /* Default name session, extra path with session name in it*/
+ {"hostname/test-20190319-120000-20190918-180921/ust/uid/1000/64-bit",
+ "test-20190319-120000", "hostname",
+ "20190918-180921", "", "ust/uid/1000/64-bit",
+ true},
+ /* Empty path */
+ {"", "test", "", "", "", "", false},
+ /* Path without second token */
+ {"hostname", "test", "hostname", "", "", "", false},
+ /* No leftover */
+ {"hostname/test", "test", "hostname", "", "", "", true},
+ /* Path with ession name but no datetime */
+ {"hostname/test/ust/uid/1000/64-bit", "test", "hostname", "",
+ "", "ust/uid/1000/64-bit", true},
+};
+
+static char *craft_expected(struct test *test)
+{
+ int ret;
+ char *result = NULL;
+
+ ret = asprintf(&result, "%s/%s%s%s/%s%s%s", test->session_name,
+ test->hostname,
+ test->creation_time[0] != '\0' ? "-" : "",
+ test->creation_time, test->extra_path,
+ test->extra_path[0] != '\0' ? "/" : "", test->leftover);
+ if (ret < 0) {
+ result = NULL;
+ }
+ return result;
+}
+
+int main(int argc, char **argv)
+{
+ int num_test = sizeof(tests) / sizeof(struct test);
+
+ plan_tests(NUM_TESTS_PER_TEST * num_test);
+ diag("Backward compatibility utils for lttng-relayd --group-by-session");
+ for (int i = 0; i < num_test; i++) {
+ char *expected = NULL;
+ char *result = NULL;
+
+ expected = craft_expected(&tests[i]);
+ if (!expected) {
+ fprintf(stderr, "Failed to craft expected output\n");
+ goto loop;
+ }
+
+ result = backward_compat_group_by_session(
+ tests[i].stream_path, tests[i].session_name);
+ if (!result && tests[i].is_valid) {
+ fprintf(stderr, "Failed to get result\n");
+ goto loop;
+ } else if (!result && tests[i].is_valid == false) {
+ pass("Returned null as expected");
+ goto loop;
+ }
+
+ ok(strncmp(expected, result, strlen(expected)) == 0,
+ "In: %s, out: %s, expected: %s",
+ tests[i].stream_path, result, expected);
+ loop:
+ free(expected);
+ free(result);
+ }
+ return exit_status();
+}
projects / lttng-tools.git / blobdiff