fix local tso

Signed-off-by: okJiang <[email protected]>
tikv · Dec 11, 2024 · 3e32eb2 · 3e32eb2
1 parent 422251e
commit 3e32eb2
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/oracle/oracles/pd.go b/oracle/oracles/pd.go
@@ -246,11 +246,7 @@ func (f *tsFuture) Wait() (uint64, error) {
 
 func (o *pdOracle) GetTimestampAsync(ctx context.Context, opt *oracle.Option) oracle.Future {
 	var ts pd.TSFuture
-	if opt.TxnScope == oracle.GlobalTxnScope || opt.TxnScope == "" {
-		ts = o.c.GetTSAsync(ctx)
-	} else {
-		ts = o.c.GetLocalTSAsync(ctx, opt.TxnScope)
-	}
+	ts = o.c.GetTSAsync(ctx)
 	return &tsFuture{ts, o, opt.TxnScope}
 }
 
@@ -260,11 +256,7 @@ func (o *pdOracle) getTimestamp(ctx context.Context, txnScope string) (uint64, e
 		physical, logical int64
 		err               error
 	)
-	if txnScope == oracle.GlobalTxnScope || txnScope == "" {
-		physical, logical, err = o.c.GetTS(ctx)
-	} else {
-		physical, logical, err = o.c.GetLocalTS(ctx, txnScope)
-	}
+	physical, logical, err = o.c.GetTS(ctx)
 	if err != nil {
 		return 0, errors.WithStack(err)
 	}