aboutsummaryrefslogtreecommitdiff
path: root/weed/command/shell.go
diff options
context:
space:
mode:
authorLei Liu <lei01.liu@horizon.ai>2019-11-12 14:21:43 +0800
committerLei Liu <lei01.liu@horizon.ai>2019-11-12 14:46:10 +0800
commit46755ea1e1e4d79e4c0368aa7fcb17ee8aa812cc (patch)
tree616583cdfdd2803465345fee4ee4cdbcba5f72aa /weed/command/shell.go
parentee90236a972acea8722dccfa1b04926d551fc82d (diff)
downloadseaweedfs-46755ea1e1e4d79e4c0368aa7fcb17ee8aa812cc.tar.xz
seaweedfs-46755ea1e1e4d79e4c0368aa7fcb17ee8aa812cc.zip
fix master maintenance logic
Signed-off-by: Lei Liu <lei01.liu@horizon.ai>
Diffstat (limited to 'weed/command/shell.go')
-rw-r--r--weed/command/shell.go24
1 files changed, 1 insertions, 23 deletions
diff --git a/weed/command/shell.go b/weed/command/shell.go
index 91aa8770a..34b5aef31 100644
--- a/weed/command/shell.go
+++ b/weed/command/shell.go
@@ -2,9 +2,6 @@ package command
import (
"fmt"
- "net/url"
- "strconv"
- "strings"
"github.com/chrislusf/seaweedfs/weed/security"
"github.com/chrislusf/seaweedfs/weed/shell"
@@ -37,7 +34,7 @@ func runShell(command *Command, args []string) bool {
shellOptions.GrpcDialOption = security.LoadClientTLS(viper.Sub("grpc"), "client")
var filerPwdErr error
- shellOptions.FilerHost, shellOptions.FilerPort, shellOptions.Directory, filerPwdErr = parseFilerUrl(*shellInitialFilerUrl)
+ shellOptions.FilerHost, shellOptions.FilerPort, shellOptions.Directory, filerPwdErr = util.ParseFilerUrl(*shellInitialFilerUrl)
if filerPwdErr != nil {
fmt.Printf("failed to parse url filer.url=%s : %v\n", *shellInitialFilerUrl, filerPwdErr)
return false
@@ -48,22 +45,3 @@ func runShell(command *Command, args []string) bool {
return true
}
-
-func parseFilerUrl(entryPath string) (filerServer string, filerPort int64, path string, err error) {
- if !strings.HasPrefix(entryPath, "http://") && !strings.HasPrefix(entryPath, "https://") {
- entryPath = "http://" + entryPath
- }
-
- var u *url.URL
- u, err = url.Parse(entryPath)
- if err != nil {
- return
- }
- filerServer = u.Hostname()
- portString := u.Port()
- if portString != "" {
- filerPort, err = strconv.ParseInt(portString, 10, 32)
- }
- path = u.Path
- return
-}