diff options
| author | chenwanli <chenwanli@sensetime.com> | 2019-03-04 12:43:43 +0800 |
|---|---|---|
| committer | chenwanli <chenwanli@sensetime.com> | 2019-03-04 12:43:43 +0800 |
| commit | f233bbe9c01c9b721de914543f38dc9fd0e8bf31 (patch) | |
| tree | 2f9fea32074cd1d8d5f83fe82908f77083faf7f1 | |
| parent | 219b651bc3642b74e5ffd824a0fedc904ec9796c (diff) | |
| download | seaweedfs-f233bbe9c01c9b721de914543f38dc9fd0e8bf31.tar.xz seaweedfs-f233bbe9c01c9b721de914543f38dc9fd0e8bf31.zip | |
Fix https://github.com/chrislusf/seaweedfs/issues/825#issuecomment-469097375
| -rw-r--r-- | weed/server/master_grpc_server.go | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index 043a6ff51..4c8ff5700 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -102,12 +102,13 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ // tell the volume servers about the leader newLeader, err := t.Leader() - if err == nil { - if err := stream.Send(&master_pb.HeartbeatResponse{ - Leader: newLeader, - }); err != nil { - return err - } + if err != nil { + return err + } + if err := stream.Send(&master_pb.HeartbeatResponse{ + Leader: newLeader, + }); err != nil { + return err } } } |