diff options
| author | zc <ce.zheng@daocloud.io> | 2021-03-22 15:59:15 +0800 |
|---|---|---|
| committer | zc <ce.zheng@daocloud.io> | 2021-03-22 16:02:48 +0800 |
| commit | 683212b2e3337804d225ad4c30870d69efad9c2d (patch) | |
| tree | 3fa70c00b915e614d33bed04d0a575f3334b240c /edge/cmd | |
| parent | Merge pull request #2670 from Iceber/fix-downstream-log (diff) | |
| download | kubeedge-683212b2e3337804d225ad4c30870d69efad9c2d.tar.gz | |
optimize code
Signed-off-by: zc <ce.zheng@daocloud.io>
Diffstat (limited to 'edge/cmd')
| -rw-r--r-- | edge/cmd/edgecore/app/server.go | 36 |
1 files changed, 11 insertions, 25 deletions
diff --git a/edge/cmd/edgecore/app/server.go b/edge/cmd/edgecore/app/server.go index f4369185c..4a263fc8d 100644 --- a/edge/cmd/edgecore/app/server.go +++ b/edge/cmd/edgecore/app/server.go @@ -119,37 +119,23 @@ offering HTTP client capabilities to components of cloud to reach HTTP servers r return cmd } -// findProcess find a running process by name -func findProcess(name string) (bool, error) { - processes, err := ps.Processes() - if err != nil { - return false, err - } - - for _, process := range processes { - if process.Executable() == name { - return true, nil - } - } - - return false, nil -} - // environmentCheck check the environment before edgecore start // if Check failed, return errors func environmentCheck() error { - // if kubelet is running, return error - if find, err := findProcess("kubelet"); err != nil { + processes, err := ps.Processes() + if err != nil { return err - } else if find { - return errors.New("Kubelet should not running on edge node when running edgecore") } - // if kube-proxy is running, return error - if find, err := findProcess("kube-proxy"); err != nil { - return err - } else if find { - return errors.New("Kube-proxy should not running on edge node when running edgecore") + for _, process := range processes { + // if kubelet is running, return error + if process.Executable() == "kubelet" { + return errors.New("kubelet should not running on edge node when running edgecore") + } + // if kube-proxy is running, return error + if process.Executable() == "kube-proxy" { + return errors.New("kube-proxy should not running on edge node when running edgecore") + } } return nil |
