Update analytic_engine/src/instance/serial_executor.rs

MichaelLeeHZ · ShiKaiWi · web-flow · commit e5cb6d9a1767 · 2023-05-12T15:29:05.000+08:00
Co-authored-by: WEI Xikai &lt;ShiKaiWi@users.noreply.github.com&gt;
diff --git a/analytic_engine/src/instance/serial_executor.rs b/analytic_engine/src/instance/serial_executor.rs
@@ -53,9 +53,7 @@ impl ScheduleSync {
 
     #[inline]
     pub fn reset_retry_flush_count(&self) {
-        if self.retry_flush_count.load(Ordering::Relaxed) > 0 {
-            self.retry_flush_count.store(0, Ordering::Relaxed);
-        }
+        self.retry_flush_count.store(0, Ordering::Relaxed);
     }
 }
 

Original file line number	Diff line number	Diff line change
`@@ -53,9 +53,7 @@ impl ScheduleSync {`
`53`	`53`
`54`	`54`	`#[inline]`
`55`	`55`	`pub fn reset_retry_flush_count(&self) {`
`56`		`- if self.retry_flush_count.load(Ordering::Relaxed) > 0 {`
`57`		`- self.retry_flush_count.store(0, Ordering::Relaxed);`
`58`		`- }`
	`56`	`+ self.retry_flush_count.store(0, Ordering::Relaxed);`
`59`	`57`	`}`
`60`	`58`	`}`
`61`	`59`