Store BSCs

Once a BSC has sent a RESET to BSCNAT, store it. This will be used in
future patches to build connection mappings between MSC and BSCs, and to
block messages from BSCs that did not send a RESET.

I've considered using a FSM, but at least right now there doesn't seem
to be multiple states worth storing. We only have the BSC before it has
done the RESET (and then it's simply not in our list) and after it did
the RESET (in the list).

Don't use the stored BSCs in the forwarding logic just yet, a future
commit will replace the current forwarding code with proper connection
mappings.

Related: SYS#5560
Change-Id: Icd7316c49ef26fb45ad45a2ccc1a7916bfb0a387
This commit is contained in:
Oliver Smith 2022-03-09 16:41:41 +01:00
parent 318b4820fc
commit 793ca23f07
7 changed files with 110 additions and 0 deletions

View File

@ -1,4 +1,5 @@
noinst_HEADERS = \
bsc.h \
bsc_nat.h \
bsc_nat_fsm.h \
bssap.h \

View File

@ -0,0 +1,31 @@
/* (C) 2021 by sysmocom - s.f.m.c. GmbH <info@sysmocom.de>
* Author: Oliver Smith <osmith@sysmocom.de>
* All Rights Reserved
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/lienses/>.
*
*/
#pragma once
#include <osmocom/sigtran/sccp_sap.h>
struct bsc {
struct llist_head list;
struct osmo_sccp_addr addr;
};
struct bsc *bsc_alloc(struct osmo_sccp_addr *addr);
struct bsc *bsc_get_by_pc(uint32_t pointcode);
void bsc_free(struct bsc *bsc);

View File

@ -44,6 +44,7 @@ struct bsc_nat {
struct {
struct bsc_nat_sccp_inst *sccp_inst;
struct llist_head bscs; /* list of struct bsc */
} ran;
};

View File

@ -25,6 +25,7 @@ bin_PROGRAMS = \
$(NULL)
osmo_bsc_nat_SOURCES = \
bsc.c \
bsc_nat.c \
bsc_nat_fsm.c \
bssap.c \

59
src/osmo-bsc-nat/bsc.c Normal file
View File

@ -0,0 +1,59 @@
/* (C) 2021 by sysmocom - s.f.m.c. GmbH <info@sysmocom.de>
* Author: Oliver Smith <osmith@sysmocom.de>
* All Rights Reserved
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation; either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/lienses/>.
*
*/
#include "config.h"
#include <osmocom/bsc_nat/bsc.h>
#include <osmocom/bsc_nat/bsc_nat.h>
#include <osmocom/bsc_nat/logging.h>
struct bsc *bsc_alloc(struct osmo_sccp_addr *addr)
{
struct bsc *bsc = talloc_zero(g_bsc_nat, struct bsc);
OSMO_ASSERT(bsc);
talloc_set_name(bsc, "BSC(PC=%s)", osmo_ss7_pointcode_print(NULL, addr->pc));
LOGP(DMAIN, LOGL_DEBUG, "Add %s\n", talloc_get_name(bsc));
bsc->addr = *addr;
INIT_LLIST_HEAD(&bsc->list);
llist_add(&bsc->list, &g_bsc_nat->ran.bscs);
return bsc;
}
struct bsc *bsc_get_by_pc(uint32_t pointcode)
{
struct bsc *bsc;
llist_for_each_entry(bsc, &g_bsc_nat->ran.bscs, list) {
if (bsc->addr.pc == pointcode)
return bsc;
}
return NULL;
}
void bsc_free(struct bsc *bsc)
{
LOGP(DMAIN, LOGL_DEBUG, "Del %s\n", talloc_get_name(bsc));
llist_del(&bsc->list);
talloc_free(bsc);
}

View File

@ -20,8 +20,10 @@
#include "config.h"
#include <osmocom/core/talloc.h>
#include <osmocom/core/utils.h>
#include <osmocom/bsc_nat/bsc.h>
#include <osmocom/bsc_nat/bsc_nat.h>
#include <osmocom/bsc_nat/bsc_nat_fsm.h>
#include <osmocom/bsc_nat/logging.h>
struct bsc_nat *bsc_nat_alloc(void *tall_ctx)
{
@ -38,6 +40,8 @@ struct bsc_nat *bsc_nat_alloc(void *tall_ctx)
OSMO_ASSERT(bsc_nat->ran.sccp_inst);
talloc_set_name_const(bsc_nat->ran.sccp_inst, "struct bsc_nat_sccp_inst (RAN)");
INIT_LLIST_HEAD(&bsc_nat->ran.bscs);
bsc_nat_fsm_alloc(bsc_nat);
return bsc_nat;
@ -45,11 +49,17 @@ struct bsc_nat *bsc_nat_alloc(void *tall_ctx)
void bsc_nat_free(struct bsc_nat *bsc_nat)
{
struct bsc *bsc, *b;
if (bsc_nat->fi) {
osmo_fsm_inst_free(bsc_nat->fi);
bsc_nat->fi = NULL;
}
llist_for_each_entry_safe(bsc, b, &bsc_nat->ran.bscs, list) {
bsc_free(bsc);
}
talloc_free(bsc_nat);
}

View File

@ -22,12 +22,19 @@
#include <osmocom/gsm/gsm0808.h>
#include <osmocom/sigtran/sccp_helpers.h>
#include <osmocom/sigtran/sccp_sap.h>
#include <osmocom/bsc_nat/bsc.h>
#include <osmocom/bsc_nat/bsc_nat.h>
#include <osmocom/bsc_nat/logging.h>
static int bssap_ran_handle_reset(struct osmo_sccp_addr *addr, struct msgb *msg, unsigned int length)
{
struct bsc_nat_sccp_inst *sccp_inst = g_bsc_nat->ran.sccp_inst;
struct bsc *bsc;
/* Store the BSC, since RESET was done the BSCNAT should accept its messages */
bsc = bsc_get_by_pc(addr->pc);
if (!bsc)
bsc = bsc_alloc(addr);
LOGP(DMAIN, LOGL_NOTICE, "Rx RESET from %s\n", bsc_nat_print_addr_ran(addr));