diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-07-28 03:58:13 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-07-28 03:58:13 -0700 |
| commit | 8afd8d35b3230f6fc286967e8aa9641bd8c1460c (patch) | |
| tree | 8c134e958969a7aec6337c8c7bab120009006941 /weed/server/filer_grpc_server.go | |
| parent | 2c6cf72e73861f3bdefaba28189fa2b15fa26d9e (diff) | |
| download | seaweedfs-8afd8d35b3230f6fc286967e8aa9641bd8c1460c.tar.xz seaweedfs-8afd8d35b3230f6fc286967e8aa9641bd8c1460c.zip | |
master: followers can also lookup and redirect
improve scalability
Diffstat (limited to 'weed/server/filer_grpc_server.go')
| -rw-r--r-- | weed/server/filer_grpc_server.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/server/filer_grpc_server.go b/weed/server/filer_grpc_server.go index 8eea2441e..0b395701d 100644 --- a/weed/server/filer_grpc_server.go +++ b/weed/server/filer_grpc_server.go @@ -95,7 +95,11 @@ func (fs *FilerServer) LookupVolume(ctx context.Context, req *filer_pb.LookupVol return nil, err } var locs []*filer_pb.Location - for _, loc := range fs.filer.MasterClient.GetLocations(uint32(vid)) { + locations, found := fs.filer.MasterClient.GetLocations(uint32(vid)) + if !found { + continue + } + for _, loc := range locations { locs = append(locs, &filer_pb.Location{ Url: loc.Url, PublicUrl: loc.PublicUrl, |