Change downsampling for cover equal intervals

eclipse-zenoh · Jan 24, 2024 · 233e4e9 · 233e4e9
1 parent 4017d13
commit 233e4e9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/zenoh/src/net/routing/interceptor/downsampling.rs b/zenoh/src/net/routing/interceptor/downsampling.rs
@@ -45,7 +45,7 @@ impl InterceptorTrait for IngressMsgDownsampler {
                         self.latest_message_timestamp.lock().unwrap();
 
                     if timestamp - *latest_message_timestamp
-                        > std::time::Duration::from_millis(self.conf.threshold_ms)
+                        >= std::time::Duration::from_millis(self.conf.threshold_ms)
                     {
                         *latest_message_timestamp = timestamp;
                         log::trace!("Interceptor: Passed threshold, passing.");