diff options
| author | Chris Lu <chris.lu@gmail.com> | 2017-01-18 09:34:27 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2017-01-18 09:34:27 -0800 |
| commit | 5b0f5f456e0cbae8616f5b6beeb12e1d7dcc0caf (patch) | |
| tree | ece2db44e5d4dee382f31cf3e9c5e9f7bb984695 /weed/server/master_grpc_server.go | |
| parent | 59022b6fe00f25ceef8d7a027cbc90bf14f7605e (diff) | |
| download | seaweedfs-5b0f5f456e0cbae8616f5b6beeb12e1d7dcc0caf.tar.xz seaweedfs-5b0f5f456e0cbae8616f5b6beeb12e1d7dcc0caf.zip | |
volume server get notified of leader change
Diffstat (limited to 'weed/server/master_grpc_server.go')
| -rw-r--r-- | weed/server/master_grpc_server.go | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index b5cbd85b7..8a9117b1e 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -65,5 +65,17 @@ 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 + } + } + } + } } |