part 2
This commit is contained in:
parent
b517ddd6d3
commit
b32ceb3c22
|
@ -269,22 +269,22 @@ stfu_frame_t *stfu_n_read_a_frame(stfu_instance_t *i)
|
||||||
{
|
{
|
||||||
uint32_t index;
|
uint32_t index;
|
||||||
stfu_frame_t *rframe = NULL;
|
stfu_frame_t *rframe = NULL;
|
||||||
|
|
||||||
if (((i->out_queue->wr_len == i->out_queue->array_len) || !i->out_queue->array_len)) {
|
if (((i->out_queue->wr_len == i->out_queue->array_len) || !i->out_queue->array_len)) {
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (i->cur_ts == 0) {
|
if (i->cur_ts == 0) {
|
||||||
i->cur_ts = i->out_queue->array[1].ts;
|
i->cur_ts = i->out_queue->array[0].ts;
|
||||||
} else {
|
} else {
|
||||||
i->cur_ts += i->interval;
|
i->cur_ts += i->interval;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
if (stfu_n_find_frame(i->out_queue, i->cur_ts, &rframe, &index) || stfu_n_find_frame(i->in_queue, i->cur_ts, &rframe, &index)) {
|
if (stfu_n_find_frame(i->out_queue, i->cur_ts, &rframe, &index) || stfu_n_find_frame(i->in_queue, i->cur_ts, &rframe, &index)) {
|
||||||
i->last_frame = rframe;
|
i->last_frame = rframe;
|
||||||
i->out_queue->wr_len++;
|
i->out_queue->wr_len++;
|
||||||
i->last_wr_ts = rframe->ts;
|
i->last_wr_ts = rframe->ts;
|
||||||
rframe->was_read = 1;
|
|
||||||
i->miss_count = 0;
|
i->miss_count = 0;
|
||||||
} else {
|
} else {
|
||||||
i->last_wr_ts = i->cur_ts;
|
i->last_wr_ts = i->cur_ts;
|
||||||
|
|
Loading…
Reference in New Issue