diff --git a/go/cmd/topo2topo/topo2topo.go b/go/cmd/topo2topo/topo2topo.go index df2cef54862..157960548b8 100644 --- a/go/cmd/topo2topo/topo2topo.go +++ b/go/cmd/topo2topo/topo2topo.go @@ -77,6 +77,7 @@ func main() { logutil.RegisterFlags(fs) servenv.ParseFlags("topo2topo") + servenv.Init() fromTS, err := topo.OpenServer(fromImplementation, fromServerAddress, fromRoot) if err != nil { diff --git a/go/cmd/vtaclcheck/vtaclcheck.go b/go/cmd/vtaclcheck/vtaclcheck.go index 74e9261e67b..8b916a8cc0c 100644 --- a/go/cmd/vtaclcheck/vtaclcheck.go +++ b/go/cmd/vtaclcheck/vtaclcheck.go @@ -47,6 +47,7 @@ func main() { defer logutil.Flush() servenv.ParseFlags("vtaclcheck") + servenv.Init() err := run() if err != nil { diff --git a/go/cmd/vtbench/vtbench.go b/go/cmd/vtbench/vtbench.go index 13c024fdd8e..19044aae4ed 100644 --- a/go/cmd/vtbench/vtbench.go +++ b/go/cmd/vtbench/vtbench.go @@ -121,6 +121,7 @@ func main() { }) servenv.ParseFlags("vtbench") + servenv.Init() defer exit.Recover() diff --git a/go/cmd/vtexplain/vtexplain.go b/go/cmd/vtexplain/vtexplain.go index 721bc98358a..b173a7566c0 100644 --- a/go/cmd/vtexplain/vtexplain.go +++ b/go/cmd/vtexplain/vtexplain.go @@ -104,6 +104,7 @@ func main() { defer logutil.Flush() servenv.ParseFlags("vtexplain") + servenv.Init() err := parseAndRun() if err != nil { fmt.Printf("ERROR: %s\n", err) diff --git a/go/cmd/vtorc/main.go b/go/cmd/vtorc/main.go index f3591505c45..c80f0573948 100644 --- a/go/cmd/vtorc/main.go +++ b/go/cmd/vtorc/main.go @@ -104,6 +104,7 @@ func main() { fs.StringVar(&configFile, "config", "", "config file name") }) servenv.ParseFlags("vtorc") + servenv.Init() config.UpdateConfigValuesFromFlags() log.Info("starting vtorc") diff --git a/go/cmd/vttestserver/main.go b/go/cmd/vttestserver/main.go index 3727a668f77..f5f9c6bf41c 100644 --- a/go/cmd/vttestserver/main.go +++ b/go/cmd/vttestserver/main.go @@ -268,6 +268,7 @@ func parseFlags() (env vttest.Environment, err error) { func main() { cluster, err := runCluster() + servenv.Init() if err != nil { log.Fatal(err) } diff --git a/go/cmd/zkctld/zkctld.go b/go/cmd/zkctld/zkctld.go index 1e512382ab4..dac1866f60f 100644 --- a/go/cmd/zkctld/zkctld.go +++ b/go/cmd/zkctld/zkctld.go @@ -57,6 +57,7 @@ func main() { defer logutil.Flush() servenv.ParseFlags("zkctld") + servenv.Init() zkConfig := zkctl.MakeZkConfigFromString(zkCfg, uint32(myID)) zkd := zkctl.NewZkd(zkConfig)