autoflush these channels that use queues

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@13057 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Anthony Minessale 2009-04-16 14:26:50 +00:00
parent bd4356aaac
commit b7775547b3
2 changed files with 7 additions and 4 deletions

View File

@ -623,8 +623,9 @@ static switch_status_t channel_read_frame(switch_core_session_t *session, switch
return SWITCH_STATUS_FALSE;
}
switch_core_timer_next(&tech_pvt->timer);
if (!switch_queue_size(tech_pvt->frame_queue)) {
switch_core_timer_next(&tech_pvt->timer);
}
if (switch_queue_trypop(tech_pvt->frame_queue, &pop) == SWITCH_STATUS_SUCCESS && pop) {
if (tech_pvt->read_frame) {

View File

@ -548,8 +548,10 @@ static switch_status_t channel_read_frame(switch_core_session_t *session, switch
goto end;
}
switch_core_timer_next(&tech_pvt->timer);
if (!switch_queue_size(tech_pvt->frame_queue)) {
switch_core_timer_next(&tech_pvt->timer);
}
if (switch_queue_trypop(tech_pvt->frame_queue, &pop) == SWITCH_STATUS_SUCCESS && pop) {
if (tech_pvt->write_frame) {
switch_frame_free(&tech_pvt->write_frame);