diff options
| author | chrislu <chris.lu@gmail.com> | 2022-06-27 12:40:50 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-06-27 12:40:50 -0700 |
| commit | 4b1f48a399ac8e18154929b942d47e10c60a54d9 (patch) | |
| tree | a93a65a5a00ee3ec6ec4fcb8e88fdcfc42148331 /weed/server/master_grpc_server.go | |
| parent | 4a65159250c0ca7cf0fc203dd300bf402c1016f9 (diff) | |
| parent | dc6b1a52e8a2b34c1e775fe21013e366c6a37ca6 (diff) | |
| download | seaweedfs-4b1f48a399ac8e18154929b942d47e10c60a54d9.tar.xz seaweedfs-4b1f48a399ac8e18154929b942d47e10c60a54d9.zip | |
Merge branch 'master' of https://github.com/chrislusf/seaweedfs
Diffstat (limited to 'weed/server/master_grpc_server.go')
| -rw-r--r-- | weed/server/master_grpc_server.go | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index 4d0fbbc41..4f5455cb1 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -263,8 +263,12 @@ func (ms *MasterServer) KeepConnected(stream master_pb.Seaweed_KeepConnectedServ } ms.deleteClient(clientName) }() - - for _, message := range ms.Topo.ToVolumeLocations() { + for i, message := range ms.Topo.ToVolumeLocations() { + if i == 0 { + if leader, err := ms.Topo.Leader(); err == nil { + message.Leader = string(leader) + } + } if sendErr := stream.Send(&master_pb.KeepConnectedResponse{VolumeLocation: message}); sendErr != nil { return sendErr } |