Skip to content

Commit

Permalink
Rename forwardTSO to forwardToTSOService
Browse files Browse the repository at this point in the history
Signed-off-by: JmPotato <[email protected]>
  • Loading branch information
JmPotato committed Feb 25, 2025
1 parent 6c725cb commit 5c42dcb
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions server/forward.go
Original file line number Diff line number Diff line change
Expand Up @@ -39,8 +39,8 @@ import (
"github.com/tikv/pd/server/cluster"
)

// forwardTSO forward the TSO requests to the TSO service.
func (s *GrpcServer) forwardTSO(stream pdpb.PD_TsoServer) error {
// forwardToTSOService forward the TSO requests to the TSO service.
func (s *GrpcServer) forwardToTSOService(stream pdpb.PD_TsoServer) error {
var (
server = &tsoServer{stream: stream}
forwarder = newTSOForwarder(server)
Expand Down
2 changes: 1 addition & 1 deletion server/grpc_service.go
Original file line number Diff line number Diff line change
Expand Up @@ -487,7 +487,7 @@ func (s *GrpcServer) Tso(stream pdpb.PD_TsoServer) error {
defer done()
}
if s.IsServiceIndependent(constant.TSOServiceName) {
return s.forwardTSO(stream)
return s.forwardToTSOService(stream)
}

tsDeadlineCh := make(chan *tsoutil.TSDeadline, 1)
Expand Down

0 comments on commit 5c42dcb

Please sign in to comment.