<p>Harald Welte has uploaded this change for <strong>review</strong>.</p><p><a href="https://gerrit.osmocom.org/10283">View Change</a></p><pre style="font-family: monospace,monospace; white-space: pre-wrap;">Remove local libgsupclient; Use libosmo-gsup-client from osmo-hlr<br><br>osmo-hlr has recently (as of Change-Id<br>Iad227bb477d64da30dd6bfbbe1bd0c0a55be9474) a working shared library<br>implementation of libosmo-gsup-client.<br><br>We can remove the local implementation in osmo-msc and use the<br>system-installed shared library instead.<br><br>Change-Id: I6f542945403cf2e3ddac419186b09ec0e2d43b69<br>---<br>M configure.ac<br>M include/osmocom/msc/Makefile.am<br>D include/osmocom/msc/gsup_client.h<br>M include/osmocom/msc/vlr.h<br>M src/Makefile.am<br>D src/libgsupclient/Makefile.am<br>D src/libgsupclient/gsup_client.c<br>D src/libgsupclient/gsup_test_client.c<br>M src/libmsc/gsm_09_11.c<br>M src/libvlr/vlr.c<br>M src/osmo-msc/Makefile.am<br>M tests/msc_vlr/Makefile.am<br>M tests/msc_vlr/msc_vlr_tests.c<br>M tests/sms_queue/Makefile.am<br>14 files changed, 35 insertions(+), 806 deletions(-)<br><br></pre><pre style="font-family: monospace,monospace; white-space: pre-wrap;">git pull ssh://gerrit.osmocom.org:29418/osmo-msc refs/changes/83/10283/1</pre><pre style="font-family: monospace,monospace; white-space: pre-wrap;"><span>diff --git a/configure.ac b/configure.ac</span><br><span>index be66d51..03acc0c 100644</span><br><span>--- a/configure.ac</span><br><span>+++ b/configure.ac</span><br><span>@@ -44,6 +44,7 @@</span><br><span> PKG_CHECK_MODULES(LIBOSMOSIGTRAN, libosmo-sigtran >= 0.9.0)</span><br><span> PKG_CHECK_MODULES(LIBOSMOSCCP, libosmo-sccp >= 0.9.0)</span><br><span> PKG_CHECK_MODULES(LIBOSMOMGCPCLIENT, libosmo-mgcp-client >= 1.3.0)</span><br><span style="color: hsl(120, 100%, 40%);">+PKG_CHECK_MODULES(LIBOSMOGSUPCLIENT, libosmo-gsup-client >= 0.2.1)</span><br><span> </span><br><span> AC_ARG_ENABLE(sanitize,</span><br><span>  [AS_HELP_STRING(</span><br><span>@@ -193,7 +194,6 @@</span><br><span>     src/Makefile</span><br><span>     src/libmsc/Makefile</span><br><span>     src/libvlr/Makefile</span><br><span style="color: hsl(0, 100%, 40%);">-    src/libgsupclient/Makefile</span><br><span>     src/osmo-msc/Makefile</span><br><span>     src/utils/Makefile</span><br><span>     tests/Makefile</span><br><span>diff --git a/include/osmocom/msc/Makefile.am b/include/osmocom/msc/Makefile.am</span><br><span>index b1a4810..ebc946a 100644</span><br><span>--- a/include/osmocom/msc/Makefile.am</span><br><span>+++ b/include/osmocom/msc/Makefile.am</span><br><span>@@ -13,7 +13,6 @@</span><br><span>     gsm_data.h \</span><br><span>         gsm_data_shared.h \</span><br><span>  gsm_subscriber.h \</span><br><span style="color: hsl(0, 100%, 40%);">-      gsup_client.h \</span><br><span>      iucs.h \</span><br><span>     iucs_ranap.h \</span><br><span>       iu_dummy.h \</span><br><span>diff --git a/include/osmocom/msc/gsup_client.h b/include/osmocom/msc/gsup_client.h</span><br><span>deleted file mode 100644</span><br><span>index 2f6170b..0000000</span><br><span>--- a/include/osmocom/msc/gsup_client.h</span><br><span>+++ /dev/null</span><br><span>@@ -1,67 +0,0 @@</span><br><span style="color: hsl(0, 100%, 40%);">-/* GPRS Subscriber Update Protocol client */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* (C) 2014 by Sysmocom s.f.m.c. GmbH</span><br><span style="color: hsl(0, 100%, 40%);">- * All Rights Reserved</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Author: Jacob Erlbeck</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This program is free software; you can redistribute it and/or modify</span><br><span style="color: hsl(0, 100%, 40%);">- * it under the terms of the GNU Affero General Public License as published by</span><br><span style="color: hsl(0, 100%, 40%);">- * the Free Software Foundation; either version 3 of the License, or</span><br><span style="color: hsl(0, 100%, 40%);">- * (at your option) any later version.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This program is distributed in the hope that it will be useful,</span><br><span style="color: hsl(0, 100%, 40%);">- * but WITHOUT ANY WARRANTY; without even the implied warranty of</span><br><span style="color: hsl(0, 100%, 40%);">- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the</span><br><span style="color: hsl(0, 100%, 40%);">- * GNU Affero General Public License for more details.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * You should have received a copy of the GNU Affero General Public License</span><br><span style="color: hsl(0, 100%, 40%);">- * along with this program.  If not, see <http://www.gnu.org/licenses/>.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-#pragma once</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/timer.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/gsm/oap_client.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* a loss of GSUP between MSC and HLR is considered quite serious, let's try to recover as quickly as</span><br><span style="color: hsl(0, 100%, 40%);">- * possible.  Even one new connection attempt per second should be quite acceptable until the link is</span><br><span style="color: hsl(0, 100%, 40%);">- * re-established */</span><br><span style="color: hsl(0, 100%, 40%);">-#define GSUP_CLIENT_RECONNECT_INTERVAL 1</span><br><span style="color: hsl(0, 100%, 40%);">-#define GSUP_CLIENT_PING_INTERVAL 20</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct msgb;</span><br><span style="color: hsl(0, 100%, 40%);">-struct ipa_client_conn;</span><br><span style="color: hsl(0, 100%, 40%);">-struct gsup_client;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* Expects message in msg->l2h */</span><br><span style="color: hsl(0, 100%, 40%);">-typedef int (*gsup_client_read_cb_t)(struct gsup_client *gsupc,</span><br><span style="color: hsl(0, 100%, 40%);">-                                     struct msgb *msg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct gsup_client {</span><br><span style="color: hsl(0, 100%, 40%);">-     const char *unit_name;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-  struct ipa_client_conn *link;</span><br><span style="color: hsl(0, 100%, 40%);">-   gsup_client_read_cb_t read_cb;</span><br><span style="color: hsl(0, 100%, 40%);">-  void *data;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     struct osmo_oap_client_state oap_state;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- struct osmo_timer_list ping_timer;</span><br><span style="color: hsl(0, 100%, 40%);">-      struct osmo_timer_list connect_timer;</span><br><span style="color: hsl(0, 100%, 40%);">-   int is_connected;</span><br><span style="color: hsl(0, 100%, 40%);">-       int got_ipa_pong;</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct gsup_client *gsup_client_create(void *talloc_ctx,</span><br><span style="color: hsl(0, 100%, 40%);">-                                    const char *unit_name,</span><br><span style="color: hsl(0, 100%, 40%);">-                                  const char *ip_addr,</span><br><span style="color: hsl(0, 100%, 40%);">-                                    unsigned int tcp_port,</span><br><span style="color: hsl(0, 100%, 40%);">-                                  gsup_client_read_cb_t read_cb,</span><br><span style="color: hsl(0, 100%, 40%);">-                                  struct osmo_oap_client_config *oapc_config);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-void gsup_client_destroy(struct gsup_client *gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-int gsup_client_send(struct gsup_client *gsupc, struct msgb *msg);</span><br><span style="color: hsl(0, 100%, 40%);">-struct msgb *gsup_client_msgb_alloc(void);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span>diff --git a/include/osmocom/msc/vlr.h b/include/osmocom/msc/vlr.h</span><br><span>index b54aa55..91c28db 100644</span><br><span>--- a/include/osmocom/msc/vlr.h</span><br><span>+++ b/include/osmocom/msc/vlr.h</span><br><span>@@ -12,6 +12,7 @@</span><br><span> #include <osmocom/msc/gsm_data.h></span><br><span> // for GSM_NAME_LENGTH</span><br><span> #include <osmocom/msc/gsm_subscriber.h></span><br><span style="color: hsl(120, 100%, 40%);">+#include <osmocom/gsupclient/gsup_client.h></span><br><span> </span><br><span> #define LOGGSUPP(level, gsup, fmt, args...)                            \</span><br><span>    LOGP(DVLR, level, "GSUP(%s) " fmt, (gsup)->imsi, ## args)</span><br><span>@@ -243,7 +244,7 @@</span><br><span> struct vlr_instance {</span><br><span>        struct llist_head subscribers;</span><br><span>       struct llist_head operations;</span><br><span style="color: hsl(0, 100%, 40%);">-   struct gsup_client *gsup_client;</span><br><span style="color: hsl(120, 100%, 40%);">+      struct osmo_gsup_client *gsup_client;</span><br><span>        struct vlr_ops ops;</span><br><span>  struct osmo_timer_list lu_expire_timer;</span><br><span>      struct {</span><br><span>diff --git a/src/Makefile.am b/src/Makefile.am</span><br><span>index 2322ade..4e7cea1 100644</span><br><span>--- a/src/Makefile.am</span><br><span>+++ b/src/Makefile.am</span><br><span>@@ -21,7 +21,6 @@</span><br><span> </span><br><span> # Libraries</span><br><span> SUBDIRS = \</span><br><span style="color: hsl(0, 100%, 40%);">- libgsupclient \</span><br><span>      libvlr \</span><br><span>     libmsc \</span><br><span>     $(NULL)</span><br><span>diff --git a/src/libgsupclient/Makefile.am b/src/libgsupclient/Makefile.am</span><br><span>deleted file mode 100644</span><br><span>index 6381687..0000000</span><br><span>--- a/src/libgsupclient/Makefile.am</span><br><span>+++ /dev/null</span><br><span>@@ -1,38 +0,0 @@</span><br><span style="color: hsl(0, 100%, 40%);">-AM_CPPFLAGS = \</span><br><span style="color: hsl(0, 100%, 40%);">-        $(all_includes) \</span><br><span style="color: hsl(0, 100%, 40%);">-       -I$(top_srcdir)/include \</span><br><span style="color: hsl(0, 100%, 40%);">-       -I$(top_builddir) \</span><br><span style="color: hsl(0, 100%, 40%);">-     $(NULL)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-AM_CFLAGS = \</span><br><span style="color: hsl(0, 100%, 40%);">-    -Wall \</span><br><span style="color: hsl(0, 100%, 40%);">- $(LIBOSMOCORE_CFLAGS) \</span><br><span style="color: hsl(0, 100%, 40%);">- $(LIBOSMOGSM_CFLAGS) \</span><br><span style="color: hsl(0, 100%, 40%);">-  $(LIBOSMOVTY_CFLAGS) \</span><br><span style="color: hsl(0, 100%, 40%);">-  $(LIBOSMOABIS_CFLAGS) \</span><br><span style="color: hsl(0, 100%, 40%);">- $(COVERAGE_CFLAGS) \</span><br><span style="color: hsl(0, 100%, 40%);">-    $(NULL)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-noinst_LIBRARIES = \</span><br><span style="color: hsl(0, 100%, 40%);">-     libgsupclient.a \</span><br><span style="color: hsl(0, 100%, 40%);">-       $(NULL)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-libgsupclient_a_SOURCES = \</span><br><span style="color: hsl(0, 100%, 40%);">-      gsup_client.c \</span><br><span style="color: hsl(0, 100%, 40%);">- $(NULL)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-noinst_PROGRAMS = \</span><br><span style="color: hsl(0, 100%, 40%);">-      gsup_test_client \</span><br><span style="color: hsl(0, 100%, 40%);">-      $(NULL)</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-gsup_test_client_SOURCES = \</span><br><span style="color: hsl(0, 100%, 40%);">-     gsup_test_client.c \</span><br><span style="color: hsl(0, 100%, 40%);">-    $(NULL)</span><br><span style="color: hsl(0, 100%, 40%);">-gsup_test_client_LDADD = \</span><br><span style="color: hsl(0, 100%, 40%);">-       libgsupclient.a \</span><br><span style="color: hsl(0, 100%, 40%);">-       $(LIBOSMOCORE_LIBS) \</span><br><span style="color: hsl(0, 100%, 40%);">-   $(LIBOSMOGSM_LIBS) \</span><br><span style="color: hsl(0, 100%, 40%);">-    $(LIBOSMOVTY_LIBS) \</span><br><span style="color: hsl(0, 100%, 40%);">-    $(LIBOSMOABIS_LIBS) \</span><br><span style="color: hsl(0, 100%, 40%);">-   -lrt \</span><br><span style="color: hsl(0, 100%, 40%);">-  $(NULL)</span><br><span>diff --git a/src/libgsupclient/gsup_client.c b/src/libgsupclient/gsup_client.c</span><br><span>deleted file mode 100644</span><br><span>index 39dc181..0000000</span><br><span>--- a/src/libgsupclient/gsup_client.c</span><br><span>+++ /dev/null</span><br><span>@@ -1,347 +0,0 @@</span><br><span style="color: hsl(0, 100%, 40%);">-/* Generic Subscriber Update Protocol client */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* (C) 2014-2016 by Sysmocom s.f.m.c. GmbH</span><br><span style="color: hsl(0, 100%, 40%);">- * All Rights Reserved</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * Author: Jacob Erlbeck</span><br><span style="color: hsl(0, 100%, 40%);">- * Author: Neels Hofmeyr</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This program is free software; you can redistribute it and/or modify</span><br><span style="color: hsl(0, 100%, 40%);">- * it under the terms of the GNU Affero General Public License as published by</span><br><span style="color: hsl(0, 100%, 40%);">- * the Free Software Foundation; either version 3 of the License, or</span><br><span style="color: hsl(0, 100%, 40%);">- * (at your option) any later version.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * This program is distributed in the hope that it will be useful,</span><br><span style="color: hsl(0, 100%, 40%);">- * but WITHOUT ANY WARRANTY; without even the implied warranty of</span><br><span style="color: hsl(0, 100%, 40%);">- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the</span><br><span style="color: hsl(0, 100%, 40%);">- * GNU Affero General Public License for more details.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- * You should have received a copy of the GNU Affero General Public License</span><br><span style="color: hsl(0, 100%, 40%);">- * along with this program.  If not, see <http://www.gnu.org/licenses/>.</span><br><span style="color: hsl(0, 100%, 40%);">- *</span><br><span style="color: hsl(0, 100%, 40%);">- */</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/msc/gsup_client.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/abis/ipa.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/gsm/protocol/ipaccess.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/gsm/oap_client.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/msgb.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/logging.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/msc/debug.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <errno.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <string.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void start_test_procedure(struct gsup_client *gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void gsup_client_send_ping(struct gsup_client *gsupc)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-    struct msgb *msg = gsup_client_msgb_alloc();</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    msg->l2h = msgb_put(msg, 1);</span><br><span style="color: hsl(0, 100%, 40%);">- msg->l2h[0] = IPAC_MSGT_PING;</span><br><span style="color: hsl(0, 100%, 40%);">-        ipa_msg_push_header(msg, IPAC_PROTO_IPACCESS);</span><br><span style="color: hsl(0, 100%, 40%);">-  ipa_client_conn_send(gsupc->link, msg);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int gsup_client_connect(struct gsup_client *gsupc)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-   int rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- if (gsupc->is_connected)</span><br><span style="color: hsl(0, 100%, 40%);">-             return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       if (osmo_timer_pending(&gsupc->connect_timer)) {</span><br><span style="color: hsl(0, 100%, 40%);">-         LOGP(DLGSUP, LOGL_DEBUG,</span><br><span style="color: hsl(0, 100%, 40%);">-                     "GSUP connect: connect timer already running\n");</span><br><span style="color: hsl(0, 100%, 40%);">-                osmo_timer_del(&gsupc->connect_timer);</span><br><span style="color: hsl(0, 100%, 40%);">-   }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       if (osmo_timer_pending(&gsupc->ping_timer)) {</span><br><span style="color: hsl(0, 100%, 40%);">-            LOGP(DLGSUP, LOGL_DEBUG,</span><br><span style="color: hsl(0, 100%, 40%);">-                     "GSUP connect: ping timer already running\n");</span><br><span style="color: hsl(0, 100%, 40%);">-           osmo_timer_del(&gsupc->ping_timer);</span><br><span style="color: hsl(0, 100%, 40%);">-      }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       if (ipa_client_conn_clear_queue(gsupc->link) > 0)</span><br><span style="color: hsl(0, 100%, 40%);">-         LOGP(DLGSUP, LOGL_DEBUG, "GSUP connect: discarded stored messages\n");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-        rc = ipa_client_conn_open(gsupc->link);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      if (rc >= 0) {</span><br><span style="color: hsl(0, 100%, 40%);">-               LOGP(DLGSUP, LOGL_NOTICE, "GSUP connecting to %s:%d\n",</span><br><span style="color: hsl(0, 100%, 40%);">-                    gsupc->link->addr, gsupc->link->port);</span><br><span style="color: hsl(0, 100%, 40%);">-         return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-       }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       LOGP(DLGSUP, LOGL_ERROR, "GSUP failed to connect to %s:%d: %s\n",</span><br><span style="color: hsl(0, 100%, 40%);">-          gsupc->link->addr, gsupc->link->port, strerror(-rc));</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-  if (rc == -EBADF || rc == -ENOTSOCK || rc == -EAFNOSUPPORT ||</span><br><span style="color: hsl(0, 100%, 40%);">-       rc == -EINVAL)</span><br><span style="color: hsl(0, 100%, 40%);">-              return rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      osmo_timer_schedule(&gsupc->connect_timer,</span><br><span style="color: hsl(0, 100%, 40%);">-                           GSUP_CLIENT_RECONNECT_INTERVAL, 0);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- LOGP(DLGSUP, LOGL_INFO, "Scheduled timer to retry GSUP connect to %s:%d\n",</span><br><span style="color: hsl(0, 100%, 40%);">-        gsupc->link->addr, gsupc->link->port);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void connect_timer_cb(void *gsupc_)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-   struct gsup_client *gsupc = gsupc_;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     if (gsupc->is_connected)</span><br><span style="color: hsl(0, 100%, 40%);">-             return;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- gsup_client_connect(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void client_send(struct gsup_client *gsupc, int proto_ext,</span><br><span style="color: hsl(0, 100%, 40%);">-                   struct msgb *msg_tx)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-   ipa_prepend_header_ext(msg_tx, proto_ext);</span><br><span style="color: hsl(0, 100%, 40%);">-      ipa_msg_push_header(msg_tx, IPAC_PROTO_OSMO);</span><br><span style="color: hsl(0, 100%, 40%);">-   ipa_client_conn_send(gsupc->link, msg_tx);</span><br><span style="color: hsl(0, 100%, 40%);">-   /* msg_tx is now queued and will be freed. */</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void gsup_client_oap_register(struct gsup_client *gsupc)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-  struct msgb *msg_tx;</span><br><span style="color: hsl(0, 100%, 40%);">-    int rc;</span><br><span style="color: hsl(0, 100%, 40%);">- rc = osmo_oap_client_register(&gsupc->oap_state, &msg_tx);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-   if ((rc < 0) || (!msg_tx)) {</span><br><span style="color: hsl(0, 100%, 40%);">-         LOGP(DLGSUP, LOGL_ERROR, "GSUP OAP set up, but cannot register.\n");</span><br><span style="color: hsl(0, 100%, 40%);">-          return;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       client_send(gsupc, IPAC_PROTO_EXT_OAP, msg_tx);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void gsup_client_updown_cb(struct ipa_client_conn *link, int up)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-        struct gsup_client *gsupc = link->data;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      LOGP(DLGSUP, LOGL_INFO, "GSUP link to %s:%d %s\n",</span><br><span style="color: hsl(0, 100%, 40%);">-                 link->addr, link->port, up ? "UP" : "DOWN");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     gsupc->is_connected = up;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    if (up) {</span><br><span style="color: hsl(0, 100%, 40%);">-               start_test_procedure(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-            if (gsupc->oap_state.state == OSMO_OAP_INITIALIZED)</span><br><span style="color: hsl(0, 100%, 40%);">-                  gsup_client_oap_register(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-                osmo_timer_del(&gsupc->connect_timer);</span><br><span style="color: hsl(0, 100%, 40%);">-   } else {</span><br><span style="color: hsl(0, 100%, 40%);">-                osmo_timer_del(&gsupc->ping_timer);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-              osmo_timer_schedule(&gsupc->connect_timer,</span><br><span style="color: hsl(0, 100%, 40%);">-                                   GSUP_CLIENT_RECONNECT_INTERVAL, 0);</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int gsup_client_oap_handle(struct gsup_client *gsupc, struct msgb *msg_rx)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-    int rc;</span><br><span style="color: hsl(0, 100%, 40%);">- struct msgb *msg_tx;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    /* If the oap_state is disabled, this will reject the messages. */</span><br><span style="color: hsl(0, 100%, 40%);">-      rc = osmo_oap_client_handle(&gsupc->oap_state, msg_rx, &msg_tx);</span><br><span style="color: hsl(0, 100%, 40%);">-     msgb_free(msg_rx);</span><br><span style="color: hsl(0, 100%, 40%);">-      if (rc < 0)</span><br><span style="color: hsl(0, 100%, 40%);">-          return rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      if (msg_tx)</span><br><span style="color: hsl(0, 100%, 40%);">-             client_send(gsupc, IPAC_PROTO_EXT_OAP, msg_tx);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int gsup_client_read_cb(struct ipa_client_conn *link, struct msgb *msg)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-       struct ipaccess_head *hh = (struct ipaccess_head *) msg->data;</span><br><span style="color: hsl(0, 100%, 40%);">-       struct ipaccess_head_ext *he = (struct ipaccess_head_ext *) msgb_l2(msg);</span><br><span style="color: hsl(0, 100%, 40%);">-       struct gsup_client *gsupc = (struct gsup_client *)link->data;</span><br><span style="color: hsl(0, 100%, 40%);">-        int rc;</span><br><span style="color: hsl(0, 100%, 40%);">- struct ipaccess_unit ipa_dev = {</span><br><span style="color: hsl(0, 100%, 40%);">-                /* see gsup_client_create() on const vs non-const */</span><br><span style="color: hsl(0, 100%, 40%);">-            .unit_name = (char*)gsupc->unit_name,</span><br><span style="color: hsl(0, 100%, 40%);">-        };</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      OSMO_ASSERT(ipa_dev.unit_name);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- msg->l2h = &hh->data[0];</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      rc = ipaccess_bts_handle_ccm(link, &ipa_dev, msg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-  if (rc < 0) {</span><br><span style="color: hsl(0, 100%, 40%);">-                LOGP(DLGSUP, LOGL_NOTICE,</span><br><span style="color: hsl(0, 100%, 40%);">-                    "GSUP received an invalid IPA/CCM message from %s:%d\n",</span><br><span style="color: hsl(0, 100%, 40%);">-              link->addr, link->port);</span><br><span style="color: hsl(0, 100%, 40%);">-             /* Link has been closed */</span><br><span style="color: hsl(0, 100%, 40%);">-              gsupc->is_connected = 0;</span><br><span style="color: hsl(0, 100%, 40%);">-             msgb_free(msg);</span><br><span style="color: hsl(0, 100%, 40%);">-         return -1;</span><br><span style="color: hsl(0, 100%, 40%);">-      }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       if (rc == 1) {</span><br><span style="color: hsl(0, 100%, 40%);">-          uint8_t msg_type = *(msg->l2h);</span><br><span style="color: hsl(0, 100%, 40%);">-              /* CCM message */</span><br><span style="color: hsl(0, 100%, 40%);">-               if (msg_type == IPAC_MSGT_PONG) {</span><br><span style="color: hsl(0, 100%, 40%);">-                       LOGP(DLGSUP, LOGL_DEBUG, "GSUP receiving PONG\n");</span><br><span style="color: hsl(0, 100%, 40%);">-                    gsupc->got_ipa_pong = 1;</span><br><span style="color: hsl(0, 100%, 40%);">-             }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-               msgb_free(msg);</span><br><span style="color: hsl(0, 100%, 40%);">-         return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-       }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       if (hh->proto != IPAC_PROTO_OSMO)</span><br><span style="color: hsl(0, 100%, 40%);">-            goto invalid;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-   if (!he || msgb_l2len(msg) < sizeof(*he))</span><br><span style="color: hsl(0, 100%, 40%);">-            goto invalid;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-   msg->l2h = &he->data[0];</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      if (he->proto == IPAC_PROTO_EXT_GSUP) {</span><br><span style="color: hsl(0, 100%, 40%);">-              OSMO_ASSERT(gsupc->read_cb != NULL);</span><br><span style="color: hsl(0, 100%, 40%);">-         gsupc->read_cb(gsupc, msg);</span><br><span style="color: hsl(0, 100%, 40%);">-          /* expecting read_cb() to free msg */</span><br><span style="color: hsl(0, 100%, 40%);">-   } else if (he->proto == IPAC_PROTO_EXT_OAP) {</span><br><span style="color: hsl(0, 100%, 40%);">-                return gsup_client_oap_handle(gsupc, msg);</span><br><span style="color: hsl(0, 100%, 40%);">-              /* gsup_client_oap_handle frees msg */</span><br><span style="color: hsl(0, 100%, 40%);">-  } else</span><br><span style="color: hsl(0, 100%, 40%);">-          goto invalid;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-   return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-invalid:</span><br><span style="color: hsl(0, 100%, 40%);">-       LOGP(DLGSUP, LOGL_NOTICE,</span><br><span style="color: hsl(0, 100%, 40%);">-            "GSUP received an invalid IPA message from %s:%d, size = %d\n",</span><br><span style="color: hsl(0, 100%, 40%);">-       link->addr, link->port, msgb_length(msg));</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-   msgb_free(msg);</span><br><span style="color: hsl(0, 100%, 40%);">- return -1;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void ping_timer_cb(void *gsupc_)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-     struct gsup_client *gsupc = gsupc_;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     LOGP(DLGSUP, LOGL_INFO, "GSUP ping callback (%s, %s PONG)\n",</span><br><span style="color: hsl(0, 100%, 40%);">-      gsupc->is_connected ? "connected" : "not connected",</span><br><span style="color: hsl(0, 100%, 40%);">-             gsupc->got_ipa_pong ? "got" : "didn't get");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    if (gsupc->got_ipa_pong) {</span><br><span style="color: hsl(0, 100%, 40%);">-           start_test_procedure(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-            return;</span><br><span style="color: hsl(0, 100%, 40%);">- }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       LOGP(DLGSUP, LOGL_NOTICE, "GSUP ping timed out, reconnecting\n");</span><br><span style="color: hsl(0, 100%, 40%);">-     ipa_client_conn_close(gsupc->link);</span><br><span style="color: hsl(0, 100%, 40%);">-  gsupc->is_connected = 0;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     gsup_client_connect(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void start_test_procedure(struct gsup_client *gsupc)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-        osmo_timer_setup(&gsupc->ping_timer, ping_timer_cb, gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      gsupc->got_ipa_pong = 0;</span><br><span style="color: hsl(0, 100%, 40%);">-     osmo_timer_schedule(&gsupc->ping_timer, GSUP_CLIENT_PING_INTERVAL, 0);</span><br><span style="color: hsl(0, 100%, 40%);">-   LOGP(DLGSUP, LOGL_DEBUG, "GSUP sending PING\n");</span><br><span style="color: hsl(0, 100%, 40%);">-      gsup_client_send_ping(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct gsup_client *gsup_client_create(void *talloc_ctx,</span><br><span style="color: hsl(0, 100%, 40%);">-                                 const char *unit_name,</span><br><span style="color: hsl(0, 100%, 40%);">-                                  const char *ip_addr,</span><br><span style="color: hsl(0, 100%, 40%);">-                                    unsigned int tcp_port,</span><br><span style="color: hsl(0, 100%, 40%);">-                                  gsup_client_read_cb_t read_cb,</span><br><span style="color: hsl(0, 100%, 40%);">-                                  struct osmo_oap_client_config *oapc_config)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-     struct gsup_client *gsupc;</span><br><span style="color: hsl(0, 100%, 40%);">-      int rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- gsupc = talloc_zero(talloc_ctx, struct gsup_client);</span><br><span style="color: hsl(0, 100%, 40%);">-    OSMO_ASSERT(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     /* struct ipaccess_unit has a non-const unit_name, so let's copy to be</span><br><span style="color: hsl(0, 100%, 40%);">-       * able to have a non-const unit_name here as well. To not taint the</span><br><span style="color: hsl(0, 100%, 40%);">-     * public gsup_client API, let's store it in a const char* anyway. */</span><br><span style="color: hsl(0, 100%, 40%);">-       gsupc->unit_name = talloc_strdup(gsupc, unit_name);</span><br><span style="color: hsl(0, 100%, 40%);">-  OSMO_ASSERT(gsupc->unit_name);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       /* a NULL oapc_config will mark oap_state disabled. */</span><br><span style="color: hsl(0, 100%, 40%);">-  rc = osmo_oap_client_init(oapc_config, &gsupc->oap_state);</span><br><span style="color: hsl(0, 100%, 40%);">-       if (rc != 0)</span><br><span style="color: hsl(0, 100%, 40%);">-            goto failed;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    gsupc->link = ipa_client_conn_create(gsupc,</span><br><span style="color: hsl(0, 100%, 40%);">-                                       /* no e1inp */ NULL,</span><br><span style="color: hsl(0, 100%, 40%);">-                                            0,</span><br><span style="color: hsl(0, 100%, 40%);">-                                      ip_addr, tcp_port,</span><br><span style="color: hsl(0, 100%, 40%);">-                                      gsup_client_updown_cb,</span><br><span style="color: hsl(0, 100%, 40%);">-                                          gsup_client_read_cb,</span><br><span style="color: hsl(0, 100%, 40%);">-                                            /* default write_cb */ NULL,</span><br><span style="color: hsl(0, 100%, 40%);">-                                            gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-    if (!gsupc->link)</span><br><span style="color: hsl(0, 100%, 40%);">-            goto failed;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    osmo_timer_setup(&gsupc->connect_timer, connect_timer_cb, gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-        rc = gsup_client_connect(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-        if (rc < 0)</span><br><span style="color: hsl(0, 100%, 40%);">-          goto failed;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    gsupc->read_cb = read_cb;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    return gsupc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-failed:</span><br><span style="color: hsl(0, 100%, 40%);">-    gsup_client_destroy(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-     return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-void gsup_client_destroy(struct gsup_client *gsupc)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-       osmo_timer_del(&gsupc->connect_timer);</span><br><span style="color: hsl(0, 100%, 40%);">-   osmo_timer_del(&gsupc->ping_timer);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      if (gsupc->link) {</span><br><span style="color: hsl(0, 100%, 40%);">-           ipa_client_conn_close(gsupc->link);</span><br><span style="color: hsl(0, 100%, 40%);">-          ipa_client_conn_destroy(gsupc->link);</span><br><span style="color: hsl(0, 100%, 40%);">-                gsupc->link = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-  }</span><br><span style="color: hsl(0, 100%, 40%);">-       talloc_free(gsupc);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-int gsup_client_send(struct gsup_client *gsupc, struct msgb *msg)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-  if (!gsupc || !gsupc->is_connected) {</span><br><span style="color: hsl(0, 100%, 40%);">-                LOGP(DLGSUP, LOGL_ERROR, "GSUP not connected, unable to send %s\n", msgb_hexdump(msg));</span><br><span style="color: hsl(0, 100%, 40%);">-               msgb_free(msg);</span><br><span style="color: hsl(0, 100%, 40%);">-         return -ENOTCONN;</span><br><span style="color: hsl(0, 100%, 40%);">-       }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       client_send(gsupc, IPAC_PROTO_EXT_GSUP, msg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-   return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct msgb *gsup_client_msgb_alloc(void)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-    return msgb_alloc_headroom(4000, 64, __func__);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span>diff --git a/src/libgsupclient/gsup_test_client.c b/src/libgsupclient/gsup_test_client.c</span><br><span>deleted file mode 100644</span><br><span>index 0ebcd4a..0000000</span><br><span>--- a/src/libgsupclient/gsup_test_client.c</span><br><span>+++ /dev/null</span><br><span>@@ -1,321 +0,0 @@</span><br><span style="color: hsl(0, 100%, 40%);">-#include <string.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <stdio.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <errno.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <signal.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/linuxlist.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/msgb.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/select.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/application.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/utils.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/core/logging.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/gsm/gsup.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/msc/gsup_client.h></span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static struct gsup_client *g_gc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/***********************************************************************</span><br><span style="color: hsl(0, 100%, 40%);">- * IMSI Operation</span><br><span style="color: hsl(0, 100%, 40%);">- ***********************************************************************/</span><br><span style="color: hsl(0, 100%, 40%);">-static LLIST_HEAD(g_imsi_ops);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct imsi_op_stats {</span><br><span style="color: hsl(0, 100%, 40%);">- uint32_t num_alloc;</span><br><span style="color: hsl(0, 100%, 40%);">-     uint32_t num_released;</span><br><span style="color: hsl(0, 100%, 40%);">-  uint32_t num_rx_success;</span><br><span style="color: hsl(0, 100%, 40%);">-        uint32_t num_rx_error;</span><br><span style="color: hsl(0, 100%, 40%);">-  uint32_t num_timeout;</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-enum imsi_op_type {</span><br><span style="color: hsl(0, 100%, 40%);">-      IMSI_OP_SAI,</span><br><span style="color: hsl(0, 100%, 40%);">-    IMSI_OP_LU,</span><br><span style="color: hsl(0, 100%, 40%);">-     IMSI_OP_ISD,</span><br><span style="color: hsl(0, 100%, 40%);">-    _NUM_IMSI_OP</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static const struct value_string imsi_op_names[] = {</span><br><span style="color: hsl(0, 100%, 40%);">-      { IMSI_OP_SAI, "SAI" },</span><br><span style="color: hsl(0, 100%, 40%);">-       { IMSI_OP_LU, "LU" },</span><br><span style="color: hsl(0, 100%, 40%);">- { IMSI_OP_ISD, "ISD" },</span><br><span style="color: hsl(0, 100%, 40%);">-       { 0, NULL }</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static struct imsi_op_stats imsi_op_stats[_NUM_IMSI_OP];</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-struct imsi_op {</span><br><span style="color: hsl(0, 100%, 40%);">-   struct llist_head list;</span><br><span style="color: hsl(0, 100%, 40%);">- char imsi[17];</span><br><span style="color: hsl(0, 100%, 40%);">-  enum imsi_op_type type;</span><br><span style="color: hsl(0, 100%, 40%);">- struct osmo_timer_list timer;</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static struct imsi_op *imsi_op_find(const char *imsi,</span><br><span style="color: hsl(0, 100%, 40%);">-                         enum imsi_op_type type)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-   struct imsi_op *io;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     llist_for_each_entry(io, &g_imsi_ops, list) {</span><br><span style="color: hsl(0, 100%, 40%);">-               if (!strcmp(io->imsi, imsi) && io->type == type)</span><br><span style="color: hsl(0, 100%, 40%);">-                  return io;</span><br><span style="color: hsl(0, 100%, 40%);">-      }</span><br><span style="color: hsl(0, 100%, 40%);">-       return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void imsi_op_timer_cb(void *data);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static struct imsi_op *imsi_op_alloc(void *ctx, const char *imsi,</span><br><span style="color: hsl(0, 100%, 40%);">-                         enum imsi_op_type type)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-        struct imsi_op *io;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     if (imsi_op_find(imsi, type))</span><br><span style="color: hsl(0, 100%, 40%);">-           return NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    io = talloc_zero(ctx, struct imsi_op);</span><br><span style="color: hsl(0, 100%, 40%);">-  OSMO_STRLCPY_ARRAY(io->imsi, imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-  io->type = type;</span><br><span style="color: hsl(0, 100%, 40%);">-     osmo_timer_setup(&io->timer, imsi_op_timer_cb, io);</span><br><span style="color: hsl(0, 100%, 40%);">-      llist_add(&io->list, &g_imsi_ops);</span><br><span style="color: hsl(0, 100%, 40%);">-   imsi_op_stats[type].num_alloc++;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-        return io;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void imsi_op_release(struct imsi_op *io)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-     osmo_timer_del(&io->timer);</span><br><span style="color: hsl(0, 100%, 40%);">-      llist_del(&io->list);</span><br><span style="color: hsl(0, 100%, 40%);">-    imsi_op_stats[io->type].num_released++;</span><br><span style="color: hsl(0, 100%, 40%);">-      talloc_free(io);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void imsi_op_timer_cb(void *data)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-      struct imsi_op *io = data;</span><br><span style="color: hsl(0, 100%, 40%);">-      printf("%s: Timer expiration\n", io->imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-        imsi_op_stats[io->type].num_timeout++;</span><br><span style="color: hsl(0, 100%, 40%);">-       imsi_op_release(io);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* allocate + generate + send Send-Auth-Info */</span><br><span style="color: hsl(0, 100%, 40%);">-static int req_auth_info(const char *imsi)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">- struct imsi_op *io = imsi_op_alloc(g_gc, imsi, IMSI_OP_SAI);</span><br><span style="color: hsl(0, 100%, 40%);">-    struct osmo_gsup_message gsup = {0};</span><br><span style="color: hsl(0, 100%, 40%);">-    struct msgb *msg = msgb_alloc_headroom(1200, 200, __func__);</span><br><span style="color: hsl(0, 100%, 40%);">-    int rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- OSMO_STRLCPY_ARRAY(gsup.imsi, io->imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-     gsup.message_type = OSMO_GSUP_MSGT_SEND_AUTH_INFO_REQUEST;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      rc = osmo_gsup_encode(msg, &gsup);</span><br><span style="color: hsl(0, 100%, 40%);">-  if (rc < 0) {</span><br><span style="color: hsl(0, 100%, 40%);">-                printf("%s: encoding failure (%s)\n", imsi, strerror(-rc));</span><br><span style="color: hsl(0, 100%, 40%);">-           return rc;</span><br><span style="color: hsl(0, 100%, 40%);">-      }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       return gsup_client_send(g_gc, msg);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* allocate + generate + send Send-Auth-Info */</span><br><span style="color: hsl(0, 100%, 40%);">-static int req_loc_upd(const char *imsi)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-    struct imsi_op *io = imsi_op_alloc(g_gc, imsi, IMSI_OP_LU);</span><br><span style="color: hsl(0, 100%, 40%);">-     struct osmo_gsup_message gsup = {0};</span><br><span style="color: hsl(0, 100%, 40%);">-    struct msgb *msg = msgb_alloc_headroom(1200, 200, __func__);</span><br><span style="color: hsl(0, 100%, 40%);">-    int rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- OSMO_STRLCPY_ARRAY(gsup.imsi, io->imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-     gsup.message_type = OSMO_GSUP_MSGT_UPDATE_LOCATION_REQUEST;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-     rc = osmo_gsup_encode(msg, &gsup);</span><br><span style="color: hsl(0, 100%, 40%);">-  if (rc < 0) {</span><br><span style="color: hsl(0, 100%, 40%);">-                printf("%s: encoding failure (%s)\n", imsi, strerror(-rc));</span><br><span style="color: hsl(0, 100%, 40%);">-           return rc;</span><br><span style="color: hsl(0, 100%, 40%);">-      }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       return gsup_client_send(g_gc, msg);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int resp_isd(struct imsi_op *io)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-    struct osmo_gsup_message gsup = {0};</span><br><span style="color: hsl(0, 100%, 40%);">-    struct msgb *msg = msgb_alloc_headroom(1200, 200, __func__);</span><br><span style="color: hsl(0, 100%, 40%);">-    int rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- OSMO_STRLCPY_ARRAY(gsup.imsi, io->imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-     gsup.message_type = OSMO_GSUP_MSGT_INSERT_DATA_RESULT;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-  rc = osmo_gsup_encode(msg, &gsup);</span><br><span style="color: hsl(0, 100%, 40%);">-  if (rc < 0) {</span><br><span style="color: hsl(0, 100%, 40%);">-                printf("%s: encoding failure (%s)\n", io->imsi, strerror(-rc));</span><br><span style="color: hsl(0, 100%, 40%);">-            return rc;</span><br><span style="color: hsl(0, 100%, 40%);">-      }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       imsi_op_release(io);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    return gsup_client_send(g_gc, msg);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* receive an incoming GSUP message */</span><br><span style="color: hsl(0, 100%, 40%);">-static void imsi_op_rx_gsup(struct imsi_op *io, const struct osmo_gsup_message *gsup)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-        int is_error = 0, rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-   if (OSMO_GSUP_IS_MSGT_ERROR(gsup->message_type)) {</span><br><span style="color: hsl(0, 100%, 40%);">-           imsi_op_stats[io->type].num_rx_error++;</span><br><span style="color: hsl(0, 100%, 40%);">-              is_error = 1;</span><br><span style="color: hsl(0, 100%, 40%);">-   } else</span><br><span style="color: hsl(0, 100%, 40%);">-          imsi_op_stats[io->type].num_rx_success++;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    switch (io->type) {</span><br><span style="color: hsl(0, 100%, 40%);">-  case IMSI_OP_SAI:</span><br><span style="color: hsl(0, 100%, 40%);">-               printf("%s; SAI Response%s\n", io->imsi, is_error ? ": ERROR" : "");</span><br><span style="color: hsl(0, 100%, 40%);">-           /* now that we have auth tuples, request LU */</span><br><span style="color: hsl(0, 100%, 40%);">-          rc = req_loc_upd(io->imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-          if (rc < 0)</span><br><span style="color: hsl(0, 100%, 40%);">-                  printf("Failed to request Location Update for %s\n", io->imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-            imsi_op_release(io);</span><br><span style="color: hsl(0, 100%, 40%);">-            break;</span><br><span style="color: hsl(0, 100%, 40%);">-  case IMSI_OP_LU:</span><br><span style="color: hsl(0, 100%, 40%);">-                printf("%s; LU Response%s\n", io->imsi, is_error ? ": ERROR" : "");</span><br><span style="color: hsl(0, 100%, 40%);">-            imsi_op_release(io);</span><br><span style="color: hsl(0, 100%, 40%);">-            break;</span><br><span style="color: hsl(0, 100%, 40%);">-  case IMSI_OP_ISD:</span><br><span style="color: hsl(0, 100%, 40%);">-               printf("%s; ISD Request%s\n", io->imsi, is_error ? ": ERROR" : "");</span><br><span style="color: hsl(0, 100%, 40%);">-            rc = resp_isd(io);</span><br><span style="color: hsl(0, 100%, 40%);">-              if (rc < 0)</span><br><span style="color: hsl(0, 100%, 40%);">-                  printf("Failed to insert subscriber data for %s\n", io->imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-             break;</span><br><span style="color: hsl(0, 100%, 40%);">-  default:</span><br><span style="color: hsl(0, 100%, 40%);">-                printf("%s: Unknown\n", io->imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-         imsi_op_release(io);</span><br><span style="color: hsl(0, 100%, 40%);">-            break;</span><br><span style="color: hsl(0, 100%, 40%);">-  }</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int op_type_by_gsup_msgt(enum osmo_gsup_message_type msg_type)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-        switch (msg_type) {</span><br><span style="color: hsl(0, 100%, 40%);">-     case OSMO_GSUP_MSGT_SEND_AUTH_INFO_RESULT:</span><br><span style="color: hsl(0, 100%, 40%);">-      case OSMO_GSUP_MSGT_SEND_AUTH_INFO_ERROR:</span><br><span style="color: hsl(0, 100%, 40%);">-               return IMSI_OP_SAI;</span><br><span style="color: hsl(0, 100%, 40%);">-     case OSMO_GSUP_MSGT_UPDATE_LOCATION_RESULT:</span><br><span style="color: hsl(0, 100%, 40%);">-     case OSMO_GSUP_MSGT_UPDATE_LOCATION_ERROR:</span><br><span style="color: hsl(0, 100%, 40%);">-              return IMSI_OP_LU;</span><br><span style="color: hsl(0, 100%, 40%);">-      case OSMO_GSUP_MSGT_INSERT_DATA_REQUEST:</span><br><span style="color: hsl(0, 100%, 40%);">-                return IMSI_OP_ISD;</span><br><span style="color: hsl(0, 100%, 40%);">-     default:</span><br><span style="color: hsl(0, 100%, 40%);">-                printf("Unknown GSUP msg_type %u\n", msg_type);</span><br><span style="color: hsl(0, 100%, 40%);">-               return -1;</span><br><span style="color: hsl(0, 100%, 40%);">-      }</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static int gsupc_read_cb(struct gsup_client *gsupc, struct msgb *msg)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-        struct osmo_gsup_message gsup_msg = {0};</span><br><span style="color: hsl(0, 100%, 40%);">-        struct imsi_op *io = NULL;</span><br><span style="color: hsl(0, 100%, 40%);">-      int rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- DEBUGP(DLGSUP, "Rx GSUP %s\n", msgb_hexdump(msg));</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-    rc = osmo_gsup_decode(msgb_l2(msg), msgb_l2len(msg), &gsup_msg);</span><br><span style="color: hsl(0, 100%, 40%);">-    if (rc < 0)</span><br><span style="color: hsl(0, 100%, 40%);">-          return rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      if (!gsup_msg.imsi[0])</span><br><span style="color: hsl(0, 100%, 40%);">-          return -1;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      rc = op_type_by_gsup_msgt(gsup_msg.message_type);</span><br><span style="color: hsl(0, 100%, 40%);">-       if (rc < 0)</span><br><span style="color: hsl(0, 100%, 40%);">-          return rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      switch (rc) {</span><br><span style="color: hsl(0, 100%, 40%);">-   case IMSI_OP_SAI:</span><br><span style="color: hsl(0, 100%, 40%);">-       case IMSI_OP_LU:</span><br><span style="color: hsl(0, 100%, 40%);">-                io = imsi_op_find(gsup_msg.imsi, rc);</span><br><span style="color: hsl(0, 100%, 40%);">-           break;</span><br><span style="color: hsl(0, 100%, 40%);">-  case IMSI_OP_ISD:</span><br><span style="color: hsl(0, 100%, 40%);">-               /* ISD is an inbound transaction */</span><br><span style="color: hsl(0, 100%, 40%);">-             io = imsi_op_alloc(g_gc, gsup_msg.imsi, IMSI_OP_ISD);</span><br><span style="color: hsl(0, 100%, 40%);">-           break;</span><br><span style="color: hsl(0, 100%, 40%);">-  }</span><br><span style="color: hsl(0, 100%, 40%);">-       if (!io)</span><br><span style="color: hsl(0, 100%, 40%);">-                return -1;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-      imsi_op_rx_gsup(io, &gsup_msg);</span><br><span style="color: hsl(0, 100%, 40%);">-     msgb_free(msg);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- return 0;</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void print_report(void)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-       unsigned int i;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- for (i = 0; i < ARRAY_SIZE(imsi_op_stats); i++) {</span><br><span style="color: hsl(0, 100%, 40%);">-            struct imsi_op_stats *st = &imsi_op_stats[i];</span><br><span style="color: hsl(0, 100%, 40%);">-               const char *name = get_value_string(imsi_op_names, i);</span><br><span style="color: hsl(0, 100%, 40%);">-          printf("%s: %u alloc, %u released, %u success, %u error , %u tout\n",</span><br><span style="color: hsl(0, 100%, 40%);">-                 name, st->num_alloc, st->num_released, st->num_rx_success,</span><br><span style="color: hsl(0, 100%, 40%);">-                     st->num_rx_error, st->num_timeout);</span><br><span style="color: hsl(0, 100%, 40%);">-       }</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static void sig_cb(int sig)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-  switch (sig) {</span><br><span style="color: hsl(0, 100%, 40%);">-  case SIGINT:</span><br><span style="color: hsl(0, 100%, 40%);">-            print_report();</span><br><span style="color: hsl(0, 100%, 40%);">-         exit(0);</span><br><span style="color: hsl(0, 100%, 40%);">-                break;</span><br><span style="color: hsl(0, 100%, 40%);">-  }</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-/* default categories */</span><br><span style="color: hsl(0, 100%, 40%);">-static struct log_info_cat default_categories[] = {</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-static const struct log_info gsup_test_client_log_info = {</span><br><span style="color: hsl(0, 100%, 40%);">-       .cat = default_categories,</span><br><span style="color: hsl(0, 100%, 40%);">-      .num_cat = ARRAY_SIZE(default_categories),</span><br><span style="color: hsl(0, 100%, 40%);">-};</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-int main(int argc, char **argv)</span><br><span style="color: hsl(0, 100%, 40%);">-{</span><br><span style="color: hsl(0, 100%, 40%);">-    unsigned long long i;</span><br><span style="color: hsl(0, 100%, 40%);">-   char *server_host = "127.0.0.1";</span><br><span style="color: hsl(0, 100%, 40%);">-      uint16_t server_port = OSMO_GSUP_PORT;</span><br><span style="color: hsl(0, 100%, 40%);">-  void *ctx = talloc_named_const(NULL, 0, "gsup_test_client");</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-  osmo_init_logging2(ctx, &gsup_test_client_log_info);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-        g_gc = gsup_client_create(ctx, "GSUPTEST", server_host, server_port,</span><br><span style="color: hsl(0, 100%, 40%);">-                            gsupc_read_cb, NULL);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- signal(SIGINT, sig_cb);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">- for (i = 0; i < 10000; i++) {</span><br><span style="color: hsl(0, 100%, 40%);">-                unsigned long long imsi = 901790000000000 + i;</span><br><span style="color: hsl(0, 100%, 40%);">-          char imsi_buf[17] = { 0 };</span><br><span style="color: hsl(0, 100%, 40%);">-              int rc;</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-         snprintf(imsi_buf, sizeof(imsi_buf), "%015llu", imsi);</span><br><span style="color: hsl(0, 100%, 40%);">-                rc = req_auth_info(imsi_buf);</span><br><span style="color: hsl(0, 100%, 40%);">-           if (rc < 0)</span><br><span style="color: hsl(0, 100%, 40%);">-                  printf("Failed to request Auth Info for %s\n", imsi_buf);</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-             osmo_select_main(0);</span><br><span style="color: hsl(0, 100%, 40%);">-    }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       while (1) {</span><br><span style="color: hsl(0, 100%, 40%);">-             osmo_select_main(0);</span><br><span style="color: hsl(0, 100%, 40%);">-    }</span><br><span style="color: hsl(0, 100%, 40%);">-</span><br><span style="color: hsl(0, 100%, 40%);">-       print_report();</span><br><span style="color: hsl(0, 100%, 40%);">- exit(0);</span><br><span style="color: hsl(0, 100%, 40%);">-}</span><br><span>diff --git a/src/libmsc/gsm_09_11.c b/src/libmsc/gsm_09_11.c</span><br><span>index 9b0a9e4..342fd2b 100644</span><br><span>--- a/src/libmsc/gsm_09_11.c</span><br><span>+++ b/src/libmsc/gsm_09_11.c</span><br><span>@@ -43,7 +43,7 @@</span><br><span> #include <osmocom/msc/vlr.h></span><br><span> #include <osmocom/msc/gsm_04_08.h></span><br><span> #include <osmocom/msc/transaction.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/msc/gsup_client.h></span><br><span style="color: hsl(120, 100%, 40%);">+#include <osmocom/gsupclient/gsup_client.h></span><br><span> #include <osmocom/msc/msc_ifaces.h></span><br><span> </span><br><span> /* FIXME: choose a proper range */</span><br><span>@@ -165,7 +165,7 @@</span><br><span>         OSMO_STRLCPY_ARRAY(gsup_msg.imsi, conn->vsub->imsi);</span><br><span> </span><br><span>       /* Allocate GSUP message buffer */</span><br><span style="color: hsl(0, 100%, 40%);">-      gsup_msgb = gsup_client_msgb_alloc();</span><br><span style="color: hsl(120, 100%, 40%);">+ gsup_msgb = osmo_gsup_client_msgb_alloc();</span><br><span>   if (!gsup_msgb) {</span><br><span>            LOGP(DMM, LOGL_ERROR, "Couldn't allocate GSUP message\n");</span><br><span>             rc = -ENOMEM;</span><br><span>@@ -180,7 +180,7 @@</span><br><span>  }</span><br><span> </span><br><span>        /* Finally send */</span><br><span style="color: hsl(0, 100%, 40%);">-      rc = gsup_client_send(conn->network->vlr->gsup_client, gsup_msgb);</span><br><span style="color: hsl(120, 100%, 40%);">+   rc = osmo_gsup_client_send(conn->network->vlr->gsup_client, gsup_msgb);</span><br><span>     if (rc) {</span><br><span>            LOGP(DMM, LOGL_ERROR, "Couldn't send GSUP message\n");</span><br><span>                 goto error;</span><br><span>diff --git a/src/libvlr/vlr.c b/src/libvlr/vlr.c</span><br><span>index 2f7dc30..bfaf333 100644</span><br><span>--- a/src/libvlr/vlr.c</span><br><span>+++ b/src/libvlr/vlr.c</span><br><span>@@ -28,7 +28,7 @@</span><br><span> #include <osmocom/gsm/apn.h></span><br><span> #include <osmocom/gsm/gsm48.h></span><br><span> #include <osmocom/msc/gsm_subscriber.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/msc/gsup_client.h></span><br><span style="color: hsl(120, 100%, 40%);">+#include <osmocom/gsupclient/gsup_client.h></span><br><span> #include <osmocom/msc/vlr.h></span><br><span> #include <osmocom/msc/debug.h></span><br><span> </span><br><span>@@ -156,7 +156,7 @@</span><br><span> static int vlr_tx_gsup_message(const struct vlr_instance *vlr,</span><br><span>                          const struct osmo_gsup_message *gsup_msg)</span><br><span> {</span><br><span style="color: hsl(0, 100%, 40%);">-   struct msgb *msg = gsup_client_msgb_alloc();</span><br><span style="color: hsl(120, 100%, 40%);">+  struct msgb *msg = osmo_gsup_client_msgb_alloc();</span><br><span> </span><br><span>        int rc = osmo_gsup_encode(msg, gsup_msg);</span><br><span>    if (rc < 0) {</span><br><span>@@ -174,7 +174,7 @@</span><br><span>       LOGP(DVLR, LOGL_DEBUG, "GSUP tx: %s\n",</span><br><span>         osmo_hexdump_nospc(msg->data, msg->len));</span><br><span> </span><br><span style="color: hsl(0, 100%, 40%);">-        return gsup_client_send(vlr->gsup_client, msg);</span><br><span style="color: hsl(120, 100%, 40%);">+    return osmo_gsup_client_send(vlr->gsup_client, msg);</span><br><span> }</span><br><span> </span><br><span> /* Transmit GSUP message for subscriber to HLR, using IMSI from subscriber */</span><br><span>@@ -974,7 +974,7 @@</span><br><span> </span><br><span> /* Incoming handler for GSUP from HLR.</span><br><span>  * Keep this function non-static for direct invocation by unit tests. */</span><br><span style="color: hsl(0, 100%, 40%);">-int vlr_gsupc_read_cb(struct gsup_client *gsupc, struct msgb *msg)</span><br><span style="color: hsl(120, 100%, 40%);">+int vlr_gsupc_read_cb(struct osmo_gsup_client *gsupc, struct msgb *msg)</span><br><span> {</span><br><span>    struct vlr_instance *vlr = (struct vlr_instance *) gsupc->data;</span><br><span>   struct vlr_subscr *vsub;</span><br><span>@@ -1214,10 +1214,10 @@</span><br><span> {</span><br><span>      OSMO_ASSERT(vlr);</span><br><span> </span><br><span style="color: hsl(0, 100%, 40%);">-   vlr->gsup_client = gsup_client_create(vlr, gsup_unit_name,</span><br><span style="color: hsl(0, 100%, 40%);">-                                         gsup_server_addr_str,</span><br><span style="color: hsl(0, 100%, 40%);">-                                           gsup_server_port,</span><br><span style="color: hsl(0, 100%, 40%);">-                                       &vlr_gsupc_read_cb, NULL);</span><br><span style="color: hsl(120, 100%, 40%);">+  vlr->gsup_client = osmo_gsup_client_create(vlr, gsup_unit_name,</span><br><span style="color: hsl(120, 100%, 40%);">+                                               gsup_server_addr_str,</span><br><span style="color: hsl(120, 100%, 40%);">+                                                 gsup_server_port,</span><br><span style="color: hsl(120, 100%, 40%);">+                                             &vlr_gsupc_read_cb, NULL);</span><br><span>    if (!vlr->gsup_client)</span><br><span>            return -ENOMEM;</span><br><span>      vlr->gsup_client->data = vlr;</span><br><span>diff --git a/src/osmo-msc/Makefile.am b/src/osmo-msc/Makefile.am</span><br><span>index 42bc69f..bcc4ada 100644</span><br><span>--- a/src/osmo-msc/Makefile.am</span><br><span>+++ b/src/osmo-msc/Makefile.am</span><br><span>@@ -17,6 +17,7 @@</span><br><span>         $(LIBASN1C_CFLAGS) \</span><br><span>         $(LIBOSMOSIGTRAN_CFLAGS) \</span><br><span>   $(LIBOSMOMGCPCLIENT_CFLAGS) \</span><br><span style="color: hsl(120, 100%, 40%);">+ $(LIBOSMOGSUPCLIENT_CFLAGS) \</span><br><span>        $(NULL)</span><br><span> </span><br><span> AM_LDFLAGS = \</span><br><span>@@ -34,7 +35,6 @@</span><br><span> osmo_msc_LDADD = \</span><br><span>      $(top_builddir)/src/libmsc/libmsc.a \</span><br><span>        $(top_builddir)/src/libvlr/libvlr.a \</span><br><span style="color: hsl(0, 100%, 40%);">-   $(top_builddir)/src/libgsupclient/libgsupclient.a \</span><br><span>  $(LIBOSMOGSM_LIBS) \</span><br><span>         $(LIBOSMOVTY_LIBS) \</span><br><span>         $(LIBOSMOCORE_LIBS) \</span><br><span>@@ -43,6 +43,7 @@</span><br><span>    $(LIBSMPP34_LIBS) \</span><br><span>  $(LIBOSMOSIGTRAN_LIBS) \</span><br><span>     $(LIBOSMOMGCPCLIENT_LIBS) \</span><br><span style="color: hsl(120, 100%, 40%);">+   $(LIBOSMOGSUPCLIENT_LIBS) \</span><br><span>  -ldbi \</span><br><span>      $(NULL)</span><br><span> if BUILD_IU</span><br><span>diff --git a/tests/msc_vlr/Makefile.am b/tests/msc_vlr/Makefile.am</span><br><span>index 8b29f79..e6b20e6 100644</span><br><span>--- a/tests/msc_vlr/Makefile.am</span><br><span>+++ b/tests/msc_vlr/Makefile.am</span><br><span>@@ -15,11 +15,12 @@</span><br><span>        $(LIBOSMORANAP_CFLAGS) \</span><br><span>     $(LIBASN1C_CFLAGS) \</span><br><span>         $(LIBOSMOMGCPCLIENT_CFLAGS) \</span><br><span style="color: hsl(120, 100%, 40%);">+ $(LIBOSMOGSUPCLIENT_CFLAGS) \</span><br><span>        $(NULL)</span><br><span> </span><br><span> AM_LDFLAGS = \</span><br><span style="color: hsl(0, 100%, 40%);">-   -Wl,--wrap=gsup_client_create \</span><br><span style="color: hsl(0, 100%, 40%);">- -Wl,--wrap=gsup_client_send \</span><br><span style="color: hsl(120, 100%, 40%);">+ -Wl,--wrap=osmo_gsup_client_create \</span><br><span style="color: hsl(120, 100%, 40%);">+  -Wl,--wrap=osmo_gsup_client_send \</span><br><span>   -Wl,--wrap=a_iface_tx_dtap \</span><br><span>         -Wl,--wrap=a_iface_tx_clear_cmd \</span><br><span>    -Wl,--wrap=a_iface_tx_paging \</span><br><span>@@ -39,7 +40,6 @@</span><br><span> LDADD = \</span><br><span>      $(top_builddir)/src/libmsc/libmsc.a \</span><br><span>        $(top_builddir)/src/libvlr/libvlr.a \</span><br><span style="color: hsl(0, 100%, 40%);">-   $(top_builddir)/src/libgsupclient/libgsupclient.a \</span><br><span>  $(LIBSMPP34_LIBS) \</span><br><span>  $(LIBOSMOCORE_LIBS) \</span><br><span>        $(LIBOSMOGSM_LIBS) \</span><br><span>@@ -48,6 +48,7 @@</span><br><span>     $(LIBOSMOSIGTRAN_LIBS) \</span><br><span>     $(LIBOSMORANAP_LIBS) \</span><br><span>       $(LIBOSMOMGCPCLIENT_LIBS) \</span><br><span style="color: hsl(120, 100%, 40%);">+   $(LIBOSMOGSUPCLIENT_LIBS) \</span><br><span>  $(LIBRARY_GSM) \</span><br><span>     -ldbi \</span><br><span>      -lrt \</span><br><span>diff --git a/tests/msc_vlr/msc_vlr_tests.c b/tests/msc_vlr/msc_vlr_tests.c</span><br><span>index 1488109..f8551dd 100644</span><br><span>--- a/tests/msc_vlr/msc_vlr_tests.c</span><br><span>+++ b/tests/msc_vlr/msc_vlr_tests.c</span><br><span>@@ -30,7 +30,7 @@</span><br><span> #include <osmocom/core/application.h></span><br><span> #include <osmocom/gsm/protocol/gsm_04_11.h></span><br><span> #include <osmocom/gsm/gsup.h></span><br><span style="color: hsl(0, 100%, 40%);">-#include <osmocom/msc/gsup_client.h></span><br><span style="color: hsl(120, 100%, 40%);">+#include <osmocom/gsupclient/gsup_client.h></span><br><span> #include <osmocom/msc/gsm_04_11.h></span><br><span> #include <osmocom/msc/debug.h></span><br><span> #include <osmocom/msc/gsm_04_08.h></span><br><span>@@ -138,7 +138,7 @@</span><br><span>    dtap_tx_confirmed = false;</span><br><span> }</span><br><span> </span><br><span style="color: hsl(0, 100%, 40%);">-int vlr_gsupc_read_cb(struct gsup_client *gsupc, struct msgb *msg);</span><br><span style="color: hsl(120, 100%, 40%);">+int vlr_gsupc_read_cb(struct osmo_gsup_client *gsupc, struct msgb *msg);</span><br><span> </span><br><span> void gsup_rx(const char *rx_hex, const char *expect_tx_hex)</span><br><span> {</span><br><span>@@ -494,24 +494,24 @@</span><br><span> }</span><br><span> </span><br><span> /* override, requires '-Wl,--wrap=gsup_client_create' */</span><br><span style="color: hsl(0, 100%, 40%);">-struct gsup_client *</span><br><span style="color: hsl(0, 100%, 40%);">-__real_gsup_client_create(const char *ip_addr, unsigned int tcp_port,</span><br><span style="color: hsl(0, 100%, 40%);">-                    gsup_client_read_cb_t read_cb,</span><br><span style="color: hsl(120, 100%, 40%);">+struct osmo_gsup_client *</span><br><span style="color: hsl(120, 100%, 40%);">+__real_osmo_gsup_client_create(const char *ip_addr, unsigned int tcp_port,</span><br><span style="color: hsl(120, 100%, 40%);">+                         osmo_gsup_client_read_cb_t read_cb,</span><br><span>                          struct osmo_oap_client_config *oap_config);</span><br><span style="color: hsl(0, 100%, 40%);">-struct gsup_client *</span><br><span style="color: hsl(0, 100%, 40%);">-__wrap_gsup_client_create(const char *ip_addr, unsigned int tcp_port,</span><br><span style="color: hsl(0, 100%, 40%);">-                    gsup_client_read_cb_t read_cb,</span><br><span style="color: hsl(120, 100%, 40%);">+struct osmo_gsup_client *</span><br><span style="color: hsl(120, 100%, 40%);">+__wrap_osmo_gsup_client_create(const char *ip_addr, unsigned int tcp_port,</span><br><span style="color: hsl(120, 100%, 40%);">+                         osmo_gsup_client_read_cb_t read_cb,</span><br><span>                          struct osmo_oap_client_config *oap_config)</span><br><span> {</span><br><span style="color: hsl(0, 100%, 40%);">-       struct gsup_client *gsupc;</span><br><span style="color: hsl(0, 100%, 40%);">-      gsupc = talloc_zero(msc_vlr_tests_ctx, struct gsup_client);</span><br><span style="color: hsl(120, 100%, 40%);">+   struct osmo_gsup_client *gsupc;</span><br><span style="color: hsl(120, 100%, 40%);">+       gsupc = talloc_zero(msc_vlr_tests_ctx, struct osmo_gsup_client);</span><br><span>     OSMO_ASSERT(gsupc);</span><br><span>  return gsupc;</span><br><span> }</span><br><span> </span><br><span> /* override, requires '-Wl,--wrap=gsup_client_send' */</span><br><span style="color: hsl(0, 100%, 40%);">-int __real_gsup_client_send(struct gsup_client *gsupc, struct msgb *msg);</span><br><span style="color: hsl(0, 100%, 40%);">-int __wrap_gsup_client_send(struct gsup_client *gsupc, struct msgb *msg)</span><br><span style="color: hsl(120, 100%, 40%);">+int __real_osmo_gsup_client_send(struct osmo_gsup_client *gsupc, struct msgb *msg);</span><br><span style="color: hsl(120, 100%, 40%);">+int __wrap_osmo_gsup_client_send(struct osmo_gsup_client *gsupc, struct msgb *msg)</span><br><span> {</span><br><span>      const char *is = osmo_hexdump_nospc(msg->data, msg->len);</span><br><span>      fprintf(stderr, "GSUP --> HLR: %s: %s\n",</span><br><span>@@ -831,7 +831,7 @@</span><br><span>         /* Expecting these to stick around in msc_vlr_tests_ctx:</span><br><span>      * talloc_total_blocks(tall_bsc_ctx) == 12</span><br><span>    * full talloc report on 'msc_vlr_tests_ctx' (total   3636 bytes in  12 blocks)</span><br><span style="color: hsl(0, 100%, 40%);">-  *     struct gsup_client             contains    248 bytes in   1 blocks (ref 0) 0x563a489c05f0</span><br><span style="color: hsl(120, 100%, 40%);">+       *     struct osmo_gsup_client        contains    248 bytes in   1 blocks (ref 0) 0x563a489c05f0</span><br><span>      *     struct gsm_network             contains   2031 bytes in   4 blocks (ref 0) 0x563a489bfbb0</span><br><span>      *         struct vlr_instance            contains    168 bytes in   1 blocks (ref 0) 0x563a489c04e0</span><br><span>          *         no_gsup_server                 contains     15 bytes in   1 blocks (ref 0) 0x563a489c0460</span><br><span>diff --git a/tests/sms_queue/Makefile.am b/tests/sms_queue/Makefile.am</span><br><span>index 61b8515..1ffbe1c 100644</span><br><span>--- a/tests/sms_queue/Makefile.am</span><br><span>+++ b/tests/sms_queue/Makefile.am</span><br><span>@@ -14,6 +14,7 @@</span><br><span>    $(LIBOSMORANAP_CFLAGS) \</span><br><span>     $(LIBASN1C_CFLAGS) \</span><br><span>         $(LIBOSMOMGCPCLIENT_CFLAGS) \</span><br><span style="color: hsl(120, 100%, 40%);">+ $(LIBOSMOGSUPCLIENT_CFLAGS) \</span><br><span>        $(NULL)</span><br><span> </span><br><span> EXTRA_DIST = \</span><br><span>@@ -32,7 +33,6 @@</span><br><span> sms_queue_test_LDADD = \</span><br><span>        $(top_builddir)/src/libmsc/libmsc.a \</span><br><span>        $(top_builddir)/src/libvlr/libvlr.a \</span><br><span style="color: hsl(0, 100%, 40%);">-   $(top_builddir)/src/libgsupclient/libgsupclient.a \</span><br><span>  $(LIBSMPP34_LIBS) \</span><br><span>  $(LIBOSMOCORE_LIBS) \</span><br><span>        $(LIBOSMOGSM_LIBS) \</span><br><span>@@ -41,6 +41,7 @@</span><br><span>     $(LIBOSMOSIGTRAN_LIBS) \</span><br><span>     $(LIBOSMORANAP_LIBS) \</span><br><span>       $(LIBOSMOMGCPCLIENT_LIBS) \</span><br><span style="color: hsl(120, 100%, 40%);">+   $(LIBOSMOGSUPCLIENT_LIBS) \</span><br><span>  $(LIBRARY_GSM) \</span><br><span>     -ldbi \</span><br><span>      -lrt \</span><br><span></span><br></pre><p>To view, visit <a href="https://gerrit.osmocom.org/10283">change 10283</a>. To unsubscribe, or for help writing mail filters, visit <a href="https://gerrit.osmocom.org/settings">settings</a>.</p><div itemscope itemtype="http://schema.org/EmailMessage"><div itemscope itemprop="action" itemtype="http://schema.org/ViewAction"><link itemprop="url" href="https://gerrit.osmocom.org/10283"/><meta itemprop="name" content="View Change"/></div></div>

<div style="display:none"> Gerrit-Project: osmo-msc </div>
<div style="display:none"> Gerrit-Branch: master </div>
<div style="display:none"> Gerrit-MessageType: newchange </div>
<div style="display:none"> Gerrit-Change-Id: I6f542945403cf2e3ddac419186b09ec0e2d43b69 </div>
<div style="display:none"> Gerrit-Change-Number: 10283 </div>
<div style="display:none"> Gerrit-PatchSet: 1 </div>
<div style="display:none"> Gerrit-Owner: Harald Welte <laforge@gnumonks.org> </div>