From d242ec2ed909e58d8f3905b185a1b1e14806f7da Mon Sep 17 00:00:00 2001 From: Jacob Erlbeck Date: Fri, 21 Feb 2014 15:09:14 +0100 Subject: agch: Keep track of AGCH queue length This patch adds and updates btsb->agch_queue_length to keep track of the queue length. Sponsored-by: On-Waves ehf --- src/common/bts.c | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'src/common') diff --git a/src/common/bts.c b/src/common/bts.c index 2ac411d0..35fc3024 100644 --- a/src/common/bts.c +++ b/src/common/bts.c @@ -65,6 +65,7 @@ int bts_init(struct gsm_bts *bts) bts->role = btsb = talloc_zero(bts, struct gsm_bts_role_bts); INIT_LLIST_HEAD(&btsb->agch_queue); + btsb->agch_queue_length = 0; /* configurable via VTY */ btsb->paging_state = paging_init(btsb, 200, 0); @@ -214,6 +215,7 @@ int bts_agch_enqueue(struct gsm_bts *bts, struct msgb *msg) /* FIXME: implement max queue length */ msgb_enqueue(&btsb->agch_queue, msg); + btsb->agch_queue_length++; return 0; } @@ -221,8 +223,12 @@ int bts_agch_enqueue(struct gsm_bts *bts, struct msgb *msg) struct msgb *bts_agch_dequeue(struct gsm_bts *bts) { struct gsm_bts_role_bts *btsb = bts_role_bts(bts); + struct msgb *msg = msgb_dequeue(&btsb->agch_queue); + if (!msg) + return NULL; - return msgb_dequeue(&btsb->agch_queue); + btsb->agch_queue_length--; + return msg; } int bts_supports_cipher(struct gsm_bts_role_bts *bts, int rsl_cipher) -- cgit v1.2.3