simple retry

Signed-off-by: lhy1024 <[email protected]>
lhy1024 · Jan 22, 2025 · 0f1a524 · 0f1a524
1 parent ae6df14
commit 0f1a524
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/pkg/tso/global_allocator.go b/pkg/tso/global_allocator.go
@@ -140,8 +140,16 @@ func (gta *GlobalTSOAllocator) IsInitialize() bool {
 }
 
 // UpdateTSO is used to update the TSO in memory and the time window in etcd.
-func (gta *GlobalTSOAllocator) UpdateTSO() error {
-	return gta.timestampOracle.UpdateTimestamp()
+func (gta *GlobalTSOAllocator) UpdateTSO() (err error) {
+	for i := 0; i < 3; i++ {
+		err = gta.timestampOracle.UpdateTimestamp()
+		if err == nil {
+			return nil
+		}
+		log.Info("failed to update the global tso", errs.ZapError(err))
+		time.Sleep(50 * time.Millisecond)
+	}
+	return
 }
 
 // SetTSO sets the physical part with given TSO.