aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2017-01-21 13:58:56 -0800
committerChris Lu <chris.lu@gmail.com>2017-01-21 13:58:56 -0800
commitf302c9fda27a955ae676003ab4afe3e44fceca2a (patch)
tree2383fb718bd44b739b0f91b2a27f04bd7f1955d1
parent3cb00710252ac004569eeeb73adace5024e9a2cc (diff)
downloadseaweedfs-f302c9fda27a955ae676003ab4afe3e44fceca2a.tar.xz
seaweedfs-f302c9fda27a955ae676003ab4afe3e44fceca2a.zip
always send the leader info on each heartbeat
-rw-r--r--weed/server/master_grpc_server.go16
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
}
}
-
}
}