Added libosmo-m3ua code which is GPLv2 / GPLv3

Copied from the libosmo project, and modified slightly.
Copyrights and licenses are unchanged

src/modules/rlm_sigtran/libosmo-m3ua/bsc.c

@@ -0,0 +1,204 @@
+/* Everything related to the global BSC */
+/*
+ * (C) 2010-2011 by Holger Hans Peter Freyther <zecke@selfish.org>
+ * (C) 2010-2011 by On-Waves
+ * 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 Affero 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/>.
+ *
+ */
+
+#include <bsc_data.h>
+#include <cellmgr_debug.h>
+#include <msc_connection.h>
+#include <mtp_pcap.h>
+
+#include <osmocom/core/talloc.h>
+#include <osmocom/vty/vty.h>
+
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <assert.h>
+#include <unistd.h>
+#include <signal.h>
+#include <pthread.h>
+
+#ifndef _GNU_SOURCE
+#define _GNU_SOURCE
+#endif
+#include <getopt.h>
+
+#undef PACKAGE_NAME
+#undef PACKAGE_VERSION
+#undef PACKAGE_BUGREPORT
+#undef PACKAGE_TARNAME
+#undef PACKAGE_STRING
+#include <cellmgr_config.h>
+
+struct bsc_data *bsc;
+char *config;
+
+struct bsc_data *bsc_data_alloc(TALLOC_CTX *ctx)
+{
+	struct bsc_data *bsc;
+
+	bsc = talloc_zero(ctx, struct bsc_data);
+	if (!bsc) return NULL;
+
+	INIT_LLIST_HEAD(&bsc->linksets);
+
+	return bsc;
+}
+
+struct bsc_data *bsc_data_create()
+{
+	struct bsc_data *bsc;
+
+	bsc = talloc_zero(NULL, struct bsc_data);
+	if (!bsc) {
+		LOGP(DINP, LOGL_ERROR, "Failed to create the BSC.\n");
+		return NULL;
+	}
+
+	INIT_LLIST_HEAD(&bsc->linksets);
+	INIT_LLIST_HEAD(&bsc->mscs);
+	INIT_LLIST_HEAD(&bsc->apps);
+
+	bsc->udp_port = 3456;
+	bsc->udp_ip = NULL;
+	bsc->udp_nr_links = 1;
+
+	bsc->udp_src_port = 1313;
+	bsc->pcap_fd = -1;
+	bsc->udp_reset_timeout = 180;
+
+	/* m2ua code */
+	bsc->m2ua_src_port = 2904;
+
+	return bsc;
+}
+
+static void sigint()
+{
+	static pthread_mutex_t exit_mutex = PTHREAD_MUTEX_INITIALIZER;
+	static int handled = 0;
+
+	struct mtp_link_set *set;
+
+	/* failed to lock */
+	if (pthread_mutex_trylock(&exit_mutex) != 0)
+		return;
+	if (handled)
+		goto out;
+
+	printf("Terminating.\n");
+	handled = 1;
+	if (bsc) {
+		llist_for_each_entry(set, &bsc->linksets, entry)
+			link_shutdown_all(set);
+	}
+
+	exit(0);
+
+out:
+	pthread_mutex_unlock(&exit_mutex);
+}
+
+static void sigusr1()
+{
+	talloc_report_full(bsc, stderr);
+}
+
+static void sigusr2()
+{
+	struct msc_connection *msc;
+	printf("Closing the MSC connection on demand.\n");
+
+	llist_for_each_entry(msc, &bsc->mscs, entry) {
+		if (!msc->msc_link_down)
+			msc_close_connection(msc);
+	}
+}
+
+
+static void print_usage(const char *arg)
+{
+	printf("Usage: %s\n", arg);
+}
+
+static void print_help()
+{
+	printf("  Some useful help...\n");
+	printf("  -h --help this text\n");
+	printf("  -c --config=CFG The config file to use.\n");
+	printf("  -p --pcap=FILE. Write MSUs to the PCAP file.\n");
+	printf("  -c --once. Send the SLTM msg only once.\n");
+	printf("  -v --version. Print the version number\n");
+}
+
+void handle_options(int argc, char **argv)
+{
+	while (1) {
+		int option_index = 0, c;
+		static struct option long_options[] = {
+			{"help", 0, 0, 'h'},
+			{"config", 1, 0, 'c'},
+			{"pcap", 1, 0, 'p'},
+			{"version", 0, 0, 0},
+			{0, 0, 0, 0},
+		};
+
+		c = getopt_long(argc, argv, "hc:p:v",
+				long_options, &option_index);
+		if (c == -1)
+			break;
+
+		switch (c) {
+		case 'h':
+			print_usage(argv[0]);
+			print_help();
+			exit(0);
+		case 'p':
+			if (bsc->pcap_fd >= 0)
+				close(bsc->pcap_fd);
+			bsc->pcap_fd = open(optarg, O_WRONLY | O_TRUNC | O_CREAT, S_IRUSR | S_IWUSR | S_IRGRP| S_IROTH);
+			if (bsc->pcap_fd < 0) {
+				fprintf(stderr, "Failed to open PCAP file.\n");
+				exit(0);
+			}
+			mtp_pcap_write_header(bsc->pcap_fd);
+			break;
+		case 'c':
+			config = optarg;
+			break;
+		case 'v':
+			printf("This is %s version %s.\n", PACKAGE, VERSION);
+			exit(0);
+			break;
+		default:
+			fprintf(stderr, "Unknown option.\n");
+			break;
+		}
+	}
+
+	signal(SIGPIPE, SIG_IGN);
+	signal(SIGINT, sigint);
+	signal(SIGUSR1, sigusr1);
+	signal(SIGUSR2, sigusr2);
+}
+

src/modules/rlm_sigtran/libosmo-m3ua/bsc_sccp.c

@@ -0,0 +1,103 @@
+/* routines to track connections */
+/*
+ * (C) 2010-2011 by Holger Hans Peter Freyther <zecke@selfish.org>
+ * (C) 2010-2011 by On-Waves
+ * 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 Affero 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/>.
+ *
+ */
+
+#include "bsc_sccp.h"
+#include "bsc_data.h"
+
+#include <cellmgr_debug.h>
+#include <ss7_application.h>
+#include <ss7_application.h>
+
+#include <osmocom/core/talloc.h>
+
+#include <string.h>
+
+struct active_sccp_con *find_con_by_dest_ref(struct ss7_application *fw, struct sccp_source_reference *ref)
+{
+	struct active_sccp_con *con;
+
+	if (!ref) {
+		LOGP(DINP, LOGL_ERROR, "Dest Reference is NULL. No connection found.\n");
+		return NULL;
+	}
+
+	llist_for_each_entry(con, &fw->sccp_connections, entry) {
+		if (memcmp(&con->dst_ref, ref, sizeof(*ref)) == 0)
+			return con;
+	}
+
+	LOGP(DINP, LOGL_ERROR, "No connection fond with: 0x%x as dest\n", sccp_src_ref_to_int(ref));
+	return NULL;
+}
+
+
+struct active_sccp_con *find_con_by_src_ref(struct ss7_application *fw, struct sccp_source_reference *src_ref)
+{
+	struct active_sccp_con *con;
+
+	/* it is quite normal to not find this one */
+	if (!src_ref)
+		return NULL;
+
+	llist_for_each_entry(con, &fw->sccp_connections, entry) {
+		if (memcmp(&con->src_ref, src_ref, sizeof(*src_ref)) == 0)
+			return con;
+	}
+
+	return NULL;
+}
+
+struct active_sccp_con *find_con_by_src_dest_ref(struct ss7_application *fw,
+						 struct sccp_source_reference *src_ref,
+						 struct sccp_source_reference *dst_ref)
+{
+	struct active_sccp_con *con;
+
+	llist_for_each_entry(con, &fw->sccp_connections, entry) {
+		if (memcmp(src_ref, &con->src_ref, sizeof(*src_ref)) == 0 &&
+		    memcmp(dst_ref, &con->dst_ref, sizeof(*dst_ref)) == 0) {
+			return con;
+		}
+	}
+
+	return NULL;
+}
+
+unsigned int sls_for_src_ref(struct ss7_application *fw, struct sccp_source_reference *ref)
+{
+	struct active_sccp_con *con;
+
+	con = find_con_by_src_ref(fw, ref);
+	if (!con)
+		return -1;
+	return con->sls;
+}
+
+/*
+ * remove data
+ */
+void free_con(struct active_sccp_con *con)
+{
+	llist_del(&con->entry);
+	osmo_timer_del(&con->rlc_timeout);
+	talloc_free(con);
+}
+

src/modules/rlm_sigtran/libosmo-m3ua/bsc_ussd.c

@@ -0,0 +1,48 @@
+/* A USSD Module */
+/*
+ * (C) 2010 by Holger Hans Peter Freyther <zecke@selfish.org>
+ * (C) 2010 by On-Waves
+ * 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 Affero 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/>.
+ *
+ */
+
+#include <bsc_data.h>
+#include <bsc_sccp.h>
+
+/*
+ * Check the msg and identify a Location Updating Request and see if the
+ * LAC is different to this one and then mark the CR message.
+ */
+int bsc_ussd_handle_out_msg(struct msc_connection *msc, struct sccp_parse_result *result,
+			    struct msgb *msg)
+{
+	/* Only search for this in the CR message */
+	if (sccp_determine_msg_type(msg) != SCCP_MSG_TYPE_CR)
+		return 0;
+
+	/* now check the kind of GSM message */
+
+	return 0;
+}
+
+/*
+ * Check the message if it contains a location update request...
+ */
+int bsc_ussd_handle_in_msg(struct msc_connection *msc, struct sccp_parse_result *res,
+			   struct msgb *msg)
+{
+	return 0;
+}