From 5e429852ae45a2f185cbeeaf3c300a9c2a71fc02 Mon Sep 17 00:00:00 2001 From: liwei Date: Wed, 19 Oct 2022 19:30:16 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=BE=E5=BC=80rpc=20=E9=99=90=E5=88=B6?= =?UTF-8?q?=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- lego/base/rpcx/service.go | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/lego/base/rpcx/service.go b/lego/base/rpcx/service.go index fc37ba59f..c06cb5b2e 100644 --- a/lego/base/rpcx/service.go +++ b/lego/base/rpcx/service.go @@ -165,10 +165,6 @@ func (this *RPCXService) RpcGo(ctx context.Context, servicePath string, serviceM ///servicePath = worker/[worker_1,worker_2] 表示随机选择[]里面的服务节点执行rpc方法 ///servicePath = worker/![worker_1,worker_2] 表示随机选择非[]里面的服务节点执行rpc方法 func (this *RPCXService) AcrossClusterRpcCall(ctx context.Context, clusterTag string, servicePath string, serviceMethod string, args interface{}, reply interface{}) (err error) { - if clusterTag == this.GetTag() { - err = fmt.Errorf("RPC equal clusterTag:%s ", clusterTag) - return - } return rpcx.AcrossClusterCall(ctx, clusterTag, servicePath, serviceMethod, args, reply) } @@ -180,10 +176,6 @@ func (this *RPCXService) AcrossClusterRpcCall(ctx context.Context, clusterTag st ///servicePath = worker/[worker_1,worker_2] 表示随机选择[]里面的服务节点执行rpc方法 ///servicePath = worker/![worker_1,worker_2] 表示随机选择非[]里面的服务节点执行rpc方法 func (this *RPCXService) AcrossClusterRpcGo(ctx context.Context, clusterTag string, servicePath string, serviceMethod string, args interface{}, reply interface{}) (call *client.Call, err error) { - if clusterTag == this.GetTag() { - err = fmt.Errorf("RPC equal clusterTag:%s ", clusterTag) - return - } return rpcx.AcrossClusterGo(ctx, clusterTag, servicePath, serviceMethod, args, reply, nil) } @@ -195,10 +187,6 @@ func (this *RPCXService) AcrossClusterRpcGo(ctx context.Context, clusterTag stri ///servicePath = worker/[worker_1,worker_2] 表示随机选择[]里面的服务节点执行rpc方法 ///servicePath = worker/![worker_1,worker_2] 表示随机选择非[]里面的服务节点执行rpc方法 func (this *RPCXService) AcrossClusterBroadcast(ctx context.Context, clusterTag string, servicePath string, serviceMethod string, args interface{}, reply interface{}) (err error) { - if clusterTag == this.GetTag() { - err = fmt.Errorf("RPC equal clusterTag:%s ", clusterTag) - return - } return rpcx.AcrossClusterBroadcast(ctx, clusterTag, servicePath, serviceMethod, args, reply) }