This is an automated email from the ASF dual-hosted git repository. carryxyh pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
The following commit(s) were added to refs/heads/master by this push: new 32140d4 fixed typo of variable (#2875) 32140d4 is described below commit 32140d44b72c142ecf046a4e6f01eedad32881a8 Author: zhangzhikai <1500303...@stu.cjlu.edu.cn> AuthorDate: Tue Dec 4 10:06:45 2018 +0800 fixed typo of variable (#2875) fixed type of variable --- .../rpc/cluster/support/FailoverClusterInvoker.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/FailoverClusterInvoker.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/FailoverClusterInvoker.java index 25d4704..0ae150f 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/FailoverClusterInvoker.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/FailoverClusterInvoker.java @@ -53,8 +53,8 @@ public class FailoverClusterInvoker<T> extends AbstractClusterInvoker<T> { @Override @SuppressWarnings({"unchecked", "rawtypes"}) public Result doInvoke(Invocation invocation, final List<Invoker<T>> invokers, LoadBalance loadbalance) throws RpcException { - List<Invoker<T>> copyinvokers = invokers; - checkInvokers(copyinvokers, invocation); + List<Invoker<T>> copyInvokers = invokers; + checkInvokers(copyInvokers, invocation); String methodName = RpcUtils.getMethodName(invocation); int len = getUrl().getMethodParameter(methodName, Constants.RETRIES_KEY, Constants.DEFAULT_RETRIES) + 1; if (len <= 0) { @@ -62,18 +62,18 @@ public class FailoverClusterInvoker<T> extends AbstractClusterInvoker<T> { } // retry loop. RpcException le = null; // last exception. - List<Invoker<T>> invoked = new ArrayList<Invoker<T>>(copyinvokers.size()); // invoked invokers. + List<Invoker<T>> invoked = new ArrayList<Invoker<T>>(copyInvokers.size()); // invoked invokers. Set<String> providers = new HashSet<String>(len); for (int i = 0; i < len; i++) { //Reselect before retry to avoid a change of candidate `invokers`. //NOTE: if `invokers` changed, then `invoked` also lose accuracy. if (i > 0) { checkWhetherDestroyed(); - copyinvokers = list(invocation); + copyInvokers = list(invocation); // check again - checkInvokers(copyinvokers, invocation); + checkInvokers(copyInvokers, invocation); } - Invoker<T> invoker = select(loadbalance, invocation, copyinvokers, invoked); + Invoker<T> invoker = select(loadbalance, invocation, copyInvokers, invoked); invoked.add(invoker); RpcContext.getContext().setInvokers((List) invoked); try { @@ -83,7 +83,7 @@ public class FailoverClusterInvoker<T> extends AbstractClusterInvoker<T> { + " in the service " + getInterface().getName() + " was successful by the provider " + invoker.getUrl().getAddress() + ", but there have been failed providers " + providers - + " (" + providers.size() + "/" + copyinvokers.size() + + " (" + providers.size() + "/" + copyInvokers.size() + ") from the registry " + directory.getUrl().getAddress() + " on the consumer " + NetUtils.getLocalHost() + " using the dubbo version " + Version.getVersion() + ". Last error is: " @@ -104,7 +104,7 @@ public class FailoverClusterInvoker<T> extends AbstractClusterInvoker<T> { throw new RpcException(le.getCode(), "Failed to invoke the method " + methodName + " in the service " + getInterface().getName() + ". Tried " + len + " times of the providers " + providers - + " (" + providers.size() + "/" + copyinvokers.size() + + " (" + providers.size() + "/" + copyInvokers.size() + ") from the registry " + directory.getUrl().getAddress() + " on the consumer " + NetUtils.getLocalHost() + " using the dubbo version " + Version.getVersion() + ". Last error is: "