diff options
| -rw-r--r-- | weed/operation/grpc_client.go | 11 |
1 files changed, 2 insertions, 9 deletions
diff --git a/weed/operation/grpc_client.go b/weed/operation/grpc_client.go index a02844657..c842ed09f 100644 --- a/weed/operation/grpc_client.go +++ b/weed/operation/grpc_client.go @@ -2,20 +2,13 @@ package operation import ( "fmt" - "strconv" - "strings" - "sync" - "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/pb/master_pb" "github.com/chrislusf/seaweedfs/weed/pb/volume_server_pb" "github.com/chrislusf/seaweedfs/weed/util" "google.golang.org/grpc" -) - -var ( - grpcClients = make(map[string]*grpc.ClientConn) - grpcClientsLock sync.Mutex + "strconv" + "strings" ) func WithVolumeServerClient(volumeServer string, grpcDialOption grpc.DialOption, fn func(volume_server_pb.VolumeServerClient) error) error { |