summaryrefslogtreecommitdiff
path: root/edge
diff options
context:
space:
mode:
authorzhengxinwei <zhengxinwei@huawei.com>2023-11-14 09:27:54 +0800
committerzhengxinwei <zhengxinwei@huawei.com>2023-11-14 09:27:54 +0800
commit6636b2a3e1c32ebb7ccd37c0aa2c58717b13c2e9 (patch)
treeeeb68cb4d6a39fb67d14d5f2c70c35baa048fbc9 /edge
parentMerge pull request #5146 from Shelley-BaoYue/bump-go1.20 (diff)
downloadkubeedge-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.go19
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