From ab2a5f4168fc08cc8762d4bbbe3db89dc1e571c6 Mon Sep 17 00:00:00 2001 From: John Rushford Date: Thu, 5 Nov 2020 20:23:27 +0000 Subject: [PATCH] t3c should use the --dir option when calling atstccfg in order to set the ATS configuration directory for config files that have a relative or not 'Path'. Also, this re-orders the rpm package check to occur before any config files are request from traffic ops. --- traffic_ops_ort/t3c/config/config.go | 23 ++++++++++++++-------- traffic_ops_ort/t3c/t3c.go | 14 ++++++------- traffic_ops_ort/t3c/torequest/torequest.go | 1 + 3 files changed, 22 insertions(+), 16 deletions(-) diff --git a/traffic_ops_ort/t3c/config/config.go b/traffic_ops_ort/t3c/config/config.go index 642c9d1576..b17ef08269 100644 --- a/traffic_ops_ort/t3c/config/config.go +++ b/traffic_ops_ort/t3c/config/config.go @@ -33,6 +33,7 @@ import ( ) var TSHome string = "/opt/trafficserver" +var TSConfigDir string = "/opt/trafficserver/etc/trafficserver" const ( StatusDir = "/opt/ort/status" @@ -248,25 +249,31 @@ func GetCfg() (Cfg, error) { if *toPassPtr == "" { toPass = os.Getenv("TO_PASS") } + // set TSHome + var tsHome = "" if *tsHomePtr != "" { - TSHome = *tsHomePtr - fmt.Printf("\nset TSHome from command line: '%s'\n\n", TSHome) + tsHome = *tsHomePtr + fmt.Printf("set TSHome from command line: '%s'\n\n", TSHome) } - if *tsHomePtr == "" { - tsHome := os.Getenv("TS_HOME") // check for the environment variable. + if *tsHomePtr == "" { // evironment or rpm check. + tsHome = os.Getenv("TS_HOME") // check for the environment variable. if tsHome != "" { - fmt.Printf("\nset TSHome from TS_HOME environment variable '%s'\n\n", TSHome) + fmt.Printf("set TSHome from TS_HOME environment variable '%s'\n", TSHome) } else { // finally check using the config file listing from the rpm package. tsHome = GetTSPackageHome() if tsHome != "" { - TSHome = tsHome - fmt.Printf("\nset TSHome from the RPM config file list '%s'\n\n", TSHome) + fmt.Printf("set TSHome from the RPM config file list '%s'\n", tsHome) } else { - fmt.Printf("\nno override for TSHome was found, using the configured default: '%s'\n\n", TSHome) + fmt.Printf("no override for TSHome was found, using the configured default: '%s'\n", TSHome) } } } + if tsHome != "" { + TSHome = tsHome + TSConfigDir = tsHome + "/etc/trafficserver" + fmt.Printf("TSHome: %s, TSConfigDir: %s\n", TSHome, TSConfigDir) + } usageStr := "basic usage: t3c --traffic-ops-url=myurl --traffic-ops-user=myuser --traffic-ops-password=mypass --cache-host-name=my-cache" if strings.TrimSpace(toURL) == "" { diff --git a/traffic_ops_ort/t3c/t3c.go b/traffic_ops_ort/t3c/t3c.go index 5dd84846b8..6df1a6df54 100644 --- a/traffic_ops_ort/t3c/t3c.go +++ b/traffic_ops_ort/t3c/t3c.go @@ -113,14 +113,6 @@ func main() { } } - log.Debugf("Preparing to fetch the config files for %s, cfg.RunMode: %s, syncdsUpdate: %s\n", cfg.CacheHostName, cfg.RunMode, syncdsUpdate) - - err = trops.GetConfigFileList() - if err != nil { - log.Errorf("Unable to continue: %s\n", err) - os.Exit(ConfigFilesError) - } - if cfg.RunMode == config.Revalidate { log.Infoln("======== Revalidating, no package processing needed ========") } else { @@ -139,6 +131,12 @@ func main() { } } + log.Debugf("Preparing to fetch the config files for %s, cfg.RunMode: %s, syncdsUpdate: %s\n", cfg.CacheHostName, cfg.RunMode, syncdsUpdate) + err = trops.GetConfigFileList() + if err != nil { + log.Errorf("Unable to continue: %s\n", err) + os.Exit(ConfigFilesError) + } syncdsUpdate, err = trops.ProcessConfigFiles() if err != nil { log.Errorf("Error while processing config files: %s\n", err.Error()) diff --git a/traffic_ops_ort/t3c/torequest/torequest.go b/traffic_ops_ort/t3c/torequest/torequest.go index b413142768..305be622bc 100644 --- a/traffic_ops_ort/t3c/torequest/torequest.go +++ b/traffic_ops_ort/t3c/torequest/torequest.go @@ -212,6 +212,7 @@ func (r *TrafficOpsReq) atsTcExecCommand(cmdstr string, queueState int, revalSta } args := []string{ + "--dir=" + config.TSConfigDir, "--traffic-ops-timeout-milliseconds=" + strconv.FormatInt(int64(r.Cfg.TOTimeoutMS), 10), "--traffic-ops-disable-proxy=" + strconv.FormatBool(r.Cfg.ReverseProxyDisable), "--traffic-ops-user=" + r.Cfg.TOUser,