kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-03-04 17:51:03 +00:00
Code Issues Projects Releases Wiki Activity

FS-10126: [freeswitch-core] General Video Improvements

Browse Source
This commit is contained in:
Anthony Minessale 2017-04-07 11:48:54 -05:00
parent 879b3b9d0c
commit 3da6bd0108
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/switch_rtp.c
View File

@ -458,6 +458,7 @@ struct switch_rtp {
uint8_t pause_jb; uint8_t pause_jb;
uint16_t last_seq; uint16_t last_seq;
uint16_t last_write_seq; uint16_t last_write_seq;
uint8_t video_delta_mode;
switch_time_t last_read_time; switch_time_t last_read_time;
switch_size_t last_flush_packet_count; switch_size_t last_flush_packet_count;
uint32_t interdigit_delay; uint32_t interdigit_delay;
@ -8017,20 +8018,26 @@ static int rtp_common_write(switch_rtp_t *rtp_session,
if (send) { if (send) {
int delta = 1; int delta = 1;
if (rtp_session->flags[SWITCH_RTP_FLAG_VIDEO] && (*flags & SFF_EXTERNAL) && rtp_session->stats.outbound.packet_count && rtp_session->flags[SWITCH_RTP_FLAG_PASSTHRU] && rtp_session->last_write_seq) { if (rtp_session->flags[SWITCH_RTP_FLAG_VIDEO] && (*flags & SFF_EXTERNAL) &&
int32_t x; rtp_session->stats.outbound.packet_count && rtp_session->flags[SWITCH_RTP_FLAG_PASSTHRU]) {
int32_t y; int32_t x = rtp_session->last_write_seq;
int32_t y = ntohs(send_msg->header.seq);
x = rtp_session->last_write_seq; if (!rtp_session->video_delta_mode) {
y = ntohs(send_msg->header.seq); rtp_session->video_delta_mode = 1;
} else {
if (x > UINT16_MAX / 2 && y < UINT16_MAX / 2) {
x -= (int32_t)UINT16_MAX+1;
}
if (x > UINT16_MAX / 2 && y < UINT16_MAX / 2) { delta = y-x;
x -= (int32_t)UINT16_MAX+1;
} }
delta = y-x; rtp_session->last_write_seq = y;
}
rtp_session->last_write_seq = rtp_session->seq; if (!rtp_session->flags[SWITCH_RTP_FLAG_PASSTHRU]) {
rtp_session->video_delta_mode = 0;
} }
rtp_session->seq += delta; rtp_session->seq += delta;