paulmataruso/osmo-mgw
1
0
Fork 0
mirror of https://gitea.osmocom.org/cellular-infrastructure/osmo-mgw.git synced 2025-11-02 21:13:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

[gprs] gb_proxy: Actually create our gbprox_peers

Browse Source 
also extend the logging verbosity and fix some compiler warnings
This commit is contained in:
Harald Welte
2010-05-01 12:10:57 +02:00
parent 79fc392751
commit 70f38d2a3b
1 changed files with 27 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
openbsc/src/gb_proxy.c
View File

@@ -82,7 +82,7 @@ static struct gbprox_peer *peer_by_nsvc(struct gprs_nsvc *nsvc)
} }
/* look-up a peer by its Routeing Area Code (RAC) */ /* look-up a peer by its Routeing Area Code (RAC) */
static struct gbprox_peer *peer_by_rac(uint8_t *ra) static struct gbprox_peer *peer_by_rac(const uint8_t *ra)
{ {
struct gbprox_peer *peer; struct gbprox_peer *peer;
llist_for_each_entry(peer, &gbprox_bts_peers, list) { llist_for_each_entry(peer, &gbprox_bts_peers, list) {
@@ -93,7 +93,7 @@ static struct gbprox_peer *peer_by_rac(uint8_t *ra)
} }
/* look-up a peer by its Location Area Code (LAC) */ /* look-up a peer by its Location Area Code (LAC) */
static struct gbprox_peer *peer_by_lac(uint8_t *la) static struct gbprox_peer *peer_by_lac(const uint8_t *la)
{ {
struct gbprox_peer *peer; struct gbprox_peer *peer;
llist_for_each_entry(peer, &gbprox_bts_peers, list) { llist_for_each_entry(peer, &gbprox_bts_peers, list) {
@@ -156,9 +156,10 @@ static int gbprox_rx_sig_from_bss(struct msgb *msg, struct gprs_nsvc *nsvc,
uint8_t pdu_type = bgph->pdu_type; uint8_t pdu_type = bgph->pdu_type;
int data_len = msgb_l3len(msg) - sizeof(*bgph); int data_len = msgb_l3len(msg) - sizeof(*bgph);
struct gbprox_peer *from_peer; struct gbprox_peer *from_peer;
struct gprs_ra_id raid;
if (ns_bvci != 0) { if (ns_bvci != 0) {
LOGP(DGPRS, LOGL_NOTICE, "BVCI %u not signalling\n", ns_bvci); LOGP(DGPRS, LOGL_NOTICE, "BVCI %u is not signalling\n", ns_bvci);
return -EINVAL; return -EINVAL;
} }
@@ -175,7 +176,11 @@ static int gbprox_rx_sig_from_bss(struct msgb *msg, struct gprs_nsvc *nsvc,
switch (pdu_type) { switch (pdu_type) {
case BSSGP_PDUT_SUSPEND: case BSSGP_PDUT_SUSPEND:
case BSSGP_PDUT_RESUME: case BSSGP_PDUT_RESUME:
/* RAC snooping for SUSPEND/RESUME */ /* We implement RAC snooping during SUSPEND/RESUME, since
* it establishes a relationsip between BVCI/peer and the
* routeing area code. The snooped information is then
* used for routing the {SUSPEND,RESUME}_[N]ACK back to
* the correct BSSGP */
if (!TLVP_PRESENT(&tp, BSSGP_IE_ROUTEING_AREA)) if (!TLVP_PRESENT(&tp, BSSGP_IE_ROUTEING_AREA))
goto err_mand_ie; goto err_mand_ie;
from_peer = peer_by_nsvc(nsvc); from_peer = peer_by_nsvc(nsvc);
@@ -183,6 +188,10 @@ static int gbprox_rx_sig_from_bss(struct msgb *msg, struct gprs_nsvc *nsvc,
goto err_no_peer; goto err_no_peer;
memcpy(&from_peer->ra, TLVP_VAL(&tp, BSSGP_IE_ROUTEING_AREA), memcpy(&from_peer->ra, TLVP_VAL(&tp, BSSGP_IE_ROUTEING_AREA),
sizeof(&from_peer->ra)); sizeof(&from_peer->ra));
gsm48_parse_ra(&raid, &from_peer->ra);
DEBUGP(DGPRS, "RAC snooping: RAC %u/%u/%u/%u behind BVCI=%u, "
"NSVCI=%u, NSEI=%u\n", raid.mcc, raid.mnc, raid.lac,
raid.rac , from_peer->bvci, nsvc->nsvci, nsvc->nsei);
/* FIXME: This only supports one BSS per RA */ /* FIXME: This only supports one BSS per RA */
break; break;
} }
@@ -227,7 +236,7 @@ static int gbprox_rx_sig_from_sgsn(struct msgb *msg, struct gprs_nsvc *nsvc,
int rc = 0; int rc = 0;
if (ns_bvci != 0) { if (ns_bvci != 0) {
LOGP(DGPRS, LOGL_NOTICE, "BVCI %u not signalling\n", ns_bvci); LOGP(DGPRS, LOGL_NOTICE, "BVCI %u is not signalling\n", ns_bvci);
return -EINVAL; return -EINVAL;
} }
@@ -307,9 +316,20 @@ int gbprox_rcvmsg(struct msgb *msg, struct gprs_nsvc *nsvc, uint16_t ns_bvci)
/* All other BVCI are PTP and thus can be simply forwarded */ /* All other BVCI are PTP and thus can be simply forwarded */
peer = peer_by_bvci(ns_bvci); peer = peer_by_bvci(ns_bvci);
if (!peer) { if (!peer) {
LOGP(DGPRS, LOGL_ERROR, "Couldn't find peer for BVCI %u\n", ns_bvci); if (!nsvc->remote_end_is_sgsn) {
LOGP(DGPRS, LOGL_NOTICE, "Allocationg new peer for "
"BVCI=%u via NSVC=%u/NSEI=%u\n", ns_bvci,
nsvc->nsvci, nsvc->nsei);
peer = peer_alloc(ns_bvci);
peer->nsvc = nsvc;
} else {
LOGP(DGPRS, LOGL_ERROR, "Couldn't find peer for "
"BVCI %u\n", ns_bvci);
/* FIXME: do we really have to free the message here? */
msgb_free(msg);
return -EIO; return -EIO;
} }
}
return gbprox_tx2peer(msg, peer, ns_bvci); return gbprox_tx2peer(msg, peer, ns_bvci);
} }