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

Merge "Frame deferral: Re-queue deferred frames one-at-a-time." into 13

Browse Source
changes/41/4541/1
Joshua Colp 9 years ago committed by Gerrit Code Review
parent 662a4741e2 17b0b91afa
commit bddc60df73
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File

15
main/channel.c
Unescape View File

@ -1069,16 +1069,15 @@ void ast_channel_start_defer_frames(struct ast_channel *chan, int defer_hangups)
void ast_channel_stop_defer_frames(struct ast_channel *chan)
{
struct ast_frame *f;
ast_clear_flag(ast_channel_flags(chan), AST_FLAG_DEFER_FRAMES);
/* Move the deferred frames onto the channel read queue, ahead of other queued frames */
ast_queue_frame_head(chan, AST_LIST_FIRST(ast_channel_deferred_readq(chan)));
/* ast_frfree will mosey down the list and free them all */
if (!AST_LIST_EMPTY(ast_channel_deferred_readq(chan))) {
ast_frfree(AST_LIST_FIRST(ast_channel_deferred_readq(chan)));
while ((f = AST_LIST_REMOVE_HEAD(ast_channel_deferred_readq(chan), frame_list))) {
ast_queue_frame_head(chan, f);
ast_frfree(f);
}
/* Reset the list to be empty */
AST_LIST_HEAD_INIT_NOLOCK(ast_channel_deferred_readq(chan));
}
static int __ast_queue_frame(struct ast_channel *chan, struct ast_frame *fin, int head, struct ast_frame *after)
@ -3903,10 +3902,10 @@ static struct ast_frame *__ast_read(struct ast_channel *chan, int dropaudio)
struct ast_frame *dup;
dup = ast_frdup(f);
AST_LIST_INSERT_TAIL(ast_channel_deferred_readq(chan), dup, frame_list);
AST_LIST_INSERT_HEAD(ast_channel_deferred_readq(chan), dup, frame_list);
}
} else {
AST_LIST_INSERT_TAIL(ast_channel_deferred_readq(chan), f, frame_list);
AST_LIST_INSERT_HEAD(ast_channel_deferred_readq(chan), f, frame_list);
AST_LIST_REMOVE_CURRENT(frame_list);
}
}

Write Preview
Loading…
Cancel
Save