Skip to content

Commit

Permalink
change func name
Browse files Browse the repository at this point in the history
  • Loading branch information
ystaticy committed Mar 28, 2024
1 parent f34e4d8 commit dd7a200
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions tikv/kv.go
Original file line number Diff line number Diff line change
Expand Up @@ -425,10 +425,10 @@ func (s *KVStore) CurrentTimestamp(txnScope string) (uint64, error) {
return startTS, nil
}

// CurrentMinTimestamp returns current timestamp across all keyspace groups.
func (s *KVStore) CurrentMinTimestamp() (uint64, error) {
// CurrentMinTimestampInAllTSOGroup returns current timestamp across all keyspace groups.
func (s *KVStore) CurrentMinTimestampInAllTSOGroup() (uint64, error) {
bo := retry.NewBackofferWithVars(context.Background(), transaction.TsoMaxBackoff, nil)
startTS, err := s.getMinTimestampWithRetry(bo)
startTS, err := s.getMinTimestampInAllTSOGroupWithRetry(bo)
if err != nil {
return 0, err
}
Expand Down Expand Up @@ -469,9 +469,9 @@ func (s *KVStore) getTimestampWithRetry(bo *Backoffer, txnScope string) (uint64,
}
}

func (s *KVStore) getMinTimestampWithRetry(bo *Backoffer) (uint64, error) {
func (s *KVStore) getMinTimestampInAllTSOGroupWithRetry(bo *Backoffer) (uint64, error) {
if span := opentracing.SpanFromContext(bo.GetCtx()); span != nil && span.Tracer() != nil {
span1 := span.Tracer().StartSpan("TiKVStore.getMinTimestampWithRetry", opentracing.ChildOf(span.Context()))
span1 := span.Tracer().StartSpan("TiKVStore.getMinTimestampInAllTSOGroupWithRetry", opentracing.ChildOf(span.Context()))
defer span1.Finish()
bo.SetCtx(opentracing.ContextWithSpan(bo.GetCtx(), span1))
}
Expand Down

0 comments on commit dd7a200

Please sign in to comment.