retronetworking
/
freeswitch
13
0
Fork 0
Code Pull Requests Releases Activity

only find exact ts not a range

This commit is contained in:
Anthony Minessale 2015-06-08 13:13:50 -05:00
parent ca2f66217d
commit 96b450817a
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/switch_stfu.c
View File

@ -770,7 +770,7 @@ static int stfu_n_find_any_frame(stfu_instance_t *in, stfu_queue_t *queue, stfu_
}
static int stfu_n_find_frame(stfu_instance_t *in, stfu_queue_t *queue, uint32_t min_ts, uint32_t max_ts, stfu_frame_t **r_frame)
static int stfu_n_find_frame(stfu_instance_t *in, stfu_queue_t *queue, uint32_t ts, stfu_frame_t **r_frame)
{
uint32_t i = 0;
stfu_frame_t *frame = NULL;
@ -782,7 +782,7 @@ static int stfu_n_find_frame(stfu_instance_t *in, stfu_queue_t *queue, uint32_t
for(i = 0; i < queue->array_len; i++) {
frame = &queue->array[i];
if (frame->ts == max_ts || (frame->ts > min_ts && frame->ts < max_ts)) {
if (frame->ts == ts) {
if (r_frame) {
*r_frame = frame;
queue->last_index = i;
@ -856,21 +856,16 @@ stfu_frame_t *stfu_n_read_a_frame(stfu_instance_t *i)
i->cur_seq++;
}
found = stfu_n_find_frame(i, i->out_queue, i->last_wr_ts, i->cur_ts, &rframe);
found = stfu_n_find_frame(i, i->out_queue, i->cur_ts, &rframe);
if (!found) {
found = stfu_n_find_frame(i, i->in_queue, i->last_wr_ts, i->cur_ts, &rframe);
found = stfu_n_find_frame(i, i->in_queue, i->cur_ts, &rframe);
if (!found) {
found = stfu_n_find_frame(i, i->old_queue, i->last_wr_ts, i->cur_ts, &rframe);
found = stfu_n_find_frame(i, i->old_queue, i->cur_ts, &rframe);
}
}
if (found) {
i->cur_ts = rframe->ts;
i->cur_seq = rframe->seq;
}
if (i->sync_out) {
if (!found) {
if ((found = stfu_n_find_any_frame(i, i->out_queue, &rframe, 1))) {