aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorNikita Korolev <66738864+doc-sheet@users.noreply.github.com>2024-03-24 21:20:33 +0300
committerGitHub <noreply@github.com>2024-03-24 11:20:33 -0700
commit2dd2bb3e16eada165a47b54af807a4c44e72f921 (patch)
tree256811b22e8bbf82bac23a99c9882c9eb6f32e31
parent1f3742850dcf0fc17545495104bbf86d8875d1e0 (diff)
downloadseaweedfs-2dd2bb3e16eada165a47b54af807a4c44e72f921.tar.xz
seaweedfs-2dd2bb3e16eada165a47b54af807a4c44e72f921.zip
fix filer address parsing (#5415)
-rw-r--r--weed/command/shell.go30
1 files changed, 17 insertions, 13 deletions
diff --git a/weed/command/shell.go b/weed/command/shell.go
index f562f624e..f78ba89fc 100644
--- a/weed/command/shell.go
+++ b/weed/command/shell.go
@@ -19,7 +19,7 @@ func init() {
cmdShell.Run = runShell // break init cycle
shellOptions.Masters = cmdShell.Flag.String("master", "", "comma-separated master servers, e.g. localhost:9333")
shellOptions.FilerGroup = cmdShell.Flag.String("filerGroup", "", "filerGroup for the filers")
- shellInitialFiler = cmdShell.Flag.String("filer", "", "filer host and port, e.g. localhost:8888")
+ shellInitialFiler = cmdShell.Flag.String("filer", "", "filer host and port for initial connection, e.g. localhost:8888")
shellCluster = cmdShell.Flag.String("cluster", "", "cluster defined in shell.toml")
}
@@ -30,32 +30,36 @@ var cmdShell = &Command{
Generate shell.toml via "weed scaffold -config=shell"
- `,
+`,
}
func runShell(command *Command, args []string) bool {
util.LoadConfiguration("security", false)
shellOptions.GrpcDialOption = security.LoadClientTLS(util.GetViper(), "grpc.client")
+ shellOptions.Directory = "/"
+
+ util.LoadConfiguration("shell", false)
+ viper := util.GetViper()
+ cluster := viper.GetString("cluster.default")
+ if *shellCluster != "" {
+ cluster = *shellCluster
+ }
if *shellOptions.Masters == "" {
- util.LoadConfiguration("shell", false)
- v := util.GetViper()
- cluster := v.GetString("cluster.default")
- if *shellCluster != "" {
- cluster = *shellCluster
- }
if cluster == "" {
*shellOptions.Masters = "localhost:9333"
} else {
- *shellOptions.Masters = v.GetString("cluster." + cluster + ".master")
- *shellInitialFiler = v.GetString("cluster." + cluster + ".filer")
- fmt.Printf("master: %s filer: %s\n", *shellOptions.Masters, *shellInitialFiler)
+ *shellOptions.Masters = viper.GetString("cluster." + cluster + ".master")
}
}
- shellOptions.FilerAddress = pb.ServerAddress(*shellInitialFiler)
- shellOptions.Directory = "/"
+ filerAddress := *shellInitialFiler
+ if filerAddress == "" && cluster != "" {
+ filerAddress = viper.GetString("cluster." + cluster + ".filer")
+ }
+ shellOptions.FilerAddress = pb.ServerAddress(filerAddress)
+ fmt.Printf("master: %s filer: %s\n", *shellOptions.Masters, shellOptions.FilerAddress)
shell.RunShell(shellOptions)