mcs: solve forward stream error

Signed-off-by: lhy1024 <[email protected]>
lhy1024 · Nov 6, 2023 · 07f806d · 07f806d
1 parent 689fcbe
commit 07f806d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/server/grpc_service.go b/server/grpc_service.go
@@ -2632,7 +2632,10 @@ func (s *GrpcServer) getGlobalTSOFromTSOServer(ctx context.Context) (pdpb.Timest
 		if err != nil {
 			return pdpb.Timestamp{}, err
 		}
-		forwardStream.Send(request)
+		err := forwardStream.Send(request)
+		if err != nil {
+			return pdpb.Timestamp{}, err
+		}
 		ts, err = forwardStream.Recv()
 		if err != nil {
 			if strings.Contains(err.Error(), errs.NotLeaderErr) {