diff options
| author | Chris Lu <chris.lu@gmail.com> | 2017-01-21 13:58:56 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2017-01-21 13:58:56 -0800 |
| commit | f302c9fda27a955ae676003ab4afe3e44fceca2a (patch) | |
| tree | 2383fb718bd44b739b0f91b2a27f04bd7f1955d1 | |
| parent | 3cb00710252ac004569eeeb73adace5024e9a2cc (diff) | |
| download | seaweedfs-f302c9fda27a955ae676003ab4afe3e44fceca2a.tar.xz seaweedfs-f302c9fda27a955ae676003ab4afe3e44fceca2a.zip | |
always send the leader info on each heartbeat
| -rw-r--r-- | weed/server/master_grpc_server.go | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index 8a9117b1e..e91e904bd 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -66,16 +66,14 @@ func (ms MasterServer) SendHeartbeat(stream pb.Seaweed_SendHeartbeatServer) erro return err } - if !t.IsLeader() { - newLeader, err := t.Leader() - if err == nil { - if err := stream.Send(&pb.HeartbeatResponse{ - Leader: newLeader, - }); err != nil { - return err - } + // tell the volume servers about the leader + newLeader, err := t.Leader() + if err == nil { + if err := stream.Send(&pb.HeartbeatResponse{ + Leader: newLeader, + }); err != nil { + return err } } - } } |
