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

mgcp: Print the system for the duplicate SSRC...

Browse Source
This commit is contained in:
Holger Hans Peter Freyther
2010-08-04 21:45:39 +08:00
parent 6526ca720c
commit 2f10458831
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
openbsc/src/mgcp/mgcp_network.c
View File

@@ -94,7 +94,8 @@ int mgcp_send_dummy(struct mgcp_endpoint *endp)
endp->net_rtp, buf, 1); endp->net_rtp, buf, 1);
} }
static void patch_and_count(struct mgcp_rtp_state *state, int payload, char *data, int len) static void patch_and_count(struct mgcp_rtp_state *state, int endp_no,
struct sockaddr_in *addr, int payload, char *data, int len)
{ {
uint16_t seq; uint16_t seq;
uint32_t timestamp; uint32_t timestamp;
@@ -117,8 +118,10 @@ static void patch_and_count(struct mgcp_rtp_state *state, int payload, char *dat
state->seq_offset = (state->seq_no + 1) - seq; state->seq_offset = (state->seq_no + 1) - seq;
state->timestamp_offset = state->last_timestamp - timestamp; state->timestamp_offset = state->last_timestamp - timestamp;
state->patch = 1; state->patch = 1;
LOGP(DMGCP, LOGL_NOTICE, "The SSRC changed... SSRC: %u offset: %d\n", LOGP(DMGCP, LOGL_NOTICE,
state->ssrc, state->seq_offset); "The SSRC changed on %d SSRC: %u offset: %d from %s:%d\n",
endp_no, state->ssrc, state->seq_offset,
inet_ntoa(addr->sin_addr), ntohs(addr->sin_port));
} }
/* apply the offset and store it back to the packet */ /* apply the offset and store it back to the packet */
@@ -235,14 +238,18 @@ static int rtp_data_cb(struct bsc_fd *fd, unsigned int what)
if (dest == DEST_NETWORK) { if (dest == DEST_NETWORK) {
if (proto == PROTO_RTP) if (proto == PROTO_RTP)
patch_and_count(&endp->bts_state, patch_and_count(&endp->bts_state,
endp->net_payload_type, buf, rc); endp->net_payload_type,
&addr,
ENDPOINT_NUMBER(endp), buf, rc);
return udp_send(fd->fd, &endp->remote, return udp_send(fd->fd, &endp->remote,
proto == PROTO_RTP ? endp->net_rtp : endp->net_rtcp, proto == PROTO_RTP ? endp->net_rtp : endp->net_rtcp,
buf, rc); buf, rc);
} else { } else {
if (proto == PROTO_RTP) if (proto == PROTO_RTP)
patch_and_count(&endp->net_state, patch_and_count(&endp->net_state,
endp->bts_payload_type, buf, rc); endp->bts_payload_type,
&addr,
ENDPOINT_NUMBER(endp), buf, rc);
return udp_send(fd->fd, &endp->bts, return udp_send(fd->fd, &endp->bts,
proto == PROTO_RTP ? endp->bts_rtp : endp->bts_rtcp, proto == PROTO_RTP ? endp->bts_rtp : endp->bts_rtcp,
buf, rc); buf, rc);