diff options
author | Jan Alexander Steffens (heftig) <jan.steffens@ltnglobal.com> | 2023-10-25 01:32:25 +0300 |
---|---|---|
committer | Jan Alexander Steffens (heftig) <jan.steffens@ltnglobal.com> | 2023-10-25 12:52:40 +0300 |
commit | 17a2448237d752d9b83358697eed16f02299c40e (patch) | |
tree | fa490389c4924b2e335dce48578fca28fe33860c /utils | |
parent | 1740a8e36314a0c8b2458c1eec19127d944669af (diff) |
livesync: Move num_in counting to the src task
This is in preparation for moving more accept/discard logic to the src
task, so we can only count `num_in` here.
Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1369>
Diffstat (limited to 'utils')
-rw-r--r-- | utils/livesync/src/livesync/imp.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/utils/livesync/src/livesync/imp.rs b/utils/livesync/src/livesync/imp.rs index 169d6102a..d198f0a67 100644 --- a/utils/livesync/src/livesync/imp.rs +++ b/utils/livesync/src/livesync/imp.rs @@ -964,7 +964,6 @@ impl LiveSync { state.queue.push_back(Item::Buffer(buffer, lateness)); state.buffer_queued = true; state.in_timestamp = timestamp; - state.num_in += 1; self.cond.notify_all(); Ok(gst::FlowSuccess::Ok) @@ -1132,6 +1131,8 @@ impl LiveSync { match in_buffer { Some((buffer, lateness)) => { + state.num_in += 1; + state.out_buffer = Some(buffer); state.out_timestamp = state.in_timestamp; |