diff options
| -rw-r--r-- | filters/f_utils.c | 3 | ||||
| -rw-r--r-- | filters/filter.c | 6 | ||||
| -rw-r--r-- | filters/filter.h | 5 |
3 files changed, 12 insertions, 2 deletions
diff --git a/filters/f_utils.c b/filters/f_utils.c index 8dc185f90e..38b4f1d3f9 100644 --- a/filters/f_utils.c +++ b/filters/f_utils.c @@ -251,8 +251,7 @@ static void fixed_aframe_size_process(struct mp_filter *f) p->out = NULL; p->out_written = 0; } else { - if (mp_pin_out_request_data(f->ppins[0])) - mp_filter_internal_mark_progress(f); + mp_pin_out_request_data_next(f->ppins[0]); } } diff --git a/filters/filter.c b/filters/filter.c index bbd8a4ff5b..60e9bc265e 100644 --- a/filters/filter.c +++ b/filters/filter.c @@ -256,6 +256,12 @@ bool mp_pin_out_request_data(struct mp_pin *p) return mp_pin_out_has_data(p); } +void mp_pin_out_request_data_next(struct mp_pin *p) +{ + if (mp_pin_out_request_data(p)) + update_filter(p->owner, p->conn->manual_connection); +} + struct mp_frame mp_pin_out_read(struct mp_pin *p) { if (!mp_pin_out_request_data(p)) diff --git a/filters/filter.h b/filters/filter.h index 9ba387691a..b618a9c637 100644 --- a/filters/filter.h +++ b/filters/filter.h @@ -47,6 +47,11 @@ bool mp_pin_in_write(struct mp_pin *p, struct mp_frame frame); // buffered in mp_pins goes against this. bool mp_pin_out_request_data(struct mp_pin *p); +// Same as mp_pin_out_request_data(), but call the filter's process() function +// next time even if there is new data. the intention is that the filter reads +// the data in the next iteration, without checking for the data now. +void mp_pin_out_request_data_next(struct mp_pin *p); + // Same as mp_pin_out_request_data(), but does not attempt to procure new frames // if the return value is false. bool mp_pin_out_has_data(struct mp_pin *p); |