aboutsummaryrefslogtreecommitdiff
path: root/weed/filesys/wfs_filer_client.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-02-27 03:03:19 -0800
committerchrislu <chris.lu@gmail.com>2022-02-27 03:03:19 -0800
commitc3792c8352d72b9dac5e6032e9b0710e032e18d2 (patch)
tree44f87f7fb040217ba3dba8c00db1b6191a60fcc6 /weed/filesys/wfs_filer_client.go
parentaa9eef81e61f29e1801b2e23a6d8db8a4836cb9c (diff)
downloadseaweedfs-c3792c8352d72b9dac5e6032e9b0710e032e18d2.tar.xz
seaweedfs-c3792c8352d72b9dac5e6032e9b0710e032e18d2.zip
remove dead code
Diffstat (limited to 'weed/filesys/wfs_filer_client.go')
-rw-r--r--weed/filesys/wfs_filer_client.go51
1 files changed, 0 insertions, 51 deletions
diff --git a/weed/filesys/wfs_filer_client.go b/weed/filesys/wfs_filer_client.go
deleted file mode 100644
index 4feef867e..000000000
--- a/weed/filesys/wfs_filer_client.go
+++ /dev/null
@@ -1,51 +0,0 @@
-package filesys
-
-import (
- "github.com/chrislusf/seaweedfs/weed/glog"
- "github.com/chrislusf/seaweedfs/weed/util"
- "google.golang.org/grpc"
-
- "github.com/chrislusf/seaweedfs/weed/pb"
- "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
-)
-
-var _ = filer_pb.FilerClient(&WFS{})
-
-func (wfs *WFS) WithFilerClient(streamingMode bool, fn func(filer_pb.SeaweedFilerClient) error) (err error) {
-
- return util.Retry("filer grpc", func() error {
-
- i := wfs.option.filerIndex
- n := len(wfs.option.FilerAddresses)
- for x := 0; x < n; x++ {
-
- filerGrpcAddress := wfs.option.FilerAddresses[i].ToGrpcAddress()
- err = pb.WithGrpcClient(streamingMode, func(grpcConnection *grpc.ClientConn) error {
- client := filer_pb.NewSeaweedFilerClient(grpcConnection)
- return fn(client)
- }, filerGrpcAddress, wfs.option.GrpcDialOption)
-
- if err != nil {
- glog.V(0).Infof("WithFilerClient %d %v: %v", x, filerGrpcAddress, err)
- } else {
- wfs.option.filerIndex = i
- return nil
- }
-
- i++
- if i >= n {
- i = 0
- }
-
- }
- return err
- })
-
-}
-
-func (wfs *WFS) AdjustedUrl(location *filer_pb.Location) string {
- if wfs.option.VolumeServerAccess == "publicUrl" {
- return location.PublicUrl
- }
- return location.Url
-}