From f4b17aebdbe901d2ef4bbecc240ddd72a0188106 Mon Sep 17 00:00:00 2001
From: boyce <6549168@qq.com>
Date: Wed, 5 Jun 2019 11:36:47 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=9C=8D=E5=8A=A1=E5=AE=89?=
 =?UTF-8?q?=E8=A3=85=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cluster/cluster.go | 3 +++
 originnode/node.go | 9 +++++++++
 2 files changed, 12 insertions(+)

diff --git a/cluster/cluster.go b/cluster/cluster.go
index 0852c36..c9e1603 100644
--- a/cluster/cluster.go
+++ b/cluster/cluster.go
@@ -360,6 +360,9 @@ func (slf *CCluster) Go(bCast bool, NodeServiceMethod string, args interface{},
 	for _, nodeid := range nodeidList {
 		if nodeid == GetNodeId() {
 			iService := service.InstanceServiceMgr().FindService(serviceName)
+			if iService == nil {
+				return fmt.Errorf("CCluster.Go(%s) cannot find  service %s", NodeServiceMethod, serviceName)
+			}
 			if iService.IsInit() == false {
 				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)
diff --git a/originnode/node.go b/originnode/node.go
index 7c41226..f17960a 100644
--- a/originnode/node.go
+++ b/originnode/node.go
@@ -31,7 +31,16 @@ type COriginNode struct {
 	debugListenAddress string
 }
 
+var initservicelist []service.IService
+
+func InitService(iservice service.IService) {
+	initservicelist = append(initservicelist, iservice)
+}
+
 func (s *COriginNode) Init() {
+
+	s.SetupService(initservicelist...)
+
 	//初始化全局模块
 	logger := service.InstanceServiceMgr().FindService("syslog").(service.ILogger)
 	ret := service.InstanceServiceMgr().Init(logger, s.exitChan, s.waitGroup)