Asterisk
/
asterisk
mirror of https://github.com/asterisk/asterisk
1
0
Fork 0
Code Issues Releases Wiki Activity

Make RTP handle codecs (first pass)

Browse Source 
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@3089 65c4cc65-6c06-0410-ace0-fbb531ad65f3
1.0
Mark Spencer 22 years ago
parent fc7593e594
commit cf57ba2310
6 changed files with 59 additions and 35 deletions
Show Stats Download Patch File Download Diff File

2
channels/chan_h323.c
Unescape View File

@ -1776,7 +1776,7 @@ static char *convertcap(int cap)
} }
static int oh323_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp) static int oh323_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp, int codecs)
{ {
/* XXX Deal with Video */ /* XXX Deal with Video */
struct oh323_pvt *p; struct oh323_pvt *p;

16
channels/chan_mgcp.c
Unescape View File

@ -433,7 +433,7 @@ static int transmit_response(struct mgcp_subchannel *sub, char *msg, struct mgcp
static int transmit_notify_request(struct mgcp_subchannel *sub, char *tone); static int transmit_notify_request(struct mgcp_subchannel *sub, char *tone);
static int transmit_modify_request(struct mgcp_subchannel *sub); static int transmit_modify_request(struct mgcp_subchannel *sub);
static int transmit_notify_request_with_callerid(struct mgcp_subchannel *sub, char *tone, char *callerid); static int transmit_notify_request_with_callerid(struct mgcp_subchannel *sub, char *tone, char *callerid);
static int transmit_modify_with_sdp(struct mgcp_subchannel *sub, struct ast_rtp *rtp); static int transmit_modify_with_sdp(struct mgcp_subchannel *sub, struct ast_rtp *rtp, int codecs);
static int transmit_connection_del(struct mgcp_subchannel *sub); static int transmit_connection_del(struct mgcp_subchannel *sub);
static int transmit_audit_endpoint(struct mgcp_endpoint *p); static int transmit_audit_endpoint(struct mgcp_endpoint *p);
static void start_rtp(struct mgcp_subchannel *sub); static void start_rtp(struct mgcp_subchannel *sub);
@ -1908,13 +1908,17 @@ static int add_sdp(struct mgcp_request *resp, struct mgcp_subchannel *sub, struc
return 0; return 0;
} }
static int transmit_modify_with_sdp(struct mgcp_subchannel *sub, struct ast_rtp *rtp) static int transmit_modify_with_sdp(struct mgcp_subchannel *sub, struct ast_rtp *rtp, int codecs)
{ {
struct mgcp_request resp; struct mgcp_request resp;
char local[256]; char local[256];
char tmp[80]; char tmp[80];
int x; int x;
int capability;
struct mgcp_endpoint *p = sub->parent; struct mgcp_endpoint *p = sub->parent;
capability = p->capability;
if (codecs)
capability = codecs;
if (!strlen(sub->cxident) && rtp) { if (!strlen(sub->cxident) && rtp) {
/* We don't have a CXident yet, store the destination and /* We don't have a CXident yet, store the destination and
wait a bit */ wait a bit */
@ -1923,7 +1927,7 @@ static int transmit_modify_with_sdp(struct mgcp_subchannel *sub, struct ast_rtp
} }
snprintf(local, sizeof(local), "p:20"); snprintf(local, sizeof(local), "p:20");
for (x=1;x<= AST_FORMAT_MAX_AUDIO; x <<= 1) { for (x=1;x<= AST_FORMAT_MAX_AUDIO; x <<= 1) {
if (p->capability & x) { if (capability & x) {
snprintf(tmp, sizeof(tmp), ", a:%s", ast_rtp_lookup_mime_subtype(1, x)); snprintf(tmp, sizeof(tmp), ", a:%s", ast_rtp_lookup_mime_subtype(1, x));
strcat(local, tmp); strcat(local, tmp);
} }
@ -2298,7 +2302,7 @@ static void handle_response(struct mgcp_endpoint *p, struct mgcp_subchannel *sub
} }
strncpy(sub->cxident, c, sizeof(sub->cxident) - 1); strncpy(sub->cxident, c, sizeof(sub->cxident) - 1);
if (sub->tmpdest.sin_addr.s_addr) { if (sub->tmpdest.sin_addr.s_addr) {
transmit_modify_with_sdp(sub, NULL); transmit_modify_with_sdp(sub, NULL, 0);
} }
} }
else { else {
@ -3710,13 +3714,13 @@ static struct ast_rtp *mgcp_get_rtp_peer(struct ast_channel *chan)
return NULL; return NULL;
} }
static int mgcp_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp) static int mgcp_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp, int codecs)
{ {
/* XXX Is there such thing as video support with MGCP? XXX */ /* XXX Is there such thing as video support with MGCP? XXX */
struct mgcp_subchannel *sub; struct mgcp_subchannel *sub;
sub = chan->pvt->pvt; sub = chan->pvt->pvt;
if (sub) { if (sub) {
transmit_modify_with_sdp(sub, rtp); transmit_modify_with_sdp(sub, rtp, codecs);
return 0; return 0;
} }
return -1; return -1;

31
channels/chan_sip.c
Unescape View File

@ -493,7 +493,7 @@ static int transmit_response_with_auth(struct sip_pvt *p, char *msg, struct sip_
static int transmit_request(struct sip_pvt *p, char *msg, int inc, int reliable, int newbranch); static int transmit_request(struct sip_pvt *p, char *msg, int inc, int reliable, int newbranch);
static int transmit_request_with_auth(struct sip_pvt *p, char *msg, int inc, int reliable, int newbranch); static int transmit_request_with_auth(struct sip_pvt *p, char *msg, int inc, int reliable, int newbranch);
static int transmit_invite(struct sip_pvt *p, char *msg, int sendsdp, char *auth, char *authheader, char *vxml_url,char *distinctive_ring, int init); static int transmit_invite(struct sip_pvt *p, char *msg, int sendsdp, char *auth, char *authheader, char *vxml_url,char *distinctive_ring, int init);
static int transmit_reinvite_with_sdp(struct sip_pvt *p, struct ast_rtp *rtp, struct ast_rtp *vrtp); static int transmit_reinvite_with_sdp(struct sip_pvt *p, struct ast_rtp *rtp, struct ast_rtp *vrtp, int codec);
static int transmit_info_with_digit(struct sip_pvt *p, char digit); static int transmit_info_with_digit(struct sip_pvt *p, char digit);
static int transmit_message_with_text(struct sip_pvt *p, char *text); static int transmit_message_with_text(struct sip_pvt *p, char *text);
static int transmit_refer(struct sip_pvt *p, char *dest); static int transmit_refer(struct sip_pvt *p, char *dest);
@ -3003,7 +3003,7 @@ static int add_digit(struct sip_request *req, char digit)
} }
/*--- add_sdp: Add Session Description Protocol message ---*/ /*--- add_sdp: Add Session Description Protocol message ---*/
static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *rtp, struct ast_rtp *vrtp) static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *rtp, struct ast_rtp *vrtp, int codecs)
{ {
int len; int len;
int codec; int codec;
@ -3022,6 +3022,7 @@ static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *
char a[1024] = ""; char a[1024] = "";
char a2[1024] = ""; char a2[1024] = "";
int x; int x;
int capability;
struct sockaddr_in dest; struct sockaddr_in dest;
struct sockaddr_in vdest = { 0, }; struct sockaddr_in vdest = { 0, };
/* XXX We break with the "recommendation" and send our IP, in order that our /* XXX We break with the "recommendation" and send our IP, in order that our
@ -3031,6 +3032,10 @@ static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *
ast_log(LOG_WARNING, "No way to add SDP without an RTP structure\n"); ast_log(LOG_WARNING, "No way to add SDP without an RTP structure\n");
return -1; return -1;
} }
capability = p->jointcapability;
if (codecs)
capability = codecs & p->jointcapability;
if (!p->sessionid) { if (!p->sessionid) {
p->sessionid = getpid(); p->sessionid = getpid();
p->sessionversion = p->sessionid; p->sessionversion = p->sessionid;
@ -3073,7 +3078,7 @@ static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *
snprintf(t, sizeof(t), "t=0 0\r\n"); snprintf(t, sizeof(t), "t=0 0\r\n");
snprintf(m, sizeof(m), "m=audio %d RTP/AVP", ntohs(dest.sin_port)); snprintf(m, sizeof(m), "m=audio %d RTP/AVP", ntohs(dest.sin_port));
snprintf(m2, sizeof(m2), "m=video %d RTP/AVP", ntohs(vdest.sin_port)); snprintf(m2, sizeof(m2), "m=video %d RTP/AVP", ntohs(vdest.sin_port));
if (p->jointcapability & p->prefcodec) { if (capability & p->prefcodec) {
if (sip_debug_test_pvt(p)) if (sip_debug_test_pvt(p))
ast_verbose("Answering/Requesting with root capability %d\n", p->prefcodec); ast_verbose("Answering/Requesting with root capability %d\n", p->prefcodec);
codec = ast_rtp_lookup_code(p->rtp, 1, p->prefcodec); codec = ast_rtp_lookup_code(p->rtp, 1, p->prefcodec);
@ -3094,7 +3099,7 @@ static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *
/* Start by sending our preferred codecs */ /* Start by sending our preferred codecs */
cur = prefs; cur = prefs;
while(cur) { while(cur) {
if ((p->jointcapability & cur->codec) && !(alreadysent & cur->codec)) { if ((capability & cur->codec) && !(alreadysent & cur->codec)) {
if (sip_debug_test_pvt(p)) if (sip_debug_test_pvt(p))
ast_verbose("Answering with preferred capability 0x%x(%s)\n", cur->codec, ast_getformatname(cur->codec)); ast_verbose("Answering with preferred capability 0x%x(%s)\n", cur->codec, ast_getformatname(cur->codec));
codec = ast_rtp_lookup_code(p->rtp, 1, cur->codec); codec = ast_rtp_lookup_code(p->rtp, 1, cur->codec);
@ -3116,7 +3121,7 @@ static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *
} }
/* Now send any other common codecs, and non-codec formats: */ /* Now send any other common codecs, and non-codec formats: */
for (x = 1; x <= (videosupport ? AST_FORMAT_MAX_VIDEO : AST_FORMAT_MAX_AUDIO); x <<= 1) { for (x = 1; x <= (videosupport ? AST_FORMAT_MAX_VIDEO : AST_FORMAT_MAX_AUDIO); x <<= 1) {
if ((p->jointcapability & x) && !(alreadysent & x)) { if ((capability & x) && !(alreadysent & x)) {
if (sip_debug_test_pvt(p)) if (sip_debug_test_pvt(p))
ast_verbose("Answering with capability 0x%x(%s)\n", x, ast_getformatname(x)); ast_verbose("Answering with capability 0x%x(%s)\n", x, ast_getformatname(x));
codec = ast_rtp_lookup_code(p->rtp, 1, x); codec = ast_rtp_lookup_code(p->rtp, 1, x);
@ -3161,7 +3166,7 @@ static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *
if ((sizeof(m) <= strlen(m) - 2) || (sizeof(m2) <= strlen(m2) - 2) || (sizeof(a) == strlen(a)) || (sizeof(a2) == strlen(a2))) if ((sizeof(m) <= strlen(m) - 2) || (sizeof(m2) <= strlen(m2) - 2) || (sizeof(a) == strlen(a)) || (sizeof(a2) == strlen(a2)))
ast_log(LOG_WARNING, "SIP SDP may be truncated due to undersized buffer!!\n"); ast_log(LOG_WARNING, "SIP SDP may be truncated due to undersized buffer!!\n");
len = strlen(v) + strlen(s) + strlen(o) + strlen(c) + strlen(t) + strlen(m) + strlen(a); len = strlen(v) + strlen(s) + strlen(o) + strlen(c) + strlen(t) + strlen(m) + strlen(a);
if ((p->vrtp) && (p->jointcapability & VIDEO_CODEC_MASK)) /* only if video response is appropriate */ if ((p->vrtp) && (capability & VIDEO_CODEC_MASK)) /* only if video response is appropriate */
len += strlen(m2) + strlen(a2); len += strlen(m2) + strlen(a2);
snprintf(costr, sizeof(costr), "%d", len); snprintf(costr, sizeof(costr), "%d", len);
add_header(resp, "Content-Type", "application/sdp"); add_header(resp, "Content-Type", "application/sdp");
@ -3173,7 +3178,7 @@ static int add_sdp(struct sip_request *resp, struct sip_pvt *p, struct ast_rtp *
add_line(resp, t); add_line(resp, t);
add_line(resp, m); add_line(resp, m);
add_line(resp, a); add_line(resp, a);
if ((p->vrtp) && (p->jointcapability & VIDEO_CODEC_MASK)) { /* only if video response is appropriate */ if ((p->vrtp) && (capability & VIDEO_CODEC_MASK)) { /* only if video response is appropriate */
add_line(resp, m2); add_line(resp, m2);
add_line(resp, a2); add_line(resp, a2);
} }
@ -3205,7 +3210,7 @@ static int transmit_response_with_sdp(struct sip_pvt *p, char *msg, struct sip_r
return -1; return -1;
} }
respprep(&resp, p, msg, req); respprep(&resp, p, msg, req);
add_sdp(&resp, p, NULL, NULL); add_sdp(&resp, p, NULL, NULL, 0);
return send_response(p, &resp, retrans, seqno); return send_response(p, &resp, retrans, seqno);
} }
@ -3272,7 +3277,7 @@ static int determine_firstline_parts( struct sip_request *req ) {
/* transmit_reinvite_with_sdp: Transmit reinvite with SDP :-) ---*/ /* transmit_reinvite_with_sdp: Transmit reinvite with SDP :-) ---*/
/* A re-invite is basically a new INVITE with the same CALL-ID and TAG as the /* A re-invite is basically a new INVITE with the same CALL-ID and TAG as the
INVITE that opened the SIP dialogue */ INVITE that opened the SIP dialogue */
static int transmit_reinvite_with_sdp(struct sip_pvt *p, struct ast_rtp *rtp, struct ast_rtp *vrtp) static int transmit_reinvite_with_sdp(struct sip_pvt *p, struct ast_rtp *rtp, struct ast_rtp *vrtp, int codec)
{ {
struct sip_request req; struct sip_request req;
if (p->canreinvite == REINVITE_UPDATE) if (p->canreinvite == REINVITE_UPDATE)
@ -3281,7 +3286,7 @@ static int transmit_reinvite_with_sdp(struct sip_pvt *p, struct ast_rtp *rtp, st
reqprep(&req, p, "INVITE", 0, 1); reqprep(&req, p, "INVITE", 0, 1);
add_header(&req, "Allow", ALLOWED_METHODS); add_header(&req, "Allow", ALLOWED_METHODS);
add_sdp(&req, p, rtp, vrtp); add_sdp(&req, p, rtp, vrtp, codec);
/* Use this as the basis */ /* Use this as the basis */
copy_request(&p->initreq, &req); copy_request(&p->initreq, &req);
parse(&p->initreq); parse(&p->initreq);
@ -3428,7 +3433,7 @@ static int transmit_invite(struct sip_pvt *p, char *cmd, int sdp, char *auth, ch
} }
add_header(&req, "Allow", ALLOWED_METHODS); add_header(&req, "Allow", ALLOWED_METHODS);
if (sdp) { if (sdp) {
add_sdp(&req, p, NULL, NULL); add_sdp(&req, p, NULL, NULL, 0);
} else { } else {
add_header(&req, "Content-Length", "0"); add_header(&req, "Content-Length", "0");
add_blank_header(&req); add_blank_header(&req);
@ -7725,7 +7730,7 @@ static struct ast_rtp *sip_get_vrtp_peer(struct ast_channel *chan)
return NULL; return NULL;
} }
static int sip_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp) static int sip_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp, int codec)
{ {
struct sip_pvt *p; struct sip_pvt *p;
p = chan->pvt->pvt; p = chan->pvt->pvt;
@ -7739,7 +7744,7 @@ static int sip_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struc
else else
memset(&p->vredirip, 0, sizeof(p->vredirip)); memset(&p->vredirip, 0, sizeof(p->vredirip));
if (!p->gotrefer) { if (!p->gotrefer) {
transmit_reinvite_with_sdp(p, rtp, vrtp); transmit_reinvite_with_sdp(p, rtp, vrtp, codec);
p->outgoing = 1; p->outgoing = 1;
} }
return 0; return 0;

2
channels/chan_skinny.c
Unescape View File

@ -948,7 +948,7 @@ static struct ast_rtp *skinny_get_rtp_peer(struct ast_channel *chan)
return NULL; return NULL;
} }
static int skinny_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp) static int skinny_set_rtp_peer(struct ast_channel *chan, struct ast_rtp *rtp, struct ast_rtp *vrtp, int codecs)
{ {
struct skinny_subchannel *sub; struct skinny_subchannel *sub;
sub = chan->pvt->pvt; sub = chan->pvt->pvt;

2
include/asterisk/rtp.h
Unescape View File

@ -38,7 +38,7 @@ extern "C" {
struct ast_rtp_protocol { struct ast_rtp_protocol {
struct ast_rtp *(*get_rtp_info)(struct ast_channel *chan); /* Get RTP struct, or NULL if unwilling to transfer */ struct ast_rtp *(*get_rtp_info)(struct ast_channel *chan); /* Get RTP struct, or NULL if unwilling to transfer */
struct ast_rtp *(*get_vrtp_info)(struct ast_channel *chan); /* Get RTP struct, or NULL if unwilling to transfer */ struct ast_rtp *(*get_vrtp_info)(struct ast_channel *chan); /* Get RTP struct, or NULL if unwilling to transfer */
int (*set_rtp_peer)(struct ast_channel *chan, struct ast_rtp *peer, struct ast_rtp *vpeer); /* Set RTP peer */ int (*set_rtp_peer)(struct ast_channel *chan, struct ast_rtp *peer, struct ast_rtp *vpeer, int codecs); /* Set RTP peer */
int (*get_codec)(struct ast_channel *chan); int (*get_codec)(struct ast_channel *chan);
char *type; char *type;
struct ast_rtp_protocol *next; struct ast_rtp_protocol *next;

41
rtp.c
Unescape View File

@ -1257,6 +1257,8 @@ int ast_rtp_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, st
void *pvt0, *pvt1; void *pvt0, *pvt1;
int to; int to;
int codec0,codec1, oldcodec0, oldcodec1;
memset(&vt0, 0, sizeof(vt0)); memset(&vt0, 0, sizeof(vt0));
memset(&vt1, 0, sizeof(vt1)); memset(&vt1, 0, sizeof(vt1));
memset(&vac0, 0, sizeof(vac0)); memset(&vac0, 0, sizeof(vac0));
@ -1307,10 +1309,15 @@ int ast_rtp_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, st
ast_mutex_unlock(&c1->lock); ast_mutex_unlock(&c1->lock);
return -2; return -2;
} }
if (pr0->get_codec && pr1->get_codec) { if (pr0->get_codec)
int codec0,codec1;
codec0 = pr0->get_codec(c0); codec0 = pr0->get_codec(c0);
else
codec0 = 0;
if (pr1->get_codec)
codec1 = pr1->get_codec(c1); codec1 = pr1->get_codec(c1);
else
codec1 = 0;
if (pr0->get_codec && pr1->get_codec) {
/* Hey, we can't do reinvite if both parties speak diffrent codecs */ /* Hey, we can't do reinvite if both parties speak diffrent codecs */
if (!(codec0 & codec1)) { if (!(codec0 & codec1)) {
ast_log(LOG_WARNING, "codec0 = %d is not codec1 = %d, cannot native bridge.\n",codec0,codec1); ast_log(LOG_WARNING, "codec0 = %d is not codec1 = %d, cannot native bridge.\n",codec0,codec1);
@ -1319,7 +1326,7 @@ int ast_rtp_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, st
return -2; return -2;
} }
} }
if (pr0->set_rtp_peer(c0, p1, vp1)) if (pr0->set_rtp_peer(c0, p1, vp1, codec1))
ast_log(LOG_WARNING, "Channel '%s' failed to talk to '%s'\n", c0->name, c1->name); ast_log(LOG_WARNING, "Channel '%s' failed to talk to '%s'\n", c0->name, c1->name);
else { else {
/* Store RTP peer */ /* Store RTP peer */
@ -1327,7 +1334,7 @@ int ast_rtp_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, st
if (vp1) if (vp1)
ast_rtp_get_peer(p1, &vac1); ast_rtp_get_peer(p1, &vac1);
} }
if (pr1->set_rtp_peer(c1, p0, vp0)) if (pr1->set_rtp_peer(c1, p0, vp0, codec0))
ast_log(LOG_WARNING, "Channel '%s' failed to talk back to '%s'\n", c1->name, c0->name); ast_log(LOG_WARNING, "Channel '%s' failed to talk back to '%s'\n", c1->name, c0->name);
else { else {
/* Store RTP peer */ /* Store RTP peer */
@ -1340,17 +1347,19 @@ int ast_rtp_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, st
cs[0] = c0; cs[0] = c0;
cs[1] = c1; cs[1] = c1;
cs[2] = NULL; cs[2] = NULL;
oldcodec0 = codec0;
oldcodec1 = codec1;
for (;;) { for (;;) {
if ((c0->pvt->pvt != pvt0) || if ((c0->pvt->pvt != pvt0) ||
(c1->pvt->pvt != pvt1) || (c1->pvt->pvt != pvt1) ||
(c0->masq || c0->masqr || c1->masq || c1->masqr)) { (c0->masq || c0->masqr || c1->masq || c1->masqr)) {
ast_log(LOG_DEBUG, "Oooh, something is weird, backing out\n"); ast_log(LOG_DEBUG, "Oooh, something is weird, backing out\n");
if (c0->pvt->pvt == pvt0) { if (c0->pvt->pvt == pvt0) {
if (pr0->set_rtp_peer(c0, NULL, NULL)) if (pr0->set_rtp_peer(c0, NULL, NULL, 0))
ast_log(LOG_WARNING, "Channel '%s' failed to revert\n", c0->name); ast_log(LOG_WARNING, "Channel '%s' failed to revert\n", c0->name);
} }
if (c1->pvt->pvt == pvt1) { if (c1->pvt->pvt == pvt1) {
if (pr1->set_rtp_peer(c1, NULL, NULL)) if (pr1->set_rtp_peer(c1, NULL, NULL, 0))
ast_log(LOG_WARNING, "Channel '%s' failed to revert back\n", c1->name); ast_log(LOG_WARNING, "Channel '%s' failed to revert back\n", c1->name);
} }
/* Tell it to try again later */ /* Tell it to try again later */
@ -1359,23 +1368,29 @@ int ast_rtp_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, st
to = -1; to = -1;
ast_rtp_get_peer(p1, &t1); ast_rtp_get_peer(p1, &t1);
ast_rtp_get_peer(p0, &t0); ast_rtp_get_peer(p0, &t0);
if (pr0->get_codec)
codec0 = pr0->get_codec(c0);
if (pr1->get_codec)
codec1 = pr1->get_codec(c1);
if (vp1) if (vp1)
ast_rtp_get_peer(vp1, &vt1); ast_rtp_get_peer(vp1, &vt1);
if (vp0) if (vp0)
ast_rtp_get_peer(vp0, &vt0); ast_rtp_get_peer(vp0, &vt0);
if (inaddrcmp(&t1, &ac1) || (vp1 && inaddrcmp(&vt1, &vac1))) { if (inaddrcmp(&t1, &ac1) || (vp1 && inaddrcmp(&vt1, &vac1)) || (codec1 != oldcodec1)) {
ast_log(LOG_DEBUG, "Oooh, '%s' changed end address\n", c1->name); ast_log(LOG_DEBUG, "Oooh, '%s' changed end address (format %d)\n", c1->name, codec1);
if (pr0->set_rtp_peer(c0, t1.sin_addr.s_addr ? p1 : NULL, vt1.sin_addr.s_addr ? vp1 : NULL)) if (pr0->set_rtp_peer(c0, t1.sin_addr.s_addr ? p1 : NULL, vt1.sin_addr.s_addr ? vp1 : NULL, codec1))
ast_log(LOG_WARNING, "Channel '%s' failed to update to '%s'\n", c0->name, c1->name); ast_log(LOG_WARNING, "Channel '%s' failed to update to '%s'\n", c0->name, c1->name);
memcpy(&ac1, &t1, sizeof(ac1)); memcpy(&ac1, &t1, sizeof(ac1));
memcpy(&vac1, &vt1, sizeof(vac1)); memcpy(&vac1, &vt1, sizeof(vac1));
oldcodec1 = codec1;
} }
if (inaddrcmp(&t0, &ac0) || (vp0 && inaddrcmp(&vt0, &vac0))) { if (inaddrcmp(&t0, &ac0) || (vp0 && inaddrcmp(&vt0, &vac0))) {
ast_log(LOG_DEBUG, "Oooh, '%s' changed end address\n", c0->name); ast_log(LOG_DEBUG, "Oooh, '%s' changed end address (format %d)\n", c0->name, codec0);
if (pr1->set_rtp_peer(c1, t0.sin_addr.s_addr ? p0 : NULL, vt0.sin_addr.s_addr ? vp0 : NULL)) if (pr1->set_rtp_peer(c1, t0.sin_addr.s_addr ? p0 : NULL, vt0.sin_addr.s_addr ? vp0 : NULL, codec0))
ast_log(LOG_WARNING, "Channel '%s' failed to update to '%s'\n", c1->name, c0->name); ast_log(LOG_WARNING, "Channel '%s' failed to update to '%s'\n", c1->name, c0->name);
memcpy(&ac0, &t0, sizeof(ac0)); memcpy(&ac0, &t0, sizeof(ac0));
memcpy(&vac0, &vt0, sizeof(vac0)); memcpy(&vac0, &vt0, sizeof(vac0));
oldcodec0 = codec0;
} }
who = ast_waitfor_n(cs, 2, &to); who = ast_waitfor_n(cs, 2, &to);
if (!who) { if (!who) {
@ -1393,11 +1408,11 @@ int ast_rtp_bridge(struct ast_channel *c0, struct ast_channel *c1, int flags, st
*rc = who; *rc = who;
ast_log(LOG_DEBUG, "Oooh, got a %s\n", f ? "digit" : "hangup"); ast_log(LOG_DEBUG, "Oooh, got a %s\n", f ? "digit" : "hangup");
if ((c0->pvt->pvt == pvt0) && (!c0->_softhangup)) { if ((c0->pvt->pvt == pvt0) && (!c0->_softhangup)) {
if (pr0->set_rtp_peer(c0, NULL, NULL)) if (pr0->set_rtp_peer(c0, NULL, NULL, 0))
ast_log(LOG_WARNING, "Channel '%s' failed to revert\n", c0->name); ast_log(LOG_WARNING, "Channel '%s' failed to revert\n", c0->name);
} }
if ((c1->pvt->pvt == pvt1) && (!c1->_softhangup)) { if ((c1->pvt->pvt == pvt1) && (!c1->_softhangup)) {
if (pr1->set_rtp_peer(c1, NULL, NULL)) if (pr1->set_rtp_peer(c1, NULL, NULL, 0))
ast_log(LOG_WARNING, "Channel '%s' failed to revert back\n", c1->name); ast_log(LOG_WARNING, "Channel '%s' failed to revert back\n", c1->name);
} }
/* That's all we needed */ /* That's all we needed */

Write Preview
Loading…
Cancel
Save