[M] Change in osmo-sgsn[master]: ranap: Clean up RANAP rx path param passing

3 Sep 2025

lynxis lazus has submitted this change. ( https://gerrit.osmocom.org/c/osmo-sgsn/+/40960?usp=email )
(
2 is the latest approved patch-set.
No files were changed between the latest approved patch-set and the submitted one.
 )Change subject: ranap: Clean up RANAP rx path param passing
......................................................................
ranap: Clean up RANAP rx path param passing
Use the osmo-iuh ranap_cn_rx_*_decode2() APIs directly. This
allows getting rid of extra "ctx" temporary structs and another level of
cb indirection.
Take the chance to update most pointers consitfying them.
Depends: osmo-iuh.git Change-Id I667dc2ef377c1ceb5b11315458f00b282c143c81
Change-Id: Ib3c00b5105b7ba4bb1a2dad1a14bea233a03c358
---
M TODO-RELEASE
M include/osmocom/sgsn/gprs_ranap.h
M src/sgsn/gprs_ranap.c
3 files changed, 102 insertions(+), 61 deletions(-)
Approvals:
  Jenkins Builder: Verified
  fixeria: Looks good to me, but someone else must approve
  lynxis lazus: Looks good to me, approved

diff --git a/TODO-RELEASE b/TODO-RELEASE
index 662cdb5..1dfbdb0 100644
--- a/TODO-RELEASE
+++ b/TODO-RELEASE
@@ -11,3 +11,4 @@
 libgtp    >1.12.0 gtp_set_cb_update_context_ind(), gtp_update_context_resp()
 libosmocore >1.10.0  enum gsm48_gprs_ie_mm: GSM48_IE_GMM_UE_NET_CAP, GSM48_IE_GMM_VD_PREF_UE_USAGE
 libosmo-gsup-client >1.8.0  osmo_gsup_client_is_connected(), osmo_gsup_client_get_rem_addr(), osmo_gsup_client_get_rem_port()
+osmo-iuh >1.7.0 ranap multiple params are constified, see osmo-iuh Change-Id I667dc2ef377c1ceb5b11315458f00b282c143c81
diff --git a/include/osmocom/sgsn/gprs_ranap.h b/include/osmocom/sgsn/gprs_ranap.h
index 8a6c189..80b57e6 100644
--- a/include/osmocom/sgsn/gprs_ranap.h
+++ b/include/osmocom/sgsn/gprs_ranap.h
@@ -39,11 +39,14 @@
 void sgsn_ranap_iu_release_free(struct sgsn_mm_ctx *ctx,
    			const struct RANAP_Cause *cause);
-int sgsn_ranap_iu_rx_cl_msg(struct sgsn_sccp_user_iups *scu_iups, struct osmo_scu_unitdata_param *ud_prim,
-			    uint8_t *data, size_t len);
-int sgsn_ranap_iu_rx_co_initial_msg(struct sgsn_sccp_user_iups *scu_iups, const struct osmo_sccp_addr *rem_sccp_addr,
-				    uint32_t conn_id, uint8_t *data, size_t len);
-int sgsn_ranap_iu_rx_co_msg(struct ranap_ue_conn_ctx *ue_ctx, uint8_t *data, size_t len);
+int sgsn_ranap_iu_rx_cl_msg(struct sgsn_sccp_user_iups *scu_iups,
+			    const struct osmo_scu_unitdata_param *ud_prim,
+			    const uint8_t *data, size_t len);
+int sgsn_ranap_iu_rx_co_initial_msg(struct sgsn_sccp_user_iups *scu_iups,
+				    const struct osmo_sccp_addr *rem_sccp_addr,
+				    uint32_t conn_id,
+				    const uint8_t *data, size_t len);
+int sgsn_ranap_iu_rx_co_msg(struct ranap_ue_conn_ctx *ue_ctx, const uint8_t *data, size_t len);
#else /* ifndef BUILD_IU */
 inline static void sgsn_ranap_iu_free(void *ctx) {};
diff --git a/src/sgsn/gprs_ranap.c b/src/sgsn/gprs_ranap.c
index 376fcac..f71db50 100644
--- a/src/sgsn/gprs_ranap.c
+++ b/src/sgsn/gprs_ranap.c
@@ -60,7 +60,7 @@
    uint16_t rnc_id;
 };
-static int iu_grnc_id_parse(struct osmo_rnc_id *dst, struct RANAP_GlobalRNC_ID *src)
+static int iu_grnc_id_parse(struct osmo_rnc_id *dst, const struct RANAP_GlobalRNC_ID *src)
 {
    /* The size is coming from arbitrary sender, check it gracefully */
    if (src->pLMNidentity.size != 3) {
@@ -86,17 +86,6 @@
 }
 #endif
-struct ranap_iu_event_sccp_new_ue_context {
-	struct sgsn_sccp_user_iups *scu_iups;
-	struct osmo_sccp_addr rem_sccp_addr;
-	uint32_t conn_id;
-};
-
-struct ranap_iu_event_cl_msg_ind {
-	struct sgsn_sccp_user_iups *scu_iups;
-	struct osmo_scu_unitdata_param *ud_prim;
-};
-
 /* Send RAB activation requests for all PDP contexts */
 void activate_pdp_rabs(struct sgsn_mm_ctx *ctx)
 {
@@ -430,9 +419,11 @@
    osmo_timer_schedule(&ctx->release_timeout, timeout, 0);
 }
-static int ranap_handle_co_initial_ue(void *ctx, RANAP_InitialUE_MessageIEs_t *ies)
+static int ranap_handle_co_initial_ue(struct sgsn_sccp_user_iups *scu_iups,
+				      const struct osmo_sccp_addr *rem_sccp_addr,
+				      uint32_t conn_id,
+				      const RANAP_InitialUE_MessageIEs_t *ies)
 {
-	struct ranap_iu_event_sccp_new_ue_context *new_ctx = ctx;
    struct gprs_ra_id ra_id = {};
    struct osmo_routing_area_id ra_id2 = {};
    struct osmo_rnc_id rnc_id = {};
@@ -470,9 +461,9 @@
    gprs_rai_to_osmo(&ra_id2, &ra_id);
/* Make sure we know the RNC Id and LAC+RAC coming in on this connection. */
-	rnc = iu_rnc_register(&rnc_id, &ra_id2, &new_ctx->rem_sccp_addr);
+	rnc = iu_rnc_register(&rnc_id, &ra_id2, rem_sccp_addr);
-	ue = ue_conn_ctx_alloc(rnc, new_ctx->scu_iups, new_ctx->conn_id);
+	ue = ue_conn_ctx_alloc(rnc, scu_iups, conn_id);
    OSMO_ASSERT(ue);
    ue->ra_id = ra_id;
@@ -485,7 +476,10 @@
    return 0;
 }
-static void cn_ranap_handle_co_initial(void *ctx, ranap_message *message)
+static void cn_ranap_handle_co_initial(struct sgsn_sccp_user_iups *scu_iups,
+				       const struct osmo_sccp_addr *rem_sccp_addr,
+				       uint32_t conn_id,
+				       const ranap_message *message)
 {
    int rc;
@@ -498,7 +492,7 @@
    	     message->direction, message->procedureCode);
    	rc = -1;
    } else
-		rc = ranap_handle_co_initial_ue(ctx, &message->msg.initialUE_MessageIEs);
+		rc = ranap_handle_co_initial_ue(scu_iups, rem_sccp_addr, conn_id, &message->msg.initialUE_MessageIEs);
if (rc) {
    	LOGP(DRANAP, LOGL_ERROR, "Error in %s (%d)\n", __func__, rc);
@@ -506,17 +500,29 @@
    }
 }
-int sgsn_ranap_iu_rx_co_initial_msg(struct sgsn_sccp_user_iups *scu_iups, const struct osmo_sccp_addr *rem_sccp_addr, uint32_t conn_id, uint8_t *data, size_t len)
+int sgsn_ranap_iu_rx_co_initial_msg(struct sgsn_sccp_user_iups *scu_iups,
+				    const struct osmo_sccp_addr *rem_sccp_addr,
+				    uint32_t conn_id,
+				    const uint8_t *data, size_t len)
 {
-	struct ranap_iu_event_sccp_new_ue_context new_ctx = {
-		.scu_iups = scu_iups,
-		.conn_id = conn_id,
-		.rem_sccp_addr = *rem_sccp_addr,
-	};
-	return ranap_cn_rx_co(cn_ranap_handle_co_initial, &new_ctx, data, len);
+	ranap_message message;
+	int rc;
+
+	rc = ranap_cn_rx_co_decode2(&message, data, len);
+	if (rc != 0) {
+		LOGP(DRANAP, LOGL_ERROR, "Not calling cn_ranap_handle_co_initial() due to rc=%d\n", rc);
+		goto free_ret;
+	}
+
+	cn_ranap_handle_co_initial(scu_iups, rem_sccp_addr, conn_id, &message);
+
+free_ret:
+	/* Free the asn1 structs in message */
+	ranap_cn_rx_co_free(&message);
+	return rc;
 }
-static int ranap_handle_co_dt(void *ctx, RANAP_DirectTransferIEs_t *ies)
+static int ranap_handle_co_dt(struct ranap_ue_conn_ctx *ue_ctx, const RANAP_DirectTransferIEs_t *ies)
 {
    struct gprs_ra_id _ra_id, *ra_id = NULL;
    uint16_t _sai, *sai = NULL;
@@ -541,7 +547,7 @@
    memcpy(msgb_gmmh(msg), ies->nas_pdu.buf, ies->nas_pdu.size);
/* Feed into the MM/CC/SMS-CP layer */
-	msg->dst = ctx;
+	msg->dst = ue_ctx;
    gsm0408_gprs_rcvmsg_iu(msg, ra_id, sai);
msgb_free(msg);
@@ -549,7 +555,7 @@
    return 0;
 }
-static int ranap_handle_co_err_ind(void *ctx, RANAP_ErrorIndicationIEs_t *ies)
+static int ranap_handle_co_err_ind(struct ranap_ue_conn_ctx *ue_ctx, const RANAP_ErrorIndicationIEs_t *ies)
 {
    if (ies->presenceMask & ERRORINDICATIONIES_RANAP_CAUSE_PRESENT)
    	LOGP(DRANAP, LOGL_ERROR, "Rx Error Indication (%s)\n",
@@ -560,19 +566,19 @@
    return 0;
 }
-static int ranap_handle_co_iu_rel_req(struct ranap_ue_conn_ctx *ctx, RANAP_Iu_ReleaseRequestIEs_t *ies)
+static int ranap_handle_co_iu_rel_req(struct ranap_ue_conn_ctx *ue_ctx, const RANAP_Iu_ReleaseRequestIEs_t *ies)
 {
    LOGP(DRANAP, LOGL_INFO, "Received Iu Release Request, Sending Release Command\n");
-	ranap_iu_tx_release(ctx, &ies->cause);
+	ranap_iu_tx_release(ue_ctx, &ies->cause);
    return 0;
 }
-static int ranap_handle_co_rab_ass_resp(struct ranap_ue_conn_ctx *ctx, RANAP_RAB_AssignmentResponseIEs_t *ies)
+static int ranap_handle_co_rab_ass_resp(struct ranap_ue_conn_ctx *ue_ctx, const RANAP_RAB_AssignmentResponseIEs_t *ies)
 {
    int rc = -1;
LOGP(DRANAP, LOGL_INFO,
-	       "Rx RAB Assignment Response for UE conn_id %u\n", ctx->conn_id);
+	       "Rx RAB Assignment Response for UE conn_id %u\n", ue_ctx->conn_id);
    if (ies->presenceMask & RAB_ASSIGNMENTRESPONSEIES_RANAP_RAB_SETUPORMODIFIEDLIST_PRESENT) {
    	/* TODO: Iterate over list of SetupOrModifiedList IEs and handle each one */
    	RANAP_IE_t *ranap_ie = ies->raB_SetupOrModifiedList.raB_SetupOrModifiedList_ies.list.array[0];
@@ -584,7 +590,7 @@
    		return rc;
    	}
-		rc = global_iu_event(ctx, RANAP_IU_EVENT_RAB_ASSIGN, &setup_ies);
+		rc = global_iu_event(ue_ctx, RANAP_IU_EVENT_RAB_ASSIGN, &setup_ies);
ranap_free_rab_setupormodifieditemies(&setup_ies);
    }
@@ -594,7 +600,7 @@
 }
/* Entry point for connection-oriented RANAP message */
-static void cn_ranap_handle_co(void *ctx, ranap_message *message)
+static void cn_ranap_handle_co(struct ranap_ue_conn_ctx *ue_ctx, const ranap_message *message)
 {
    int rc;
@@ -608,14 +614,14 @@
    		rc = -1;
    		break;
    	case RANAP_ProcedureCode_id_DirectTransfer:
-			rc = ranap_handle_co_dt(ctx, &message->msg.directTransferIEs);
+			rc = ranap_handle_co_dt(ue_ctx, &message->msg.directTransferIEs);
    		break;
    	case RANAP_ProcedureCode_id_ErrorIndication:
-			rc = ranap_handle_co_err_ind(ctx, &message->msg.errorIndicationIEs);
+			rc = ranap_handle_co_err_ind(ue_ctx, &message->msg.errorIndicationIEs);
    		break;
    	case RANAP_ProcedureCode_id_Iu_ReleaseRequest:
    		/* Iu Release Request */
-			rc = ranap_handle_co_iu_rel_req(ctx, &message->msg.iu_ReleaseRequestIEs);
+			rc = ranap_handle_co_iu_rel_req(ue_ctx, &message->msg.iu_ReleaseRequestIEs);
    		break;
    	default:
    		LOGP(DRANAP, LOGL_ERROR, "Received Initiating Message: unknown Procedure Code %d\n",
@@ -628,11 +634,11 @@
    	switch (message->procedureCode) {
    	case RANAP_ProcedureCode_id_SecurityModeControl:
    		/* Security Mode Complete */
-			rc = global_iu_event(ctx, RANAP_IU_EVENT_SECURITY_MODE_COMPLETE, NULL);
+			rc = global_iu_event(ue_ctx, RANAP_IU_EVENT_SECURITY_MODE_COMPLETE, NULL);
    		break;
    	case RANAP_ProcedureCode_id_Iu_Release:
    		/* Iu Release Complete */
-			rc = global_iu_event(ctx, RANAP_IU_EVENT_IU_RELEASE, NULL);
+			rc = global_iu_event(ue_ctx, RANAP_IU_EVENT_IU_RELEASE, NULL);
    		if (rc) {
    			LOGP(DRANAP, LOGL_ERROR, "Iu Release event: Iu Event callback returned %d\n",
    			       rc);
@@ -649,7 +655,7 @@
    	switch (message->procedureCode) {
    	case RANAP_ProcedureCode_id_RAB_Assignment:
    		/* RAB Assignment Response */
-			rc = ranap_handle_co_rab_ass_resp(ctx, &message->msg.raB_AssignmentResponseIEs);
+			rc = ranap_handle_co_rab_ass_resp(ue_ctx, &message->msg.raB_AssignmentResponseIEs);
    		break;
    	default:
    		LOGP(DRANAP, LOGL_ERROR, "Received Outcome: unknown Procedure Code %d\n",
@@ -672,14 +678,30 @@
    }
 }
-int sgsn_ranap_iu_rx_co_msg(struct ranap_ue_conn_ctx *ue_ctx, uint8_t *data, size_t len)
+int sgsn_ranap_iu_rx_co_msg(struct ranap_ue_conn_ctx *ue_ctx, const uint8_t *data, size_t len)
 {
-	return ranap_cn_rx_co(cn_ranap_handle_co, ue_ctx, data, len);
+	ranap_message message;
+	int rc;
+
+	rc = ranap_cn_rx_co_decode2(&message, data, len);
+	if (rc != 0) {
+		LOGP(DRANAP, LOGL_ERROR, "Not calling cn_ranap_handle_co() due to rc=%d\n", rc);
+		goto free_ret;
+	}
+
+	cn_ranap_handle_co(ue_ctx, &message);
+
+free_ret:
+	/* Free the asn1 structs in message */
+	ranap_cn_rx_co_free(&message);
+	return rc;
 }
-static int ranap_handle_cl_reset_req(struct ranap_iu_event_cl_msg_ind *cl_msg_ind, RANAP_ResetIEs_t *ies)
+static int ranap_handle_cl_reset_req(struct sgsn_sccp_user_iups *scu_iups,
+				     const struct osmo_scu_unitdata_param *ud_prim,
+				     const RANAP_ResetIEs_t *ies)
 {
-	RANAP_GlobalRNC_ID_t *grnc_id = NULL;
+	const RANAP_GlobalRNC_ID_t *grnc_id = NULL;
    struct msgb *resp;
/* FIXME: verify ies.cN_DomainIndicator */
@@ -692,10 +714,12 @@
    if (!resp)
    	return -ENOMEM;
    resp->l2h = resp->data;
-	return osmo_sccp_tx_unitdata_msg(cl_msg_ind->scu_iups->scu, &cl_msg_ind->scu_iups->local_sccp_addr, &cl_msg_ind->ud_prim->calling_addr, resp);
+	return osmo_sccp_tx_unitdata_msg(scu_iups->scu, &scu_iups->local_sccp_addr, &ud_prim->calling_addr, resp);
 }
-static int ranap_handle_cl_err_ind(struct ranap_iu_event_cl_msg_ind *cl_msg_ind, RANAP_ErrorIndicationIEs_t *ies)
+static int ranap_handle_cl_err_ind(struct sgsn_sccp_user_iups *scu_iups,
+				   const struct osmo_scu_unitdata_param *ud_prim,
+				   const RANAP_ErrorIndicationIEs_t *ies)
 {
    if (ies->presenceMask & ERRORINDICATIONIES_RANAP_CAUSE_PRESENT)
    	LOGP(DRANAP, LOGL_ERROR, "Rx Error Indication (%s)\n",
@@ -707,9 +731,10 @@
 }
/* Entry point for connection-less RANAP message */
-static void cn_ranap_handle_cl(void *ctx, ranap_message *message)
+static void cn_ranap_handle_cl(struct sgsn_sccp_user_iups *scu_iups,
+			       const struct osmo_scu_unitdata_param *ud_prim,
+			       const ranap_message *message)
 {
-	struct ranap_iu_event_cl_msg_ind *cl_msg_ind = ctx;
    int rc;
switch (message->direction) {
@@ -717,10 +742,10 @@
    	switch (message->procedureCode) {
    	case RANAP_ProcedureCode_id_Reset:
    		/* received reset.req, send reset.resp */
-			rc = ranap_handle_cl_reset_req(cl_msg_ind, &message->msg.resetIEs);
+			rc = ranap_handle_cl_reset_req(scu_iups, ud_prim, &message->msg.resetIEs);
    		break;
    	case RANAP_ProcedureCode_id_ErrorIndication:
-			rc = ranap_handle_cl_err_ind(cl_msg_ind, &message->msg.errorIndicationIEs);
+			rc = ranap_handle_cl_err_ind(scu_iups, ud_prim, &message->msg.errorIndicationIEs);
    		break;
    	default:
    		rc = -1;
@@ -741,11 +766,23 @@
    }
 }
-int sgsn_ranap_iu_rx_cl_msg(struct sgsn_sccp_user_iups *scu_iups, struct osmo_scu_unitdata_param *ud_prim, uint8_t *data, size_t len)
+int sgsn_ranap_iu_rx_cl_msg(struct sgsn_sccp_user_iups *scu_iups,
+			    const struct osmo_scu_unitdata_param *ud_prim,
+			    const uint8_t *data, size_t len)
 {
-	struct ranap_iu_event_cl_msg_ind cl_msg_ind = {
-		.scu_iups = scu_iups,
-		.ud_prim = ud_prim,
-	};
-	return ranap_cn_rx_cl(cn_ranap_handle_cl, &cl_msg_ind, data, len);
+	ranap_message message;
+	int rc;
+
+	rc = ranap_cn_rx_cl_decode2(&message, data, len);
+	if (rc != 0) {
+		LOGP(DRANAP, LOGL_ERROR, "Not calling cn_ranap_handle_cl() due to rc=%d\n", rc);
+		goto free_ret;
+	}
+
+	cn_ranap_handle_cl(scu_iups, ud_prim, &message);
+
+free_ret:
+	/* Free the asn1 structs in message */
+	ranap_cn_rx_cl_free(&message);
+	return rc;
 }
-- 
To view, visit https://gerrit.osmocom.org/c/osmo-sgsn/+/40960?usp=email
To unsubscribe, or for help writing mail filters, visit https://gerrit.osmocom.org/settings?usp=email

Gerrit-MessageType: merged
Gerrit-Project: osmo-sgsn
Gerrit-Branch: master
Gerrit-Change-Id: Ib3c00b5105b7ba4bb1a2dad1a14bea233a03c358
Gerrit-Change-Number: 40960
Gerrit-PatchSet: 3
Gerrit-Owner: pespin pespin@sysmocom.de
Gerrit-Reviewer: Jenkins Builder
Gerrit-Reviewer: fixeria vyanitskiy@sysmocom.de
Gerrit-Reviewer: lynxis lazus lynxis@fe80.eu



    

2025

2024

2023

2022

[M] Change in osmo-sgsn[master]: ranap: Clean up RANAP rx path param passing