From bcace08cf0b708b9851aef1fdeb1289aa6fd5c51 Mon Sep 17 00:00:00 2001 From: boyce Date: Thu, 21 Feb 2019 12:07:47 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=95=B0=E6=8D=AE=E5=BA=93?= =?UTF-8?q?=E6=A8=A1=E5=9D=97=E7=A9=BA=E9=97=B2=E6=97=B6=E5=8D=A0=E6=9C=89?= =?UTF-8?q?=E8=BF=87=E5=A4=9Acpu?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- originnode/node.go | 15 ++++++++------- service/Service.go | 1 - service/servicemanager.go | 1 - sysmodule/DBModule.go | 1 - 4 files changed, 8 insertions(+), 10 deletions(-) diff --git a/originnode/node.go b/originnode/node.go index b8834f6..904813d 100644 --- a/originnode/node.go +++ b/originnode/node.go @@ -23,9 +23,9 @@ type CExitCtl struct { type COriginNode struct { CExitCtl - serviceManager service.IServiceManager - sigs chan os.Signal - debugCheck bool + serviceManager service.IServiceManager + sigs chan os.Signal + debugListenAddress string } func (s *COriginNode) Init() { @@ -38,8 +38,9 @@ func (s *COriginNode) Init() { signal.Notify(s.sigs, syscall.SIGINT, syscall.SIGTERM) } -func (s *COriginNode) OpenDebugCheck() { - s.debugCheck = true +// OpenDebugCheck ("localhost:6060")...http://localhost:6060/ +func (s *COriginNode) OpenDebugCheck(listenAddress string) { + s.debugListenAddress = listenAddress } func (s *COriginNode) SetupService(services ...service.IService) { @@ -71,10 +72,10 @@ func (s *COriginNode) SetupService(services ...service.IService) { } func (s *COriginNode) Start() { - if s.debugCheck == true { + if s.debugListenAddress != "" { go func() { - log.Println(http.ListenAndServe("localhost:6060", nil)) + log.Println(http.ListenAndServe(s.debugListenAddress, nil)) }() } diff --git a/service/Service.go b/service/Service.go index 0d693fc..a41f12a 100644 --- a/service/Service.go +++ b/service/Service.go @@ -305,7 +305,6 @@ func (slf *BaseModule) RunModule(module IModule) error { GetLogger().Printf(LEVER_WARN, "stopping module %s...", fmt.Sprintf("%T", slf)) fmt.Println("stopping module %s...", fmt.Sprintf("%T", slf)) return nil - default: } if module.OnRun() == false { break diff --git a/service/servicemanager.go b/service/servicemanager.go index 2aa4db8..802e44b 100644 --- a/service/servicemanager.go +++ b/service/servicemanager.go @@ -70,7 +70,6 @@ func (slf *CServiceManager) CheckServiceTimeTimeout(exit chan bool, pwaitGroup * case <-exit: fmt.Println("CheckServiceTimeTimeout stopping...") return - default: } for _, s := range slf.localserviceMap { diff --git a/sysmodule/DBModule.go b/sysmodule/DBModule.go index e126fa9..acff520 100644 --- a/sysmodule/DBModule.go +++ b/sysmodule/DBModule.go @@ -360,7 +360,6 @@ func (slf *DBModule) RunExecuteDBCoroutine() { return case fun := <-slf.syncExecuteFun: fun() - default: } }