aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/wfs_filer_client.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filesys/wfs_filer_client.go')
-rw-r--r--weed/filesys/wfs_filer_client.go15
1 files changed, 3 insertions, 12 deletions
diff --git a/weed/filesys/wfs_filer_client.go b/weed/filesys/wfs_filer_client.go
index 8c30de3c5..096ee555f 100644
--- a/weed/filesys/wfs_filer_client.go
+++ b/weed/filesys/wfs_filer_client.go
@@ -1,9 +1,6 @@
package filesys
import (
- "fmt"
- "strings"
-
"google.golang.org/grpc"
"github.com/chrislusf/seaweedfs/weed/pb"
@@ -27,14 +24,8 @@ func (wfs *WFS) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) error) erro
}
func (wfs *WFS) AdjustedUrl(location *filer_pb.Location) string {
- if !wfs.option.OutsideContainerClusterMode {
- return location.Url
- }
- commaIndex := strings.Index(location.Url, ":")
- if commaIndex < 0 {
- return location.Url
+ if wfs.option.OutsideContainerClusterMode {
+ return location.PublicUrl
}
- filerCommaIndex := strings.Index(wfs.option.FilerGrpcAddress, ":")
- return fmt.Sprintf("%s:%s", wfs.option.FilerGrpcAddress[:filerCommaIndex], location.Url[commaIndex+1:])
-
+ return location.Url
}