cellular-infrastructure
/
osmo-msc
mirror of https://gerrit.osmocom.org/osmo-msc
9
0
Fork 0
Code Issues Releases Wiki Activity

subscr: Store the state of a subscr request for inspection.

This commit is contained in:
Holger Hans Peter Freyther 2010-12-29 09:33:34 +01:00
parent c02b12086c
commit 68c3bf6de8
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
openbsc/src/gsm_subscriber.c
View File

@ -58,11 +58,22 @@ struct subscr_request {
/* the requested channel type */
int channel_type;
/* what did we do */
int state;
/* the callback data */
gsm_cbfn *cbfn;
void *param;
};
enum {
REQ_STATE_INITIAL,
REQ_STATE_QUEUED,
REQ_STATE_PAGED,
REQ_STATE_FAILED_START,
REQ_STATE_DISPATCHED,
};
/*
* We got the channel assigned and can now hand this channel
* over to one of our callbacks.
@ -98,6 +109,7 @@ static int subscr_paging_dispatch(unsigned int hooknum, unsigned int event,
* the subscr_put_channel work as required...
*/
request = (struct subscr_request *)subscr->requests.next;
request->state = REQ_STATE_DISPATCHED;
llist_del(&request->entry);
subscr->in_callback = 1;
request->cbfn(hooknum, event, msg, data, request->param);
@ -178,11 +190,13 @@ static void subscr_send_paging_request(struct gsm_subscriber *subscr)
assert(!llist_empty(&subscr->requests));
request = (struct subscr_request *)subscr->requests.next;
request->state = REQ_STATE_PAGED;
rc = paging_request(subscr->net, subscr, request->channel_type,
subscr_paging_cb, subscr);
/* paging failed, quit now */
if (rc <= 0) {
request->state = REQ_STATE_FAILED_START;
subscr_paging_cb(GSM_HOOK_RR_PAGING, GSM_PAGING_BUSY,
NULL, NULL, subscr);
}
@ -206,6 +220,7 @@ void subscr_get_channel(struct gsm_subscriber *subscr,
request->channel_type = type;
request->cbfn = cbfn;
request->param = param;
request->state = REQ_STATE_INITIAL;
/*
* FIXME: We might be able to assign more than one
@ -219,6 +234,7 @@ void subscr_get_channel(struct gsm_subscriber *subscr,
} else {
/* this will be picked up later, from subscr_put_channel */
llist_add_tail(&request->entry, &subscr->requests);
request->state = REQ_STATE_QUEUED;
}
}