From bc4560cf18e98d0a768c1d7a04ca1f31eb0d0d05 Mon Sep 17 00:00:00 2001 From: Harald Welte Date: Thu, 24 Dec 2015 08:46:58 +0100 Subject: [PATCH] Implement forwarding of RANAP PAGING from CN to all HNBs --- src/hnbgw_cn.c | 28 +++++++++++++++++++--------- 1 file changed, 19 insertions(+), 9 deletions(-) diff --git a/src/hnbgw_cn.c b/src/hnbgw_cn.c index b69f250a..8333d781 100644 --- a/src/hnbgw_cn.c +++ b/src/hnbgw_cn.c @@ -121,19 +121,27 @@ static int cn_ranap_rx_reset_ack(struct hnbgw_cnlink *cnlink, } static int cn_ranap_rx_paging_cmd(struct hnbgw_cnlink *cnlink, - RANAP_InitiatingMessage_t *imsg) + RANAP_InitiatingMessage_t *imsg, + const uint8_t *data, unsigned int len) { + struct hnb_gw *gw; + struct hnb_context *hnb; RANAP_PagingIEs_t ies; - int rc; + int rc = 0; rc = ranap_decode_pagingies(&ies, &imsg->value); - /* FIXME: determine which HNBs to send this Paging command */ - return rc; + /* 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); + } + return 0; } static int cn_ranap_rx_initiating_msg(struct hnbgw_cnlink *cnlink, - RANAP_InitiatingMessage_t *imsg) + RANAP_InitiatingMessage_t *imsg, + const uint8_t *data, unsigned int len) { int rc; @@ -141,7 +149,7 @@ static int cn_ranap_rx_initiating_msg(struct hnbgw_cnlink *cnlink, 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); + 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 */ @@ -185,13 +193,15 @@ static int cn_ranap_rx_successful_msg(struct hnbgw_cnlink *cnlink, } -static int _cn_ranap_rx(struct hnbgw_cnlink *cnlink, RANAP_RANAP_PDU_t *pdu) +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); + 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); @@ -223,7 +233,7 @@ static int handle_cn_ranap(struct hnbgw_cnlink *cnlink, const uint8_t *data, return rc; } - rc = _cn_ranap_rx(cnlink, pdu); + rc = _cn_ranap_rx(cnlink, pdu, data, len); return rc; }