aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-08-14 05:03:45 -0700
committerChris Lu <chris.lu@gmail.com>2021-08-14 05:03:45 -0700
commit8126ab4b5d7204ffcba364e14e857c498e4afe55 (patch)
treea5148cddd1653ba1c25f35284dc895d060d27386
parent0db251799457849ff9d9e4839cb3efb438c93e14 (diff)
downloadseaweedfs-8126ab4b5d7204ffcba364e14e857c498e4afe55.tar.xz
seaweedfs-8126ab4b5d7204ffcba364e14e857c498e4afe55.zip
rename
-rw-r--r--weed/server/master_grpc_server.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go
index 166432c28..afd479b21 100644
--- a/weed/server/master_grpc_server.go
+++ b/weed/server/master_grpc_server.go
@@ -176,9 +176,9 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
// And clients gets the up-to-date list of volume locations
func (ms *MasterServer) KeepConnected(stream master_pb.Seaweed_KeepConnectedServer) error {
- req, err := stream.Recv()
- if err != nil {
- return err
+ req, recvErr := stream.Recv()
+ if recvErr != nil {
+ return recvErr
}
if !ms.Topo.IsLeader() {
@@ -195,8 +195,8 @@ func (ms *MasterServer) KeepConnected(stream master_pb.Seaweed_KeepConnectedServ
defer ms.deleteClient(clientName)
for _, message := range ms.Topo.ToVolumeLocations() {
- if err := stream.Send(message); err != nil {
- return err
+ if sendErr := stream.Send(message); sendErr != nil {
+ return sendErr
}
}