diff --git a/utils/livesync/src/livesync/imp.rs b/utils/livesync/src/livesync/imp.rs
index cb1eced6..76924a17 100644
--- a/utils/livesync/src/livesync/imp.rs
+++ b/utils/livesync/src/livesync/imp.rs
@@ -968,7 +968,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)
@@ -1136,6 +1135,8 @@ impl LiveSync {
 
         match in_buffer {
             Some((buffer, lateness)) => {
+                state.num_in += 1;
+
                 state.out_buffer = Some(buffer);
                 state.out_timestamp = state.in_timestamp;