smpp_mirror: Factor-out reset of SMPP read state
Change-Id: Ib9f210316eaddae19cb74db92b922016864dd786
This commit is contained in:
parent
30811f865c
commit
065b23ae5b
|
@ -214,6 +214,14 @@ static int smpp_pdu_rx(struct esme *esme, struct msgb *msg)
|
||||||
return rc;
|
return rc;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static void esme_read_state_reset(struct esme *esme)
|
||||||
|
{
|
||||||
|
esme->read_msg = NULL;
|
||||||
|
esme->read_idx = 0;
|
||||||
|
esme->read_len = 0;
|
||||||
|
esme->read_state = READ_ST_IN_LEN;
|
||||||
|
}
|
||||||
|
|
||||||
/* FIXME: merge with smpp_smsc.c */
|
/* FIXME: merge with smpp_smsc.c */
|
||||||
static int esme_read_cb(struct osmo_fd *ofd)
|
static int esme_read_cb(struct osmo_fd *ofd)
|
||||||
{
|
{
|
||||||
|
@ -264,10 +272,7 @@ static int esme_read_cb(struct osmo_fd *ofd)
|
||||||
|
|
||||||
if (esme->read_idx >= esme->read_len) {
|
if (esme->read_idx >= esme->read_len) {
|
||||||
rc = smpp_pdu_rx(esme, esme->read_msg);
|
rc = smpp_pdu_rx(esme, esme->read_msg);
|
||||||
esme->read_msg = NULL;
|
esme_read_state_reset(esme);
|
||||||
esme->read_idx = 0;
|
|
||||||
esme->read_len = 0;
|
|
||||||
esme->read_state = READ_ST_IN_LEN;
|
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue