aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-03-06 14:25:44 -0800
committerChris Lu <chris.lu@gmail.com>2021-03-06 14:26:27 -0800
commit9d402ebe9f4913899ff14f904944a376dbe99439 (patch)
tree94ff4eb33d2c2bacb518595e56c6d637f8445953
parente9eddfb8a2bf05fd5770825d54de655914942d4f (diff)
downloadseaweedfs-9d402ebe9f4913899ff14f904944a376dbe99439.tar.xz
seaweedfs-9d402ebe9f4913899ff14f904944a376dbe99439.zip
refactoring
-rw-r--r--weed/pb/grpc_client_server.go8
1 files changed, 6 insertions, 2 deletions
diff --git a/weed/pb/grpc_client_server.go b/weed/pb/grpc_client_server.go
index c7a47a91c..9efcd9bdc 100644
--- a/weed/pb/grpc_client_server.go
+++ b/weed/pb/grpc_client_server.go
@@ -109,15 +109,19 @@ func WithCachedGrpcClient(fn func(*grpc.ClientConn) error, address string, opts
}
func ParseServerToGrpcAddress(server string) (serverGrpcAddress string, err error) {
+ return ParseServerAddress(server, 10000)
+}
+
+func ParseServerAddress(server string, deltaPort int) (newServerAddress string, err error) {
host, port, parseErr := hostAndPort(server)
if parseErr != nil {
return "", fmt.Errorf("server port parse error: %v", parseErr)
}
- grpcPort := int(port) + 10000
+ newPort := int(port) + deltaPort
- return fmt.Sprintf("%s:%d", host, grpcPort), nil
+ return fmt.Sprintf("%s:%d", host, newPort), nil
}
func hostAndPort(address string) (host string, port uint64, err error) {