Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/utils
diff options
context:
space:
mode:
authorJan Alexander Steffens (heftig) <jan.steffens@ltnglobal.com>2023-10-25 01:32:25 +0300
committerJan Alexander Steffens (heftig) <jan.steffens@ltnglobal.com>2023-10-25 12:52:40 +0300
commit17a2448237d752d9b83358697eed16f02299c40e (patch)
treefa490389c4924b2e335dce48578fca28fe33860c /utils
parent1740a8e36314a0c8b2458c1eec19127d944669af (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.rs3
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;