pespin has uploaded this change for review.
Split AS/ASP/XUA_SRV VTY code to its own files
This allows readers finding more easily and focusing on the relevant
subset of VTY code for each node/object.
Change-Id: I90643bea41098cd6b711e493d4dc9852e88504b1
---
M src/Makefile.am
A src/ss7_as_vty.c
A src/ss7_asp_vty.c
M src/ss7_internal.h
M src/ss7_vty.c
A src/ss7_vty.h
A src/ss7_xua_srv_vty.c
7 files changed, 2,234 insertions(+), 2,015 deletions(-)
git pull ssh://gerrit.osmocom.org:29418/libosmo-sigtran refs/changes/56/40456/1
diff --git a/src/Makefile.am b/src/Makefile.am
index bba3d22..53b80c0 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -15,6 +15,7 @@
ss7_route.h \
ss7_route_table.h \
ss7_user.h \
+ ss7_vty.h \
ss7_xua_srv.h \
xua_asp_fsm.h \
xua_as_fsm.h \
@@ -54,7 +55,9 @@
sccp_vty.c \
ss7.c \
ss7_as.c \
+ ss7_as_vty.c \
ss7_asp.c \
+ ss7_asp_vty.c \
ss7_asp_peer.c \
ss7_combined_linkset.c \
ss7_hmrt.c \
@@ -63,6 +66,7 @@
ss7_linkset.c \
ss7_vty.c \
ss7_xua_srv.c \
+ ss7_xua_srv_vty.c \
ss7_route.c \
ss7_route_table.c \
ss7_user.c \
diff --git a/src/ss7_as_vty.c b/src/ss7_as_vty.c
new file mode 100644
index 0000000..6293de2
--- /dev/null
+++ b/src/ss7_as_vty.c
@@ -0,0 +1,627 @@
+/* SS7 AS VTY Interface */
+
+/* (C) 2015-2021 by Harald Welte <laforge@gnumonks.org>
+ * (C) 2025 by sysmocom s.f.m.c. GmbH <info@sysmocom.de>
+ * All Rights Reserved
+ *
+ * SPDX-License-Identifier: GPL-2.0+
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 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 General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+#include <stdlib.h>
+#include <unistd.h>
+#include <errno.h>
+#include <stdint.h>
+#include <string.h>
+
+#include <osmocom/vty/vty.h>
+#include <osmocom/vty/command.h>
+#include <osmocom/vty/logging.h>
+#include <osmocom/vty/telnet_interface.h>
+#include <osmocom/vty/misc.h>
+
+#include <osmocom/sigtran/protocol/mtp.h>
+
+#include "ss7_as.h"
+#include "ss7_asp.h"
+#include "ss7_route.h"
+#include "ss7_route_table.h"
+#include "ss7_internal.h"
+#include "ss7_vty.h"
+
+/***********************************************************************
+ * Application Server
+ ***********************************************************************/
+
+static struct cmd_node as_node = {
+ L_CS7_AS_NODE,
+ "%s(config-cs7-as)# ",
+ 1,
+};
+
+DEFUN_ATTR(cs7_as, cs7_as_cmd,
+ "as NAME " XUA_VAR_STR,
+ "Configure an Application Server\n"
+ "Name of the Application Server\n"
+ XUA_VAR_HELP_STR,
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_instance *inst = vty->index;
+ struct osmo_ss7_as *as;
+ const char *name = argv[0];
+ enum osmo_ss7_asp_protocol protocol = parse_asp_proto(argv[1]);
+
+ if (protocol == OSMO_SS7_ASP_PROT_NONE) {
+ vty_out(vty, "invalid protocol '%s'%s", argv[1], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ as = osmo_ss7_as_find_or_create(inst, name, protocol);
+ if (!as) {
+ vty_out(vty, "cannot create AS '%s'%s", name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ as->cfg.name = talloc_strdup(as, name);
+
+ vty->node = L_CS7_AS_NODE;
+ vty->index = as;
+ vty->index_sub = &as->cfg.description;
+
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(no_cs7_as, no_cs7_as_cmd,
+ "no as NAME",
+ NO_STR "Disable Application Server\n"
+ "Name of AS\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_instance *inst = vty->index;
+ const char *name = argv[0];
+ struct osmo_ss7_as *as;
+
+ as = osmo_ss7_as_find_by_name(inst, name);
+ if (!as) {
+ vty_out(vty, "No AS named '%s' found%s", name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ osmo_ss7_as_destroy(as);
+ return CMD_SUCCESS;
+}
+
+/* TODO: routing-key */
+DEFUN_ATTR(as_asp, as_asp_cmd,
+ "asp NAME",
+ "Specify that a given ASP is part of this AS\n"
+ "Name of ASP to be added to AS\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_as *as = vty->index;
+
+ if (osmo_ss7_as_add_asp(as, argv[0])) {
+ vty_out(vty, "cannot find ASP '%s'%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(as_no_asp, as_no_asp_cmd,
+ "no asp NAME",
+ NO_STR "Specify ASP to be removed from this AS\n"
+ "Name of ASP to be removed\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_as *as = vty->index;
+
+ if (osmo_ss7_as_del_asp(as, argv[0])) {
+ vty_out(vty, "cannot find ASP '%s'%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ return CMD_SUCCESS;
+}
+
+DEFUN_USRATTR(as_traf_mode, as_traf_mode_cmd,
+ OSMO_SCCP_LIB_ATTR_RSTRT_ASP,
+ "traffic-mode (broadcast | roundrobin | override)",
+ "Specifies traffic mode of operation of the ASP within the AS\n"
+ "Broadcast to all ASP within AS\n"
+ "Round-Robin between all ASP within AS\n"
+ "Override\n")
+{
+ struct osmo_ss7_as *as = vty->index;
+
+ as->cfg.mode = get_string_value(osmo_ss7_as_traffic_mode_vals, argv[0]);
+ as->cfg.mode_set_by_vty = true;
+ return CMD_SUCCESS;
+}
+
+DEFUN_USRATTR(as_traf_mode_loadshare, as_traf_mode_loadshare_cmd,
+ OSMO_SCCP_LIB_ATTR_RSTRT_ASP,
+ "traffic-mode loadshare [bindings] [sls] [opc-sls] [opc-shift] [<0-2>]",
+ "Specifies traffic mode of operation of the ASP within the AS\n"
+ "Share Load among all ASP within AS\n"
+ "Configure Loadshare parameters\n"
+ "Configure Loadshare SLS generation parameters\n"
+ "Generate extended SLS with OPC information\n"
+ "Shift OPC bits used during routing decision\n"
+ "How many bits from ITU OPC field (starting from least-significant-bit) to skip (default=0). 6 bits are always used\n"
+ )
+{
+ struct osmo_ss7_as *as = vty->index;
+
+ as->cfg.mode = OSMO_SS7_AS_TMOD_LOADSHARE;
+ as->cfg.mode_set_by_vty = true;
+ if (argc < 3) {
+ as->cfg.loadshare.opc_sls = false;
+ as->cfg.loadshare.opc_shift = 0;
+ return CMD_SUCCESS;
+ }
+ as->cfg.loadshare.opc_sls = true;
+ if (argc < 5) {
+ as->cfg.loadshare.opc_shift = 0;
+ return CMD_SUCCESS;
+ }
+ as->cfg.loadshare.opc_shift = atoi(argv[4]);
+ return CMD_SUCCESS;
+}
+
+DEFUN_USRATTR(as_no_traf_mode, as_no_traf_mode_cmd,
+ OSMO_SCCP_LIB_ATTR_RSTRT_ASP,
+ "no traffic-mode",
+ NO_STR "Remove explicit traffic mode of operation of this AS\n")
+{
+ struct osmo_ss7_as *as = vty->index;
+
+ as->cfg.mode = 0;
+ as->cfg.mode_set_by_vty = false;
+
+ as->cfg.loadshare.sls_shift = 0;
+ as->cfg.loadshare.opc_sls = false;
+ as->cfg.loadshare.opc_shift = 0;
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(as_sls_shift, as_sls_shift_cmd,
+ "sls-shift <0-3>",
+ "Shift SLS bits used during routing decision\n"
+ "How many bits from SLS field (starting from least-significant-bit) to skip\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_as *as = vty->index;
+ as->cfg.loadshare.sls_shift = atoi(argv[0]);
+
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(as_bindingtable_reset, as_bindingtable_reset_cmd,
+ "binding-table reset",
+ "AS Loadshare binding table operations\n"
+ "Reset loadshare binding table\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_as *as = vty->index;
+ ss7_as_loadshare_binding_table_reset(as);
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(as_recov_tout, as_recov_tout_cmd,
+ "recovery-timeout <1-2000>",
+ "Specifies the recovery timeout value in milliseconds\n"
+ "Recovery Timeout in Milliseconds\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_as *as = vty->index;
+ as->cfg.recovery_timeout_msec = atoi(argv[0]);
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(as_qos_clas, as_qos_class_cmd,
+ "qos-class " QOS_CLASS_RANGE_STR,
+ "Specity QoS Class of AS\n"
+ QOS_CLASS_RANGE_HELP_STR,
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_as *as = vty->index;
+ as->cfg.qos_class = atoi(argv[0]);
+ return CMD_SUCCESS;
+}
+
+const struct value_string mtp_si_vals[] = {
+ { MTP_SI_SCCP, "sccp" },
+ { MTP_SI_TUP, "tup" },
+ { MTP_SI_ISUP, "isup" },
+ { MTP_SI_DUP, "dup" },
+ { MTP_SI_TESTING, "testing" },
+ { MTP_SI_B_ISUP, "b-isup" },
+ { MTP_SI_SAT_ISUP, "sat-isup" },
+ { MTP_SI_AAL2_SIG, "aal2" },
+ { MTP_SI_BICC, "bicc" },
+ { MTP_SI_GCP, "h248" },
+ { 0, NULL }
+};
+
+#define ROUTING_KEY_CMD "routing-key RCONTEXT DPC"
+#define ROUTING_KEY_CMD_STRS \
+ "Define a routing key\n" \
+ "Routing context number\n" \
+ "Destination Point Code\n"
+#define ROUTING_KEY_SI_ARG " si (aal2|bicc|b-isup|h248|isup|sat-isup|sccp|tup)"
+#define ROUTING_KEY_SI_ARG_STRS \
+ "Match on Service Indicator\n" \
+ "ATM Adaption Layer 2\n" \
+ "Bearer Independent Call Control\n" \
+ "Broadband ISDN User Part\n" \
+ "H.248\n" \
+ "ISDN User Part\n" \
+ "Sattelite ISDN User Part\n" \
+ "Signalling Connection Control Part\n" \
+ "Telephony User Part\n"
+#define ROUTING_KEY_SSN_ARG " ssn SSN"
+#define ROUTING_KEY_SSN_ARG_STRS \
+ "Match on Sub-System Number\n" \
+ "Sub-System Number to match on\n"
+
+static int _rout_key(struct vty *vty,
+ const char *rcontext, const char *dpc,
+ const char *si, const char *ssn)
+{
+ struct osmo_ss7_as *as = vty->index;
+ struct osmo_ss7_routing_key *rkey = &as->cfg.routing_key;
+ struct osmo_ss7_route *rt;
+ int pc;
+
+ if (as->cfg.proto == OSMO_SS7_ASP_PROT_IPA && atoi(rcontext) != 0) {
+ vty_out(vty, "IPA doesn't support routing contexts; only permitted routing context "
+ "is 0\n");
+ return CMD_WARNING;
+ }
+
+ pc = osmo_ss7_pointcode_parse(as->inst, dpc);
+ if (pc < 0) {
+ vty_out(vty, "Invalid point code (%s)%s", dpc, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ /* When libosmo-sigtran is used in ASP role, the VTY routing table node
+ * (config-cs7-rt) is not available. However, when we add a routing key
+ * to an AS we still have to put a matching route into the routing
+ * table. This is done automatically by first removing the old route
+ * (users may change the routing key via VTY during runtime) and then
+ * putting a new route (see below). */
+ if (cs7_role == CS7_ROLE_ASP) {
+ rt = ss7_route_table_find_route_by_dpc_mask(as->inst->rtable_system, rkey->pc, 0xffffff);
+ if (rt)
+ ss7_route_destroy(rt);
+ }
+
+ rkey->pc = pc;
+
+ rkey->context = atoi(rcontext); /* FIXME: input validation */
+ rkey->si = si ? get_string_value(mtp_si_vals, si) : 0; /* FIXME: input validation */
+ rkey->ssn = ssn ? atoi(ssn) : 0; /* FIXME: input validation */
+
+ /* automatically add new route (see also comment above) */
+ if (cs7_role == CS7_ROLE_ASP) {
+ if (!ss7_route_create(as->inst->rtable_system, rkey->pc, 0xffffff, as->cfg.name)) {
+ vty_out(vty, "Cannot create route (pc=%s, linkset=%s) to AS %s", dpc, as->cfg.name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ }
+
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(as_rout_key, as_rout_key_cmd,
+ ROUTING_KEY_CMD,
+ ROUTING_KEY_CMD_STRS,
+ CMD_ATTR_IMMEDIATE)
+{
+ return _rout_key(vty, argv[0], argv[1], NULL, NULL);
+}
+
+DEFUN_ATTR(as_rout_key_si, as_rout_key_si_cmd,
+ ROUTING_KEY_CMD ROUTING_KEY_SI_ARG,
+ ROUTING_KEY_CMD_STRS ROUTING_KEY_SI_ARG_STRS,
+ CMD_ATTR_IMMEDIATE)
+{
+ return _rout_key(vty, argv[0], argv[1], argv[2], NULL);
+}
+
+DEFUN_ATTR(as_rout_key_ssn, as_rout_key_ssn_cmd,
+ ROUTING_KEY_CMD ROUTING_KEY_SSN_ARG,
+ ROUTING_KEY_CMD_STRS ROUTING_KEY_SSN_ARG_STRS,
+ CMD_ATTR_IMMEDIATE)
+{
+ return _rout_key(vty, argv[0], argv[1], NULL, argv[2]);
+}
+
+DEFUN_ATTR(as_rout_key_si_ssn, as_rout_key_si_ssn_cmd,
+ ROUTING_KEY_CMD ROUTING_KEY_SI_ARG ROUTING_KEY_SSN_ARG,
+ ROUTING_KEY_CMD_STRS ROUTING_KEY_SI_ARG_STRS ROUTING_KEY_SSN_ARG_STRS,
+ CMD_ATTR_IMMEDIATE)
+{
+ return _rout_key(vty, argv[0], argv[1], argv[2], argv[3]);
+}
+
+DEFUN_ATTR(as_pc_override, as_pc_override_cmd,
+ "point-code override dpc PC",
+ "Point Code Specific Features\n"
+ "Override (force) a point-code to hard-coded value\n"
+ "Override Source Point Code\n"
+ "Override Destination Point Code\n"
+ "New Point Code\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_as *as = vty->index;
+ int pc = osmo_ss7_pointcode_parse(as->inst, argv[0]);
+ if (pc < 0) {
+ vty_out(vty, "Invalid point code (%s)%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (as->cfg.proto != OSMO_SS7_ASP_PROT_IPA) {
+ vty_out(vty, "Only IPA type AS support point-code override. "
+ "Be happy that you don't need it!%s", VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ as->cfg.pc_override.dpc = pc;
+
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(as_pc_patch_sccp, as_pc_patch_sccp_cmd,
+ "point-code override patch-sccp (disabled|both)",
+ "Point Code Specific Features\n"
+ "Override (force) a point-code to hard-coded value\n"
+ "Patch point code values into SCCP called/calling address\n"
+ "Don't patch any point codes into SCCP called/calling address\n"
+ "Patch both origin and destination point codes into SCCP called/calling address\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_as *as = vty->index;
+
+ if (as->cfg.proto != OSMO_SS7_ASP_PROT_IPA) {
+ vty_out(vty, "Only IPA type AS support point-code patch-into-sccp. "
+ "Be happy that you don't need it!%s", VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (!strcmp(argv[0], "disabled"))
+ as->cfg.pc_override.sccp_mode = OSMO_SS7_PATCH_NONE;
+ else
+ as->cfg.pc_override.sccp_mode = OSMO_SS7_PATCH_BOTH;
+
+ return CMD_SUCCESS;
+}
+
+void ss7_vty_write_one_as(struct vty *vty, struct osmo_ss7_as *as, bool show_dyn_config)
+{
+ struct osmo_ss7_routing_key *rkey;
+ unsigned int i;
+
+ /* skip any dynamically allocated AS definitions */
+ if ((as->rkm_dyn_allocated || as->simple_client_allocated)
+ && !show_dyn_config)
+ return;
+
+ vty_out(vty, " as %s %s%s", as->cfg.name,
+ osmo_ss7_asp_protocol_name(as->cfg.proto), VTY_NEWLINE);
+ if (as->cfg.description)
+ vty_out(vty, " description %s%s", as->cfg.description, VTY_NEWLINE);
+ for (i = 0; i < ARRAY_SIZE(as->cfg.asps); i++) {
+ struct osmo_ss7_asp *asp = as->cfg.asps[i];
+ if (!asp)
+ continue;
+ /* skip any dynamically created ASPs (e.g. auto-created at connect time) */
+ if ((asp->dyn_allocated || asp->simple_client_allocated)
+ && !show_dyn_config)
+ continue;
+ vty_out(vty, " asp %s%s", asp->cfg.name, VTY_NEWLINE);
+ }
+ if (as->cfg.mode_set_by_vty) {
+ vty_out(vty, " traffic-mode %s%s", osmo_ss7_as_traffic_mode_name(as->cfg.mode), VTY_NEWLINE);
+ if (as->cfg.mode == OSMO_SS7_AS_TMOD_LOADSHARE) {
+ if (as->cfg.loadshare.opc_sls) {
+ vty_out(vty, " bindings sls opc-sls");
+ if (as->cfg.loadshare.opc_shift != 0)
+ vty_out(vty, " opc-shift %u", as->cfg.loadshare.opc_shift);
+ }
+ vty_out(vty, "%s", VTY_NEWLINE);
+ }
+
+ if (as->cfg.loadshare.sls_shift != 0)
+ vty_out(vty, " sls-shift %u%s", as->cfg.loadshare.sls_shift, VTY_NEWLINE);
+ }
+
+ if (as->cfg.recovery_timeout_msec != 2000) {
+ vty_out(vty, " recovery-timeout %u%s",
+ as->cfg.recovery_timeout_msec, VTY_NEWLINE);
+ }
+ if (as->cfg.qos_class)
+ vty_out(vty, " qos-class %u%s", as->cfg.qos_class, VTY_NEWLINE);
+ rkey = &as->cfg.routing_key;
+ vty_out(vty, " routing-key %u %s", rkey->context,
+ osmo_ss7_pointcode_print(as->inst, rkey->pc));
+ if (rkey->si)
+ vty_out(vty, " si %s",
+ get_value_string(mtp_si_vals, rkey->si));
+ if (rkey->ssn)
+ vty_out(vty, " ssn %u", rkey->ssn);
+ vty_out(vty, "%s", VTY_NEWLINE);
+
+ if (as->cfg.pc_override.dpc)
+ vty_out(vty, " point-code override dpc %s%s",
+ osmo_ss7_pointcode_print(as->inst, as->cfg.pc_override.dpc), VTY_NEWLINE);
+
+ if (as->cfg.pc_override.sccp_mode)
+ vty_out(vty, " point-code override patch-sccp both%s", VTY_NEWLINE);
+}
+
+static void show_one_as(struct vty *vty, struct osmo_ss7_as *as)
+{
+ vty_out(vty, "%-12s %-12s %-10u %-13s %4s %13s %3s %5s %4s %10s%s",
+ as->cfg.name, osmo_fsm_inst_state_name(as->fi), as->cfg.routing_key.context,
+ osmo_ss7_pointcode_print(as->inst, as->cfg.routing_key.pc),
+ "", "", "", "", "", osmo_ss7_as_traffic_mode_name(as->cfg.mode),
+ VTY_NEWLINE);
+}
+
+static int show_as(struct vty *vty, int id, const char *as_name, const char *filter)
+{
+ struct osmo_ss7_instance *inst;
+ struct osmo_ss7_as *as = NULL;
+
+ inst = osmo_ss7_instance_find(id);
+ if (!inst) {
+ vty_out(vty, "%% No SS7 instance %d found%s", id, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (as_name) {
+ as = osmo_ss7_as_find_by_name(inst, as_name);
+ if (!as) {
+ vty_out(vty, "%% No AS '%s' found%s", as_name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ }
+
+ vty_out(vty, " Routing Routing Key Cic Cic Traffic%s", VTY_NEWLINE);
+ vty_out(vty, "AS Name State Context Dpc Si Opc Ssn Min Max Mode%s", VTY_NEWLINE);
+ vty_out(vty, "------------ ------------ ---------- ------------- ---- ------------- --- ----- ----- -------%s", VTY_NEWLINE);
+
+ if (as) {
+ show_one_as(vty, as);
+ return CMD_SUCCESS;
+ }
+
+ llist_for_each_entry(as, &inst->as_list, list) {
+ if (filter && !strcmp(filter, "m3ua") && as->cfg.proto != OSMO_SS7_ASP_PROT_M3UA)
+ continue;
+ if (filter && !strcmp(filter, "sua") && as->cfg.proto != OSMO_SS7_ASP_PROT_SUA)
+ continue;
+ if (filter && !strcmp(filter, "active") && !osmo_ss7_as_active(as))
+ continue;
+ show_one_as(vty, as);
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN(show_cs7_as, show_cs7_as_cmd,
+ "show cs7 instance <0-15> as (active|all|m3ua|sua)",
+ SHOW_STR CS7_STR INST_STR INST_STR "Application Server (AS)\n"
+ "Display all active ASs\n"
+ "Display all ASs (default)\n"
+ "Display all m3ua ASs\n"
+ "Display all SUA ASs\n")
+{
+ const char *filter = argv[1];
+ int id = atoi(argv[0]);
+
+ return show_as(vty, id, NULL, filter);
+}
+
+DEFUN(show_cs7_as_name, show_cs7_as_name_cmd,
+ "show cs7 instance <0-15> as name AS_NAME",
+ SHOW_STR CS7_STR INST_STR INST_STR "Application Server (AS)\n"
+ "Look up AS with a given name\n"
+ "Name of the Application Server (AS)\n")
+{
+ int id = atoi(argv[0]);
+ const char *as_name = argv[1];
+
+ return show_as(vty, id, as_name, NULL);
+}
+
+DEFUN(show_cs7_as_bindingtable_name, show_cs7_as_bindingtable_name_cmd,
+ "show cs7 instance <0-15> as binding-table name AS_NAME",
+ SHOW_STR CS7_STR INST_STR INST_STR "Application Server (AS)\n"
+ "Display binding table\n"
+ "Look up AS with a given name\n"
+ "Name of the Application Server (AS)\n")
+{
+ int id = atoi(argv[0]);
+ const char *as_name = argv[1];
+ struct osmo_ss7_instance *inst;
+ struct osmo_ss7_as *as = NULL;
+
+ inst = osmo_ss7_instance_find(id);
+ if (!inst) {
+ vty_out(vty, "No SS7 instance %d found%s", id, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (as_name) {
+ as = osmo_ss7_as_find_by_name(inst, as_name);
+ if (!as) {
+ vty_out(vty, "No AS %s found%s", as_name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ }
+
+ vty_out(vty, "Loadshare Seed Normal ASP Active Alternative ASP Active%s", VTY_NEWLINE);
+ vty_out(vty, "-------------- --------------- ------ --------------- ------%s", VTY_NEWLINE);
+
+ for (unsigned int i = 0; i < ARRAY_SIZE(as->aesls_table); i++) {
+ struct osmo_ss7_as_esls_entry *e = &as->aesls_table[i];
+ vty_out(vty, "%-15u %-16s %-7s %-16s %-7s%s",
+ i,
+ e->normal_asp ? e->normal_asp->cfg.name : "-",
+ e->normal_asp ? (osmo_ss7_asp_active(e->normal_asp) ? "Yes" : "No") : "-",
+ e->alt_asp ? e->alt_asp->cfg.name : "-",
+ e->alt_asp ? (osmo_ss7_asp_active(e->alt_asp) ? "Yes" : "No") : "-",
+ VTY_NEWLINE);
+ }
+
+ return CMD_SUCCESS;
+}
+
+int ss7_vty_node_as_go_parent(struct vty *vty)
+{
+ struct osmo_ss7_as *as = vty->index;
+ vty->node = L_CS7_NODE;
+ vty->index = as->inst;
+ return 0;
+}
+
+void ss7_vty_init_node_as(void)
+{
+ install_node(&as_node, NULL);
+ install_lib_element_ve(&show_cs7_as_cmd);
+ install_lib_element_ve(&show_cs7_as_name_cmd);
+ install_lib_element_ve(&show_cs7_as_bindingtable_name_cmd);
+ install_lib_element(L_CS7_NODE, &cs7_as_cmd);
+ install_lib_element(L_CS7_NODE, &no_cs7_as_cmd);
+ install_lib_element(L_CS7_AS_NODE, &cfg_description_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_asp_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_no_asp_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_traf_mode_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_traf_mode_loadshare_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_no_traf_mode_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_sls_shift_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_bindingtable_reset_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_recov_tout_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_qos_class_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_rout_key_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_rout_key_si_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_rout_key_ssn_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_rout_key_si_ssn_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_pc_override_cmd);
+ install_lib_element(L_CS7_AS_NODE, &as_pc_patch_sccp_cmd);
+}
diff --git a/src/ss7_asp_vty.c b/src/ss7_asp_vty.c
new file mode 100644
index 0000000..2934ea3
--- /dev/null
+++ b/src/ss7_asp_vty.c
@@ -0,0 +1,1163 @@
+/* SS7 ASP VTY Interface */
+
+/* (C) 2015-2021 by Harald Welte <laforge@gnumonks.org>
+ * (C) 2025 by sysmocom s.f.m.c. GmbH <info@sysmocom.de>
+ * All Rights Reserved
+ *
+ * SPDX-License-Identifier: GPL-2.0+
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 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 General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+#include <stdlib.h>
+#include <unistd.h>
+#include <errno.h>
+#include <stdint.h>
+#include <string.h>
+
+#include <netdb.h>
+#include <arpa/inet.h>
+#include <sys/ioctl.h>
+
+#include <osmocom/core/sockaddr_str.h>
+
+#include <osmocom/vty/vty.h>
+#include <osmocom/vty/command.h>
+#include <osmocom/vty/logging.h>
+#include <osmocom/vty/telnet_interface.h>
+#include <osmocom/vty/misc.h>
+
+#include <osmocom/netif/stream.h>
+
+#include <osmocom/sigtran/osmo_ss7.h>
+
+#include "xua_internal.h"
+#include "ss7_as.h"
+#include "ss7_asp.h"
+#include "ss7_combined_linkset.h"
+#include <ss7_linkset.h>
+#include "ss7_internal.h"
+#include "ss7_vty.h"
+
+#include <netinet/tcp.h>
+
+#ifdef HAVE_LIBSCTP
+#include <netinet/sctp.h>
+#include <osmocom/netif/sctp.h>
+#endif
+
+/***********************************************************************
+ * Application Server Process
+ ***********************************************************************/
+
+static struct cmd_node asp_node = {
+ L_CS7_ASP_NODE,
+ "%s(config-cs7-asp)# ",
+ 1,
+};
+
+/* netinet/tcp.h */
+static const struct value_string tcp_info_state_values[] = {
+ { TCP_ESTABLISHED, "ESTABLISHED" },
+ { TCP_SYN_SENT, "SYN_SENT" },
+ { TCP_SYN_RECV, "SYN_RECV" },
+ { TCP_FIN_WAIT1, "FIN_WAIT1" },
+ { TCP_FIN_WAIT2, "FIN_WAIT2" },
+ { TCP_TIME_WAIT, "TIME_WAIT" },
+ { TCP_CLOSE, "CLOSE" },
+ { TCP_CLOSE_WAIT, "CLOSE_WAIT" },
+ { TCP_LAST_ACK, "LAST_ACK" },
+ { TCP_LISTEN, "LISTEN" },
+ { TCP_CLOSING, "CLOSING" },
+ {}
+};
+
+
+static const struct value_string asp_quirk_names[] = {
+ { OSMO_SS7_ASP_QUIRK_NO_NOTIFY, "no_notify" },
+ { OSMO_SS7_ASP_QUIRK_DAUD_IN_ASP, "daud_in_asp" },
+ { OSMO_SS7_ASP_QUIRK_SNM_INACTIVE, "snm_inactive" },
+ { 0, NULL }
+};
+
+static const struct value_string asp_quirk_descs[] = {
+ { OSMO_SS7_ASP_QUIRK_NO_NOTIFY, "Peer SG doesn't send NTFY(AS-INACTIVE) after ASP-UP" },
+ { OSMO_SS7_ASP_QUIRK_DAUD_IN_ASP, "Allow Rx of DAUD in ASP role" },
+ { OSMO_SS7_ASP_QUIRK_SNM_INACTIVE, "Allow Rx of [S]SNM in AS-INACTIVE state" },
+ { 0, NULL }
+};
+
+DEFUN_ATTR(cs7_asp, cs7_asp_cmd,
+ "asp NAME <0-65535> <0-65535> " XUA_VAR_STR,
+ "Configure Application Server Process\n"
+ "Name of ASP\n"
+ "Remote port number\n"
+ "Local port number\n"
+ XUA_VAR_HELP_STR,
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_instance *inst = vty->index;
+ const char *name = argv[0];
+ uint16_t remote_port = atoi(argv[1]);
+ uint16_t local_port = atoi(argv[2]);
+ enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[3]);
+ struct osmo_ss7_asp *asp;
+ int trans_proto;
+
+ if (proto == OSMO_SS7_ASP_PROT_NONE) {
+ vty_out(vty, "invalid protocol '%s'%s", argv[3], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ /* argv[4] can be supplied by an alias (see below) */
+ if (argc > 4)
+ trans_proto = parse_trans_proto(argv[4]);
+ else /* default transport protocol */
+ trans_proto = ss7_default_trans_proto_for_asp_proto(proto);
+ if (trans_proto < 0)
+ return CMD_WARNING;
+
+ asp = osmo_ss7_asp_find2(inst, name,
+ remote_port, local_port,
+ trans_proto, proto);
+ if (!asp) {
+ asp = osmo_ss7_asp_find_or_create2(inst, name,
+ remote_port, local_port,
+ trans_proto, proto);
+ if (!asp) {
+ vty_out(vty, "cannot create ASP '%s'%s", name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ asp->cfg.is_server = true;
+ asp->cfg.role = OSMO_SS7_ASP_ROLE_SG;
+ }
+
+ /* Reset value, will be checked at osmo_ss7_vty_go_parent() */
+ asp->cfg.explicit_shutdown_state_by_vty_since_node_enter = false;
+
+ vty->node = L_CS7_ASP_NODE;
+ vty->index = asp;
+ vty->index_sub = &asp->cfg.description;
+ return CMD_SUCCESS;
+}
+
+/* XXX: workaround for https://osmocom.org/issues/6360, can be removed once it's fixed.
+ * Currently we hit an assert if we make the IPPROTO_VAR_STR optional in cs7_asp_cmd. */
+ALIAS_ATTR(cs7_asp, cs7_asp_trans_proto_cmd,
+ "asp NAME <0-65535> <0-65535> " XUA_VAR_STR " " IPPROTO_VAR_STR,
+ "Configure Application Server Process\n"
+ "Name of ASP\n"
+ "Remote port number\n"
+ "Local port number\n"
+ XUA_VAR_HELP_STR
+ IPPROTO_VAR_HELP_STR,
+ CMD_ATTR_NODE_EXIT);
+
+DEFUN_ATTR(no_cs7_asp, no_cs7_asp_cmd,
+ "no asp NAME",
+ NO_STR "Disable Application Server Process\n"
+ "Name of ASP\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_instance *inst = vty->index;
+ const char *name = argv[0];
+ struct osmo_ss7_asp *asp;
+
+ asp = osmo_ss7_asp_find_by_name(inst, name);
+ if (!asp) {
+ vty_out(vty, "No ASP named '%s' found%s", name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ osmo_ss7_asp_destroy(asp);
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_local_ip, asp_local_ip_cmd,
+ "local-ip " VTY_IPV46_CMD " [primary]",
+ "Specify Local IP Address from which to contact ASP\n"
+ "Local IPv4 Address from which to contact of ASP\n"
+ "Local IPv6 Address from which to contact of ASP\n"
+ "Signal the SCTP peer to use this address as Primary Address\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+ bool is_primary = argc > 1;
+ int old_idx_primary = asp->cfg.local.idx_primary;
+ int old_host_count = asp->cfg.local.host_cnt;
+ int rc;
+
+ if (ss7_asp_peer_add_host2(&asp->cfg.local, asp, argv[0], is_primary) != 0) {
+ vty_out(vty, "%% Failed adding host '%s' to set%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (!ss7_asp_is_started(asp))
+ return CMD_SUCCESS;
+ if (asp->cfg.proto == OSMO_SS7_ASP_PROT_IPA)
+ return CMD_SUCCESS;
+ /* The SCTP socket is already created. */
+
+ /* dynamically apply the new address if it was added to the set: */
+ if (asp->cfg.local.host_cnt > old_host_count) {
+ if ((rc = ss7_asp_apply_new_local_address(asp, asp->cfg.local.host_cnt - 1)) < 0) {
+ /* Failed, rollback changes: */
+ TALLOC_FREE(asp->cfg.local.host[asp->cfg.local.host_cnt - 1]);
+ asp->cfg.local.host_cnt--;
+ vty_out(vty, "%% Failed adding new local address '%s'%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ vty_out(vty, "%% Local address '%s' added to the active socket bind set%s", argv[0], VTY_NEWLINE);
+ }
+
+ /* dynamically apply the new primary if it changed: */
+ if (is_primary && asp->cfg.local.idx_primary != old_idx_primary) {
+ if ((rc = ss7_asp_apply_peer_primary_address(asp)) < 0) {
+ /* Failed, rollback changes: */
+ asp->cfg.local.idx_primary = old_idx_primary;
+ vty_out(vty, "%% Failed announcing primary '%s' to peer%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ vty_out(vty, "%% Local address '%s' announced as primary to the peer on the active socket%s", argv[0], VTY_NEWLINE);
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_no_local_ip, asp_no_local_ip_cmd,
+ "no local-ip " VTY_IPV46_CMD,
+ NO_STR "Specify Local IP Address from which to contact ASP\n"
+ "Local IPv4 Address from which to contact of ASP\n"
+ "Local IPv6 Address from which to contact of ASP\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+ int idx = ss7_asp_peer_find_host(&asp->cfg.local, argv[0]);
+ int rc;
+
+ if (idx < 0) {
+ vty_out(vty, "%% Local address '%s' not found in set%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (ss7_asp_is_started(asp)) {
+ if (asp->cfg.proto != OSMO_SS7_ASP_PROT_IPA) {
+ if ((rc = ss7_asp_apply_drop_local_address(asp, idx)) < 0) {
+ vty_out(vty, "%% Failed removing local address '%s' from existing socket%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ vty_out(vty, "%% Local address '%s' removed from active socket connection%s", argv[0], VTY_NEWLINE);
+ }
+ }
+
+ if (ss7_asp_peer_del_host(&asp->cfg.local, argv[0]) != 0) {
+ vty_out(vty, "%% Failed deleting local address '%s' from set%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_remote_ip, asp_remote_ip_cmd,
+ "remote-ip " VTY_IPV46_CMD " [primary]",
+ "Specify Remote IP Address of ASP\n"
+ "Remote IPv4 Address of ASP\n"
+ "Remote IPv6 Address of ASP\n"
+ "Set remote address as SCTP Primary Address\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+ bool is_primary = argc > 1;
+ int old_idx_primary = asp->cfg.remote.idx_primary;
+ int rc;
+
+ if (ss7_asp_peer_add_host2(&asp->cfg.remote, asp, argv[0], is_primary) != 0) {
+ vty_out(vty, "%% Failed adding host '%s' to set%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (!ss7_asp_is_started(asp))
+ return CMD_SUCCESS;
+ if (asp->cfg.proto == OSMO_SS7_ASP_PROT_IPA)
+ return CMD_SUCCESS;
+
+ /* The SCTP socket is already created, dynamically apply the new primary if it changed: */
+ if (asp->cfg.proto != OSMO_SS7_ASP_PROT_IPA && ss7_asp_is_started(asp)) {
+ if ((rc = ss7_asp_apply_primary_address(asp)) < 0) {
+ /* Failed, rollback changes: */
+ asp->cfg.remote.idx_primary = old_idx_primary;
+ vty_out(vty, "%% Failed applying primary on host '%s'%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_no_remote_ip, asp_no_remote_ip_cmd,
+ "no remote-ip " VTY_IPV46_CMD,
+ NO_STR "Specify Remote IP Address of ASP\n"
+ "Remote IPv4 Address of ASP\n"
+ "Remote IPv6 Address of ASP\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+ int idx = ss7_asp_peer_find_host(&asp->cfg.remote, argv[0]);
+
+ if (idx < 0) {
+ vty_out(vty, "%% Remote address '%s' not found in set%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (ss7_asp_peer_del_host(&asp->cfg.remote, argv[0]) != 0) {
+ vty_out(vty, "%% Failed deleting remote address '%s' from set%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_qos_clas, asp_qos_class_cmd,
+ "qos-class " QOS_CLASS_RANGE_STR,
+ "Specify QoS Class of ASP\n"
+ QOS_CLASS_RANGE_HELP_STR,
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+ asp->cfg.qos_class = atoi(argv[0]);
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_role, asp_role_cmd,
+ "role (sg|asp|ipsp)",
+ "Specify the xUA role for this ASP\n"
+ "SG (Signaling Gateway)\n"
+ "ASP (Application Server Process)\n"
+ "IPSP (IP Signalling Point)\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+
+ if (!strcmp(argv[0], "ipsp")) {
+ vty_out(vty, "IPSP role isn't supported yet%s", VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (!strcmp(argv[0], "sg"))
+ asp->cfg.role = OSMO_SS7_ASP_ROLE_SG;
+ else if (!strcmp(argv[0], "asp"))
+ asp->cfg.role = OSMO_SS7_ASP_ROLE_ASP;
+ else
+ OSMO_ASSERT(0);
+
+ asp->cfg.role_set_by_vty = true;
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_transport_role, asp_transport_role_cmd,
+ "transport-role (client|server)",
+ "Specify the transport layer role for this ASP\n"
+ "Operate as a client; connect to a server\n"
+ "Operate as a server; wait for client connections\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+
+ if (!strcmp(argv[0], "client"))
+ asp->cfg.is_server = false;
+ else if (!strcmp(argv[0], "server"))
+ asp->cfg.is_server = true;
+ else
+ OSMO_ASSERT(0);
+
+ asp->cfg.trans_role_set_by_vty = true;
+ return CMD_SUCCESS;
+}
+
+ALIAS_ATTR(asp_transport_role, asp_sctp_role_cmd,
+ "sctp-role (client|server)",
+ "Specify the SCTP role for this ASP\n"
+ "Operate as SCTP client; connect to a server\n"
+ "Operate as SCTP server; wait for client connections\n",
+ CMD_ATTR_HIDDEN | CMD_ATTR_NODE_EXIT);
+
+#define ASP_SCTP_PARAM_INIT_DESC \
+ "Configure SCTP parameters\n" \
+ "Configure INIT related parameters\n" \
+ "Configure INIT Number of Outbound Streams\n" \
+ "Configure INIT Maximum Inboud Streams\n" \
+ "Configure INIT Maximum Attempts\n" \
+ "Configure INIT Timeout (milliseconds)\n"
+#define ASP_SCTP_PARAM_INIT_FIELDS "(num-ostreams|max-instreams|max-attempts|timeout)"
+
+DEFUN_ATTR(asp_sctp_param_init, asp_sctp_param_init_cmd,
+ "sctp-param init " ASP_SCTP_PARAM_INIT_FIELDS " <0-65535>",
+ ASP_SCTP_PARAM_INIT_DESC
+ "Value of the parameter\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+
+ uint16_t val = atoi(argv[1]);
+
+ if (strcmp(argv[0], "num-ostreams") == 0) {
+ asp->cfg.sctp_init.num_ostreams_present = true;
+ asp->cfg.sctp_init.num_ostreams_value = val;
+ } else if (strcmp(argv[0], "max-instreams") == 0) {
+ asp->cfg.sctp_init.max_instreams_present = true;
+ asp->cfg.sctp_init.max_instreams_value = val;
+ } else if (strcmp(argv[0], "max-attempts") == 0) {
+ asp->cfg.sctp_init.max_attempts_present = true;
+ asp->cfg.sctp_init.max_attempts_value = val;
+ } else if (strcmp(argv[0], "timeout") == 0) {
+ asp->cfg.sctp_init.max_init_timeo_present = true;
+ asp->cfg.sctp_init.max_init_timeo_value = val;
+ } else {
+ OSMO_ASSERT(0);
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_no_sctp_param_init, asp_no_sctp_param_init_cmd,
+ "no sctp-param init " ASP_SCTP_PARAM_INIT_FIELDS,
+ NO_STR ASP_SCTP_PARAM_INIT_DESC,
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+
+ if (strcmp(argv[0], "num-ostreams") == 0)
+ asp->cfg.sctp_init.num_ostreams_present = false;
+ else if (strcmp(argv[0], "max-instreams") == 0)
+ asp->cfg.sctp_init.max_instreams_present = false;
+ else if (strcmp(argv[0], "max-attempts") == 0)
+ asp->cfg.sctp_init.max_attempts_present = false;
+ else if (strcmp(argv[0], "timeout") == 0)
+ asp->cfg.sctp_init.max_init_timeo_present = false;
+ else
+ OSMO_ASSERT(0);
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_block, asp_block_cmd,
+ "block",
+ "Allows a SCTP Association with ASP, but doesn't let it become active\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ /* TODO */
+ vty_out(vty, "Not supported yet%s", VTY_NEWLINE);
+ return CMD_WARNING;
+}
+
+DEFUN_ATTR(asp_shutdown, asp_shutdown_cmd,
+ "shutdown",
+ "Terminates SCTP association; New associations will be rejected\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+
+ LOGPASP(asp, DLSS7, LOGL_NOTICE, "Applying Adm State change: %s -> %s\n",
+ get_value_string(osmo_ss7_asp_admin_state_names, asp->cfg.adm_state),
+ get_value_string(osmo_ss7_asp_admin_state_names, OSMO_SS7_ASP_ADM_S_SHUTDOWN));
+
+ asp->cfg.explicit_shutdown_state_by_vty_since_node_enter = true;
+ asp->cfg.adm_state = OSMO_SS7_ASP_ADM_S_SHUTDOWN;
+ ss7_asp_restart_after_reconfigure(asp);
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_no_shutdown, asp_no_shutdown_cmd,
+ "no shutdown",
+ NO_STR "Terminates SCTP association; New associations will be rejected\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+
+ LOGPASP(asp, DLSS7, LOGL_NOTICE, "Applying Adm State change: %s -> %s\n",
+ get_value_string(osmo_ss7_asp_admin_state_names, asp->cfg.adm_state),
+ get_value_string(osmo_ss7_asp_admin_state_names, OSMO_SS7_ASP_ADM_S_ENABLED));
+
+ asp->cfg.explicit_shutdown_state_by_vty_since_node_enter = true;
+ asp->cfg.adm_state = OSMO_SS7_ASP_ADM_S_ENABLED;
+ ss7_asp_restart_after_reconfigure(asp);
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_quirk, asp_quirk_cmd,
+ "OVERWRITTEN",
+ "OVERWRITTEN\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+ int quirk = get_string_value(asp_quirk_names, argv[0]);
+
+ if (quirk < 0)
+ return CMD_WARNING;
+
+ asp->cfg.quirks |= quirk;
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(asp_no_quirk, asp_no_quirk_cmd,
+ "OVERWRITTEN",
+ "OVERWRITTEN\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+ int quirk = get_string_value(asp_quirk_names, argv[0]);
+
+ if (quirk < 0)
+ return CMD_WARNING;
+
+ asp->cfg.quirks &= ~quirk;
+ return CMD_SUCCESS;
+}
+
+/* timer lm <name> <1-999999>
+ * (cmdstr and doc are dynamically generated from ss7_asp_lm_timer_names.) */
+DEFUN_ATTR(asp_timer, asp_timer_cmd,
+ NULL, NULL, CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+ enum ss7_asp_lm_timer timer = get_string_value(ss7_asp_lm_timer_names, argv[0]);
+
+ if (timer <= 0 || timer >= SS7_ASP_LM_TIMERS_LEN) {
+ vty_out(vty, "%% Invalid timer: %s%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ osmo_tdef_set(asp->cfg.T_defs_lm, timer, atoi(argv[1]), OSMO_TDEF_S);
+ return CMD_SUCCESS;
+}
+
+static void gen_asp_timer_cmd_strs(struct cmd_element *cmd)
+{
+ int i;
+ char *cmd_str = NULL;
+ char *doc_str = NULL;
+
+ OSMO_ASSERT(cmd->string == NULL);
+ OSMO_ASSERT(cmd->doc == NULL);
+
+ osmo_talloc_asprintf(tall_vty_ctx, cmd_str, "timer lm (");
+ osmo_talloc_asprintf(tall_vty_ctx, doc_str,
+ "Configure ASP default timer values\n"
+ "Configure ASP default lm timer values\n");
+
+ for (i = 0; ss7_asp_lm_timer_names[i].str; i++) {
+ const struct osmo_tdef *def;
+ enum ss7_asp_lm_timer timer;
+
+ timer = ss7_asp_lm_timer_names[i].value;
+ def = osmo_tdef_get_entry((struct osmo_tdef *)&ss7_asp_lm_timer_defaults, timer);
+ OSMO_ASSERT(def);
+
+ osmo_talloc_asprintf(tall_vty_ctx, cmd_str, "%s%s",
+ i ? "|" : "",
+ ss7_asp_lm_timer_names[i].str);
+ osmo_talloc_asprintf(tall_vty_ctx, doc_str, "%s (default: %lu)\n",
+ def->desc,
+ def->default_val);
+ }
+
+ osmo_talloc_asprintf(tall_vty_ctx, cmd_str, ") <1-999999>");
+ osmo_talloc_asprintf(tall_vty_ctx, doc_str,
+ "Timer value, in seconds\n");
+
+ cmd->string = cmd_str;
+ cmd->doc = doc_str;
+}
+
+static void write_asp_timers(struct vty *vty, const char *indent,
+ struct osmo_ss7_asp *asp)
+{
+ int i;
+
+ for (i = 0; ss7_asp_lm_timer_names[i].str; i++) {
+ const struct osmo_tdef *tdef = osmo_tdef_get_entry(asp->cfg.T_defs_lm, ss7_asp_lm_timer_names[i].value);
+ if (!tdef)
+ continue;
+ if (tdef->val == tdef->default_val)
+ continue;
+ vty_out(vty, "%stimer lm %s %lu%s", indent, ss7_asp_lm_timer_names[i].str,
+ tdef->val, VTY_NEWLINE);
+ }
+}
+
+static char *as_list_for_asp(const struct osmo_ss7_asp *asp, char *buf, size_t buf_len)
+{
+ struct osmo_strbuf sb = { .buf = buf, .len = buf_len };
+ const struct osmo_ss7_as *as;
+ unsigned int count = 0;
+ llist_for_each_entry(as, &asp->inst->as_list, list) {
+ if (!osmo_ss7_as_has_asp(as, asp))
+ continue;
+ OSMO_STRBUF_PRINTF(sb, "%s%s", count != 0 ? "," : "", as->cfg.name);
+ count++;
+ break;
+ }
+
+ if (count == 0)
+ OSMO_STRBUF_PRINTF(sb, "?");
+ return buf;
+}
+
+/* Similar to osmo_sock_multiaddr_get_name_buf(), but aimed at listening sockets (only local part): */
+static char *get_sockname_buf(char *buf, size_t buf_len, int fd, int proto, bool local)
+{
+ char hostbuf[OSMO_SOCK_MAX_ADDRS][INET6_ADDRSTRLEN];
+ size_t num_hostbuf = ARRAY_SIZE(hostbuf);
+ char portbuf[6];
+ struct osmo_strbuf sb = { .buf = buf, .len = buf_len };
+ bool need_more_bufs;
+ int rc;
+
+ rc = osmo_sock_multiaddr_get_ip_and_port(fd, proto, &hostbuf[0][0],
+ &num_hostbuf, sizeof(hostbuf[0]),
+ portbuf, sizeof(portbuf), local);
+ if (rc < 0)
+ return NULL;
+
+ need_more_bufs = num_hostbuf > ARRAY_SIZE(hostbuf);
+ if (need_more_bufs)
+ num_hostbuf = ARRAY_SIZE(hostbuf);
+ OSMO_STRBUF_APPEND(sb, osmo_multiaddr_ip_and_port_snprintf,
+ &hostbuf[0][0], num_hostbuf, sizeof(hostbuf[0]), portbuf);
+ if (need_more_bufs)
+ OSMO_STRBUF_PRINTF(sb, "<need-more-bufs!>");
+
+ return buf;
+}
+
+static void show_one_asp(struct vty *vty, struct osmo_ss7_asp *asp)
+{
+ char as_buf[64];
+ char buf_loc[OSMO_SOCK_MULTIADDR_PEER_STR_MAXLEN];
+ char buf_rem[sizeof(buf_loc)];
+
+ int fd = ss7_asp_get_fd(asp);
+ if (fd > 0) {
+ const int trans_proto = asp->cfg.trans_proto;
+ if (!get_sockname_buf(buf_loc, sizeof(buf_loc), fd, trans_proto, true))
+ OSMO_STRLCPY_ARRAY(buf_loc, "<sockname-error>");
+ if (!get_sockname_buf(buf_rem, sizeof(buf_rem), fd, trans_proto, false))
+ OSMO_STRLCPY_ARRAY(buf_rem, "<sockname-error>");
+ } else {
+ ss7_asp_peer_snprintf(buf_loc, sizeof(buf_loc), &asp->cfg.local);
+ ss7_asp_peer_snprintf(buf_rem, sizeof(buf_rem), &asp->cfg.remote);
+ }
+
+ vty_out(vty, "%-12s %-12s %-13s %-4s %-4s %-9s %-23s %-23s%s",
+ asp->cfg.name,
+ as_list_for_asp(asp, as_buf, sizeof(as_buf)),
+ asp->fi ? osmo_fsm_inst_state_name(asp->fi) : "uninitialized",
+ get_value_string(osmo_ss7_asp_protocol_vals, asp->cfg.proto),
+ osmo_str_tolower(get_value_string(osmo_ss7_asp_role_names, asp->cfg.role)),
+ asp->cfg.is_server ? "server" : "client",
+ buf_loc, buf_rem,
+ VTY_NEWLINE);
+}
+
+static int show_asp(struct vty *vty, int id, const char *asp_name)
+{
+ struct osmo_ss7_instance *inst;
+ struct osmo_ss7_asp *asp = NULL;
+
+ inst = osmo_ss7_instance_find(id);
+ if (!inst) {
+ vty_out(vty, "No SS7 instance %d found%s", id, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (asp_name) {
+ asp = osmo_ss7_asp_find_by_name(inst, asp_name);
+ if (!asp) {
+ vty_out(vty, "No ASP %s found%s", asp_name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ }
+
+ vty_out(vty, "ASP Name AS Name State Type Role SCTP Role Local Addresses Remote Addresses%s", VTY_NEWLINE);
+ vty_out(vty, "------------ ------------ ------------- ---- ---- --------- ----------------------- -----------------------%s", VTY_NEWLINE);
+
+ if (asp) {
+ show_one_asp(vty, asp);
+ return CMD_SUCCESS;
+ }
+
+ llist_for_each_entry(asp, &inst->asp_list, list)
+ show_one_asp(vty, asp);
+ return CMD_SUCCESS;
+}
+
+DEFUN(show_cs7_asp, show_cs7_asp_cmd,
+ "show cs7 instance <0-15> asp",
+ SHOW_STR CS7_STR INST_STR INST_STR
+ "Application Server Process (ASP)\n")
+{
+ int id = atoi(argv[0]);
+
+ return show_asp(vty, id, NULL);
+}
+
+DEFUN(show_cs7_asp_name, show_cs7_asp_name_cmd,
+ "show cs7 instance <0-15> asp name ASP_NAME",
+ SHOW_STR CS7_STR INST_STR INST_STR
+ "Application Server Process (ASP)\n"
+ "Lookup ASP with a given name\n"
+ "Name of the Application Server Process (ASP)\n")
+{
+ int id = atoi(argv[0]);
+ const char *asp_name = argv[1];
+
+ return show_asp(vty, id, asp_name);
+}
+
+static void show_one_asp_remaddr_tcp(struct vty *vty, struct osmo_ss7_asp *asp)
+{
+ struct osmo_sockaddr osa = {};
+ struct tcp_info tcpi = {};
+ socklen_t len;
+ int fd, rc;
+
+ fd = ss7_asp_get_fd(asp);
+ if (fd < 0) {
+ vty_out(vty, "%-12s %-46s uninitialized%s", asp->cfg.name, "", VTY_NEWLINE);
+ return;
+ }
+
+ len = sizeof(osa.u.sas);
+ rc = getpeername(fd, &osa.u.sa, &len);
+
+ len = sizeof(tcpi);
+ rc = getsockopt(fd, SOL_TCP, TCP_INFO, &tcpi, &len);
+ if (rc < 0) {
+ char buf_err[128];
+ strerror_r(errno, buf_err, sizeof(buf_err));
+ vty_out(vty, "%-12s %-46s getsockopt(TCP_INFO) failed: %s%s",
+ asp->cfg.name, osmo_sockaddr_to_str(&osa), buf_err, VTY_NEWLINE);
+ return;
+ }
+
+ vty_out(vty, "%-12s %-46s TCP_%-19s %-8u %-8u %-8u %-8u%s",
+ asp->cfg.name,
+ osmo_sockaddr_to_str(&osa),
+ get_value_string(tcp_info_state_values, tcpi.tcpi_state),
+ tcpi.tcpi_snd_cwnd, tcpi.tcpi_rtt,
+ tcpi.tcpi_rto, tcpi.tcpi_pmtu,
+ VTY_NEWLINE);
+}
+
+#ifdef HAVE_LIBSCTP
+static void show_one_asp_remaddr_sctp(struct vty *vty, struct osmo_ss7_asp *asp)
+{
+ struct sctp_paddrinfo pinfo[OSMO_SOCK_MAX_ADDRS];
+ struct osmo_sockaddr osa = {};
+ size_t pinfo_cnt = ARRAY_SIZE(pinfo);
+ bool more_needed;
+ int fd, rc;
+ unsigned int i;
+
+ fd = ss7_asp_get_fd(asp);
+ if (fd < 0) {
+ vty_out(vty, "%-12s %-46s uninitialized%s", asp->cfg.name, "", VTY_NEWLINE);
+ return;
+ }
+
+ rc = osmo_sock_sctp_get_peer_addr_info(fd, &pinfo[0], &pinfo_cnt);
+ if (rc < 0) {
+ char buf_err[128];
+ strerror_r(errno, buf_err, sizeof(buf_err));
+ vty_out(vty, "%-12s %-46s getsockopt(SCTP_GET_PEER_ADDR_INFO) failed: %s%s", asp->cfg.name, "", buf_err, VTY_NEWLINE);
+ return;
+ }
+
+ more_needed = pinfo_cnt > ARRAY_SIZE(pinfo);
+ if (pinfo_cnt > ARRAY_SIZE(pinfo))
+ pinfo_cnt = ARRAY_SIZE(pinfo);
+
+ for (i = 0; i < pinfo_cnt; i++) {
+ osa.u.sas = pinfo[i].spinfo_address;
+ vty_out(vty, "%-12s %-46s SCTP_%-18s %-8u %-8u %-8u %-8u%s",
+ asp->cfg.name,
+ osmo_sockaddr_to_str(&osa),
+ osmo_sctp_spinfo_state_str(pinfo[i].spinfo_state),
+ pinfo[i].spinfo_cwnd, pinfo[i].spinfo_srtt,
+ pinfo[i].spinfo_rto, pinfo[i].spinfo_mtu,
+ VTY_NEWLINE);
+ }
+
+ if (more_needed)
+ vty_out(vty, "%-12s more address buffers needed!%s", asp->cfg.name, VTY_NEWLINE);
+}
+#endif
+
+static void show_one_asp_remaddr(struct vty *vty, struct osmo_ss7_asp *asp)
+{
+ switch (asp->cfg.trans_proto) {
+ case IPPROTO_TCP:
+ show_one_asp_remaddr_tcp(vty, asp);
+ break;
+#ifdef HAVE_LIBSCTP
+ case IPPROTO_SCTP:
+ show_one_asp_remaddr_sctp(vty, asp);
+ break;
+#endif
+ default:
+ vty_out(vty, "%-12s %-46s unknown proto %d%s",
+ asp->cfg.name, "", asp->cfg.trans_proto, VTY_NEWLINE);
+ break;
+ }
+}
+
+static int show_asp_remaddr(struct vty *vty, int id, const char *asp_name)
+{
+ struct osmo_ss7_instance *inst;
+ struct osmo_ss7_asp *asp = NULL;
+
+ inst = osmo_ss7_instance_find(id);
+ if (!inst) {
+ vty_out(vty, "No SS7 instance %d found%s", id, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (asp_name) {
+ asp = osmo_ss7_asp_find_by_name(inst, asp_name);
+ if (!asp) {
+ vty_out(vty, "No ASP %s found%s", asp_name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ }
+
+ vty_out(vty, "ASP Name Remote IP Address & Port State CWND SRTT RTO MTU%s", VTY_NEWLINE);
+ vty_out(vty, "------------ ---------------------------------------------- ----------------------- -------- -------- -------- --------%s", VTY_NEWLINE);
+
+ if (asp) {
+ show_one_asp_remaddr(vty, asp);
+ return CMD_SUCCESS;
+ }
+
+ llist_for_each_entry(asp, &inst->asp_list, list) {
+ show_one_asp_remaddr(vty, asp);
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN(show_cs7_asp_remaddr, show_cs7_asp_remaddr_cmd,
+ "show cs7 instance <0-15> asp-remaddr",
+ SHOW_STR CS7_STR INST_STR INST_STR
+ "Application Server Process (ASP) remote addresses information\n")
+{
+ int id = atoi(argv[0]);
+
+ return show_asp_remaddr(vty, id, NULL);
+}
+
+
+DEFUN(show_cs7_asp_remaddr_name, show_cs7_asp_remaddr_name_cmd,
+ "show cs7 instance <0-15> asp-remaddr name ASP_NAME",
+ SHOW_STR CS7_STR INST_STR INST_STR
+ "Application Server Process (ASP) remote addresses information\n"
+ "Lookup ASP with a given name\n"
+ "Name of the Application Server Process (ASP)\n")
+{
+ int id = atoi(argv[0]);
+ const char *asp_name = argv[1];
+
+ return show_asp_remaddr(vty, id, asp_name);
+}
+
+static void show_one_asp_assoc_status_tcp(struct vty *vty, struct osmo_ss7_asp *asp)
+{
+ struct osmo_sockaddr osa = {};
+ struct tcp_info tcpi = {};
+ socklen_t len;
+ int fd, rc;
+ int rx_pend_bytes = 0;
+
+ fd = ss7_asp_get_fd(asp);
+ if (fd < 0) {
+ vty_out(vty, "%-12s uninitialized%s", asp->cfg.name, VTY_NEWLINE);
+ return;
+ }
+
+ len = sizeof(osa.u.sas);
+ rc = getpeername(fd, &osa.u.sa, &len);
+
+ len = sizeof(tcpi);
+ rc = getsockopt(fd, SOL_TCP, TCP_INFO, &tcpi, &len);
+ if (rc < 0) {
+ char buf_err[128];
+ strerror_r(errno, buf_err, sizeof(buf_err));
+ vty_out(vty, "%-12s getsockopt(TCP_INFO) failed: %s%s",
+ asp->cfg.name, buf_err, VTY_NEWLINE);
+ return;
+ }
+
+ rc = ioctl(fd, FIONREAD, &rx_pend_bytes);
+
+ /* FIXME: RWND: struct tcp_info from linux/tcp.h contains more fields
+ * than the one from netinet/tcp.h we currently use, including
+ * "tcpi_rcv_wnd" which we could use to print RWND here. However,
+ * linux/tcp.h seems to be missing the state defines used in
+ * "tcp_info_state_values", so we cannot use that one instead.
+ */
+
+ vty_out(vty, "%-12s TCP_%-19s %-9s %-10s %-8s %-9u %-7u %-9u %-46s%s",
+ asp->cfg.name,
+ get_value_string(tcp_info_state_values, tcpi.tcpi_state),
+ "-", "-", "-", tcpi.tcpi_unacked, rx_pend_bytes,
+ tcpi.tcpi_pmtu, osmo_sockaddr_to_str(&osa),
+ VTY_NEWLINE);
+}
+
+#ifdef HAVE_LIBSCTP
+static void show_one_asp_assoc_status_sctp(struct vty *vty, struct osmo_ss7_asp *asp)
+{
+ struct osmo_sockaddr osa = {};
+ struct sctp_status st;
+ socklen_t len;
+ int fd, rc;
+
+ fd = ss7_asp_get_fd(asp);
+ if (fd < 0) {
+ vty_out(vty, "%-12s uninitialized%s", asp->cfg.name, VTY_NEWLINE);
+ return;
+ }
+
+ memset(&st, 0, sizeof(st));
+ len = sizeof(st);
+ rc = getsockopt(fd, IPPROTO_SCTP, SCTP_STATUS, &st, &len);
+ if (rc < 0) {
+ char buf_err[128];
+ strerror_r(errno, buf_err, sizeof(buf_err));
+ vty_out(vty, "%-12s getsockopt(SCTP_STATUS) failed: %s%s", asp->cfg.name, buf_err, VTY_NEWLINE);
+ return;
+ }
+
+ osa.u.sas = st.sstat_primary.spinfo_address;
+ vty_out(vty, "%-12s SCTP_%-18s %-9u %-10u %-8u %-9u %-7u %-9u %-46s%s",
+ asp->cfg.name,
+ osmo_sctp_sstat_state_str(st.sstat_state),
+ st.sstat_instrms, st.sstat_outstrms,
+ st.sstat_rwnd, st.sstat_unackdata, st.sstat_penddata,
+ st.sstat_fragmentation_point,
+ osmo_sockaddr_to_str(&osa),
+ VTY_NEWLINE);
+}
+#endif
+
+static void show_one_asp_assoc_status(struct vty *vty, struct osmo_ss7_asp *asp)
+{
+ switch (asp->cfg.trans_proto) {
+ case IPPROTO_TCP:
+ show_one_asp_assoc_status_tcp(vty, asp);
+ break;
+#ifdef HAVE_LIBSCTP
+ case IPPROTO_SCTP:
+ show_one_asp_assoc_status_sctp(vty, asp);
+ break;
+#endif
+ default:
+ vty_out(vty, "%-12s unknown proto %d%s",
+ asp->cfg.name, asp->cfg.trans_proto, VTY_NEWLINE);
+ break;
+ }
+}
+
+static int show_asp_assoc_status(struct vty *vty, int id, const char *asp_name)
+{
+ struct osmo_ss7_instance *inst;
+ struct osmo_ss7_asp *asp = NULL;
+
+ inst = osmo_ss7_instance_find(id);
+ if (!inst) {
+ vty_out(vty, "No SS7 instance %d found%s", id, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+
+ if (asp_name) {
+ asp = osmo_ss7_asp_find_by_name(inst, asp_name);
+ if (!asp) {
+ vty_out(vty, "No ASP %s found%s", asp_name, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ }
+
+ vty_out(vty, "ASP Name State InStreams OutStreams RWND UnackData PenData FragPoint Current Primary Remote IP Address & Port%s", VTY_NEWLINE);
+ vty_out(vty, "------------ ----------------------- --------- ---------- -------- --------- ------- --------- ----------------------------------------------%s", VTY_NEWLINE);
+
+ if (asp) {
+ show_one_asp_assoc_status(vty, asp);
+ return CMD_SUCCESS;
+ }
+
+ llist_for_each_entry(asp, &inst->asp_list, list)
+ show_one_asp_assoc_status(vty, asp);
+ return CMD_SUCCESS;
+}
+
+DEFUN(show_cs7_asp_assoc_status, show_cs7_asp_assoc_status_cmd,
+ "show cs7 instance <0-15> asp-assoc-status",
+ SHOW_STR CS7_STR INST_STR INST_STR
+ "Application Server Process (ASP) SCTP association status\n")
+{
+ int id = atoi(argv[0]);
+
+ return show_asp_assoc_status(vty, id, NULL);
+}
+
+
+DEFUN(show_cs7_asp_assoc_status_name, show_cs7_asp_assoc_status_name_cmd,
+ "show cs7 instance <0-15> asp-assoc-status name ASP_NAME",
+ SHOW_STR CS7_STR INST_STR INST_STR
+ "Application Server Process (ASP) SCTP association information\n"
+ "Lookup ASP with a given name\n"
+ "Name of the Application Server Process (ASP)\n")
+{
+ int id = atoi(argv[0]);
+ const char *asp_name = argv[1];
+
+ return show_asp_assoc_status(vty, id, asp_name);
+}
+
+void ss7_vty_write_one_asp(struct vty *vty, struct osmo_ss7_asp *asp, bool show_dyn_config)
+{
+ int i;
+ /* skip any dynamically created ASPs (e.g. auto-created at connect time) */
+ if ((asp->dyn_allocated || asp->simple_client_allocated)
+ && !show_dyn_config)
+ return;
+
+ vty_out(vty, " asp %s %u %u %s",
+ asp->cfg.name, asp->cfg.remote.port, asp->cfg.local.port,
+ osmo_ss7_asp_protocol_name(asp->cfg.proto));
+ if (asp->cfg.trans_proto != ss7_default_trans_proto_for_asp_proto(asp->cfg.proto))
+ vty_out(vty, " %s", get_value_string(ipproto_vals, asp->cfg.trans_proto));
+ vty_out(vty, "%s", VTY_NEWLINE);
+ if (asp->cfg.description)
+ vty_out(vty, " description %s%s", asp->cfg.description, VTY_NEWLINE);
+ for (i = 0; i < asp->cfg.local.host_cnt; i++) {
+ if (asp->cfg.local.host[i])
+ vty_out(vty, " local-ip %s%s%s", asp->cfg.local.host[i],
+ asp->cfg.local.idx_primary == i ? " primary" : "", VTY_NEWLINE);
+ }
+ for (i = 0; i < asp->cfg.remote.host_cnt; i++) {
+ if (asp->cfg.remote.host[i])
+ vty_out(vty, " remote-ip %s%s%s", asp->cfg.remote.host[i],
+ asp->cfg.remote.idx_primary == i ? " primary" : "", VTY_NEWLINE);
+ }
+ if (asp->cfg.qos_class)
+ vty_out(vty, " qos-class %u%s", asp->cfg.qos_class, VTY_NEWLINE);
+ vty_out(vty, " role %s%s", osmo_str_tolower(get_value_string(osmo_ss7_asp_role_names, asp->cfg.role)),
+ VTY_NEWLINE);
+ if (asp->cfg.trans_proto == IPPROTO_SCTP)
+ vty_out(vty, " sctp-role %s%s", asp->cfg.is_server ? "server" : "client", VTY_NEWLINE);
+ else
+ vty_out(vty, " transport-role %s%s", asp->cfg.is_server ? "server" : "client", VTY_NEWLINE);
+ if (asp->cfg.sctp_init.num_ostreams_present)
+ vty_out(vty, " sctp-param init num-ostreams %u%s", asp->cfg.sctp_init.num_ostreams_value, VTY_NEWLINE);
+ if (asp->cfg.sctp_init.max_instreams_present)
+ vty_out(vty, " sctp-param init max-instreams %u%s", asp->cfg.sctp_init.max_instreams_value, VTY_NEWLINE);
+ if (asp->cfg.sctp_init.max_attempts_present)
+ vty_out(vty, " sctp-param init max-attempts %u%s", asp->cfg.sctp_init.max_attempts_value, VTY_NEWLINE);
+ if (asp->cfg.sctp_init.max_init_timeo_present)
+ vty_out(vty, " sctp-param init timeout %u%s", asp->cfg.sctp_init.max_init_timeo_value, VTY_NEWLINE);
+ for (i = 0; i < sizeof(uint32_t) * 8; i++) {
+ if (!(asp->cfg.quirks & ((uint32_t) 1 << i)))
+ continue;
+ vty_out(vty, " quirk %s%s", get_value_string(asp_quirk_names, (1 << i)), VTY_NEWLINE);
+ }
+ write_asp_timers(vty, " ", asp);
+
+ switch (asp->cfg.adm_state) {
+ case OSMO_SS7_ASP_ADM_S_SHUTDOWN:
+ vty_out(vty, " shutdown%s", VTY_NEWLINE);
+ break;
+ case OSMO_SS7_ASP_ADM_S_BLOCKED:
+ vty_out(vty, " blocked%s", VTY_NEWLINE);
+ break;
+ case OSMO_SS7_ASP_ADM_S_ENABLED:
+ /* Default, no need to print: */
+ vty_out(vty, " no shutdown%s", VTY_NEWLINE);
+ break;
+ }
+}
+
+int ss7_vty_node_asp_go_parent(struct vty *vty)
+{
+ struct osmo_ss7_asp *asp = vty->index;
+
+ if (asp->cfg.explicit_shutdown_state_by_vty_since_node_enter) {
+ /* Interactive VTY, inform of new behavior upon use of new '[no] shutdown' commands: */
+ if (vty->type != VTY_FILE)
+ vty_out(vty, "%% NOTE: Skipping automatic restart of ASP since an explicit '[no] shutdown' command was entered%s", VTY_NEWLINE);
+ asp->cfg.explicit_shutdown_state_by_vty_since_node_enter = false;
+ } else if (vty->type == VTY_FILE) {
+ /* Make sure config reading is backward compatible by starting the ASP if no explicit 'no shutdown' is read: */
+ vty_out(vty,
+ "%% VTY node 'asp' without a '[no] shutdown' command at the end is deprecated, "
+ "please make sure you update your cfg file for future compatibility.%s",
+ VTY_NEWLINE);
+ ss7_asp_restart_after_reconfigure(asp);
+ } else {
+ /* Interactive VTY without '[no] shutdown' explicit cmd, remind the user that we are no
+ * longer automatically restarting the ASP when going out of the "asp" node: */
+ vty_out(vty,
+ "%% NOTE: Make sure to use '[no] shutdown' command in 'asp' node "
+ "in order to restart the ASP for new configs to be applied.%s",
+ VTY_NEWLINE);
+ }
+ vty->node = L_CS7_NODE;
+ vty->index = asp->inst;
+ return 0;
+}
+
+void ss7_vty_init_node_asp(void)
+{
+ asp_quirk_cmd.string = vty_cmd_string_from_valstr(g_ctx, asp_quirk_names,
+ "quirk (", "|", ")", VTY_DO_LOWER);
+ asp_quirk_cmd.doc = vty_cmd_string_from_valstr(g_ctx, asp_quirk_descs,
+ "Enable quirk to work around interop issues\n",
+ "\n", "\n", 0);
+ asp_no_quirk_cmd.string = vty_cmd_string_from_valstr(g_ctx, asp_quirk_names,
+ "no quirk (", "|", ")", VTY_DO_LOWER);
+ asp_no_quirk_cmd.doc = vty_cmd_string_from_valstr(g_ctx, asp_quirk_descs,
+ NO_STR "Disable quirk to work around interop issues\n",
+ "\n", "\n", 0);
+
+ install_node(&asp_node, NULL);
+ install_lib_element_ve(&show_cs7_asp_cmd);
+ install_lib_element_ve(&show_cs7_asp_name_cmd);
+ install_lib_element_ve(&show_cs7_asp_remaddr_cmd);
+ install_lib_element_ve(&show_cs7_asp_remaddr_name_cmd);
+ install_lib_element_ve(&show_cs7_asp_assoc_status_cmd);
+ install_lib_element_ve(&show_cs7_asp_assoc_status_name_cmd);
+ install_lib_element(L_CS7_NODE, &cs7_asp_cmd);
+ install_lib_element(L_CS7_NODE, &cs7_asp_trans_proto_cmd);
+ install_lib_element(L_CS7_NODE, &no_cs7_asp_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &cfg_description_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_remote_ip_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_no_remote_ip_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_local_ip_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_no_local_ip_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_qos_class_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_role_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_transport_role_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_sctp_role_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_sctp_param_init_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_no_sctp_param_init_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_quirk_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_no_quirk_cmd);
+ gen_asp_timer_cmd_strs(&asp_timer_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_timer_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_block_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_shutdown_cmd);
+ install_lib_element(L_CS7_ASP_NODE, &asp_no_shutdown_cmd);
+}
diff --git a/src/ss7_internal.h b/src/ss7_internal.h
index 9475645..7dc2c57 100644
--- a/src/ss7_internal.h
+++ b/src/ss7_internal.h
@@ -28,3 +28,6 @@
int ss7_asp_xua_srv_conn_closed_cb(struct osmo_stream_srv *srv);
int xua_tcp_segmentation_cb(struct msgb *msg);
+
+/* VTY */
+#define XUA_VAR_STR "(sua|m3ua|ipa)"
diff --git a/src/ss7_vty.c b/src/ss7_vty.c
index 41872fe..862e9ff 100644
--- a/src/ss7_vty.c
+++ b/src/ss7_vty.c
@@ -1,4 +1,4 @@
-/* Core SS7 Instance/Linkset/Link/AS/ASP VTY Interface */
+/* Core SS7 Instance/Linkset/Link VTY Interface */
/* (C) 2015-2021 by Harald Welte <laforge@gnumonks.org>
* All Rights Reserved
@@ -26,20 +26,12 @@
#include <stdint.h>
#include <string.h>
-#include <netdb.h>
-#include <arpa/inet.h>
-#include <sys/ioctl.h>
-
-#include <osmocom/core/sockaddr_str.h>
-
#include <osmocom/vty/vty.h>
#include <osmocom/vty/command.h>
#include <osmocom/vty/logging.h>
#include <osmocom/vty/telnet_interface.h>
#include <osmocom/vty/misc.h>
-#include <osmocom/netif/stream.h>
-
#include <osmocom/sigtran/osmo_ss7.h>
#include <osmocom/sigtran/protocol/mtp.h>
@@ -53,34 +45,9 @@
#include "ss7_route.h"
#include "ss7_route_table.h"
#include "ss7_internal.h"
+#include "ss7_vty.h"
#include "ss7_xua_srv.h"
-#include <netinet/tcp.h>
-
-#ifdef HAVE_LIBSCTP
-#include <netinet/sctp.h>
-#include <osmocom/netif/sctp.h>
-#endif
-
-#define XUA_VAR_STR "(sua|m3ua|ipa)"
-
-#define XUA_VAR_HELP_STR \
- "SCCP User Adaptation\n" \
- "MTP3 User Adaptation\n" \
- "IPA Multiplex (SCCP Lite)\n"
-
-#define IPPROTO_VAR_STR "(sctp|tcp)"
-#define IPPROTO_VAR_HELP_STR \
- "SCTP (Stream Control Transmission Protocol)\n" \
- "TCP (Transmission Control Protocol)\n"
-
-#define QOS_CLASS_RANGE_STR "<0-7>"
-#define QOS_CLASS_RANGE_HELP_STR "QoS Class\n"
-#define QOS_CLASS_VAR_STR "(" QOS_CLASS_RANGE_STR "|default)"
-#define QOS_CLASS_VAR_HELP_STR \
- QOS_CLASS_RANGE_HELP_STR \
- "Default QoS Class (0)\n"
-
#define ROUTE_PRIO_RANGE_STR "<1-9>"
#define ROUTE_PRIO_RANGE_HELP_STR "Priority\n"
#define ROUTE_PRIO_VAR_STR "(" ROUTE_PRIO_RANGE_STR "|default)"
@@ -88,43 +55,28 @@
ROUTE_PRIO_RANGE_HELP_STR \
"Default Priority (5)\n"
-/* netinet/tcp.h */
-static const struct value_string tcp_info_state_values[] = {
- { TCP_ESTABLISHED, "ESTABLISHED" },
- { TCP_SYN_SENT, "SYN_SENT" },
- { TCP_SYN_RECV, "SYN_RECV" },
- { TCP_FIN_WAIT1, "FIN_WAIT1" },
- { TCP_FIN_WAIT2, "FIN_WAIT2" },
- { TCP_TIME_WAIT, "TIME_WAIT" },
- { TCP_CLOSE, "CLOSE" },
- { TCP_CLOSE_WAIT, "CLOSE_WAIT" },
- { TCP_LAST_ACK, "LAST_ACK" },
- { TCP_LISTEN, "LISTEN" },
- { TCP_CLOSING, "CLOSING" },
- {}
+const struct value_string ipproto_vals[] = {
+ { IPPROTO_SCTP, "sctp" },
+ { IPPROTO_TCP, "tcp" },
+ { 0, NULL },
};
-static const struct value_string asp_quirk_names[] = {
- { OSMO_SS7_ASP_QUIRK_NO_NOTIFY, "no_notify" },
- { OSMO_SS7_ASP_QUIRK_DAUD_IN_ASP, "daud_in_asp" },
- { OSMO_SS7_ASP_QUIRK_SNM_INACTIVE, "snm_inactive" },
- { 0, NULL }
-};
+int parse_trans_proto(const char *protocol)
+{
+ return get_string_value(ipproto_vals, protocol);
+}
-static const struct value_string asp_quirk_descs[] = {
- { OSMO_SS7_ASP_QUIRK_NO_NOTIFY, "Peer SG doesn't send NTFY(AS-INACTIVE) after ASP-UP" },
- { OSMO_SS7_ASP_QUIRK_DAUD_IN_ASP, "Allow Rx of DAUD in ASP role" },
- { OSMO_SS7_ASP_QUIRK_SNM_INACTIVE, "Allow Rx of [S]SNM in AS-INACTIVE state" },
- { 0, NULL }
-};
+enum osmo_ss7_asp_protocol parse_asp_proto(const char *protocol)
+{
+ return get_string_value(osmo_ss7_asp_protocol_vals, protocol);
+}
/***********************************************************************
* Core CS7 Configuration
***********************************************************************/
-enum cs7_role_t {CS7_ROLE_SG, CS7_ROLE_ASP};
-static enum cs7_role_t cs7_role;
-static void *g_ctx;
+enum cs7_role_t cs7_role;
+void *g_ctx;
static struct cmd_node cs7_node = {
L_CS7_NODE,
@@ -737,293 +689,6 @@
return CMD_SUCCESS;
}
-/***********************************************************************
- * xUA Listener Configuration (SG)
- ***********************************************************************/
-
-static const struct value_string ipproto_vals[] = {
- { IPPROTO_SCTP, "sctp" },
- { IPPROTO_TCP, "tcp" },
- { 0, NULL },
-};
-
-static int parse_trans_proto(const char *protocol)
-{
- return get_string_value(ipproto_vals, protocol);
-}
-
-static enum osmo_ss7_asp_protocol parse_asp_proto(const char *protocol)
-{
- return get_string_value(osmo_ss7_asp_protocol_vals, protocol);
-}
-
-static struct cmd_node xua_node = {
- L_CS7_XUA_NODE,
- "%s(config-cs7-listen)# ",
- 1,
-};
-
-DEFUN_ATTR(cs7_xua, cs7_xua_cmd,
- "listen " XUA_VAR_STR " <0-65534> [" IPPROTO_VAR_STR "]",
- "Configure/Enable xUA Listener\n"
- XUA_VAR_HELP_STR
- "Port number\n"
- IPPROTO_VAR_HELP_STR,
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_instance *inst = vty->index;
- struct osmo_xua_server *xs;
- enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[0]);
- uint16_t port = atoi(argv[1]);
- int trans_proto;
-
- if (argc > 2)
- trans_proto = parse_trans_proto(argv[2]);
- else /* default transport protocol */
- trans_proto = ss7_default_trans_proto_for_asp_proto(proto);
- if (trans_proto < 0)
- return CMD_WARNING;
-
- xs = ss7_xua_server_find2(inst, trans_proto, proto, port);
- if (!xs) {
- xs = ss7_xua_server_create2(inst, trans_proto, proto, port, NULL);
- if (!xs)
- return CMD_WARNING;
- /* Drop first dummy address created automatically by _create(): */
- ss7_xua_server_set_local_hosts(xs, NULL, 0);
- }
-
- vty->node = L_CS7_XUA_NODE;
- vty->index = xs;
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(no_cs7_xua, no_cs7_xua_cmd,
- "no listen " XUA_VAR_STR " <0-65534> [" IPPROTO_VAR_STR "]",
- NO_STR "Disable xUA Listener on given port\n"
- XUA_VAR_HELP_STR
- "Port number\n"
- IPPROTO_VAR_HELP_STR,
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_instance *inst = vty->index;
- struct osmo_xua_server *xs;
- enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[0]);
- uint16_t port = atoi(argv[1]);
- int trans_proto;
-
- if (argc > 2)
- trans_proto = parse_trans_proto(argv[2]);
- else /* default transport protocol */
- trans_proto = ss7_default_trans_proto_for_asp_proto(proto);
- if (trans_proto < 0)
- return CMD_WARNING;
-
- xs = ss7_xua_server_find2(inst, trans_proto, proto, port);
- if (!xs) {
- vty_out(vty, "No xUA server for port %u found%s", port, VTY_NEWLINE);
- return CMD_WARNING;
- }
- ss7_xua_server_destroy(xs);
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(xua_local_ip, xua_local_ip_cmd,
- "local-ip " VTY_IPV46_CMD,
- "Configure the Local IP Address for xUA\n"
- "IPv4 Address to use for XUA\n"
- "IPv6 Address to use for XUA\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_xua_server *xs = vty->index;
-
- ss7_xua_server_add_local_host(xs, argv[0]);
-
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(xua_no_local_ip, xua_no_local_ip_cmd,
- "no local-ip " VTY_IPV46_CMD,
- NO_STR "Configure the Local IP Address for xUA\n"
- "IPv4 Address to use for XUA\n"
- "IPv6 Address to use for XUA\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_xua_server *xs = vty->index;
-
- if (ss7_xua_server_del_local_host(xs, argv[0]) != 0) {
- vty_out(vty, "%% Failed deleting local address '%s' from set%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(xua_accept_dyn_asp, xua_accept_dyn_asp_cmd,
- "accept-asp-connections (pre-configured|dynamic-permitted)",
- "Define what kind of ASP connections to accept\n"
- "Accept only pre-configured ASPs (source IP/port)\n"
- "Accept any connection and dynamically create an ASP definition\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_xua_server *xs = vty->index;
-
- if (!strcmp(argv[0], "dynamic-permitted"))
- xs->cfg.accept_dyn_reg = true;
- else
- xs->cfg.accept_dyn_reg = false;
-
- return CMD_SUCCESS;
-}
-
-#define XUA_SRV_SCTP_PARAM_INIT_DESC \
- "Configure SCTP parameters\n" \
- "Configure INIT related parameters\n" \
- "Configure INIT Number of Outbound Streams\n" \
- "Configure INIT Maximum Inboud Streams\n"
-#define XUA_SRV_SCTP_PARAM_INIT_FIELDS "(num-ostreams|max-instreams)"
-
-DEFUN_ATTR(xua_sctp_param_init, xua_sctp_param_init_cmd,
- "sctp-param init " XUA_SRV_SCTP_PARAM_INIT_FIELDS " <0-65535>",
- XUA_SRV_SCTP_PARAM_INIT_DESC
- "Value of the parameter\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_xua_server *xs = vty->index;
-
- uint16_t val = atoi(argv[1]);
-
- if (strcmp(argv[0], "num-ostreams") == 0) {
- xs->cfg.sctp_init.num_ostreams_present = true;
- xs->cfg.sctp_init.num_ostreams_value = val;
- } else if (strcmp(argv[0], "max-instreams") == 0) {
- xs->cfg.sctp_init.max_instreams_present = true;
- xs->cfg.sctp_init.max_instreams_value = val;
- } else {
- OSMO_ASSERT(0);
- }
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(xua_no_sctp_param_init, xua_no_sctp_param_init_cmd,
- "no sctp-param init " XUA_SRV_SCTP_PARAM_INIT_FIELDS,
- NO_STR XUA_SRV_SCTP_PARAM_INIT_DESC,
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_xua_server *xs = vty->index;
-
- if (strcmp(argv[0], "num-ostreams") == 0)
- xs->cfg.sctp_init.num_ostreams_present = false;
- else if (strcmp(argv[0], "max-instreams") == 0)
- xs->cfg.sctp_init.max_instreams_present = false;
- else
- OSMO_ASSERT(0);
- return CMD_SUCCESS;
-}
-
-static void write_one_xua(struct vty *vty, struct osmo_xua_server *xs)
-{
- int i;
-
- vty_out(vty, " listen %s %u",
- get_value_string(osmo_ss7_asp_protocol_vals, xs->cfg.proto),
- xs->cfg.local.port);
- if (xs->cfg.trans_proto != ss7_default_trans_proto_for_asp_proto(xs->cfg.proto))
- vty_out(vty, " %s", get_value_string(ipproto_vals, xs->cfg.trans_proto));
- vty_out(vty, "%s", VTY_NEWLINE);
-
- for (i = 0; i < xs->cfg.local.host_cnt; i++) {
- if (xs->cfg.local.host[i])
- vty_out(vty, " local-ip %s%s", xs->cfg.local.host[i], VTY_NEWLINE);
- }
- if (xs->cfg.accept_dyn_reg)
- vty_out(vty, " accept-asp-connections dynamic-permitted%s", VTY_NEWLINE);
- if (xs->cfg.sctp_init.num_ostreams_present)
- vty_out(vty, " sctp-param init num-ostreams %u%s", xs->cfg.sctp_init.num_ostreams_value, VTY_NEWLINE);
- if (xs->cfg.sctp_init.max_instreams_present)
- vty_out(vty, " sctp-param init max-instreams %u%s", xs->cfg.sctp_init.max_instreams_value, VTY_NEWLINE);
-}
-
-static void vty_dump_xua_server(struct vty *vty, struct osmo_xua_server *xs)
-{
- char buf[OSMO_SOCK_MULTIADDR_PEER_STR_MAXLEN];
- const char *proto = get_value_string(osmo_ss7_asp_protocol_vals, xs->cfg.proto);
- int fd = xs->server ? osmo_stream_srv_link_get_fd(xs->server) : -1;
-
- if (fd < 0) {
- if (ss7_asp_peer_snprintf(buf, sizeof(buf), &xs->cfg.local) < 0)
- snprintf(buf, sizeof(buf), "<error>");
- } else {
- char hostbuf[OSMO_SOCK_MAX_ADDRS][INET6_ADDRSTRLEN];
- size_t num_hostbuf = ARRAY_SIZE(hostbuf);
- char portbuf[6];
- int rc;
- rc = osmo_sock_multiaddr_get_ip_and_port(fd, xs->cfg.trans_proto,
- &hostbuf[0][0], &num_hostbuf, sizeof(hostbuf[0]),
- portbuf, sizeof(portbuf), true);
- if (rc < 0) {
- snprintf(buf, sizeof(buf), "<error>");
- } else {
- if (num_hostbuf > ARRAY_SIZE(hostbuf))
- num_hostbuf = ARRAY_SIZE(hostbuf);
- osmo_multiaddr_ip_and_port_snprintf(buf, sizeof(buf),
- &hostbuf[0][0], num_hostbuf, sizeof(hostbuf[0]),
- portbuf);
- }
- }
- vty_out(vty, "xUA server for %s/%s on %s is %s%s",
- proto, get_value_string(ipproto_vals, xs->cfg.trans_proto),
- buf, fd >= 0 ? "listening" : "inactive", VTY_NEWLINE);
-}
-
-static int _show_cs7_xua(struct vty *vty,
- enum osmo_ss7_asp_protocol proto,
- int trans_proto, int local_port)
-{
- const struct osmo_ss7_instance *inst;
-
- llist_for_each_entry(inst, &osmo_ss7_instances, list) {
- struct osmo_xua_server *xs;
-
- llist_for_each_entry(xs, &inst->xua_servers, list) {
- if (xs->cfg.proto != proto)
- continue;
- if (local_port >= 0 && xs->cfg.local.port != local_port) /* optional */
- continue;
- if (trans_proto >= 0 && xs->cfg.trans_proto != trans_proto) /* optional */
- continue;
- vty_dump_xua_server(vty, xs);
- }
- }
-
- return CMD_SUCCESS;
-}
-
-#define SHOW_CS7_XUA_CMD \
- "show cs7 " XUA_VAR_STR
-#define SHOW_CS7_XUA_CMD_HELP \
- SHOW_STR CS7_STR XUA_VAR_HELP_STR
-
-DEFUN(show_cs7_xua, show_cs7_xua_cmd,
- SHOW_CS7_XUA_CMD " [<0-65534>]",
- SHOW_CS7_XUA_CMD_HELP "Local Port Number\n")
-{
- enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[0]);
- int local_port = (argc > 1) ? atoi(argv[1]) : -1;
-
- return _show_cs7_xua(vty, proto, -1, local_port);
-}
-
-DEFUN(show_cs7_xua_trans_proto, show_cs7_xua_trans_proto_cmd,
- SHOW_CS7_XUA_CMD " " IPPROTO_VAR_STR " [<0-65534>]",
- SHOW_CS7_XUA_CMD_HELP IPPROTO_VAR_HELP_STR "Local Port Number\n")
-{
- enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[0]);
- int trans_proto = parse_trans_proto(argv[1]);
- int local_port = (argc > 2) ? atoi(argv[2]) : -1;
-
- return _show_cs7_xua(vty, proto, trans_proto, local_port);
-}
-
DEFUN(show_cs7_config, show_cs7_config_cmd,
"show cs7 config",
SHOW_STR CS7_STR "Currently running cs7 configuration")
@@ -1059,1556 +724,6 @@
/***********************************************************************
- * Application Server Process
- ***********************************************************************/
-
-static struct cmd_node asp_node = {
- L_CS7_ASP_NODE,
- "%s(config-cs7-asp)# ",
- 1,
-};
-
-DEFUN_ATTR(cs7_asp, cs7_asp_cmd,
- "asp NAME <0-65535> <0-65535> " XUA_VAR_STR,
- "Configure Application Server Process\n"
- "Name of ASP\n"
- "Remote port number\n"
- "Local port number\n"
- XUA_VAR_HELP_STR,
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_instance *inst = vty->index;
- const char *name = argv[0];
- uint16_t remote_port = atoi(argv[1]);
- uint16_t local_port = atoi(argv[2]);
- enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[3]);
- struct osmo_ss7_asp *asp;
- int trans_proto;
-
- if (proto == OSMO_SS7_ASP_PROT_NONE) {
- vty_out(vty, "invalid protocol '%s'%s", argv[3], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- /* argv[4] can be supplied by an alias (see below) */
- if (argc > 4)
- trans_proto = parse_trans_proto(argv[4]);
- else /* default transport protocol */
- trans_proto = ss7_default_trans_proto_for_asp_proto(proto);
- if (trans_proto < 0)
- return CMD_WARNING;
-
- asp = osmo_ss7_asp_find2(inst, name,
- remote_port, local_port,
- trans_proto, proto);
- if (!asp) {
- asp = osmo_ss7_asp_find_or_create2(inst, name,
- remote_port, local_port,
- trans_proto, proto);
- if (!asp) {
- vty_out(vty, "cannot create ASP '%s'%s", name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- asp->cfg.is_server = true;
- asp->cfg.role = OSMO_SS7_ASP_ROLE_SG;
- }
-
- /* Reset value, will be checked at osmo_ss7_vty_go_parent() */
- asp->cfg.explicit_shutdown_state_by_vty_since_node_enter = false;
-
- vty->node = L_CS7_ASP_NODE;
- vty->index = asp;
- vty->index_sub = &asp->cfg.description;
- return CMD_SUCCESS;
-}
-
-/* XXX: workaround for https://osmocom.org/issues/6360, can be removed once it's fixed.
- * Currently we hit an assert if we make the IPPROTO_VAR_STR optional in cs7_asp_cmd. */
-ALIAS_ATTR(cs7_asp, cs7_asp_trans_proto_cmd,
- "asp NAME <0-65535> <0-65535> " XUA_VAR_STR " " IPPROTO_VAR_STR,
- "Configure Application Server Process\n"
- "Name of ASP\n"
- "Remote port number\n"
- "Local port number\n"
- XUA_VAR_HELP_STR
- IPPROTO_VAR_HELP_STR,
- CMD_ATTR_NODE_EXIT);
-
-DEFUN_ATTR(no_cs7_asp, no_cs7_asp_cmd,
- "no asp NAME",
- NO_STR "Disable Application Server Process\n"
- "Name of ASP\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_instance *inst = vty->index;
- const char *name = argv[0];
- struct osmo_ss7_asp *asp;
-
- asp = osmo_ss7_asp_find_by_name(inst, name);
- if (!asp) {
- vty_out(vty, "No ASP named '%s' found%s", name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- osmo_ss7_asp_destroy(asp);
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_local_ip, asp_local_ip_cmd,
- "local-ip " VTY_IPV46_CMD " [primary]",
- "Specify Local IP Address from which to contact ASP\n"
- "Local IPv4 Address from which to contact of ASP\n"
- "Local IPv6 Address from which to contact of ASP\n"
- "Signal the SCTP peer to use this address as Primary Address\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
- bool is_primary = argc > 1;
- int old_idx_primary = asp->cfg.local.idx_primary;
- int old_host_count = asp->cfg.local.host_cnt;
- int rc;
-
- if (ss7_asp_peer_add_host2(&asp->cfg.local, asp, argv[0], is_primary) != 0) {
- vty_out(vty, "%% Failed adding host '%s' to set%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (!ss7_asp_is_started(asp))
- return CMD_SUCCESS;
- if (asp->cfg.proto == OSMO_SS7_ASP_PROT_IPA)
- return CMD_SUCCESS;
- /* The SCTP socket is already created. */
-
- /* dynamically apply the new address if it was added to the set: */
- if (asp->cfg.local.host_cnt > old_host_count) {
- if ((rc = ss7_asp_apply_new_local_address(asp, asp->cfg.local.host_cnt - 1)) < 0) {
- /* Failed, rollback changes: */
- TALLOC_FREE(asp->cfg.local.host[asp->cfg.local.host_cnt - 1]);
- asp->cfg.local.host_cnt--;
- vty_out(vty, "%% Failed adding new local address '%s'%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
- vty_out(vty, "%% Local address '%s' added to the active socket bind set%s", argv[0], VTY_NEWLINE);
- }
-
- /* dynamically apply the new primary if it changed: */
- if (is_primary && asp->cfg.local.idx_primary != old_idx_primary) {
- if ((rc = ss7_asp_apply_peer_primary_address(asp)) < 0) {
- /* Failed, rollback changes: */
- asp->cfg.local.idx_primary = old_idx_primary;
- vty_out(vty, "%% Failed announcing primary '%s' to peer%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
- vty_out(vty, "%% Local address '%s' announced as primary to the peer on the active socket%s", argv[0], VTY_NEWLINE);
- }
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_no_local_ip, asp_no_local_ip_cmd,
- "no local-ip " VTY_IPV46_CMD,
- NO_STR "Specify Local IP Address from which to contact ASP\n"
- "Local IPv4 Address from which to contact of ASP\n"
- "Local IPv6 Address from which to contact of ASP\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
- int idx = ss7_asp_peer_find_host(&asp->cfg.local, argv[0]);
- int rc;
-
- if (idx < 0) {
- vty_out(vty, "%% Local address '%s' not found in set%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (ss7_asp_is_started(asp)) {
- if (asp->cfg.proto != OSMO_SS7_ASP_PROT_IPA) {
- if ((rc = ss7_asp_apply_drop_local_address(asp, idx)) < 0) {
- vty_out(vty, "%% Failed removing local address '%s' from existing socket%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
- vty_out(vty, "%% Local address '%s' removed from active socket connection%s", argv[0], VTY_NEWLINE);
- }
- }
-
- if (ss7_asp_peer_del_host(&asp->cfg.local, argv[0]) != 0) {
- vty_out(vty, "%% Failed deleting local address '%s' from set%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_remote_ip, asp_remote_ip_cmd,
- "remote-ip " VTY_IPV46_CMD " [primary]",
- "Specify Remote IP Address of ASP\n"
- "Remote IPv4 Address of ASP\n"
- "Remote IPv6 Address of ASP\n"
- "Set remote address as SCTP Primary Address\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
- bool is_primary = argc > 1;
- int old_idx_primary = asp->cfg.remote.idx_primary;
- int rc;
-
- if (ss7_asp_peer_add_host2(&asp->cfg.remote, asp, argv[0], is_primary) != 0) {
- vty_out(vty, "%% Failed adding host '%s' to set%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (!ss7_asp_is_started(asp))
- return CMD_SUCCESS;
- if (asp->cfg.proto == OSMO_SS7_ASP_PROT_IPA)
- return CMD_SUCCESS;
-
- /* The SCTP socket is already created, dynamically apply the new primary if it changed: */
- if (asp->cfg.proto != OSMO_SS7_ASP_PROT_IPA && ss7_asp_is_started(asp)) {
- if ((rc = ss7_asp_apply_primary_address(asp)) < 0) {
- /* Failed, rollback changes: */
- asp->cfg.remote.idx_primary = old_idx_primary;
- vty_out(vty, "%% Failed applying primary on host '%s'%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
- }
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_no_remote_ip, asp_no_remote_ip_cmd,
- "no remote-ip " VTY_IPV46_CMD,
- NO_STR "Specify Remote IP Address of ASP\n"
- "Remote IPv4 Address of ASP\n"
- "Remote IPv6 Address of ASP\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
- int idx = ss7_asp_peer_find_host(&asp->cfg.remote, argv[0]);
-
- if (idx < 0) {
- vty_out(vty, "%% Remote address '%s' not found in set%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (ss7_asp_peer_del_host(&asp->cfg.remote, argv[0]) != 0) {
- vty_out(vty, "%% Failed deleting remote address '%s' from set%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_qos_clas, asp_qos_class_cmd,
- "qos-class " QOS_CLASS_RANGE_STR,
- "Specify QoS Class of ASP\n"
- QOS_CLASS_RANGE_HELP_STR,
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
- asp->cfg.qos_class = atoi(argv[0]);
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_role, asp_role_cmd,
- "role (sg|asp|ipsp)",
- "Specify the xUA role for this ASP\n"
- "SG (Signaling Gateway)\n"
- "ASP (Application Server Process)\n"
- "IPSP (IP Signalling Point)\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
-
- if (!strcmp(argv[0], "sg")) {
- asp->cfg.role = OSMO_SS7_ASP_ROLE_SG;
- } else if (!strcmp(argv[0], "asp")) {
- asp->cfg.role = OSMO_SS7_ASP_ROLE_ASP;
- } else if (!strcmp(argv[0], "ipsp")) {
- vty_out(vty, "IPSP role isn't supported yet%s", VTY_NEWLINE);
- return CMD_WARNING;
- } else
- OSMO_ASSERT(0);
-
- asp->cfg.role_set_by_vty = true;
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_transport_role, asp_transport_role_cmd,
- "transport-role (client|server)",
- "Specify the transport layer role for this ASP\n"
- "Operate as a client; connect to a server\n"
- "Operate as a server; wait for client connections\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
-
- if (!strcmp(argv[0], "client"))
- asp->cfg.is_server = false;
- else if (!strcmp(argv[0], "server"))
- asp->cfg.is_server = true;
- else
- OSMO_ASSERT(0);
-
- asp->cfg.trans_role_set_by_vty = true;
- return CMD_SUCCESS;
-}
-
-ALIAS_ATTR(asp_transport_role, asp_sctp_role_cmd,
- "sctp-role (client|server)",
- "Specify the SCTP role for this ASP\n"
- "Operate as SCTP client; connect to a server\n"
- "Operate as SCTP server; wait for client connections\n",
- CMD_ATTR_HIDDEN | CMD_ATTR_NODE_EXIT);
-
-#define ASP_SCTP_PARAM_INIT_DESC \
- "Configure SCTP parameters\n" \
- "Configure INIT related parameters\n" \
- "Configure INIT Number of Outbound Streams\n" \
- "Configure INIT Maximum Inboud Streams\n" \
- "Configure INIT Maximum Attempts\n" \
- "Configure INIT Timeout (milliseconds)\n"
-#define ASP_SCTP_PARAM_INIT_FIELDS "(num-ostreams|max-instreams|max-attempts|timeout)"
-
-DEFUN_ATTR(asp_sctp_param_init, asp_sctp_param_init_cmd,
- "sctp-param init " ASP_SCTP_PARAM_INIT_FIELDS " <0-65535>",
- ASP_SCTP_PARAM_INIT_DESC
- "Value of the parameter\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
-
- uint16_t val = atoi(argv[1]);
-
- if (strcmp(argv[0], "num-ostreams") == 0) {
- asp->cfg.sctp_init.num_ostreams_present = true;
- asp->cfg.sctp_init.num_ostreams_value = val;
- } else if (strcmp(argv[0], "max-instreams") == 0) {
- asp->cfg.sctp_init.max_instreams_present = true;
- asp->cfg.sctp_init.max_instreams_value = val;
- } else if (strcmp(argv[0], "max-attempts") == 0) {
- asp->cfg.sctp_init.max_attempts_present = true;
- asp->cfg.sctp_init.max_attempts_value = val;
- } else if (strcmp(argv[0], "timeout") == 0) {
- asp->cfg.sctp_init.max_init_timeo_present = true;
- asp->cfg.sctp_init.max_init_timeo_value = val;
- } else {
- OSMO_ASSERT(0);
- }
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_no_sctp_param_init, asp_no_sctp_param_init_cmd,
- "no sctp-param init " ASP_SCTP_PARAM_INIT_FIELDS,
- NO_STR ASP_SCTP_PARAM_INIT_DESC,
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
-
- if (strcmp(argv[0], "num-ostreams") == 0)
- asp->cfg.sctp_init.num_ostreams_present = false;
- else if (strcmp(argv[0], "max-instreams") == 0)
- asp->cfg.sctp_init.max_instreams_present = false;
- else if (strcmp(argv[0], "max-attempts") == 0)
- asp->cfg.sctp_init.max_attempts_present = false;
- else if (strcmp(argv[0], "timeout") == 0)
- asp->cfg.sctp_init.max_init_timeo_present = false;
- else
- OSMO_ASSERT(0);
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_block, asp_block_cmd,
- "block",
- "Allows a SCTP Association with ASP, but doesn't let it become active\n",
- CMD_ATTR_NODE_EXIT)
-{
- /* TODO */
- vty_out(vty, "Not supported yet%s", VTY_NEWLINE);
- return CMD_WARNING;
-}
-
-DEFUN_ATTR(asp_shutdown, asp_shutdown_cmd,
- "shutdown",
- "Terminates SCTP association; New associations will be rejected\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
-
- LOGPASP(asp, DLSS7, LOGL_NOTICE, "Applying Adm State change: %s -> %s\n",
- get_value_string(osmo_ss7_asp_admin_state_names, asp->cfg.adm_state),
- get_value_string(osmo_ss7_asp_admin_state_names, OSMO_SS7_ASP_ADM_S_SHUTDOWN));
-
- asp->cfg.explicit_shutdown_state_by_vty_since_node_enter = true;
- asp->cfg.adm_state = OSMO_SS7_ASP_ADM_S_SHUTDOWN;
- ss7_asp_restart_after_reconfigure(asp);
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_no_shutdown, asp_no_shutdown_cmd,
- "no shutdown",
- NO_STR "Terminates SCTP association; New associations will be rejected\n",
- CMD_ATTR_NODE_EXIT)
-{
- struct osmo_ss7_asp *asp = vty->index;
-
- LOGPASP(asp, DLSS7, LOGL_NOTICE, "Applying Adm State change: %s -> %s\n",
- get_value_string(osmo_ss7_asp_admin_state_names, asp->cfg.adm_state),
- get_value_string(osmo_ss7_asp_admin_state_names, OSMO_SS7_ASP_ADM_S_ENABLED));
-
- asp->cfg.explicit_shutdown_state_by_vty_since_node_enter = true;
- asp->cfg.adm_state = OSMO_SS7_ASP_ADM_S_ENABLED;
- ss7_asp_restart_after_reconfigure(asp);
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_quirk, asp_quirk_cmd,
- "OVERWRITTEN",
- "OVERWRITTEN\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_asp *asp = vty->index;
- int quirk = get_string_value(asp_quirk_names, argv[0]);
-
- if (quirk < 0)
- return CMD_WARNING;
-
- asp->cfg.quirks |= quirk;
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(asp_no_quirk, asp_no_quirk_cmd,
- "OVERWRITTEN",
- "OVERWRITTEN\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_asp *asp = vty->index;
- int quirk = get_string_value(asp_quirk_names, argv[0]);
-
- if (quirk < 0)
- return CMD_WARNING;
-
- asp->cfg.quirks &= ~quirk;
- return CMD_SUCCESS;
-}
-
-/* timer lm <name> <1-999999>
- * (cmdstr and doc are dynamically generated from ss7_asp_lm_timer_names.) */
-DEFUN_ATTR(asp_timer, asp_timer_cmd,
- NULL, NULL, CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_asp *asp = vty->index;
- enum ss7_asp_lm_timer timer = get_string_value(ss7_asp_lm_timer_names, argv[0]);
-
- if (timer <= 0 || timer >= SS7_ASP_LM_TIMERS_LEN) {
- vty_out(vty, "%% Invalid timer: %s%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- osmo_tdef_set(asp->cfg.T_defs_lm, timer, atoi(argv[1]), OSMO_TDEF_S);
- return CMD_SUCCESS;
-}
-
-static void gen_asp_timer_cmd_strs(struct cmd_element *cmd)
-{
- int i;
- char *cmd_str = NULL;
- char *doc_str = NULL;
-
- OSMO_ASSERT(cmd->string == NULL);
- OSMO_ASSERT(cmd->doc == NULL);
-
- osmo_talloc_asprintf(tall_vty_ctx, cmd_str, "timer lm (");
- osmo_talloc_asprintf(tall_vty_ctx, doc_str,
- "Configure ASP default timer values\n"
- "Configure ASP default lm timer values\n");
-
- for (i = 0; ss7_asp_lm_timer_names[i].str; i++) {
- const struct osmo_tdef *def;
- enum ss7_asp_lm_timer timer;
-
- timer = ss7_asp_lm_timer_names[i].value;
- def = osmo_tdef_get_entry((struct osmo_tdef *)&ss7_asp_lm_timer_defaults, timer);
- OSMO_ASSERT(def);
-
- osmo_talloc_asprintf(tall_vty_ctx, cmd_str, "%s%s",
- i ? "|" : "",
- ss7_asp_lm_timer_names[i].str);
- osmo_talloc_asprintf(tall_vty_ctx, doc_str, "%s (default: %lu)\n",
- def->desc,
- def->default_val);
- }
-
- osmo_talloc_asprintf(tall_vty_ctx, cmd_str, ") <1-999999>");
- osmo_talloc_asprintf(tall_vty_ctx, doc_str,
- "Timer value, in seconds\n");
-
- cmd->string = cmd_str;
- cmd->doc = doc_str;
-}
-
-static void write_asp_timers(struct vty *vty, const char *indent,
- struct osmo_ss7_asp *asp)
-{
- int i;
-
- for (i = 0; ss7_asp_lm_timer_names[i].str; i++) {
- const struct osmo_tdef *tdef = osmo_tdef_get_entry(asp->cfg.T_defs_lm, ss7_asp_lm_timer_names[i].value);
- if (!tdef)
- continue;
- if (tdef->val == tdef->default_val)
- continue;
- vty_out(vty, "%stimer lm %s %lu%s", indent, ss7_asp_lm_timer_names[i].str,
- tdef->val, VTY_NEWLINE);
- }
-}
-
-static char *as_list_for_asp(const struct osmo_ss7_asp *asp, char *buf, size_t buf_len)
-{
- struct osmo_strbuf sb = { .buf = buf, .len = buf_len };
- const struct osmo_ss7_as *as;
- unsigned int count = 0;
- llist_for_each_entry(as, &asp->inst->as_list, list) {
- if (!osmo_ss7_as_has_asp(as, asp))
- continue;
- OSMO_STRBUF_PRINTF(sb, "%s%s", count != 0 ? "," : "", as->cfg.name);
- count++;
- break;
- }
-
- if (count == 0)
- OSMO_STRBUF_PRINTF(sb, "?");
- return buf;
-}
-
-/* Similar to osmo_sock_multiaddr_get_name_buf(), but aimed at listening sockets (only local part): */
-static char *get_sockname_buf(char *buf, size_t buf_len, int fd, int proto, bool local)
-{
- char hostbuf[OSMO_SOCK_MAX_ADDRS][INET6_ADDRSTRLEN];
- size_t num_hostbuf = ARRAY_SIZE(hostbuf);
- char portbuf[6];
- struct osmo_strbuf sb = { .buf = buf, .len = buf_len };
- bool need_more_bufs;
- int rc;
-
- rc = osmo_sock_multiaddr_get_ip_and_port(fd, proto, &hostbuf[0][0],
- &num_hostbuf, sizeof(hostbuf[0]),
- portbuf, sizeof(portbuf), local);
- if (rc < 0)
- return NULL;
-
- need_more_bufs = num_hostbuf > ARRAY_SIZE(hostbuf);
- if (need_more_bufs)
- num_hostbuf = ARRAY_SIZE(hostbuf);
- OSMO_STRBUF_APPEND(sb, osmo_multiaddr_ip_and_port_snprintf,
- &hostbuf[0][0], num_hostbuf, sizeof(hostbuf[0]), portbuf);
- if (need_more_bufs)
- OSMO_STRBUF_PRINTF(sb, "<need-more-bufs!>");
-
- return buf;
-}
-
-static void show_one_asp(struct vty *vty, struct osmo_ss7_asp *asp)
-{
- char as_buf[64];
- char buf_loc[OSMO_SOCK_MULTIADDR_PEER_STR_MAXLEN];
- char buf_rem[sizeof(buf_loc)];
-
- int fd = ss7_asp_get_fd(asp);
- if (fd > 0) {
- const int trans_proto = asp->cfg.trans_proto;
- if (!get_sockname_buf(buf_loc, sizeof(buf_loc), fd, trans_proto, true))
- OSMO_STRLCPY_ARRAY(buf_loc, "<sockname-error>");
- if (!get_sockname_buf(buf_rem, sizeof(buf_rem), fd, trans_proto, false))
- OSMO_STRLCPY_ARRAY(buf_rem, "<sockname-error>");
- } else {
- ss7_asp_peer_snprintf(buf_loc, sizeof(buf_loc), &asp->cfg.local);
- ss7_asp_peer_snprintf(buf_rem, sizeof(buf_rem), &asp->cfg.remote);
- }
-
- vty_out(vty, "%-12s %-12s %-13s %-4s %-4s %-9s %-23s %-23s%s",
- asp->cfg.name,
- as_list_for_asp(asp, as_buf, sizeof(as_buf)),
- asp->fi ? osmo_fsm_inst_state_name(asp->fi) : "uninitialized",
- get_value_string(osmo_ss7_asp_protocol_vals, asp->cfg.proto),
- osmo_str_tolower(get_value_string(osmo_ss7_asp_role_names, asp->cfg.role)),
- asp->cfg.is_server ? "server" : "client",
- buf_loc, buf_rem,
- VTY_NEWLINE);
-}
-
-static int show_asp(struct vty *vty, int id, const char *asp_name)
-{
- struct osmo_ss7_instance *inst;
- struct osmo_ss7_asp *asp = NULL;
-
- inst = osmo_ss7_instance_find(id);
- if (!inst) {
- vty_out(vty, "No SS7 instance %d found%s", id, VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (asp_name) {
- asp = osmo_ss7_asp_find_by_name(inst, asp_name);
- if (!asp) {
- vty_out(vty, "No ASP %s found%s", asp_name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- }
-
- vty_out(vty, "ASP Name AS Name State Type Role SCTP Role Local Addresses Remote Addresses%s", VTY_NEWLINE);
- vty_out(vty, "------------ ------------ ------------- ---- ---- --------- ----------------------- -----------------------%s", VTY_NEWLINE);
-
- if (asp) {
- show_one_asp(vty, asp);
- return CMD_SUCCESS;
- }
-
- llist_for_each_entry(asp, &inst->asp_list, list)
- show_one_asp(vty, asp);
- return CMD_SUCCESS;
-}
-
-DEFUN(show_cs7_asp, show_cs7_asp_cmd,
- "show cs7 instance <0-15> asp",
- SHOW_STR CS7_STR INST_STR INST_STR
- "Application Server Process (ASP)\n")
-{
- int id = atoi(argv[0]);
-
- return show_asp(vty, id, NULL);
-}
-
-DEFUN(show_cs7_asp_name, show_cs7_asp_name_cmd,
- "show cs7 instance <0-15> asp name ASP_NAME",
- SHOW_STR CS7_STR INST_STR INST_STR
- "Application Server Process (ASP)\n"
- "Lookup ASP with a given name\n"
- "Name of the Application Server Process (ASP)\n")
-{
- int id = atoi(argv[0]);
- const char *asp_name = argv[1];
-
- return show_asp(vty, id, asp_name);
-}
-
-static void show_one_asp_remaddr_tcp(struct vty *vty, struct osmo_ss7_asp *asp)
-{
- struct osmo_sockaddr osa = {};
- struct tcp_info tcpi = {};
- socklen_t len;
- int fd, rc;
-
- fd = ss7_asp_get_fd(asp);
- if (fd < 0) {
- vty_out(vty, "%-12s %-46s uninitialized%s", asp->cfg.name, "", VTY_NEWLINE);
- return;
- }
-
- len = sizeof(osa.u.sas);
- rc = getpeername(fd, &osa.u.sa, &len);
-
- len = sizeof(tcpi);
- rc = getsockopt(fd, SOL_TCP, TCP_INFO, &tcpi, &len);
- if (rc < 0) {
- char buf_err[128];
- strerror_r(errno, buf_err, sizeof(buf_err));
- vty_out(vty, "%-12s %-46s getsockopt(TCP_INFO) failed: %s%s",
- asp->cfg.name, osmo_sockaddr_to_str(&osa), buf_err, VTY_NEWLINE);
- return;
- }
-
- vty_out(vty, "%-12s %-46s TCP_%-19s %-8u %-8u %-8u %-8u%s",
- asp->cfg.name,
- osmo_sockaddr_to_str(&osa),
- get_value_string(tcp_info_state_values, tcpi.tcpi_state),
- tcpi.tcpi_snd_cwnd, tcpi.tcpi_rtt,
- tcpi.tcpi_rto, tcpi.tcpi_pmtu,
- VTY_NEWLINE);
-}
-
-#ifdef HAVE_LIBSCTP
-static void show_one_asp_remaddr_sctp(struct vty *vty, struct osmo_ss7_asp *asp)
-{
- struct sctp_paddrinfo pinfo[OSMO_SOCK_MAX_ADDRS];
- struct osmo_sockaddr osa = {};
- size_t pinfo_cnt = ARRAY_SIZE(pinfo);
- bool more_needed;
- int fd, rc;
- unsigned int i;
-
- fd = ss7_asp_get_fd(asp);
- if (fd < 0) {
- vty_out(vty, "%-12s %-46s uninitialized%s", asp->cfg.name, "", VTY_NEWLINE);
- return;
- }
-
- rc = osmo_sock_sctp_get_peer_addr_info(fd, &pinfo[0], &pinfo_cnt);
- if (rc < 0) {
- char buf_err[128];
- strerror_r(errno, buf_err, sizeof(buf_err));
- vty_out(vty, "%-12s %-46s getsockopt(SCTP_GET_PEER_ADDR_INFO) failed: %s%s", asp->cfg.name, "", buf_err, VTY_NEWLINE);
- return;
- }
-
- more_needed = pinfo_cnt > ARRAY_SIZE(pinfo);
- if (pinfo_cnt > ARRAY_SIZE(pinfo))
- pinfo_cnt = ARRAY_SIZE(pinfo);
-
- for (i = 0; i < pinfo_cnt; i++) {
- osa.u.sas = pinfo[i].spinfo_address;
- vty_out(vty, "%-12s %-46s SCTP_%-18s %-8u %-8u %-8u %-8u%s",
- asp->cfg.name,
- osmo_sockaddr_to_str(&osa),
- osmo_sctp_spinfo_state_str(pinfo[i].spinfo_state),
- pinfo[i].spinfo_cwnd, pinfo[i].spinfo_srtt,
- pinfo[i].spinfo_rto, pinfo[i].spinfo_mtu,
- VTY_NEWLINE);
- }
-
- if (more_needed)
- vty_out(vty, "%-12s more address buffers needed!%s", asp->cfg.name, VTY_NEWLINE);
-}
-#endif
-
-static void show_one_asp_remaddr(struct vty *vty, struct osmo_ss7_asp *asp)
-{
- switch (asp->cfg.trans_proto) {
- case IPPROTO_TCP:
- show_one_asp_remaddr_tcp(vty, asp);
- break;
-#ifdef HAVE_LIBSCTP
- case IPPROTO_SCTP:
- show_one_asp_remaddr_sctp(vty, asp);
- break;
-#endif
- default:
- vty_out(vty, "%-12s %-46s unknown proto %d%s",
- asp->cfg.name, "", asp->cfg.trans_proto, VTY_NEWLINE);
- break;
- }
-}
-
-static int show_asp_remaddr(struct vty *vty, int id, const char *asp_name)
-{
- struct osmo_ss7_instance *inst;
- struct osmo_ss7_asp *asp = NULL;
-
- inst = osmo_ss7_instance_find(id);
- if (!inst) {
- vty_out(vty, "No SS7 instance %d found%s", id, VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (asp_name) {
- asp = osmo_ss7_asp_find_by_name(inst, asp_name);
- if (!asp) {
- vty_out(vty, "No ASP %s found%s", asp_name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- }
-
- vty_out(vty, "ASP Name Remote IP Address & Port State CWND SRTT RTO MTU%s", VTY_NEWLINE);
- vty_out(vty, "------------ ---------------------------------------------- ----------------------- -------- -------- -------- --------%s", VTY_NEWLINE);
-
- if (asp) {
- show_one_asp_remaddr(vty, asp);
- return CMD_SUCCESS;
- }
-
- llist_for_each_entry(asp, &inst->asp_list, list) {
- show_one_asp_remaddr(vty, asp);
- }
- return CMD_SUCCESS;
-}
-
-DEFUN(show_cs7_asp_remaddr, show_cs7_asp_remaddr_cmd,
- "show cs7 instance <0-15> asp-remaddr",
- SHOW_STR CS7_STR INST_STR INST_STR
- "Application Server Process (ASP) remote addresses information\n")
-{
- int id = atoi(argv[0]);
-
- return show_asp_remaddr(vty, id, NULL);
-}
-
-
-DEFUN(show_cs7_asp_remaddr_name, show_cs7_asp_remaddr_name_cmd,
- "show cs7 instance <0-15> asp-remaddr name ASP_NAME",
- SHOW_STR CS7_STR INST_STR INST_STR
- "Application Server Process (ASP) remote addresses information\n"
- "Lookup ASP with a given name\n"
- "Name of the Application Server Process (ASP)\n")
-{
- int id = atoi(argv[0]);
- const char *asp_name = argv[1];
-
- return show_asp_remaddr(vty, id, asp_name);
-}
-
-static void show_one_asp_assoc_status_tcp(struct vty *vty, struct osmo_ss7_asp *asp)
-{
- struct osmo_sockaddr osa = {};
- struct tcp_info tcpi = {};
- socklen_t len;
- int fd, rc;
- int rx_pend_bytes = 0;
-
- fd = ss7_asp_get_fd(asp);
- if (fd < 0) {
- vty_out(vty, "%-12s uninitialized%s", asp->cfg.name, VTY_NEWLINE);
- return;
- }
-
- len = sizeof(osa.u.sas);
- rc = getpeername(fd, &osa.u.sa, &len);
-
- len = sizeof(tcpi);
- rc = getsockopt(fd, SOL_TCP, TCP_INFO, &tcpi, &len);
- if (rc < 0) {
- char buf_err[128];
- strerror_r(errno, buf_err, sizeof(buf_err));
- vty_out(vty, "%-12s getsockopt(TCP_INFO) failed: %s%s",
- asp->cfg.name, buf_err, VTY_NEWLINE);
- return;
- }
-
- rc = ioctl(fd, FIONREAD, &rx_pend_bytes);
-
- /* FIXME: RWND: struct tcp_info from linux/tcp.h contains more fields
- * than the one from netinet/tcp.h we currently use, including
- * "tcpi_rcv_wnd" which we could use to print RWND here. However,
- * linux/tcp.h seems to be missing the state defines used in
- * "tcp_info_state_values", so we cannot use that one instead.
- */
-
- vty_out(vty, "%-12s TCP_%-19s %-9s %-10s %-8s %-9u %-7u %-9u %-46s%s",
- asp->cfg.name,
- get_value_string(tcp_info_state_values, tcpi.tcpi_state),
- "-", "-", "-", tcpi.tcpi_unacked, rx_pend_bytes,
- tcpi.tcpi_pmtu, osmo_sockaddr_to_str(&osa),
- VTY_NEWLINE);
-}
-
-#ifdef HAVE_LIBSCTP
-static void show_one_asp_assoc_status_sctp(struct vty *vty, struct osmo_ss7_asp *asp)
-{
- struct osmo_sockaddr osa = {};
- struct sctp_status st;
- socklen_t len;
- int fd, rc;
-
- fd = ss7_asp_get_fd(asp);
- if (fd < 0) {
- vty_out(vty, "%-12s uninitialized%s", asp->cfg.name, VTY_NEWLINE);
- return;
- }
-
- memset(&st, 0, sizeof(st));
- len = sizeof(st);
- rc = getsockopt(fd, IPPROTO_SCTP, SCTP_STATUS, &st, &len);
- if (rc < 0) {
- char buf_err[128];
- strerror_r(errno, buf_err, sizeof(buf_err));
- vty_out(vty, "%-12s getsockopt(SCTP_STATUS) failed: %s%s", asp->cfg.name, buf_err, VTY_NEWLINE);
- return;
- }
-
- osa.u.sas = st.sstat_primary.spinfo_address;
- vty_out(vty, "%-12s SCTP_%-18s %-9u %-10u %-8u %-9u %-7u %-9u %-46s%s",
- asp->cfg.name,
- osmo_sctp_sstat_state_str(st.sstat_state),
- st.sstat_instrms, st.sstat_outstrms,
- st.sstat_rwnd, st.sstat_unackdata, st.sstat_penddata,
- st.sstat_fragmentation_point,
- osmo_sockaddr_to_str(&osa),
- VTY_NEWLINE);
-}
-#endif
-
-static void show_one_asp_assoc_status(struct vty *vty, struct osmo_ss7_asp *asp)
-{
- switch (asp->cfg.trans_proto) {
- case IPPROTO_TCP:
- show_one_asp_assoc_status_tcp(vty, asp);
- break;
-#ifdef HAVE_LIBSCTP
- case IPPROTO_SCTP:
- show_one_asp_assoc_status_sctp(vty, asp);
- break;
-#endif
- default:
- vty_out(vty, "%-12s unknown proto %d%s",
- asp->cfg.name, asp->cfg.trans_proto, VTY_NEWLINE);
- break;
- }
-}
-
-static int show_asp_assoc_status(struct vty *vty, int id, const char *asp_name)
-{
- struct osmo_ss7_instance *inst;
- struct osmo_ss7_asp *asp = NULL;
-
- inst = osmo_ss7_instance_find(id);
- if (!inst) {
- vty_out(vty, "No SS7 instance %d found%s", id, VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (asp_name) {
- asp = osmo_ss7_asp_find_by_name(inst, asp_name);
- if (!asp) {
- vty_out(vty, "No ASP %s found%s", asp_name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- }
-
- vty_out(vty, "ASP Name State InStreams OutStreams RWND UnackData PenData FragPoint Current Primary Remote IP Address & Port%s", VTY_NEWLINE);
- vty_out(vty, "------------ ----------------------- --------- ---------- -------- --------- ------- --------- ----------------------------------------------%s", VTY_NEWLINE);
-
- if (asp) {
- show_one_asp_assoc_status(vty, asp);
- return CMD_SUCCESS;
- }
-
- llist_for_each_entry(asp, &inst->asp_list, list)
- show_one_asp_assoc_status(vty, asp);
- return CMD_SUCCESS;
-}
-
-DEFUN(show_cs7_asp_assoc_status, show_cs7_asp_assoc_status_cmd,
- "show cs7 instance <0-15> asp-assoc-status",
- SHOW_STR CS7_STR INST_STR INST_STR
- "Application Server Process (ASP) SCTP association status\n")
-{
- int id = atoi(argv[0]);
-
- return show_asp_assoc_status(vty, id, NULL);
-}
-
-
-DEFUN(show_cs7_asp_assoc_status_name, show_cs7_asp_assoc_status_name_cmd,
- "show cs7 instance <0-15> asp-assoc-status name ASP_NAME",
- SHOW_STR CS7_STR INST_STR INST_STR
- "Application Server Process (ASP) SCTP association information\n"
- "Lookup ASP with a given name\n"
- "Name of the Application Server Process (ASP)\n")
-{
- int id = atoi(argv[0]);
- const char *asp_name = argv[1];
-
- return show_asp_assoc_status(vty, id, asp_name);
-}
-
-static void write_one_asp(struct vty *vty, struct osmo_ss7_asp *asp, bool show_dyn_config)
-{
- int i;
- /* skip any dynamically created ASPs (e.g. auto-created at connect time) */
- if ((asp->dyn_allocated || asp->simple_client_allocated)
- && !show_dyn_config)
- return;
-
- vty_out(vty, " asp %s %u %u %s",
- asp->cfg.name, asp->cfg.remote.port, asp->cfg.local.port,
- osmo_ss7_asp_protocol_name(asp->cfg.proto));
- if (asp->cfg.trans_proto != ss7_default_trans_proto_for_asp_proto(asp->cfg.proto))
- vty_out(vty, " %s", get_value_string(ipproto_vals, asp->cfg.trans_proto));
- vty_out(vty, "%s", VTY_NEWLINE);
- if (asp->cfg.description)
- vty_out(vty, " description %s%s", asp->cfg.description, VTY_NEWLINE);
- for (i = 0; i < asp->cfg.local.host_cnt; i++) {
- if (asp->cfg.local.host[i])
- vty_out(vty, " local-ip %s%s%s", asp->cfg.local.host[i],
- asp->cfg.local.idx_primary == i ? " primary" : "", VTY_NEWLINE);
- }
- for (i = 0; i < asp->cfg.remote.host_cnt; i++) {
- if (asp->cfg.remote.host[i])
- vty_out(vty, " remote-ip %s%s%s", asp->cfg.remote.host[i],
- asp->cfg.remote.idx_primary == i ? " primary" : "", VTY_NEWLINE);
- }
- if (asp->cfg.qos_class)
- vty_out(vty, " qos-class %u%s", asp->cfg.qos_class, VTY_NEWLINE);
- vty_out(vty, " role %s%s", osmo_str_tolower(get_value_string(osmo_ss7_asp_role_names, asp->cfg.role)),
- VTY_NEWLINE);
- if (asp->cfg.trans_proto == IPPROTO_SCTP)
- vty_out(vty, " sctp-role %s%s", asp->cfg.is_server ? "server" : "client", VTY_NEWLINE);
- else
- vty_out(vty, " transport-role %s%s", asp->cfg.is_server ? "server" : "client", VTY_NEWLINE);
- if (asp->cfg.sctp_init.num_ostreams_present)
- vty_out(vty, " sctp-param init num-ostreams %u%s", asp->cfg.sctp_init.num_ostreams_value, VTY_NEWLINE);
- if (asp->cfg.sctp_init.max_instreams_present)
- vty_out(vty, " sctp-param init max-instreams %u%s", asp->cfg.sctp_init.max_instreams_value, VTY_NEWLINE);
- if (asp->cfg.sctp_init.max_attempts_present)
- vty_out(vty, " sctp-param init max-attempts %u%s", asp->cfg.sctp_init.max_attempts_value, VTY_NEWLINE);
- if (asp->cfg.sctp_init.max_init_timeo_present)
- vty_out(vty, " sctp-param init timeout %u%s", asp->cfg.sctp_init.max_init_timeo_value, VTY_NEWLINE);
- for (i = 0; i < sizeof(uint32_t) * 8; i++) {
- if (!(asp->cfg.quirks & ((uint32_t) 1 << i)))
- continue;
- vty_out(vty, " quirk %s%s", get_value_string(asp_quirk_names, (1 << i)), VTY_NEWLINE);
- }
- write_asp_timers(vty, " ", asp);
-
- switch (asp->cfg.adm_state) {
- case OSMO_SS7_ASP_ADM_S_SHUTDOWN:
- vty_out(vty, " shutdown%s", VTY_NEWLINE);
- break;
- case OSMO_SS7_ASP_ADM_S_BLOCKED:
- vty_out(vty, " blocked%s", VTY_NEWLINE);
- break;
- case OSMO_SS7_ASP_ADM_S_ENABLED:
- /* Default, no need to print: */
- vty_out(vty, " no shutdown%s", VTY_NEWLINE);
- break;
- }
-}
-
-
-/***********************************************************************
- * Application Server
- ***********************************************************************/
-
-static struct cmd_node as_node = {
- L_CS7_AS_NODE,
- "%s(config-cs7-as)# ",
- 1,
-};
-
-DEFUN_ATTR(cs7_as, cs7_as_cmd,
- "as NAME " XUA_VAR_STR,
- "Configure an Application Server\n"
- "Name of the Application Server\n"
- XUA_VAR_HELP_STR,
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_instance *inst = vty->index;
- struct osmo_ss7_as *as;
- const char *name = argv[0];
- enum osmo_ss7_asp_protocol protocol = parse_asp_proto(argv[1]);
-
- if (protocol == OSMO_SS7_ASP_PROT_NONE) {
- vty_out(vty, "invalid protocol '%s'%s", argv[1], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- as = osmo_ss7_as_find_or_create(inst, name, protocol);
- if (!as) {
- vty_out(vty, "cannot create AS '%s'%s", name, VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- as->cfg.name = talloc_strdup(as, name);
-
- vty->node = L_CS7_AS_NODE;
- vty->index = as;
- vty->index_sub = &as->cfg.description;
-
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(no_cs7_as, no_cs7_as_cmd,
- "no as NAME",
- NO_STR "Disable Application Server\n"
- "Name of AS\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_instance *inst = vty->index;
- const char *name = argv[0];
- struct osmo_ss7_as *as;
-
- as = osmo_ss7_as_find_by_name(inst, name);
- if (!as) {
- vty_out(vty, "No AS named '%s' found%s", name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- osmo_ss7_as_destroy(as);
- return CMD_SUCCESS;
-}
-
-/* TODO: routing-key */
-DEFUN_ATTR(as_asp, as_asp_cmd,
- "asp NAME",
- "Specify that a given ASP is part of this AS\n"
- "Name of ASP to be added to AS\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_as *as = vty->index;
-
- if (osmo_ss7_as_add_asp(as, argv[0])) {
- vty_out(vty, "cannot find ASP '%s'%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(as_no_asp, as_no_asp_cmd,
- "no asp NAME",
- NO_STR "Specify ASP to be removed from this AS\n"
- "Name of ASP to be removed\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_as *as = vty->index;
-
- if (osmo_ss7_as_del_asp(as, argv[0])) {
- vty_out(vty, "cannot find ASP '%s'%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- return CMD_SUCCESS;
-}
-
-DEFUN_USRATTR(as_traf_mode, as_traf_mode_cmd,
- OSMO_SCCP_LIB_ATTR_RSTRT_ASP,
- "traffic-mode (broadcast | roundrobin | override)",
- "Specifies traffic mode of operation of the ASP within the AS\n"
- "Broadcast to all ASP within AS\n"
- "Round-Robin between all ASP within AS\n"
- "Override\n")
-{
- struct osmo_ss7_as *as = vty->index;
-
- as->cfg.mode = get_string_value(osmo_ss7_as_traffic_mode_vals, argv[0]);
- as->cfg.mode_set_by_vty = true;
- return CMD_SUCCESS;
-}
-
-DEFUN_USRATTR(as_traf_mode_loadshare, as_traf_mode_loadshare_cmd,
- OSMO_SCCP_LIB_ATTR_RSTRT_ASP,
- "traffic-mode loadshare [bindings] [sls] [opc-sls] [opc-shift] [<0-2>]",
- "Specifies traffic mode of operation of the ASP within the AS\n"
- "Share Load among all ASP within AS\n"
- "Configure Loadshare parameters\n"
- "Configure Loadshare SLS generation parameters\n"
- "Generate extended SLS with OPC information\n"
- "Shift OPC bits used during routing decision\n"
- "How many bits from ITU OPC field (starting from least-significant-bit) to skip (default=0). 6 bits are always used\n"
- )
-{
- struct osmo_ss7_as *as = vty->index;
-
- as->cfg.mode = OSMO_SS7_AS_TMOD_LOADSHARE;
- as->cfg.mode_set_by_vty = true;
- if (argc < 3) {
- as->cfg.loadshare.opc_sls = false;
- as->cfg.loadshare.opc_shift = 0;
- return CMD_SUCCESS;
- }
- as->cfg.loadshare.opc_sls = true;
- if (argc < 5) {
- as->cfg.loadshare.opc_shift = 0;
- return CMD_SUCCESS;
- }
- as->cfg.loadshare.opc_shift = atoi(argv[4]);
- return CMD_SUCCESS;
-}
-
-DEFUN_USRATTR(as_no_traf_mode, as_no_traf_mode_cmd,
- OSMO_SCCP_LIB_ATTR_RSTRT_ASP,
- "no traffic-mode",
- NO_STR "Remove explicit traffic mode of operation of this AS\n")
-{
- struct osmo_ss7_as *as = vty->index;
-
- as->cfg.mode = 0;
- as->cfg.mode_set_by_vty = false;
-
- as->cfg.loadshare.sls_shift = 0;
- as->cfg.loadshare.opc_sls = false;
- as->cfg.loadshare.opc_shift = 0;
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(as_sls_shift, as_sls_shift_cmd,
- "sls-shift <0-3>",
- "Shift SLS bits used during routing decision\n"
- "How many bits from SLS field (starting from least-significant-bit) to skip\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_as *as = vty->index;
- as->cfg.loadshare.sls_shift = atoi(argv[0]);
-
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(as_bindingtable_reset, as_bindingtable_reset_cmd,
- "binding-table reset",
- "AS Loadshare binding table operations\n"
- "Reset loadshare binding table\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_as *as = vty->index;
- ss7_as_loadshare_binding_table_reset(as);
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(as_recov_tout, as_recov_tout_cmd,
- "recovery-timeout <1-2000>",
- "Specifies the recovery timeout value in milliseconds\n"
- "Recovery Timeout in Milliseconds\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_as *as = vty->index;
- as->cfg.recovery_timeout_msec = atoi(argv[0]);
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(as_qos_clas, as_qos_class_cmd,
- "qos-class " QOS_CLASS_RANGE_STR,
- "Specity QoS Class of AS\n"
- QOS_CLASS_RANGE_HELP_STR,
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_as *as = vty->index;
- as->cfg.qos_class = atoi(argv[0]);
- return CMD_SUCCESS;
-}
-
-const struct value_string mtp_si_vals[] = {
- { MTP_SI_SCCP, "sccp" },
- { MTP_SI_TUP, "tup" },
- { MTP_SI_ISUP, "isup" },
- { MTP_SI_DUP, "dup" },
- { MTP_SI_TESTING, "testing" },
- { MTP_SI_B_ISUP, "b-isup" },
- { MTP_SI_SAT_ISUP, "sat-isup" },
- { MTP_SI_AAL2_SIG, "aal2" },
- { MTP_SI_BICC, "bicc" },
- { MTP_SI_GCP, "h248" },
- { 0, NULL }
-};
-
-#define ROUTING_KEY_CMD "routing-key RCONTEXT DPC"
-#define ROUTING_KEY_CMD_STRS \
- "Define a routing key\n" \
- "Routing context number\n" \
- "Destination Point Code\n"
-#define ROUTING_KEY_SI_ARG " si (aal2|bicc|b-isup|h248|isup|sat-isup|sccp|tup)"
-#define ROUTING_KEY_SI_ARG_STRS \
- "Match on Service Indicator\n" \
- "ATM Adaption Layer 2\n" \
- "Bearer Independent Call Control\n" \
- "Broadband ISDN User Part\n" \
- "H.248\n" \
- "ISDN User Part\n" \
- "Sattelite ISDN User Part\n" \
- "Signalling Connection Control Part\n" \
- "Telephony User Part\n"
-#define ROUTING_KEY_SSN_ARG " ssn SSN"
-#define ROUTING_KEY_SSN_ARG_STRS \
- "Match on Sub-System Number\n" \
- "Sub-System Number to match on\n"
-
-static int _rout_key(struct vty *vty,
- const char *rcontext, const char *dpc,
- const char *si, const char *ssn)
-{
- struct osmo_ss7_as *as = vty->index;
- struct osmo_ss7_routing_key *rkey = &as->cfg.routing_key;
- struct osmo_ss7_route *rt;
- int pc;
-
- if (as->cfg.proto == OSMO_SS7_ASP_PROT_IPA && atoi(rcontext) != 0) {
- vty_out(vty, "IPA doesn't support routing contexts; only permitted routing context "
- "is 0\n");
- return CMD_WARNING;
- }
-
- pc = osmo_ss7_pointcode_parse(as->inst, dpc);
- if (pc < 0) {
- vty_out(vty, "Invalid point code (%s)%s", dpc, VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- /* When libosmo-sigtran is used in ASP role, the VTY routing table node
- * (config-cs7-rt) is not available. However, when we add a routing key
- * to an AS we still have to put a matching route into the routing
- * table. This is done automatically by first removing the old route
- * (users may change the routing key via VTY during runtime) and then
- * putting a new route (see below). */
- if (cs7_role == CS7_ROLE_ASP) {
- rt = ss7_route_table_find_route_by_dpc_mask(as->inst->rtable_system, rkey->pc, 0xffffff);
- if (rt)
- ss7_route_destroy(rt);
- }
-
- rkey->pc = pc;
-
- rkey->context = atoi(rcontext); /* FIXME: input validation */
- rkey->si = si ? get_string_value(mtp_si_vals, si) : 0; /* FIXME: input validation */
- rkey->ssn = ssn ? atoi(ssn) : 0; /* FIXME: input validation */
-
- /* automatically add new route (see also comment above) */
- if (cs7_role == CS7_ROLE_ASP) {
- if (!ss7_route_create(as->inst->rtable_system, rkey->pc, 0xffffff, as->cfg.name)) {
- vty_out(vty, "Cannot create route (pc=%s, linkset=%s) to AS %s", dpc, as->cfg.name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- }
-
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(as_rout_key, as_rout_key_cmd,
- ROUTING_KEY_CMD,
- ROUTING_KEY_CMD_STRS,
- CMD_ATTR_IMMEDIATE)
-{
- return _rout_key(vty, argv[0], argv[1], NULL, NULL);
-}
-
-DEFUN_ATTR(as_rout_key_si, as_rout_key_si_cmd,
- ROUTING_KEY_CMD ROUTING_KEY_SI_ARG,
- ROUTING_KEY_CMD_STRS ROUTING_KEY_SI_ARG_STRS,
- CMD_ATTR_IMMEDIATE)
-{
- return _rout_key(vty, argv[0], argv[1], argv[2], NULL);
-}
-
-DEFUN_ATTR(as_rout_key_ssn, as_rout_key_ssn_cmd,
- ROUTING_KEY_CMD ROUTING_KEY_SSN_ARG,
- ROUTING_KEY_CMD_STRS ROUTING_KEY_SSN_ARG_STRS,
- CMD_ATTR_IMMEDIATE)
-{
- return _rout_key(vty, argv[0], argv[1], NULL, argv[2]);
-}
-
-DEFUN_ATTR(as_rout_key_si_ssn, as_rout_key_si_ssn_cmd,
- ROUTING_KEY_CMD ROUTING_KEY_SI_ARG ROUTING_KEY_SSN_ARG,
- ROUTING_KEY_CMD_STRS ROUTING_KEY_SI_ARG_STRS ROUTING_KEY_SSN_ARG_STRS,
- CMD_ATTR_IMMEDIATE)
-{
- return _rout_key(vty, argv[0], argv[1], argv[2], argv[3]);
-}
-
-DEFUN_ATTR(as_pc_override, as_pc_override_cmd,
- "point-code override dpc PC",
- "Point Code Specific Features\n"
- "Override (force) a point-code to hard-coded value\n"
- "Override Source Point Code\n"
- "Override Destination Point Code\n"
- "New Point Code\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_as *as = vty->index;
- int pc = osmo_ss7_pointcode_parse(as->inst, argv[0]);
- if (pc < 0) {
- vty_out(vty, "Invalid point code (%s)%s", argv[0], VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (as->cfg.proto != OSMO_SS7_ASP_PROT_IPA) {
- vty_out(vty, "Only IPA type AS support point-code override. "
- "Be happy that you don't need it!%s", VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- as->cfg.pc_override.dpc = pc;
-
- return CMD_SUCCESS;
-}
-
-DEFUN_ATTR(as_pc_patch_sccp, as_pc_patch_sccp_cmd,
- "point-code override patch-sccp (disabled|both)",
- "Point Code Specific Features\n"
- "Override (force) a point-code to hard-coded value\n"
- "Patch point code values into SCCP called/calling address\n"
- "Don't patch any point codes into SCCP called/calling address\n"
- "Patch both origin and destination point codes into SCCP called/calling address\n",
- CMD_ATTR_IMMEDIATE)
-{
- struct osmo_ss7_as *as = vty->index;
-
- if (as->cfg.proto != OSMO_SS7_ASP_PROT_IPA) {
- vty_out(vty, "Only IPA type AS support point-code patch-into-sccp. "
- "Be happy that you don't need it!%s", VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (!strcmp(argv[0], "disabled"))
- as->cfg.pc_override.sccp_mode = OSMO_SS7_PATCH_NONE;
- else
- as->cfg.pc_override.sccp_mode = OSMO_SS7_PATCH_BOTH;
-
- return CMD_SUCCESS;
-}
-
-static void write_one_as(struct vty *vty, struct osmo_ss7_as *as, bool show_dyn_config)
-{
- struct osmo_ss7_routing_key *rkey;
- unsigned int i;
-
- /* skip any dynamically allocated AS definitions */
- if ((as->rkm_dyn_allocated || as->simple_client_allocated)
- && !show_dyn_config)
- return;
-
- vty_out(vty, " as %s %s%s", as->cfg.name,
- osmo_ss7_asp_protocol_name(as->cfg.proto), VTY_NEWLINE);
- if (as->cfg.description)
- vty_out(vty, " description %s%s", as->cfg.description, VTY_NEWLINE);
- for (i = 0; i < ARRAY_SIZE(as->cfg.asps); i++) {
- struct osmo_ss7_asp *asp = as->cfg.asps[i];
- if (!asp)
- continue;
- /* skip any dynamically created ASPs (e.g. auto-created at connect time) */
- if ((asp->dyn_allocated || asp->simple_client_allocated)
- && !show_dyn_config)
- continue;
- vty_out(vty, " asp %s%s", asp->cfg.name, VTY_NEWLINE);
- }
- if (as->cfg.mode_set_by_vty) {
- vty_out(vty, " traffic-mode %s%s", osmo_ss7_as_traffic_mode_name(as->cfg.mode), VTY_NEWLINE);
- if (as->cfg.mode == OSMO_SS7_AS_TMOD_LOADSHARE) {
- if (as->cfg.loadshare.opc_sls) {
- vty_out(vty, " bindings sls opc-sls");
- if (as->cfg.loadshare.opc_shift != 0)
- vty_out(vty, " opc-shift %u", as->cfg.loadshare.opc_shift);
- }
- vty_out(vty, "%s", VTY_NEWLINE);
- }
-
- if (as->cfg.loadshare.sls_shift != 0)
- vty_out(vty, " sls-shift %u%s", as->cfg.loadshare.sls_shift, VTY_NEWLINE);
- }
-
- if (as->cfg.recovery_timeout_msec != 2000) {
- vty_out(vty, " recovery-timeout %u%s",
- as->cfg.recovery_timeout_msec, VTY_NEWLINE);
- }
- if (as->cfg.qos_class)
- vty_out(vty, " qos-class %u%s", as->cfg.qos_class, VTY_NEWLINE);
- rkey = &as->cfg.routing_key;
- vty_out(vty, " routing-key %u %s", rkey->context,
- osmo_ss7_pointcode_print(as->inst, rkey->pc));
- if (rkey->si)
- vty_out(vty, " si %s",
- get_value_string(mtp_si_vals, rkey->si));
- if (rkey->ssn)
- vty_out(vty, " ssn %u", rkey->ssn);
- vty_out(vty, "%s", VTY_NEWLINE);
-
- if (as->cfg.pc_override.dpc)
- vty_out(vty, " point-code override dpc %s%s",
- osmo_ss7_pointcode_print(as->inst, as->cfg.pc_override.dpc), VTY_NEWLINE);
-
- if (as->cfg.pc_override.sccp_mode)
- vty_out(vty, " point-code override patch-sccp both%s", VTY_NEWLINE);
-}
-
-static void show_one_as(struct vty *vty, struct osmo_ss7_as *as)
-{
- vty_out(vty, "%-12s %-12s %-10u %-13s %4s %13s %3s %5s %4s %10s%s",
- as->cfg.name, osmo_fsm_inst_state_name(as->fi), as->cfg.routing_key.context,
- osmo_ss7_pointcode_print(as->inst, as->cfg.routing_key.pc),
- "", "", "", "", "", osmo_ss7_as_traffic_mode_name(as->cfg.mode),
- VTY_NEWLINE);
-}
-
-static int show_as(struct vty *vty, int id, const char *as_name, const char *filter)
-{
- struct osmo_ss7_instance *inst;
- struct osmo_ss7_as *as = NULL;
-
- inst = osmo_ss7_instance_find(id);
- if (!inst) {
- vty_out(vty, "%% No SS7 instance %d found%s", id, VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (as_name) {
- as = osmo_ss7_as_find_by_name(inst, as_name);
- if (!as) {
- vty_out(vty, "%% No AS '%s' found%s", as_name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- }
-
- vty_out(vty, " Routing Routing Key Cic Cic Traffic%s", VTY_NEWLINE);
- vty_out(vty, "AS Name State Context Dpc Si Opc Ssn Min Max Mode%s", VTY_NEWLINE);
- vty_out(vty, "------------ ------------ ---------- ------------- ---- ------------- --- ----- ----- -------%s", VTY_NEWLINE);
-
- if (as) {
- show_one_as(vty, as);
- return CMD_SUCCESS;
- }
-
- llist_for_each_entry(as, &inst->as_list, list) {
- if (filter && !strcmp(filter, "m3ua") && as->cfg.proto != OSMO_SS7_ASP_PROT_M3UA)
- continue;
- if (filter && !strcmp(filter, "sua") && as->cfg.proto != OSMO_SS7_ASP_PROT_SUA)
- continue;
- if (filter && !strcmp(filter, "active") && !osmo_ss7_as_active(as))
- continue;
- show_one_as(vty, as);
- }
- return CMD_SUCCESS;
-}
-
-DEFUN(show_cs7_as, show_cs7_as_cmd,
- "show cs7 instance <0-15> as (active|all|m3ua|sua)",
- SHOW_STR CS7_STR INST_STR INST_STR "Application Server (AS)\n"
- "Display all active ASs\n"
- "Display all ASs (default)\n"
- "Display all m3ua ASs\n"
- "Display all SUA ASs\n")
-{
- const char *filter = argv[1];
- int id = atoi(argv[0]);
-
- return show_as(vty, id, NULL, filter);
-}
-
-DEFUN(show_cs7_as_name, show_cs7_as_name_cmd,
- "show cs7 instance <0-15> as name AS_NAME",
- SHOW_STR CS7_STR INST_STR INST_STR "Application Server (AS)\n"
- "Look up AS with a given name\n"
- "Name of the Application Server (AS)\n")
-{
- int id = atoi(argv[0]);
- const char *as_name = argv[1];
-
- return show_as(vty, id, as_name, NULL);
-}
-
-DEFUN(show_cs7_as_bindingtable_name, show_cs7_as_bindingtable_name_cmd,
- "show cs7 instance <0-15> as binding-table name AS_NAME",
- SHOW_STR CS7_STR INST_STR INST_STR "Application Server (AS)\n"
- "Display binding table\n"
- "Look up AS with a given name\n"
- "Name of the Application Server (AS)\n")
-{
- int id = atoi(argv[0]);
- const char *as_name = argv[1];
- struct osmo_ss7_instance *inst;
- struct osmo_ss7_as *as = NULL;
-
- inst = osmo_ss7_instance_find(id);
- if (!inst) {
- vty_out(vty, "No SS7 instance %d found%s", id, VTY_NEWLINE);
- return CMD_WARNING;
- }
-
- if (as_name) {
- as = osmo_ss7_as_find_by_name(inst, as_name);
- if (!as) {
- vty_out(vty, "No AS %s found%s", as_name, VTY_NEWLINE);
- return CMD_WARNING;
- }
- }
-
- vty_out(vty, "Loadshare Seed Normal ASP Active Alternative ASP Active%s", VTY_NEWLINE);
- vty_out(vty, "-------------- --------------- ------ --------------- ------%s", VTY_NEWLINE);
-
- for (unsigned int i = 0; i < ARRAY_SIZE(as->aesls_table); i++) {
- struct osmo_ss7_as_esls_entry *e = &as->aesls_table[i];
- vty_out(vty, "%-15u %-16s %-7s %-16s %-7s%s",
- i,
- e->normal_asp ? e->normal_asp->cfg.name : "-",
- e->normal_asp ? (osmo_ss7_asp_active(e->normal_asp) ? "Yes" : "No") : "-",
- e->alt_asp ? e->alt_asp->cfg.name : "-",
- e->alt_asp ? (osmo_ss7_asp_active(e->alt_asp) ? "Yes" : "No") : "-",
- VTY_NEWLINE);
- }
-
- return CMD_SUCCESS;
-}
-
-/***********************************************************************
* SCCP addressbook handling
***********************************************************************/
@@ -3287,11 +1402,11 @@
/* first dump ASPs, as ASs reference them */
llist_for_each_entry(asp, &inst->asp_list, list)
- write_one_asp(vty, asp, show_dyn_config);
+ ss7_vty_write_one_asp(vty, asp, show_dyn_config);
/* then dump ASPs, as routes reference them */
llist_for_each_entry(as, &inst->as_list, list)
- write_one_as(vty, as, show_dyn_config);
+ ss7_vty_write_one_as(vty, as, show_dyn_config);
/* now dump everything that is relevent for the SG role */
if (cs7_role == CS7_ROLE_SG) {
@@ -3301,7 +1416,7 @@
write_one_rtable(vty, rtable);
llist_for_each_entry(oxs, &inst->xua_servers, list)
- write_one_xua(vty, oxs);
+ ss7_vty_write_one_oxs(vty, oxs);
}
/* Append SCCP Addressbook */
@@ -3313,57 +1428,21 @@
int osmo_ss7_vty_go_parent(struct vty *vty)
{
- struct osmo_ss7_as *as;
- struct osmo_ss7_asp *asp;
struct osmo_ss7_route_table *rtbl;
- struct osmo_xua_server *oxs;
struct osmo_sccp_addr_entry *entry;
switch (vty->node) {
case L_CS7_ASP_NODE:
- asp = vty->index;
- if (asp->cfg.explicit_shutdown_state_by_vty_since_node_enter) {
- /* Interactive VTY, inform of new behavior upon use of new '[no] shutdown' commands: */
- if (vty->type != VTY_FILE)
- vty_out(vty, "%% NOTE: Skipping automatic restart of ASP since an explicit '[no] shutdown' command was entered%s", VTY_NEWLINE);
- asp->cfg.explicit_shutdown_state_by_vty_since_node_enter = false;
- } else if (vty->type == VTY_FILE) {
- /* Make sure config reading is backward compatible by starting the ASP if no explicit 'no shutdown' is read: */
- vty_out(vty,
- "%% VTY node 'asp' without a '[no] shutdown' command at the end is deprecated, "
- "please make sure you update your cfg file for future compatibility.%s",
- VTY_NEWLINE);
- ss7_asp_restart_after_reconfigure(asp);
- } else {
- /* Interactive VTY without '[no] shutdown' explicit cmd, remind the user that we are no
- * longer automatically restarting the ASP when going out of the "asp" node: */
- vty_out(vty,
- "%% NOTE: Make sure to use '[no] shutdown' command in 'asp' node "
- "in order to restart the ASP for new configs to be applied.%s",
- VTY_NEWLINE);
- }
- vty->node = L_CS7_NODE;
- vty->index = asp->inst;
- break;
+ return ss7_vty_node_asp_go_parent(vty);
case L_CS7_RTABLE_NODE:
rtbl = vty->index;
vty->node = L_CS7_NODE;
vty->index = rtbl->inst;
break;
case L_CS7_AS_NODE:
- as = vty->index;
- vty->node = L_CS7_NODE;
- vty->index = as->inst;
- break;
+ return ss7_vty_node_as_go_parent(vty);
case L_CS7_XUA_NODE:
- oxs = vty->index;
- /* If no local addr was set, or erased after _create(): */
- ss7_xua_server_set_default_local_hosts(oxs);
- if (ss7_xua_server_bind(oxs) < 0)
- vty_out(vty, "%% Unable to bind xUA server to IP(s)%s", VTY_NEWLINE);
- vty->node = L_CS7_NODE;
- vty->index = oxs->inst;
- break;
+ return ss7_vty_node_oxs_go_parent(vty);
case L_CS7_SCCPADDR_NODE:
entry = vty->index;
vty->node = L_CS7_NODE;
@@ -3437,20 +1516,8 @@
{
g_ctx = ctx;
- asp_quirk_cmd.string = vty_cmd_string_from_valstr(ctx, asp_quirk_names,
- "quirk (", "|", ")", VTY_DO_LOWER);
- asp_quirk_cmd.doc = vty_cmd_string_from_valstr(ctx, asp_quirk_descs,
- "Enable quirk to work around interop issues\n",
- "\n", "\n", 0);
- asp_no_quirk_cmd.string = vty_cmd_string_from_valstr(ctx, asp_quirk_names,
- "no quirk (", "|", ")", VTY_DO_LOWER);
- asp_no_quirk_cmd.doc = vty_cmd_string_from_valstr(ctx, asp_quirk_descs,
- NO_STR "Disable quirk to work around interop issues\n",
- "\n", "\n", 0);
-
install_lib_element_ve(&show_cs7_user_cmd);
- install_lib_element_ve(&show_cs7_xua_cmd);
- install_lib_element_ve(&show_cs7_xua_trans_proto_cmd);
+ ss7_vty_init_show_oxs();
install_lib_element_ve(&show_cs7_config_cmd);
install_lib_element(ENABLE_NODE, &cs7_asp_disconnect_cmd);
@@ -3469,57 +1536,8 @@
install_lib_element(L_CS7_NODE, &cs7_opc_dpc_shift_cmd);
install_lib_element(L_CS7_NODE, &cs7_sls_shift_cmd);
- install_node(&asp_node, NULL);
- install_lib_element_ve(&show_cs7_asp_cmd);
- install_lib_element_ve(&show_cs7_asp_name_cmd);
- install_lib_element_ve(&show_cs7_asp_remaddr_cmd);
- install_lib_element_ve(&show_cs7_asp_remaddr_name_cmd);
- install_lib_element_ve(&show_cs7_asp_assoc_status_cmd);
- install_lib_element_ve(&show_cs7_asp_assoc_status_name_cmd);
- install_lib_element(L_CS7_NODE, &cs7_asp_cmd);
- install_lib_element(L_CS7_NODE, &cs7_asp_trans_proto_cmd);
- install_lib_element(L_CS7_NODE, &no_cs7_asp_cmd);
- install_lib_element(L_CS7_ASP_NODE, &cfg_description_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_remote_ip_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_no_remote_ip_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_local_ip_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_no_local_ip_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_qos_class_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_role_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_transport_role_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_sctp_role_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_sctp_param_init_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_no_sctp_param_init_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_quirk_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_no_quirk_cmd);
- gen_asp_timer_cmd_strs(&asp_timer_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_timer_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_block_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_shutdown_cmd);
- install_lib_element(L_CS7_ASP_NODE, &asp_no_shutdown_cmd);
-
- install_node(&as_node, NULL);
- install_lib_element_ve(&show_cs7_as_cmd);
- install_lib_element_ve(&show_cs7_as_name_cmd);
- install_lib_element_ve(&show_cs7_as_bindingtable_name_cmd);
- install_lib_element(L_CS7_NODE, &cs7_as_cmd);
- install_lib_element(L_CS7_NODE, &no_cs7_as_cmd);
- install_lib_element(L_CS7_AS_NODE, &cfg_description_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_asp_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_no_asp_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_traf_mode_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_traf_mode_loadshare_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_no_traf_mode_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_sls_shift_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_bindingtable_reset_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_recov_tout_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_qos_class_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_rout_key_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_rout_key_si_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_rout_key_ssn_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_rout_key_si_ssn_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_pc_override_cmd);
- install_lib_element(L_CS7_AS_NODE, &as_pc_patch_sccp_cmd);
+ ss7_vty_init_node_asp();
+ ss7_vty_init_node_as();
install_lib_element_ve(&show_cs7_route_cmd);
install_lib_element_ve(&show_cs7_route_bindingtable_cmd);
@@ -3545,12 +1563,5 @@
install_lib_element(L_CS7_RTABLE_NODE, &cs7_rt_upd_cmd);
install_lib_element(L_CS7_RTABLE_NODE, &cs7_rt_rem_cmd);
- install_node(&xua_node, NULL);
- install_lib_element(L_CS7_NODE, &cs7_xua_cmd);
- install_lib_element(L_CS7_NODE, &no_cs7_xua_cmd);
- install_lib_element(L_CS7_XUA_NODE, &xua_local_ip_cmd);
- install_lib_element(L_CS7_XUA_NODE, &xua_no_local_ip_cmd);
- install_lib_element(L_CS7_XUA_NODE, &xua_accept_dyn_asp_cmd);
- install_lib_element(L_CS7_XUA_NODE, &xua_sctp_param_init_cmd);
- install_lib_element(L_CS7_XUA_NODE, &xua_no_sctp_param_init_cmd);
+ ss7_vty_init_node_oxs();
}
diff --git a/src/ss7_vty.h b/src/ss7_vty.h
new file mode 100644
index 0000000..18dc5a6
--- /dev/null
+++ b/src/ss7_vty.h
@@ -0,0 +1,64 @@
+#pragma once
+
+/* Internal header used by libosmo-sccp, not available publicly for lib users */
+
+#include <stdbool.h>
+#include <stdint.h>
+
+#include <osmocom/vty/vty.h>
+
+#include <osmocom/netif/stream.h>
+#include <osmocom/sigtran/osmo_ss7.h>
+
+#include "ss7_instance.h"
+
+enum cs7_role_t {
+ CS7_ROLE_SG,
+ CS7_ROLE_ASP
+};
+
+extern void *g_ctx;
+extern enum cs7_role_t cs7_role;
+extern const struct value_string ipproto_vals[];
+
+#define CS7_STR "ITU-T Signaling System 7\n"
+#define PC_STR "Point Code\n"
+#define INST_STR "An instance of the SS7 stack\n"
+
+#define XUA_VAR_STR "(sua|m3ua|ipa)"
+
+#define XUA_VAR_HELP_STR \
+ "SCCP User Adaptation\n" \
+ "MTP3 User Adaptation\n" \
+ "IPA Multiplex (SCCP Lite)\n"
+
+#define IPPROTO_VAR_STR "(sctp|tcp)"
+#define IPPROTO_VAR_HELP_STR \
+ "SCTP (Stream Control Transmission Protocol)\n" \
+ "TCP (Transmission Control Protocol)\n"
+
+#define QOS_CLASS_RANGE_STR "<0-7>"
+#define QOS_CLASS_RANGE_HELP_STR "QoS Class\n"
+#define QOS_CLASS_VAR_STR "(" QOS_CLASS_RANGE_STR "|default)"
+#define QOS_CLASS_VAR_HELP_STR \
+ QOS_CLASS_RANGE_HELP_STR \
+ "Default QoS Class (0)\n"
+
+int parse_trans_proto(const char *protocol);
+enum osmo_ss7_asp_protocol parse_asp_proto(const char *protocol);
+
+/* ss7_asp_vty.c */
+void ss7_vty_init_node_asp(void);
+void ss7_vty_write_one_asp(struct vty *vty, struct osmo_ss7_asp *asp, bool show_dyn_config);
+int ss7_vty_node_asp_go_parent(struct vty *vty);
+
+/* ss7_as_vty.c */
+void ss7_vty_init_node_as(void);
+void ss7_vty_write_one_as(struct vty *vty, struct osmo_ss7_as *as, bool show_dyn_config);
+int ss7_vty_node_as_go_parent(struct vty *vty);
+
+/* ss7_xua_srv_vty.c */
+void ss7_vty_init_node_oxs(void);
+void ss7_vty_init_show_oxs(void);
+void ss7_vty_write_one_oxs(struct vty *vty, struct osmo_xua_server *xs);
+int ss7_vty_node_oxs_go_parent(struct vty *vty);
diff --git a/src/ss7_xua_srv_vty.c b/src/ss7_xua_srv_vty.c
new file mode 100644
index 0000000..3a5e4ae
--- /dev/null
+++ b/src/ss7_xua_srv_vty.c
@@ -0,0 +1,347 @@
+/* SS7 xua_srv VTY Interface */
+
+/* (C) 2015-2021 by Harald Welte <laforge@gnumonks.org>
+ * (C) 2025 by sysmocom s.f.m.c. GmbH <info@sysmocom.de>
+ * All Rights Reserved
+ *
+ * SPDX-License-Identifier: GPL-2.0+
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 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 General Public License
+ * along with this program. If not, see <http://www.gnu.org/licenses/>.
+ *
+ */
+
+#include <stdlib.h>
+#include <unistd.h>
+#include <errno.h>
+#include <stdint.h>
+#include <string.h>
+
+#include <osmocom/vty/vty.h>
+#include <osmocom/vty/command.h>
+#include <osmocom/vty/logging.h>
+#include <osmocom/vty/telnet_interface.h>
+#include <osmocom/vty/misc.h>
+
+#include <osmocom/netif/stream.h>
+
+#include <osmocom/sigtran/osmo_ss7.h>
+
+#include "xua_internal.h"
+#include "ss7_asp.h"
+#include "ss7_internal.h"
+#include "ss7_vty.h"
+#include "ss7_xua_srv.h"
+
+/***********************************************************************
+ * xUA Listener Configuration (SG)
+ ***********************************************************************/
+
+static struct cmd_node xua_node = {
+ L_CS7_XUA_NODE,
+ "%s(config-cs7-listen)# ",
+ 1,
+};
+
+DEFUN_ATTR(cs7_xua, cs7_xua_cmd,
+ "listen " XUA_VAR_STR " <0-65534> [" IPPROTO_VAR_STR "]",
+ "Configure/Enable xUA Listener\n"
+ XUA_VAR_HELP_STR
+ "Port number\n"
+ IPPROTO_VAR_HELP_STR,
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_instance *inst = vty->index;
+ struct osmo_xua_server *xs;
+ enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[0]);
+ uint16_t port = atoi(argv[1]);
+ int trans_proto;
+
+ if (argc > 2)
+ trans_proto = parse_trans_proto(argv[2]);
+ else /* default transport protocol */
+ trans_proto = ss7_default_trans_proto_for_asp_proto(proto);
+ if (trans_proto < 0)
+ return CMD_WARNING;
+
+ xs = ss7_xua_server_find2(inst, trans_proto, proto, port);
+ if (!xs) {
+ xs = ss7_xua_server_create2(inst, trans_proto, proto, port, NULL);
+ if (!xs)
+ return CMD_WARNING;
+ /* Drop first dummy address created automatically by _create(): */
+ ss7_xua_server_set_local_hosts(xs, NULL, 0);
+ }
+
+ vty->node = L_CS7_XUA_NODE;
+ vty->index = xs;
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(no_cs7_xua, no_cs7_xua_cmd,
+ "no listen " XUA_VAR_STR " <0-65534> [" IPPROTO_VAR_STR "]",
+ NO_STR "Disable xUA Listener on given port\n"
+ XUA_VAR_HELP_STR
+ "Port number\n"
+ IPPROTO_VAR_HELP_STR,
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_ss7_instance *inst = vty->index;
+ struct osmo_xua_server *xs;
+ enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[0]);
+ uint16_t port = atoi(argv[1]);
+ int trans_proto;
+
+ if (argc > 2)
+ trans_proto = parse_trans_proto(argv[2]);
+ else /* default transport protocol */
+ trans_proto = ss7_default_trans_proto_for_asp_proto(proto);
+ if (trans_proto < 0)
+ return CMD_WARNING;
+
+ xs = ss7_xua_server_find2(inst, trans_proto, proto, port);
+ if (!xs) {
+ vty_out(vty, "No xUA server for port %u found%s", port, VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ ss7_xua_server_destroy(xs);
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(xua_local_ip, xua_local_ip_cmd,
+ "local-ip " VTY_IPV46_CMD,
+ "Configure the Local IP Address for xUA\n"
+ "IPv4 Address to use for XUA\n"
+ "IPv6 Address to use for XUA\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_xua_server *xs = vty->index;
+
+ ss7_xua_server_add_local_host(xs, argv[0]);
+
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(xua_no_local_ip, xua_no_local_ip_cmd,
+ "no local-ip " VTY_IPV46_CMD,
+ NO_STR "Configure the Local IP Address for xUA\n"
+ "IPv4 Address to use for XUA\n"
+ "IPv6 Address to use for XUA\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_xua_server *xs = vty->index;
+
+ if (ss7_xua_server_del_local_host(xs, argv[0]) != 0) {
+ vty_out(vty, "%% Failed deleting local address '%s' from set%s", argv[0], VTY_NEWLINE);
+ return CMD_WARNING;
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(xua_accept_dyn_asp, xua_accept_dyn_asp_cmd,
+ "accept-asp-connections (pre-configured|dynamic-permitted)",
+ "Define what kind of ASP connections to accept\n"
+ "Accept only pre-configured ASPs (source IP/port)\n"
+ "Accept any connection and dynamically create an ASP definition\n",
+ CMD_ATTR_IMMEDIATE)
+{
+ struct osmo_xua_server *xs = vty->index;
+
+ if (!strcmp(argv[0], "dynamic-permitted"))
+ xs->cfg.accept_dyn_reg = true;
+ else
+ xs->cfg.accept_dyn_reg = false;
+
+ return CMD_SUCCESS;
+}
+
+#define XUA_SRV_SCTP_PARAM_INIT_DESC \
+ "Configure SCTP parameters\n" \
+ "Configure INIT related parameters\n" \
+ "Configure INIT Number of Outbound Streams\n" \
+ "Configure INIT Maximum Inboud Streams\n"
+#define XUA_SRV_SCTP_PARAM_INIT_FIELDS "(num-ostreams|max-instreams)"
+
+DEFUN_ATTR(xua_sctp_param_init, xua_sctp_param_init_cmd,
+ "sctp-param init " XUA_SRV_SCTP_PARAM_INIT_FIELDS " <0-65535>",
+ XUA_SRV_SCTP_PARAM_INIT_DESC
+ "Value of the parameter\n",
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_xua_server *xs = vty->index;
+
+ uint16_t val = atoi(argv[1]);
+
+ if (strcmp(argv[0], "num-ostreams") == 0) {
+ xs->cfg.sctp_init.num_ostreams_present = true;
+ xs->cfg.sctp_init.num_ostreams_value = val;
+ } else if (strcmp(argv[0], "max-instreams") == 0) {
+ xs->cfg.sctp_init.max_instreams_present = true;
+ xs->cfg.sctp_init.max_instreams_value = val;
+ } else {
+ OSMO_ASSERT(0);
+ }
+ return CMD_SUCCESS;
+}
+
+DEFUN_ATTR(xua_no_sctp_param_init, xua_no_sctp_param_init_cmd,
+ "no sctp-param init " XUA_SRV_SCTP_PARAM_INIT_FIELDS,
+ NO_STR XUA_SRV_SCTP_PARAM_INIT_DESC,
+ CMD_ATTR_NODE_EXIT)
+{
+ struct osmo_xua_server *xs = vty->index;
+
+ if (strcmp(argv[0], "num-ostreams") == 0)
+ xs->cfg.sctp_init.num_ostreams_present = false;
+ else if (strcmp(argv[0], "max-instreams") == 0)
+ xs->cfg.sctp_init.max_instreams_present = false;
+ else
+ OSMO_ASSERT(0);
+ return CMD_SUCCESS;
+}
+
+void ss7_vty_write_one_oxs(struct vty *vty, struct osmo_xua_server *xs)
+{
+ int i;
+
+ vty_out(vty, " listen %s %u",
+ get_value_string(osmo_ss7_asp_protocol_vals, xs->cfg.proto),
+ xs->cfg.local.port);
+ if (xs->cfg.trans_proto != ss7_default_trans_proto_for_asp_proto(xs->cfg.proto))
+ vty_out(vty, " %s", get_value_string(ipproto_vals, xs->cfg.trans_proto));
+ vty_out(vty, "%s", VTY_NEWLINE);
+
+ for (i = 0; i < xs->cfg.local.host_cnt; i++) {
+ if (xs->cfg.local.host[i])
+ vty_out(vty, " local-ip %s%s", xs->cfg.local.host[i], VTY_NEWLINE);
+ }
+ if (xs->cfg.accept_dyn_reg)
+ vty_out(vty, " accept-asp-connections dynamic-permitted%s", VTY_NEWLINE);
+ if (xs->cfg.sctp_init.num_ostreams_present)
+ vty_out(vty, " sctp-param init num-ostreams %u%s", xs->cfg.sctp_init.num_ostreams_value, VTY_NEWLINE);
+ if (xs->cfg.sctp_init.max_instreams_present)
+ vty_out(vty, " sctp-param init max-instreams %u%s", xs->cfg.sctp_init.max_instreams_value, VTY_NEWLINE);
+}
+
+static void vty_dump_xua_server(struct vty *vty, struct osmo_xua_server *xs)
+{
+ char buf[OSMO_SOCK_MULTIADDR_PEER_STR_MAXLEN];
+ const char *proto = get_value_string(osmo_ss7_asp_protocol_vals, xs->cfg.proto);
+ int fd = xs->server ? osmo_stream_srv_link_get_fd(xs->server) : -1;
+
+ if (fd < 0) {
+ if (ss7_asp_peer_snprintf(buf, sizeof(buf), &xs->cfg.local) < 0)
+ snprintf(buf, sizeof(buf), "<error>");
+ } else {
+ char hostbuf[OSMO_SOCK_MAX_ADDRS][INET6_ADDRSTRLEN];
+ size_t num_hostbuf = ARRAY_SIZE(hostbuf);
+ char portbuf[6];
+ int rc;
+ rc = osmo_sock_multiaddr_get_ip_and_port(fd, xs->cfg.trans_proto,
+ &hostbuf[0][0], &num_hostbuf, sizeof(hostbuf[0]),
+ portbuf, sizeof(portbuf), true);
+ if (rc < 0) {
+ snprintf(buf, sizeof(buf), "<error>");
+ } else {
+ if (num_hostbuf > ARRAY_SIZE(hostbuf))
+ num_hostbuf = ARRAY_SIZE(hostbuf);
+ osmo_multiaddr_ip_and_port_snprintf(buf, sizeof(buf),
+ &hostbuf[0][0], num_hostbuf, sizeof(hostbuf[0]),
+ portbuf);
+ }
+ }
+ vty_out(vty, "xUA server for %s/%s on %s is %s%s",
+ proto, get_value_string(ipproto_vals, xs->cfg.trans_proto),
+ buf, fd >= 0 ? "listening" : "inactive", VTY_NEWLINE);
+}
+
+static int _show_cs7_xua(struct vty *vty,
+ enum osmo_ss7_asp_protocol proto,
+ int trans_proto, int local_port)
+{
+ const struct osmo_ss7_instance *inst;
+
+ llist_for_each_entry(inst, &osmo_ss7_instances, list) {
+ struct osmo_xua_server *xs;
+
+ llist_for_each_entry(xs, &inst->xua_servers, list) {
+ if (xs->cfg.proto != proto)
+ continue;
+ if (local_port >= 0 && xs->cfg.local.port != local_port) /* optional */
+ continue;
+ if (trans_proto >= 0 && xs->cfg.trans_proto != trans_proto) /* optional */
+ continue;
+ vty_dump_xua_server(vty, xs);
+ }
+ }
+
+ return CMD_SUCCESS;
+}
+
+#define SHOW_CS7_XUA_CMD \
+ "show cs7 " XUA_VAR_STR
+#define SHOW_CS7_XUA_CMD_HELP \
+ SHOW_STR CS7_STR XUA_VAR_HELP_STR
+
+DEFUN(show_cs7_xua, show_cs7_xua_cmd,
+ SHOW_CS7_XUA_CMD " [<0-65534>]",
+ SHOW_CS7_XUA_CMD_HELP "Local Port Number\n")
+{
+ enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[0]);
+ int local_port = (argc > 1) ? atoi(argv[1]) : -1;
+
+ return _show_cs7_xua(vty, proto, -1, local_port);
+}
+
+DEFUN(show_cs7_xua_trans_proto, show_cs7_xua_trans_proto_cmd,
+ SHOW_CS7_XUA_CMD " " IPPROTO_VAR_STR " [<0-65534>]",
+ SHOW_CS7_XUA_CMD_HELP IPPROTO_VAR_HELP_STR "Local Port Number\n")
+{
+ enum osmo_ss7_asp_protocol proto = parse_asp_proto(argv[0]);
+ int trans_proto = parse_trans_proto(argv[1]);
+ int local_port = (argc > 2) ? atoi(argv[2]) : -1;
+
+ return _show_cs7_xua(vty, proto, trans_proto, local_port);
+}
+
+int ss7_vty_node_oxs_go_parent(struct vty *vty)
+{
+ struct osmo_xua_server *oxs = vty->index;
+
+ /* If no local addr was set, or erased after _create(): */
+ ss7_xua_server_set_default_local_hosts(oxs);
+ if (ss7_xua_server_bind(oxs) < 0)
+ vty_out(vty, "%% Unable to bind xUA server to IP(s)%s", VTY_NEWLINE);
+ vty->node = L_CS7_NODE;
+ vty->index = oxs->inst;
+
+ return 0;
+}
+
+void ss7_vty_init_show_oxs(void)
+{
+ install_lib_element_ve(&show_cs7_xua_cmd);
+ install_lib_element_ve(&show_cs7_xua_trans_proto_cmd);
+}
+
+void ss7_vty_init_node_oxs(void)
+{
+ install_node(&xua_node, NULL);
+ install_lib_element(L_CS7_NODE, &cs7_xua_cmd);
+ install_lib_element(L_CS7_NODE, &no_cs7_xua_cmd);
+ install_lib_element(L_CS7_XUA_NODE, &xua_local_ip_cmd);
+ install_lib_element(L_CS7_XUA_NODE, &xua_no_local_ip_cmd);
+ install_lib_element(L_CS7_XUA_NODE, &xua_accept_dyn_asp_cmd);
+ install_lib_element(L_CS7_XUA_NODE, &xua_sctp_param_init_cmd);
+ install_lib_element(L_CS7_XUA_NODE, &xua_no_sctp_param_init_cmd);
+}
To view, visit change 40456. To unsubscribe, or for help writing mail filters, visit settings.