diff --git a/cluster/dynamicdiscovery.go b/cluster/dynamicdiscovery.go index e797610..7db631a 100644 --- a/cluster/dynamicdiscovery.go +++ b/cluster/dynamicdiscovery.go @@ -60,6 +60,21 @@ func (ds *DynamicDiscoveryMaster) addNodeInfo(nodeInfo *rpc.NodeInfo) { ds.nodeInfo = append(ds.nodeInfo, nodeInfo) } +func (ds *DynamicDiscoveryMaster) removeNodeInfo(nodeId int32) { + if _,ok:= ds.mapNodeInfo[nodeId];ok == false { + return + } + + for i:=0;i 0 { + err = fmt.Errorf("cannot find %s from nodeId %d",serviceMethod,nodeId) + }else { + err = fmt.Errorf("No %s service found in the origin network",serviceMethod) + } } fVal.Call([]reflect.Value{reflect.ValueOf(reply), reflect.ValueOf(err)}) log.SError("Call serviceMethod is error:", err.Error())