bsc: Look for CM Service Requests with emergency cause
Look for emergency calls and send them to a MSC that can handle them properly.
This commit is contained in:
parent
210565ed8c
commit
18fa70aa3a
|
@ -46,6 +46,7 @@ struct osmo_msc_data {
|
||||||
/* Back pointer */
|
/* Back pointer */
|
||||||
struct gsm_network *network;
|
struct gsm_network *network;
|
||||||
|
|
||||||
|
int allow_emerg;
|
||||||
int type;
|
int type;
|
||||||
|
|
||||||
/* Connection data */
|
/* Connection data */
|
||||||
|
|
|
@ -106,6 +106,21 @@ static int handle_page_resp(struct gsm_subscriber_connection *conn, struct msgb
|
||||||
subscr_put(subscr);
|
subscr_put(subscr);
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static int is_cm_service_for_emerg(struct msgb *msg)
|
||||||
|
{
|
||||||
|
struct gsm48_service_request *cm;
|
||||||
|
struct gsm48_hdr *gh = msgb_l3(msg);
|
||||||
|
|
||||||
|
if (msgb_l3len(msg) < sizeof(*gh) + sizeof(*cm)) {
|
||||||
|
LOGP(DMSC, LOGL_ERROR, "CM ServiceRequest does not fit.\n");
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
cm = (struct gsm48_service_request *) &gh->data[0];
|
||||||
|
return cm->cm_service_type == GSM48_CMSERV_EMERGENCY;
|
||||||
|
}
|
||||||
|
|
||||||
struct osmo_msc_data *bsc_find_msc(struct gsm_subscriber_connection *conn,
|
struct osmo_msc_data *bsc_find_msc(struct gsm_subscriber_connection *conn,
|
||||||
struct msgb *msg)
|
struct msgb *msg)
|
||||||
{
|
{
|
||||||
|
@ -115,6 +130,7 @@ struct osmo_msc_data *bsc_find_msc(struct gsm_subscriber_connection *conn,
|
||||||
struct osmo_bsc_data *bsc;
|
struct osmo_bsc_data *bsc;
|
||||||
struct osmo_msc_data *msc, *pag_msc;
|
struct osmo_msc_data *msc, *pag_msc;
|
||||||
struct gsm_subscriber *subscr;
|
struct gsm_subscriber *subscr;
|
||||||
|
int is_emerg = 0;
|
||||||
|
|
||||||
bsc = conn->bts->network->bsc_data;
|
bsc = conn->bts->network->bsc_data;
|
||||||
|
|
||||||
|
@ -135,14 +151,19 @@ struct osmo_msc_data *bsc_find_msc(struct gsm_subscriber_connection *conn,
|
||||||
*/
|
*/
|
||||||
if (pdisc == GSM48_PDISC_RR && mtype == GSM48_MT_RR_PAG_RESP)
|
if (pdisc == GSM48_PDISC_RR && mtype == GSM48_MT_RR_PAG_RESP)
|
||||||
goto paging;
|
goto paging;
|
||||||
else
|
else if (pdisc == GSM48_PDISC_MM && mtype == GSM48_MT_MM_CM_SERV_REQ) {
|
||||||
|
is_emerg = is_cm_service_for_emerg(msg);
|
||||||
|
goto round_robin;
|
||||||
|
} else
|
||||||
goto round_robin;
|
goto round_robin;
|
||||||
|
|
||||||
round_robin:
|
round_robin:
|
||||||
llist_for_each_entry(msc, &bsc->mscs, entry) {
|
llist_for_each_entry(msc, &bsc->mscs, entry) {
|
||||||
if (!msc->msc_con->is_authenticated)
|
if (!msc->msc_con->is_authenticated)
|
||||||
continue;
|
continue;
|
||||||
if (msc->type != MSC_CON_TYPE_NORMAL)
|
if (!is_emerg && msc->type != MSC_CON_TYPE_NORMAL)
|
||||||
|
continue;
|
||||||
|
if (is_emerg && !msc->allow_emerg)
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
/* force round robin by moving it to the end */
|
/* force round robin by moving it to the end */
|
||||||
|
|
|
@ -492,6 +492,7 @@ struct osmo_msc_data *osmo_msc_data_alloc(struct gsm_network *net, int nr)
|
||||||
msc_data->rtp_base = 4000;
|
msc_data->rtp_base = 4000;
|
||||||
|
|
||||||
msc_data->nr = nr;
|
msc_data->nr = nr;
|
||||||
|
msc_data->allow_emerg = 1;
|
||||||
|
|
||||||
return msc_data;
|
return msc_data;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue