diff options
Diffstat (limited to 'tests/llc/LlcTest.cpp')
| -rw-r--r-- | tests/llc/LlcTest.cpp | 173 |
1 files changed, 173 insertions, 0 deletions
diff --git a/tests/llc/LlcTest.cpp b/tests/llc/LlcTest.cpp new file mode 100644 index 00000000..9e1d35d0 --- /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(); } +} |