413 lines
12 KiB
C
413 lines
12 KiB
C
/* IuCS/IuPS Core Network interface of HNB-GW */
|
|
|
|
/* (C) 2015 by Harald Welte <laforge@gnumonks.org>
|
|
* All Rights Reserved
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU Affero General Public License as published by
|
|
* the Free Software Foundation; either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Affero General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
|
|
#include <arpa/inet.h>
|
|
|
|
#include <osmocom/core/msgb.h>
|
|
#include <osmocom/core/utils.h>
|
|
#include <osmocom/core/timer.h>
|
|
|
|
#include <osmocom/sigtran/protocol/sua.h>
|
|
#include <osmocom/sigtran/sua.h>
|
|
#include <osmocom/sigtran/sccp_sap.h>
|
|
#include <osmocom/sigtran/sccp_helpers.h>
|
|
|
|
#include <osmocom/iuh/hnbgw.h>
|
|
#include <osmocom/iuh/hnbgw_rua.h>
|
|
#include <osmocom/ranap/ranap_ies_defs.h>
|
|
#include <osmocom/ranap/ranap_msg_factory.h>
|
|
#include <osmocom/iuh/context_map.h>
|
|
|
|
/***********************************************************************
|
|
* Outbound RANAP RESET to CN
|
|
***********************************************************************/
|
|
|
|
int hnbgw_cnlink_change_state(struct hnbgw_cnlink *cnlink, enum hnbgw_cnlink_state state);
|
|
|
|
static int transmit_rst(struct hnbgw_cnlink *cnlink)
|
|
{
|
|
struct msgb *msg;
|
|
struct msgb *msgprim;
|
|
RANAP_CN_DomainIndicator_t domain;
|
|
RANAP_Cause_t cause = {
|
|
.present = RANAP_Cause_PR_transmissionNetwork,
|
|
.choice. transmissionNetwork = RANAP_CauseTransmissionNetwork_signalling_transport_resource_failure,
|
|
};
|
|
|
|
if (cnlink->is_ps)
|
|
domain = RANAP_CN_DomainIndicator_ps_domain;
|
|
else
|
|
domain = RANAP_CN_DomainIndicator_cs_domain;
|
|
|
|
msg = ranap_new_msg_reset(domain, &cause);
|
|
|
|
return osmo_sccp_tx_unitdata_msg(cnlink->sua_link, &cnlink->local_addr,
|
|
&cnlink->remote_addr, msg);
|
|
}
|
|
|
|
/* Timer callback once T_RafC expires */
|
|
static void cnlink_trafc_cb(void *data)
|
|
{
|
|
struct hnbgw_cnlink *cnlink = data;
|
|
|
|
transmit_rst(cnlink);
|
|
hnbgw_cnlink_change_state(cnlink, CNLINK_S_EST_RST_TX_WAIT_ACK);
|
|
/* The spec states that we should abandon after a configurable
|
|
* number of times. We decide to simply continue trying */
|
|
}
|
|
|
|
/* change the state of a CN Link */
|
|
int hnbgw_cnlink_change_state(struct hnbgw_cnlink *cnlink, enum hnbgw_cnlink_state state)
|
|
{
|
|
switch (state) {
|
|
case CNLINK_S_NULL:
|
|
case CNLINK_S_EST_PEND:
|
|
break;
|
|
case CNLINK_S_EST_CONF:
|
|
cnlink_trafc_cb(cnlink);
|
|
break;
|
|
case CNLINK_S_EST_RST_TX_WAIT_ACK:
|
|
osmo_timer_schedule(&cnlink->T_RafC, 5, 0);
|
|
break;
|
|
case CNLINK_S_EST_ACTIVE:
|
|
osmo_timer_del(&cnlink->T_RafC);
|
|
break;
|
|
}
|
|
}
|
|
|
|
/***********************************************************************
|
|
* Incoming primitives from SCCP User SAP
|
|
***********************************************************************/
|
|
|
|
static int cn_ranap_rx_reset_cmd(struct hnbgw_cnlink *cnlink,
|
|
RANAP_InitiatingMessage_t *imsg)
|
|
{
|
|
RANAP_ResetIEs_t ies;
|
|
int rc;
|
|
|
|
rc = ranap_decode_reseties(&ies, &imsg->value);
|
|
/* FIXME: reset resources and return reset ack */
|
|
|
|
ranap_free_reseties(&ies);
|
|
return rc;
|
|
}
|
|
|
|
static int cn_ranap_rx_reset_ack(struct hnbgw_cnlink *cnlink,
|
|
RANAP_SuccessfulOutcome_t *omsg)
|
|
{
|
|
RANAP_ResetAcknowledgeIEs_t ies;
|
|
int rc;
|
|
|
|
rc = ranap_decode_resetacknowledgeies(&ies, &omsg->value);
|
|
|
|
hnbgw_cnlink_change_state(cnlink, CNLINK_S_EST_ACTIVE);
|
|
|
|
ranap_free_resetacknowledgeies(&ies);
|
|
return rc;
|
|
}
|
|
|
|
static int cn_ranap_rx_paging_cmd(struct hnbgw_cnlink *cnlink,
|
|
RANAP_InitiatingMessage_t *imsg,
|
|
const uint8_t *data, unsigned int len)
|
|
{
|
|
struct hnb_gw *gw = cnlink->gw;
|
|
struct hnb_context *hnb;
|
|
RANAP_PagingIEs_t ies;
|
|
int rc = 0;
|
|
|
|
rc = ranap_decode_pagingies(&ies, &imsg->value);
|
|
|
|
/* FIXME: determine which HNBs to send this Paging command,
|
|
* rather than broadcasting to all HNBs */
|
|
llist_for_each_entry(hnb, &gw->hnb_list, list) {
|
|
rc = rua_tx_udt(hnb, data, len);
|
|
}
|
|
|
|
ranap_free_pagingies(&ies);
|
|
return 0;
|
|
}
|
|
|
|
static int cn_ranap_rx_initiating_msg(struct hnbgw_cnlink *cnlink,
|
|
RANAP_InitiatingMessage_t *imsg,
|
|
const uint8_t *data, unsigned int len)
|
|
{
|
|
int rc;
|
|
|
|
switch (imsg->procedureCode) {
|
|
case RANAP_ProcedureCode_id_Reset:
|
|
return cn_ranap_rx_reset_cmd(cnlink, imsg);
|
|
case RANAP_ProcedureCode_id_Paging:
|
|
return cn_ranap_rx_paging_cmd(cnlink, imsg, data, len);
|
|
case RANAP_ProcedureCode_id_OverloadControl: /* Overload ind */
|
|
break;
|
|
case RANAP_ProcedureCode_id_ErrorIndication: /* Error ind */
|
|
break;
|
|
case RANAP_ProcedureCode_id_ResetResource: /* request */
|
|
case RANAP_ProcedureCode_id_InformationTransfer:
|
|
case RANAP_ProcedureCode_id_DirectInformationTransfer:
|
|
case RANAP_ProcedureCode_id_UplinkInformationExchange:
|
|
LOGP(DRANAP, LOGL_NOTICE, "Received unsupported RANAP "
|
|
"Procedure %u from CN, ignoring\n", imsg->procedureCode);
|
|
break;
|
|
default:
|
|
LOGP(DRANAP, LOGL_NOTICE, "Received suspicious RANAP "
|
|
"Procedure %u from CN, ignoring\n", imsg->procedureCode);
|
|
break;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static int cn_ranap_rx_successful_msg(struct hnbgw_cnlink *cnlink,
|
|
RANAP_SuccessfulOutcome_t *omsg)
|
|
{
|
|
int rc;
|
|
|
|
switch (omsg->procedureCode) {
|
|
case RANAP_ProcedureCode_id_Reset: /* Reset acknowledge */
|
|
return cn_ranap_rx_reset_ack(cnlink, omsg);
|
|
case RANAP_ProcedureCode_id_ResetResource: /* response */
|
|
case RANAP_ProcedureCode_id_InformationTransfer:
|
|
case RANAP_ProcedureCode_id_DirectInformationTransfer:
|
|
case RANAP_ProcedureCode_id_UplinkInformationExchange:
|
|
LOGP(DRANAP, LOGL_NOTICE, "Received unsupported RANAP "
|
|
"Procedure %u from CN, ignoring\n", omsg->procedureCode);
|
|
break;
|
|
default:
|
|
LOGP(DRANAP, LOGL_NOTICE, "Received suspicious RANAP "
|
|
"Procedure %u from CN, ignoring\n", omsg->procedureCode);
|
|
break;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
static int _cn_ranap_rx(struct hnbgw_cnlink *cnlink, RANAP_RANAP_PDU_t *pdu,
|
|
const uint8_t *data, unsigned int len)
|
|
{
|
|
int rc;
|
|
|
|
switch (pdu->present) {
|
|
case RANAP_RANAP_PDU_PR_initiatingMessage:
|
|
rc = cn_ranap_rx_initiating_msg(cnlink, &pdu->choice.initiatingMessage,
|
|
data, len);
|
|
break;
|
|
case RANAP_RANAP_PDU_PR_successfulOutcome:
|
|
rc = cn_ranap_rx_successful_msg(cnlink, &pdu->choice.successfulOutcome);
|
|
break;
|
|
case RANAP_RANAP_PDU_PR_unsuccessfulOutcome:
|
|
LOGP(DRANAP, LOGL_NOTICE, "Received unsupported RANAP "
|
|
"unsuccessful outcome procedure %u from CN, ignoring\n",
|
|
pdu->choice.unsuccessfulOutcome.procedureCode);
|
|
break;
|
|
default:
|
|
LOGP(DRANAP, LOGL_NOTICE, "Received suspicious RANAP "
|
|
"presence %u from CN, ignoring\n", pdu->present);
|
|
break;
|
|
}
|
|
}
|
|
|
|
static int handle_cn_ranap(struct hnbgw_cnlink *cnlink, const uint8_t *data,
|
|
unsigned int len)
|
|
{
|
|
RANAP_RANAP_PDU_t _pdu, *pdu = &_pdu;
|
|
asn_dec_rval_t dec_ret;
|
|
int rc;
|
|
|
|
memset(pdu, 0, sizeof(*pdu));
|
|
dec_ret = aper_decode(NULL,&asn_DEF_RANAP_RANAP_PDU, (void **) &pdu,
|
|
data, len, 0, 0);
|
|
if (dec_ret.code != RC_OK) {
|
|
LOGP(DRANAP, LOGL_ERROR, "Error in RANAP ASN.1 decode\n");
|
|
return rc;
|
|
}
|
|
|
|
rc = _cn_ranap_rx(cnlink, pdu, data, len);
|
|
|
|
return rc;
|
|
}
|
|
|
|
|
|
static int handle_cn_unitdata(struct hnbgw_cnlink *cnlink,
|
|
const struct osmo_scu_unitdata_param *param,
|
|
struct osmo_prim_hdr *oph)
|
|
{
|
|
if (param->called_addr.ssn != OSMO_SCCP_SSN_RANAP) {
|
|
LOGP(DMAIN, LOGL_NOTICE, "N-UNITDATA.ind for unknown SSN %u\n",
|
|
param->called_addr.ssn);
|
|
return -1;
|
|
}
|
|
|
|
return handle_cn_ranap(cnlink, msgb_l2(oph->msg), msgb_l2len(oph->msg));
|
|
}
|
|
|
|
static int handle_cn_conn_conf(struct hnbgw_cnlink *cnlink,
|
|
const struct osmo_scu_connect_param *param,
|
|
struct osmo_prim_hdr *oph)
|
|
{
|
|
/* we don't actually need to do anything, as RUA towards the HNB
|
|
* doesn't seem to know any confirmations to its CONNECT
|
|
* operation */
|
|
|
|
LOGP(DMAIN, LOGL_DEBUG, "handle_cn_conn_conf() conn_id=%d\n",
|
|
param->conn_id);
|
|
LOGP(DMAIN, LOGL_DEBUG, "handle_cn_conn_conf() called_addr=%s\n",
|
|
inet_ntoa(param->called_addr.ip.v4));
|
|
LOGP(DMAIN, LOGL_DEBUG, "handle_cn_conn_conf() calling_addr=%s\n",
|
|
inet_ntoa(param->calling_addr.ip.v4));
|
|
LOGP(DMAIN, LOGL_DEBUG, "handle_cn_conn_conf() responding_addr=%s\n",
|
|
inet_ntoa(param->responding_addr.ip.v4));
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int handle_cn_data_ind(struct hnbgw_cnlink *cnlink,
|
|
const struct osmo_scu_data_param *param,
|
|
struct osmo_prim_hdr *oph)
|
|
{
|
|
struct hnbgw_context_map *map;
|
|
|
|
/* connection-oriented data is always passed transparently
|
|
* towards the specific HNB, via a RUA connection identified by
|
|
* conn_id */
|
|
|
|
map = context_map_by_cn(cnlink, param->conn_id);
|
|
if (!map) {
|
|
/* FIXME: Return an error / released primitive */
|
|
return 0;
|
|
}
|
|
|
|
return rua_tx_dt(map->hnb_ctx, map->cn_link->is_ps, map->rua_ctx_id,
|
|
msgb_l2(oph->msg), msgb_l2len(oph->msg));
|
|
}
|
|
|
|
static int handle_cn_disc_ind(struct hnbgw_cnlink *cnlink,
|
|
const struct osmo_scu_disconn_param *param,
|
|
struct osmo_prim_hdr *oph)
|
|
{
|
|
struct hnbgw_context_map *map;
|
|
|
|
LOGP(DMAIN, LOGL_DEBUG, "handle_cn_disc_ind() conn_id=%d originator=%d\n",
|
|
param->conn_id, param->originator);
|
|
LOGP(DMAIN, LOGL_DEBUG, "handle_cn_disc_ind() responding_addr=%s\n",
|
|
inet_ntoa(param->responding_addr.ip.v4));
|
|
|
|
RUA_Cause_t rua_cause = {
|
|
.present = RUA_Cause_PR_NOTHING,
|
|
/* FIXME: Convert incoming SCCP cause to RUA cause */
|
|
};
|
|
|
|
/* we need to notify the HNB associated with this connection via
|
|
* a RUA DISCONNECT */
|
|
|
|
map = context_map_by_cn(cnlink, param->conn_id);
|
|
if (!map) {
|
|
/* FIXME: Return an error / released primitive */
|
|
return 0;
|
|
}
|
|
|
|
return rua_tx_disc(map->hnb_ctx, map->cn_link->is_ps, map->rua_ctx_id,
|
|
&rua_cause, msgb_l2(oph->msg), msgb_l2len(oph->msg));
|
|
}
|
|
|
|
/* Entry point for primitives coming up from SCCP User SAP */
|
|
static int sccp_sap_up(struct osmo_prim_hdr *oph, void *ctx)
|
|
{
|
|
struct osmo_sccp_link *slink = ctx;
|
|
struct hnbgw_cnlink *cnlink = osmo_sua_link_get_user_priv(slink);
|
|
struct osmo_scu_prim *prim = (struct osmo_scu_prim *) oph;
|
|
int rc;
|
|
|
|
LOGP(DMAIN, LOGL_DEBUG, "sccp_sap_up(%s)\n", osmo_scu_prim_name(oph));
|
|
|
|
switch (OSMO_PRIM_HDR(oph)) {
|
|
case OSMO_PRIM(OSMO_SCU_PRIM_N_UNITDATA, PRIM_OP_INDICATION):
|
|
rc = handle_cn_unitdata(cnlink, &prim->u.unitdata, oph);
|
|
break;
|
|
case OSMO_PRIM(OSMO_SCU_PRIM_N_CONNECT, PRIM_OP_CONFIRM):
|
|
rc = handle_cn_conn_conf(cnlink, &prim->u.connect, oph);
|
|
break;
|
|
case OSMO_PRIM(OSMO_SCU_PRIM_N_DATA, PRIM_OP_INDICATION):
|
|
rc = handle_cn_data_ind(cnlink, &prim->u.data, oph);
|
|
break;
|
|
case OSMO_PRIM(OSMO_SCU_PRIM_N_DISCONNECT, PRIM_OP_INDICATION):
|
|
rc = handle_cn_disc_ind(cnlink, &prim->u.disconnect, oph);
|
|
break;
|
|
defualt:
|
|
LOGP(DMAIN, LOGL_ERROR,
|
|
"Received unknown prim %u from SCCP USER SAP\n",
|
|
OSMO_PRIM_HDR(oph));
|
|
break;
|
|
}
|
|
|
|
msgb_free(oph->msg);
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
/* Set up a link towards the core network for the circuit switched (is_ps == 0)
|
|
* or packet switched (is_ps != 0) domain. */
|
|
struct hnbgw_cnlink *hnbgw_cnlink_init(struct hnb_gw *gw, const char *host, uint16_t port, int is_ps)
|
|
{
|
|
struct hnbgw_cnlink *cnlink = talloc_zero(gw, struct hnbgw_cnlink);
|
|
int rc;
|
|
|
|
cnlink->gw = gw;
|
|
INIT_LLIST_HEAD(&cnlink->map_list);
|
|
cnlink->T_RafC.cb = cnlink_trafc_cb;
|
|
cnlink->T_RafC.data = cnlink;
|
|
cnlink->next_conn_id = 1000;
|
|
cnlink->is_ps = is_ps;
|
|
osmo_sccp_make_addr_pc_ssn(&cnlink->local_addr, 2,
|
|
OSMO_SCCP_SSN_RANAP);
|
|
osmo_sccp_make_addr_pc_ssn(&cnlink->remote_addr, 1,
|
|
OSMO_SCCP_SSN_RANAP);
|
|
|
|
LOGP(DRUA, LOGL_DEBUG, "New hnbgw_cnlink %p (gw %p): %s %d %s\n",
|
|
cnlink, cnlink->gw, host, port, is_ps? "PS" : "CS");
|
|
|
|
cnlink->sua_user = osmo_sua_user_create(cnlink, sccp_sap_up, cnlink);
|
|
if (!cnlink->sua_user) {
|
|
LOGP(DMAIN, LOGL_ERROR, "Failed to init SUA\n");
|
|
goto out_free;
|
|
}
|
|
rc = osmo_sua_client_connect(cnlink->sua_user, host, port);
|
|
if (rc < 0) {
|
|
LOGP(DMAIN, LOGL_ERROR, "Failed to connect SUA\n");
|
|
goto out_user;
|
|
}
|
|
cnlink->sua_link = osmo_sua_client_get_link(cnlink->sua_user);
|
|
if (!cnlink->sua_link) {
|
|
LOGP(DMAIN, LOGL_ERROR, "Failed to get SUA link\n");
|
|
goto out_disconnect;
|
|
}
|
|
|
|
llist_add_tail(&cnlink->list, &gw->cn_list);
|
|
|
|
return cnlink;
|
|
|
|
out_disconnect:
|
|
/* FIXME */
|
|
out_user:
|
|
osmo_sua_user_destroy(cnlink->sua_user);
|
|
out_free:
|
|
talloc_free(cnlink);
|
|
}
|