Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-04 06:54:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

新增服务安装方式

Browse Source
This commit is contained in:
boyce
2019-06-05 11:36:47 +08:00
parent f39550329a
commit f4b17aebdb
2 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
cluster/cluster.go
View File

@@ -360,6 +360,9 @@ func (slf *CCluster) Go(bCast bool, NodeServiceMethod string, args interface{},
for _, nodeid := range nodeidList { for _, nodeid := range nodeidList {
if nodeid == GetNodeId() { if nodeid == GetNodeId() {
iService := service.InstanceServiceMgr().FindService(serviceName) iService := service.InstanceServiceMgr().FindService(serviceName)
if iService == nil {
return fmt.Errorf("CCluster.Go(%s) cannot find service %s", NodeServiceMethod, serviceName)
}
if iService.IsInit() == false { if iService.IsInit() == false {
service.GetLogger().Printf(sysmodule.LEVER_WARN, "CCluster.Call(%s): NodeId %d is not init.", NodeServiceMethod, nodeid) service.GetLogger().Printf(sysmodule.LEVER_WARN, "CCluster.Call(%s): NodeId %d is not init.", NodeServiceMethod, nodeid)
return fmt.Errorf("CCluster.Call(%s): NodeId %d is not init.", NodeServiceMethod, nodeid) return fmt.Errorf("CCluster.Call(%s): NodeId %d is not init.", NodeServiceMethod, nodeid)

9
originnode/node.go
View File

@@ -31,7 +31,16 @@ type COriginNode struct {
debugListenAddress string debugListenAddress string
} }
var initservicelist []service.IService
func InitService(iservice service.IService) {
initservicelist = append(initservicelist, iservice)
}
func (s *COriginNode) Init() { func (s *COriginNode) Init() {
s.SetupService(initservicelist...)
//初始化全局模块 //初始化全局模块
logger := service.InstanceServiceMgr().FindService("syslog").(service.ILogger) logger := service.InstanceServiceMgr().FindService("syslog").(service.ILogger)
ret := service.InstanceServiceMgr().Init(logger, s.exitChan, s.waitGroup) ret := service.InstanceServiceMgr().Init(logger, s.exitChan, s.waitGroup)