gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

fix entry full url lookup

Browse source
This commit is contained in:
chrislu 2022-06-25 09:22:49 -07:00
parent 9c517d2b35
commit 3ce46c3566
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
weed/wdclient/masterclient.go
View file

@ -44,6 +44,9 @@ func (mc *MasterClient) GetLookupFileIdFunction() LookupFileIdFunctionType {
func (mc *MasterClient) LookupFileIdWithFallback(fileId string) (fullUrls []string, err error) { func (mc *MasterClient) LookupFileIdWithFallback(fileId string) (fullUrls []string, err error) {
fullUrls, err = mc.vidMap.LookupFileId(fileId) fullUrls, err = mc.vidMap.LookupFileId(fileId)
if err == nil {
return
}
err = pb.WithMasterClient(false, mc.currentMaster, mc.grpcDialOption, func(client master_pb.SeaweedClient) error { err = pb.WithMasterClient(false, mc.currentMaster, mc.grpcDialOption, func(client master_pb.SeaweedClient) error {
resp, err := client.LookupVolume(context.Background(), &master_pb.LookupVolumeRequest{ resp, err := client.LookupVolume(context.Background(), &master_pb.LookupVolumeRequest{
VolumeOrFileIds: []string{fileId}, VolumeOrFileIds: []string{fileId},
@ -59,7 +62,7 @@ func (mc *MasterClient) LookupFileIdWithFallback(fileId string) (fullUrls []stri
GrpcPort: int(vidLoc.GrpcPort), GrpcPort: int(vidLoc.GrpcPort),
} }
mc.vidMap.addLocation(uint32(vid), loc) mc.vidMap.addLocation(uint32(vid), loc)
fullUrls = append(fullUrls, loc.Url) fullUrls = append(fullUrls, "http://"+loc.Url+"/"+fileId)
} }
} }