gtp: Rework parsing logic of UpdatePdpCtxResponse

The previous order of parsing lead to non-optimal information gathering
when pushing events to upper layers.

This patch rearranges parsing of packet data to always gather as much
info as possible for the benefit of the upper layer. This way it can
gather information such as the cause, which is important in the case of
"Non-existent", since user should then drop the context.

First we want to parse the recovery state, but delay cb to upper layers
until we tried to gather the pdp ctx (meaning all except that pdp ctx
should be freed).
Second, we want to parse the cause, in order to know if there's an
associated pdp ctx we can gather from TEID.
Third, once we know if we should expect a meaningul TEID, parse it.

Related: SYS#5435
Change-Id: Idd10b494e8fbac8703c49ecd8f9bbe4246e51c57
This commit is contained in:
Pau Espin 2021-04-22 13:47:57 +02:00
parent 0b1d9dbc40
commit 00e0559e17
1 changed files with 30 additions and 19 deletions

View File

@ -2324,26 +2324,20 @@ static int gtp_update_pdp_ind(struct gsn_t *gsn, uint8_t version,
static int gtp_update_pdp_conf(struct gsn_t *gsn, uint8_t version, static int gtp_update_pdp_conf(struct gsn_t *gsn, uint8_t version,
struct sockaddr_in *peer, void *pack, unsigned len) struct sockaddr_in *peer, void *pack, unsigned len)
{ {
struct pdp_t *pdp; struct pdp_t *pdp = NULL;
union gtpie_member *ie[GTPIE_SIZE]; union gtpie_member *ie[GTPIE_SIZE];
uint8_t cause, recovery; uint8_t cause = EOF;
uint8_t recovery;
int rc = 0;
void *cbp = NULL; void *cbp = NULL;
uint8_t type = 0; uint8_t type = 0;
bool trigger_recovery = false;
int hlen = get_hlen(pack); int hlen = get_hlen(pack);
/* Remove packet from queue */ /* Remove packet from queue */
if (gtp_conf(gsn, 0, peer, pack, len, &type, &cbp)) if (gtp_conf(gsn, 0, peer, pack, len, &type, &cbp))
return EOF; return EOF;
/* Find the context in question */
if (gtp_pdp_getgtp1(gsn, &pdp, get_tei(pack))) {
gsn->err_unknownpdp++;
GTP_LOGPKG(LOGL_ERROR, peer, pack, len,
"Unknown PDP context: %u\n", get_tei(pack));
pdp = NULL;
goto err_out;
}
/* Decode information elements */ /* Decode information elements */
if (gtpie_decaps(ie, version, pack + hlen, len - hlen)) { if (gtpie_decaps(ie, version, pack + hlen, len - hlen)) {
gsn->invalid++; gsn->invalid++;
@ -2352,19 +2346,34 @@ static int gtp_update_pdp_conf(struct gsn_t *gsn, uint8_t version,
goto err_out; goto err_out;
} }
/* Extract recovery (optional) */
if (!gtpie_gettv1(ie, GTPIE_RECOVERY, 0, &recovery))
trigger_recovery = true;
/* Extract cause value (mandatory) */ /* Extract cause value (mandatory) */
if (gtpie_gettv1(ie, GTPIE_CAUSE, 0, &cause)) { if (gtpie_gettv1(ie, GTPIE_CAUSE, 0, &cause)) {
goto err_missing; goto err_missing;
} }
/* Extract recovery (optional) */ /* 3GPP TS 29.060 sec 8.2: "Receiving node shall send back to the source
if (!gtpie_gettv1(ie, GTPIE_RECOVERY, 0, &recovery)) { * of the message, a response with the appropriate cause value (either
emit_cb_recovery(gsn, peer, pdp, recovery); * "Non-existent" or "Context not found"). The Tunnel Endpoint
* Identifier used in the response message shall be set to all zeroes."
* Hence, TEID=0 in this scenario, it makes no sense to infer PDP ctx
* from it. User is responsible to infer it from cbp */
if (cause != GTPCAUSE_NON_EXIST && cause != GTPCAUSE_CONTEXT_NOT_FOUND) {
/* Find the context in question */
if (gtp_pdp_getgtp1(gsn, &pdp, get_tei(pack))) {
gsn->err_unknownpdp++;
GTP_LOGPKG(LOGL_ERROR, peer, pack, len,
"Unknown PDP context: %u\n", get_tei(pack));
goto err_out;
}
} }
/* Check all conditional information elements */ /* Check all conditional information elements */
/* TODO: This does not handle GGSN-initiated update responses */ /* TODO: This does not handle GGSN-initiated update responses */
if (GTPCAUSE_ACC_REQ == cause) { if (cause == GTPCAUSE_ACC_REQ) {
if (version == 0) { if (version == 0) {
if (gtpie_gettv0(ie, GTPIE_QOS_PROFILE0, 0, if (gtpie_gettv0(ie, GTPIE_QOS_PROFILE0, 0,
&pdp->qos_neg0, &pdp->qos_neg0,
@ -2416,18 +2425,20 @@ static int gtp_update_pdp_conf(struct gsn_t *gsn, uint8_t version,
} }
} }
generic_ret:
if (trigger_recovery)
emit_cb_recovery(gsn, peer, pdp, recovery);
if (gsn->cb_conf) if (gsn->cb_conf)
gsn->cb_conf(type, cause, pdp, cbp); gsn->cb_conf(type, cause, pdp, cbp);
return 0; /* Succes */ return rc; /* Succes */
err_missing: err_missing:
gsn->missing++; gsn->missing++;
GTP_LOGPKG(LOGL_ERROR, peer, pack, len, GTP_LOGPKG(LOGL_ERROR, peer, pack, len,
"Missing information field\n"); "Missing information field\n");
err_out: err_out:
if (gsn->cb_conf) rc = EOF;
gsn->cb_conf(type, EOF, pdp, cbp); goto generic_ret;
return EOF;
} }
/* API: Deprecated. Send Delete PDP Context Request And free pdp ctx. */ /* API: Deprecated. Send Delete PDP Context Request And free pdp ctx. */