From 5c42dcbd3fa42584a2c4f6ae58fc7b7a5d3955a2 Mon Sep 17 00:00:00 2001 From: JmPotato Date: Tue, 25 Feb 2025 14:40:07 +0800 Subject: [PATCH] Rename forwardTSO to forwardToTSOService Signed-off-by: JmPotato --- server/forward.go | 4 ++-- server/grpc_service.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/server/forward.go b/server/forward.go index de3fe024197..de507eedcea 100644 --- a/server/forward.go +++ b/server/forward.go @@ -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) diff --git a/server/grpc_service.go b/server/grpc_service.go index 58c7828f5e2..a311b8aedc3 100644 --- a/server/grpc_service.go +++ b/server/grpc_service.go @@ -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)