summaryrefslogtreecommitdiff
path: root/edge/cmd
diff options
context:
space:
mode:
authorzc <ce.zheng@daocloud.io>2021-03-22 15:59:15 +0800
committerzc <ce.zheng@daocloud.io>2021-03-22 16:02:48 +0800
commit683212b2e3337804d225ad4c30870d69efad9c2d (patch)
tree3fa70c00b915e614d33bed04d0a575f3334b240c /edge/cmd
parentMerge pull request #2670 from Iceber/fix-downstream-log (diff)
downloadkubeedge-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.go36
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