llc/test: Add test program for LLC related tests
Sponsored-by: On-Waves ehf
diff --git a/tests/llc/LlcTest.cpp b/tests/llc/LlcTest.cpp
new file mode 100644
index 0000000..9e1d35d
--- /dev/null
+++ b/tests/llc/LlcTest.cpp
@@ -0,0 +1,173 @@
+/*
+ * LlcTest.cpp
+ *
+ * Copyright (C) 2015 by Sysmocom s.f.m.c. GmbH
+ *
+ * All Rights Reserved
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * 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 Affero General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+extern "C" {
+ #include <osmocom/core/linuxlist.h>
+}
+
+#include "llc.h"
+#include "gprs_debug.h"
+
+extern "C" {
+#include "pcu_vty.h"
+
+#include <osmocom/core/application.h>
+#include <osmocom/core/msgb.h>
+#include <osmocom/core/talloc.h>
+#include <osmocom/core/utils.h>
+#include <osmocom/vty/vty.h>
+}
+
+
+void *tall_pcu_ctx;
+int16_t spoof_mnc = 0, spoof_mcc = 0;
+
+static void enqueue_data(gprs_llc_queue *queue, const uint8_t *data, size_t len)
+{
+ struct timeval *tv;
+ uint8_t *msg_data;
+ struct msgb *llc_msg = msgb_alloc(len + sizeof(*tv) * 2,
+ "llc_pdu_queue");
+
+ tv = (struct timeval *)msgb_put(llc_msg, sizeof(*tv));
+ memset(tv, 0, sizeof(*tv));
+ tv = (struct timeval *)msgb_put(llc_msg, sizeof(*tv));
+ memset(tv, 0, sizeof(*tv));
+ msg_data = (uint8_t *)msgb_put(llc_msg, len);
+
+ memcpy(msg_data, data, len);
+
+ queue->enqueue(llc_msg);
+}
+
+static void dequeue_and_check(gprs_llc_queue *queue, const uint8_t *exp_data, size_t len)
+{
+ struct msgb *llc_msg;
+ uint8_t *msg_data;
+
+ llc_msg = queue->dequeue();
+ OSMO_ASSERT(llc_msg != NULL);
+
+ fprintf(stderr, "dequeued msg, length %d, data %s\n",
+ msgb_length(llc_msg), msgb_hexdump(llc_msg));
+
+ OSMO_ASSERT(msgb_length(llc_msg) >= 2*sizeof(struct timeval));
+ msgb_pull(llc_msg, sizeof(struct timeval));
+ msgb_pull(llc_msg, sizeof(struct timeval));
+
+ fprintf(stderr, "LLC message, length %d (expected %d)\n",
+ msgb_length(llc_msg), len);
+
+ OSMO_ASSERT(msgb_length(llc_msg) == len);
+ msg_data = msgb_data(llc_msg);
+
+ OSMO_ASSERT(memcmp(msg_data, exp_data, len) == 0);
+ msgb_free(llc_msg);
+}
+
+static void enqueue_data(gprs_llc_queue *queue, const char *message)
+{
+ enqueue_data(queue, (uint8_t *)(message), strlen(message));
+}
+
+static void dequeue_and_check(gprs_llc_queue *queue, const char *exp_message)
+{
+ dequeue_and_check(queue, (uint8_t *)(exp_message), strlen(exp_message));
+}
+
+static void test_llc_queue()
+{
+ gprs_llc_queue queue;
+
+ printf("=== start %s ===\n", __func__);
+
+ queue.init();
+ OSMO_ASSERT(queue.size() == 0);
+
+ enqueue_data(&queue, "LLC message");
+ OSMO_ASSERT(queue.size() == 1);
+
+ enqueue_data(&queue, "other LLC message");
+ OSMO_ASSERT(queue.size() == 2);
+
+ dequeue_and_check(&queue, "LLC message");
+ OSMO_ASSERT(queue.size() == 1);
+
+ dequeue_and_check(&queue, "other LLC message");
+ OSMO_ASSERT(queue.size() == 0);
+
+ enqueue_data(&queue, "LLC");
+ OSMO_ASSERT(queue.size() == 1);
+
+ queue.clear(NULL);
+ OSMO_ASSERT(queue.size() == 0);
+
+ printf("=== end %s ===\n", __func__);
+}
+
+static const struct log_info_cat default_categories[] = {
+ {"DPCU", "", "GPRS Packet Control Unit (PCU)", LOGL_INFO, 1},
+};
+
+static int filter_fn(const struct log_context *ctx,
+ struct log_target *tar)
+{
+ return 1;
+}
+
+const struct log_info debug_log_info = {
+ filter_fn,
+ (struct log_info_cat*)default_categories,
+ ARRAY_SIZE(default_categories),
+};
+
+int main(int argc, char **argv)
+{
+ struct vty_app_info pcu_vty_info = {0};
+
+ tall_pcu_ctx = talloc_named_const(NULL, 1, "LlcTest context");
+ if (!tall_pcu_ctx)
+ abort();
+
+ msgb_set_talloc_ctx(tall_pcu_ctx);
+ osmo_init_logging(&debug_log_info);
+ log_set_use_color(osmo_stderr_target, 0);
+ log_set_print_filename(osmo_stderr_target, 0);
+ log_set_log_level(osmo_stderr_target, LOGL_INFO);
+
+ vty_init(&pcu_vty_info);
+ pcu_vty_init(&debug_log_info);
+
+ test_llc_queue();
+
+ if (getenv("TALLOC_REPORT_FULL"))
+ talloc_report_full(tall_pcu_ctx, stderr);
+
+ return EXIT_SUCCESS;
+}
+
+extern "C" {
+void l1if_pdch_req() { abort(); }
+void l1if_connect_pdch() { abort(); }
+void l1if_close_pdch() { abort(); }
+void l1if_open_pdch() { abort(); }
+}