diff options
| author | Nikita Korolev <66738864+doc-sheet@users.noreply.github.com> | 2024-03-24 21:20:33 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-03-24 11:20:33 -0700 |
| commit | 2dd2bb3e16eada165a47b54af807a4c44e72f921 (patch) | |
| tree | 256811b22e8bbf82bac23a99c9882c9eb6f32e31 | |
| parent | 1f3742850dcf0fc17545495104bbf86d8875d1e0 (diff) | |
| download | seaweedfs-2dd2bb3e16eada165a47b54af807a4c44e72f921.tar.xz seaweedfs-2dd2bb3e16eada165a47b54af807a4c44e72f921.zip | |
fix filer address parsing (#5415)
| -rw-r--r-- | weed/command/shell.go | 30 |
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) |
