mirror of
https://github.com/duanhf2012/origin.git
synced 2026-02-04 06:54:45 +08:00
整理代码
This commit is contained in:
@@ -496,12 +496,10 @@ func (slf *CCluster) AddLocalService(iservice service.IService) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func GetNodeName(nodeid int) string {
|
func GetNodeName(nodeid int) string {
|
||||||
//
|
|
||||||
return _self.cfg.GetNodeNameByNodeId(nodeid)
|
return _self.cfg.GetNodeNameByNodeId(nodeid)
|
||||||
}
|
}
|
||||||
|
|
||||||
func DynamicCall(address string, serviceMethod string, args interface{}, reply interface{}) error {
|
func DynamicCall(address string, serviceMethod string, args interface{}, reply interface{}) error {
|
||||||
//conn, err := rpc.DialHTTP("tcp", "127.0.0.1:8095")
|
|
||||||
rpcClient, err := rpc.Dial("tcp", address)
|
rpcClient, err := rpc.Dial("tcp", address)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
Reference in New Issue
Block a user