mirror of
https://github.com/signalwire/freeswitch.git
synced 2025-03-03 17:30:37 +00:00
FS-8130 fix minor regression
This commit is contained in:
parent
75b01a306e
commit
b5e486fd5c
@ -4856,6 +4856,7 @@ static switch_size_t do_flush(switch_rtp_t *rtp_session, int force, switch_size_
|
|||||||
int was_blocking = 0;
|
int was_blocking = 0;
|
||||||
switch_size_t bytes;
|
switch_size_t bytes;
|
||||||
uint32_t flushed = 0;
|
uint32_t flushed = 0;
|
||||||
|
switch_size_t bytes_out = 0;
|
||||||
|
|
||||||
if (!switch_rtp_ready(rtp_session)) {
|
if (!switch_rtp_ready(rtp_session)) {
|
||||||
return 0;
|
return 0;
|
||||||
@ -4878,16 +4879,18 @@ static switch_size_t do_flush(switch_rtp_t *rtp_session, int force, switch_size_
|
|||||||
|
|
||||||
if (rtp_session->jb && !rtp_session->pause_jb && jb_valid(rtp_session)) {
|
if (rtp_session->jb && !rtp_session->pause_jb && jb_valid(rtp_session)) {
|
||||||
//switch_jb_reset(rtp_session->jb);
|
//switch_jb_reset(rtp_session->jb);
|
||||||
return bytes_in;
|
bytes_out = bytes_in;
|
||||||
|
goto end;
|
||||||
}
|
}
|
||||||
|
|
||||||
//if (rtp_session->vb) {
|
|
||||||
// switch_jb_reset(rtp_session->vb);
|
|
||||||
//}
|
|
||||||
|
|
||||||
if (rtp_session->vbw) {
|
if (rtp_session->vbw) {
|
||||||
switch_jb_reset(rtp_session->vbw);
|
switch_jb_reset(rtp_session->vbw);
|
||||||
//return bytes_in;
|
}
|
||||||
|
|
||||||
|
if (rtp_session->vb) {
|
||||||
|
//switch_jb_reset(rtp_session->vb);
|
||||||
|
bytes_out = bytes_in;
|
||||||
|
goto end;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (rtp_session->flags[SWITCH_RTP_FLAG_DEBUG_RTP_READ]) {
|
if (rtp_session->flags[SWITCH_RTP_FLAG_DEBUG_RTP_READ]) {
|
||||||
@ -4943,9 +4946,11 @@ static switch_size_t do_flush(switch_rtp_t *rtp_session, int force, switch_size_
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
end:
|
||||||
|
|
||||||
READ_DEC(rtp_session);
|
READ_DEC(rtp_session);
|
||||||
|
|
||||||
return 0;
|
return bytes_out;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int check_recv_payload(switch_rtp_t *rtp_session)
|
static int check_recv_payload(switch_rtp_t *rtp_session)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user