diff options
| author | zhengxinwei <zhengxinwei@huawei.com> | 2023-11-14 09:27:54 +0800 |
|---|---|---|
| committer | zhengxinwei <zhengxinwei@huawei.com> | 2023-11-14 09:27:54 +0800 |
| commit | 6636b2a3e1c32ebb7ccd37c0aa2c58717b13c2e9 (patch) | |
| tree | eeb68cb4d6a39fb67d14d5f2c70c35baa048fbc9 /edge | |
| parent | Merge pull request #5146 from Shelley-BaoYue/bump-go1.20 (diff) | |
| download | kubeedge-6636b2a3e1c32ebb7ccd37c0aa2c58717b13c2e9.tar.gz | |
Refactor the code for skip environment check
Signed-off-by: zhengxinwei <zhengxinwei@huawei.com>
Diffstat (limited to 'edge')
| -rw-r--r-- | edge/cmd/edgecore/app/server.go | 19 |
1 files changed, 8 insertions, 11 deletions
diff --git a/edge/cmd/edgecore/app/server.go b/edge/cmd/edgecore/app/server.go index e3ad3429e..8cd11902a 100644 --- a/edge/cmd/edgecore/app/server.go +++ b/edge/cmd/edgecore/app/server.go @@ -101,17 +101,11 @@ offering HTTP client capabilities to components of cloud to reach HTTP servers r // To help debugging, immediately log version klog.Infof("Version: %+v", version.Get()) - // Check the running environment by default - checkEnv := os.Getenv("CHECK_EDGECORE_ENVIRONMENT") // Force skip check if enable metaserver - if config.Modules.MetaManager.MetaServer.Enable { - checkEnv = "false" - } - if checkEnv != "false" { - // Check running environment before run edge core - if err := environmentCheck(); err != nil { - klog.Exit(fmt.Errorf("failed to check the running environment: %v", err)) - } + skipCheck := os.Getenv("CHECK_EDGECORE_ENVIRONMENT") == "false" || config.Modules.MetaManager.MetaServer.Enable + // Check running environment before run edge core + if err := environmentCheck(skipCheck); err != nil { + klog.Exit(fmt.Errorf("failed to check the running environment: %v", err)) } // Get edge node local ip only when the customInterfaceName has been set. @@ -167,7 +161,10 @@ func cleanupToken(config v1alpha2.EdgeCoreConfig, file string) error { // environmentCheck check the environment before edgecore start // if Check failed, return errors -func environmentCheck() error { +func environmentCheck(skipCheck bool) error { + if skipCheck { + return nil + } processes, err := ps.Processes() if err != nil { return err |
