diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/ConditionRouter.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/ConditionRouter.java index 9b3e5271b520..a33e1801fd6e 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/ConditionRouter.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/condition/ConditionRouter.java @@ -127,7 +127,7 @@ else if ("!=".equals(separator)) { values.add(content); } // The Value in the KV part, if Value have more than one items. - else if (",".equals(separator)) { // Should be seperateed by ',' + else if (",".equals(separator)) { // Should be separated by ',' if (values == null || values.isEmpty()) { throw new ParseException("Illegal route rule \"" + rule + "\", The error char '" + separator diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/script/ScriptRouterFactory.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/script/ScriptRouterFactory.java index 56976ed731a2..b29f25e23dd1 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/script/ScriptRouterFactory.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/router/script/ScriptRouterFactory.java @@ -25,7 +25,7 @@ *

* Example URLS used by Script Router Factory： *

    - *
  1. script://registyAddress?type=js&rule=xxxx + *
  2. script://registryAddress?type=js&rule=xxxx *
  3. script:///path/to/routerfile.js?type=js&rule=xxxx *
  4. script://D:\path\to\routerfile.js?type=js&rule=xxxx *
  5. script://C:/path/to/routerfile.js?type=js&rule=xxxx diff --git a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/wrapper/MockClusterInvoker.java b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/wrapper/MockClusterInvoker.java index 2fd1af923c89..293d3bda1582 100644 --- a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/wrapper/MockClusterInvoker.java +++ b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/wrapper/MockClusterInvoker.java @@ -143,7 +143,7 @@ private List> selectMockInvoker(Invocation invocation) { List> invokers = null; //TODO generic invoker？ if (invocation instanceof RpcInvocation) { - //Note the implicit contract (although the description is added to the interface declaration, but extensibility is a problem. The practice placed in the attachement needs to be improved) + //Note the implicit contract (although the description is added to the interface declaration, but extensibility is a problem. The practice placed in the attachment needs to be improved) ((RpcInvocation) invocation).setAttachment(Constants.INVOCATION_NEED_MOCK, Boolean.TRUE.toString()); //directory will return a list of normal invokers if Constants.INVOCATION_NEED_MOCK is present in invocation, otherwise, a list of mock invokers will return. try { diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/compiler/support/ClassUtils.java b/dubbo-common/src/main/java/org/apache/dubbo/common/compiler/support/ClassUtils.java index 40c050f79e57..e4db9a8cb5cc 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/common/compiler/support/ClassUtils.java +++ b/dubbo-common/src/main/java/org/apache/dubbo/common/compiler/support/ClassUtils.java @@ -422,8 +422,8 @@ public static String getInitCode(Class type) { public static Map toMap(Map.Entry[] entries) { Map map = new HashMap(); if (entries != null && entries.length > 0) { - for (Map.Entry enrty : entries) { - map.put(enrty.getKey(), enrty.getValue()); + for (Map.Entry entry : entries) { + map.put(entry.getKey(), entry.getValue()); } } return map; diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/io/StreamUtils.java b/dubbo-common/src/main/java/org/apache/dubbo/common/io/StreamUtils.java index 0bb950531fee..2a463c3e0986 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/common/io/StreamUtils.java +++ b/dubbo-common/src/main/java/org/apache/dubbo/common/io/StreamUtils.java @@ -189,7 +189,7 @@ public synchronized void mark(int readlimit) { @Override public synchronized void reset() throws IOException { if (!mInMarked) { - throw new IOException("should mark befor reset!"); + throw new IOException("should mark before reset!"); } mInReset = true; diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/io/UnsafeByteArrayInputStream.java b/dubbo-common/src/main/java/org/apache/dubbo/common/io/UnsafeByteArrayInputStream.java index 16bb0d6c479a..c5b72bdc1992 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/common/io/UnsafeByteArrayInputStream.java +++ b/dubbo-common/src/main/java/org/apache/dubbo/common/io/UnsafeByteArrayInputStream.java @@ -20,7 +20,7 @@ import java.io.InputStream; /** - * UnsafeByteArrayInputStrem. + * UnsafeByteArrayInputStream. */ public class UnsafeByteArrayInputStream extends InputStream { protected byte mData[]; diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/utils/Assert.java b/dubbo-common/src/main/java/org/apache/dubbo/common/utils/Assert.java index 4c6582ed9c67..46b20892f717 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/common/utils/Assert.java +++ b/dubbo-common/src/main/java/org/apache/dubbo/common/utils/Assert.java @@ -28,9 +28,9 @@ public static void notNull(Object obj, String message) { } } - public static void notNull(Object obj, RuntimeException exeception) { + public static void notNull(Object obj, RuntimeException exception) { if (obj == null) { - throw exeception; + throw exception; } } diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/utils/ConfigUtils.java b/dubbo-common/src/main/java/org/apache/dubbo/common/utils/ConfigUtils.java index 436cf8f42eb4..ea5de7313796 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/common/utils/ConfigUtils.java +++ b/dubbo-common/src/main/java/org/apache/dubbo/common/utils/ConfigUtils.java @@ -213,7 +213,7 @@ public static Properties loadProperties(String fileName, boolean allowMultiFile) *
  6. return empty Properties if no file found. *
  7. merge multi properties file if found multi file * - * @throws IllegalStateException not allow multi-file, but multi-file exsit on class path. + * @throws IllegalStateException not allow multi-file, but multi-file exist on class path. */ public static Properties loadProperties(String fileName, boolean allowMultiFile, boolean optional) { Properties properties = new Properties(); diff --git a/dubbo-common/src/main/java/org/apache/dubbo/common/utils/PojoUtils.java b/dubbo-common/src/main/java/org/apache/dubbo/common/utils/PojoUtils.java index d8c00f31ce7b..e9a9c63201a2 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/common/utils/PojoUtils.java +++ b/dubbo-common/src/main/java/org/apache/dubbo/common/utils/PojoUtils.java @@ -175,9 +175,9 @@ private static Object generalize(Object pojo, Map history) { try { Object fieldValue = field.get(pojo); if (history.containsKey(pojo)) { - Object pojoGenerilizedValue = history.get(pojo); - if (pojoGenerilizedValue instanceof Map - && ((Map) pojoGenerilizedValue).containsKey(field.getName())) { + Object pojoGeneralizedValue = history.get(pojo); + if (pojoGeneralizedValue instanceof Map + && ((Map) pojoGeneralizedValue).containsKey(field.getName())) { continue; } } diff --git a/dubbo-compatible/src/main/java/com/alibaba/dubbo/qos/command/CommandContext.java b/dubbo-compatible/src/main/java/com/alibaba/dubbo/qos/command/CommandContext.java index 2b6a4d9da2f4..98f799de2a30 100644 --- a/dubbo-compatible/src/main/java/com/alibaba/dubbo/qos/command/CommandContext.java +++ b/dubbo-compatible/src/main/java/com/alibaba/dubbo/qos/command/CommandContext.java @@ -23,7 +23,7 @@ public class CommandContext extends org.apache.dubbo.qos.command.CommandContext public CommandContext(org.apache.dubbo.qos.command.CommandContext context) { super(context.getCommandName(), context.getArgs(), context.isHttp()); setRemote(context.getRemote()); - setOrginRequest(context.getOrginRequest()); + setOriginRequest(context.getOriginRequest()); } public CommandContext(String commandName) { diff --git a/dubbo-compatible/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/CompatibleServiceAnnotationBeanPostProcessor.java b/dubbo-compatible/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/CompatibleServiceAnnotationBeanPostProcessor.java index 5f4d99035213..7c87087dc9af 100644 --- a/dubbo-compatible/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/CompatibleServiceAnnotationBeanPostProcessor.java +++ b/dubbo-compatible/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/CompatibleServiceAnnotationBeanPostProcessor.java @@ -209,7 +209,7 @@ private BeanNameGenerator resolveBeanNameGenerator(BeanDefinitionRegistry regist * {@link Service} Annotation. * * @param scanner {@link ClassPathBeanDefinitionScanner} - * @param packageToScan pachage to scan + * @param packageToScan package to scan * @param registry {@link BeanDefinitionRegistry} * @return non-null * @since 2.5.8 diff --git a/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ReferenceAnnotationBeanPostProcessor.java b/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ReferenceAnnotationBeanPostProcessor.java index e82239588c57..4d8f0bdd29ef 100644 --- a/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ReferenceAnnotationBeanPostProcessor.java +++ b/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ReferenceAnnotationBeanPostProcessor.java @@ -509,7 +509,7 @@ private T getFieldValue(Object object, String fieldName, Class fieldType) /** * Generate a key based on the annotation. * - * @param annotations annotatoin value + * @param annotations annotation value * @return unique key, never null will be returned. * @since 2.7.0 */ diff --git a/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ServiceAnnotationBeanPostProcessor.java b/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ServiceAnnotationBeanPostProcessor.java index c08cc13e6a79..37fed800348f 100644 --- a/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ServiceAnnotationBeanPostProcessor.java +++ b/dubbo-config/dubbo-config-spring/src/main/java/org/apache/dubbo/config/spring/beans/factory/annotation/ServiceAnnotationBeanPostProcessor.java @@ -208,7 +208,7 @@ private BeanNameGenerator resolveBeanNameGenerator(BeanDefinitionRegistry regist * {@link Service} Annotation. * * @param scanner {@link ClassPathBeanDefinitionScanner} - * @param packageToScan pachage to scan + * @param packageToScan package to scan * @param registry {@link BeanDefinitionRegistry} * @return non-null * @since 2.5.8 diff --git a/dubbo-filter/dubbo-filter-cache/src/main/java/org/apache/dubbo/cache/Cache.java b/dubbo-filter/dubbo-filter-cache/src/main/java/org/apache/dubbo/cache/Cache.java index fb2a329fc15f..bba7aca0ee59 100644 --- a/dubbo-filter/dubbo-filter-cache/src/main/java/org/apache/dubbo/cache/Cache.java +++ b/dubbo-filter/dubbo-filter-cache/src/main/java/org/apache/dubbo/cache/Cache.java @@ -19,7 +19,7 @@ /** * Cache interface to support storing and retrieval of value against a lookup key. It has two operation get and put. *
  8. put-Storing value against a key.
    9. - *
  9. get-Retrival of object.
    10. + *
  10. get-Retrieval of object.
    11. * @see org.apache.dubbo.cache.support.lru.LruCache * @see org.apache.dubbo.cache.support.jcache.JCache * @see org.apache.dubbo.cache.support.expiring.ExpiringCache diff --git a/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/CommandContext.java b/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/CommandContext.java index 0dae56238133..0bd427b654a2 100644 --- a/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/CommandContext.java +++ b/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/CommandContext.java @@ -24,7 +24,7 @@ public class CommandContext { private String[] args; private Channel remote; private boolean isHttp; - private Object orginRequest; + private Object originRequest; public CommandContext(String commandName) { this.commandName = commandName; @@ -68,11 +68,11 @@ public void setHttp(boolean http) { isHttp = http; } - public Object getOrginRequest() { - return orginRequest; + public Object getOriginRequest() { + return originRequest; } - public void setOrginRequest(Object orginRequest) { - this.orginRequest = orginRequest; + public void setOriginRequest(Object originRequest) { + this.originRequest = originRequest; } } diff --git a/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/decoder/TelnetCommandDecoder.java b/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/decoder/TelnetCommandDecoder.java index 8dfd039a1d4a..52e58b50ba05 100644 --- a/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/decoder/TelnetCommandDecoder.java +++ b/dubbo-plugin/dubbo-qos/src/main/java/org/apache/dubbo/qos/command/decoder/TelnetCommandDecoder.java @@ -31,7 +31,7 @@ public static final CommandContext decode(String str) { String[] targetArgs = new String[array.length - 1]; System.arraycopy(array, 1, targetArgs, 0, array.length - 1); commandContext = CommandContextFactory.newInstance( name, targetArgs,false); - commandContext.setOrginRequest(str); + commandContext.setOriginRequest(str); } } diff --git a/dubbo-plugin/dubbo-qos/src/test/java/org/apache/dubbo/qos/command/CommandContextTest.java b/dubbo-plugin/dubbo-qos/src/test/java/org/apache/dubbo/qos/command/CommandContextTest.java index 4cc7416bf47c..5ec78b0b3bc3 100644 --- a/dubbo-plugin/dubbo-qos/src/test/java/org/apache/dubbo/qos/command/CommandContextTest.java +++ b/dubbo-plugin/dubbo-qos/src/test/java/org/apache/dubbo/qos/command/CommandContextTest.java @@ -33,23 +33,23 @@ public class CommandContextTest { public void test() throws Exception { CommandContext context = new CommandContext("test", new String[]{"hello"}, true); Object request = new Object(); - context.setOrginRequest(request); + context.setOriginRequest(request); Channel channel = Mockito.mock(Channel.class); context.setRemote(channel); assertThat(context.getCommandName(), equalTo("test")); assertThat(context.getArgs(), arrayContaining("hello")); - assertThat(context.getOrginRequest(), is(request)); + assertThat(context.getOriginRequest(), is(request)); assertTrue(context.isHttp()); assertThat(context.getRemote(), is(channel)); context = new CommandContext("command"); context.setRemote(channel); - context.setOrginRequest(request); + context.setOriginRequest(request); context.setArgs(new String[]{"world"}); context.setHttp(false); assertThat(context.getCommandName(), equalTo("command")); assertThat(context.getArgs(), arrayContaining("world")); - assertThat(context.getOrginRequest(), is(request)); + assertThat(context.getOriginRequest(), is(request)); assertFalse(context.isHttp()); assertThat(context.getRemote(), is(channel)); } diff --git a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/RegistryDirectory.java b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/RegistryDirectory.java index 051c29e33c1c..ba8706365adf 100644 --- a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/RegistryDirectory.java +++ b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/integration/RegistryDirectory.java @@ -562,7 +562,7 @@ private void destroyUnusedInvokers(Map> oldUrlInvokerMap, Map logger.debug("destroy invoker[" + invoker.getUrl() + "] success. "); } } catch (Exception e) { - logger.warn("destroy invoker[" + invoker.getUrl() + "] faild. " + e.getMessage(), e); + logger.warn("destroy invoker[" + invoker.getUrl() + "] failed. " + e.getMessage(), e); } } } diff --git a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/support/FailbackRegistry.java b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/support/FailbackRegistry.java index 5d2d2f041f84..c7a4bb9bcba7 100644 --- a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/support/FailbackRegistry.java +++ b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/support/FailbackRegistry.java @@ -272,7 +272,7 @@ public void unregister(URL url) { } throw new IllegalStateException("Failed to unregister " + url + " to registry " + getUrl().getAddress() + ", cause: " + t.getMessage(), t); } else { - logger.error("Failed to uregister " + url + ", waiting for retry, cause: " + t.getMessage(), t); + logger.error("Failed to unregister " + url + ", waiting for retry, cause: " + t.getMessage(), t); } // Record a failed registration request to a failed list, retry regularly diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/Response.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/Response.java index c24e5e4d9aca..d1ed88b12512 100644 --- a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/Response.java +++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/Response.java @@ -31,7 +31,7 @@ public class Response { public static final byte OK = 20; /** - * clien side timeout. + * client side timeout. */ public static final byte CLIENT_TIMEOUT = 30; diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/DefaultFuture.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/DefaultFuture.java index 5ec3fbec44f3..f79d99df5049 100644 --- a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/DefaultFuture.java +++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/DefaultFuture.java @@ -265,7 +265,7 @@ private void invokeCallback(ResponseCallback c) { try { callbackCopy.done(res.getResult()); } catch (Exception e) { - logger.error("callback invoke error .reasult:" + res.getResult() + ",url:" + channel.getUrl(), e); + logger.error("callback invoke error .result:" + res.getResult() + ",url:" + channel.getUrl(), e); } } else if (res.getStatus() == Response.CLIENT_TIMEOUT || res.getStatus() == Response.SERVER_TIMEOUT) { try { diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/transport/AbstractServer.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/transport/AbstractServer.java index b3bd60771440..c95183835b9b 100644 --- a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/transport/AbstractServer.java +++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/transport/AbstractServer.java @@ -202,7 +202,7 @@ public void connected(Channel ch) throws RemotingException { public void disconnected(Channel ch) throws RemotingException { Collection channels = getChannels(); if (channels.isEmpty()) { - logger.warn("All clients has discontected from " + ch.getLocalAddress() + ". You can graceful shutdown now."); + logger.warn("All clients has disconnected from " + ch.getLocalAddress() + ". You can graceful shutdown now."); } super.disconnected(ch); } diff --git a/dubbo-remoting/dubbo-remoting-netty/src/main/java/org/apache/dubbo/remoting/transport/netty/NettyBackedChannelBuffer.java b/dubbo-remoting/dubbo-remoting-netty/src/main/java/org/apache/dubbo/remoting/transport/netty/NettyBackedChannelBuffer.java index 2eb73a0db54d..3bd911fedf64 100644 --- a/dubbo-remoting/dubbo-remoting-netty/src/main/java/org/apache/dubbo/remoting/transport/netty/NettyBackedChannelBuffer.java +++ b/dubbo-remoting/dubbo-remoting-netty/src/main/java/org/apache/dubbo/remoting/transport/netty/NettyBackedChannelBuffer.java @@ -261,7 +261,7 @@ public void readBytes(ChannelBuffer dst) { @Override public void readBytes(ChannelBuffer dst, int length) { - // carefule + // careful if (length > dst.writableBytes()) { throw new IndexOutOfBoundsException(); } diff --git a/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyBackedChannelBuffer.java b/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyBackedChannelBuffer.java index 143660a3d931..c6e0c6ddee17 100644 --- a/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyBackedChannelBuffer.java +++ b/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyBackedChannelBuffer.java @@ -261,7 +261,7 @@ public void readBytes(ChannelBuffer dst) { @Override public void readBytes(ChannelBuffer dst, int length) { - // carefule + // careful if (length > dst.writableBytes()) { throw new IndexOutOfBoundsException(); } diff --git a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContext.java b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContext.java index bf166066b6a2..b3bf4152fe68 100644 --- a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContext.java +++ b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContext.java @@ -42,7 +42,7 @@ public interface AsyncContext { void write(Object value); /** - * @return true if the aysnc context is started + * @return true if the async context is started */ boolean isAsyncStarted(); diff --git a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContextImpl.java b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContextImpl.java index 0142f7391534..77cf0bd17b8c 100644 --- a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContextImpl.java +++ b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/AsyncContextImpl.java @@ -26,7 +26,7 @@ public class AsyncContextImpl implements AsyncContext { private static final Logger logger = LoggerFactory.getLogger(AsyncContextImpl.class); private final AtomicBoolean started = new AtomicBoolean(false); - private final AtomicBoolean stoped = new AtomicBoolean(false); + private final AtomicBoolean stopped = new AtomicBoolean(false); private CompletableFuture future; @@ -63,7 +63,7 @@ public boolean isAsyncStarted() { @Override public boolean stop() { - return stoped.compareAndSet(false, true); + return stopped.compareAndSet(false, true); } @Override diff --git a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/tps/DefaultTPSLimiter.java b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/tps/DefaultTPSLimiter.java index 71b579bc75d3..a623e2e6bdf0 100644 --- a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/tps/DefaultTPSLimiter.java +++ b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/tps/DefaultTPSLimiter.java @@ -24,7 +24,7 @@ import java.util.concurrent.ConcurrentMap; /** - * DefaultTPSLimiter is a default implementation for tps filter. It is an in memory based implementation for stroring + * DefaultTPSLimiter is a default implementation for tps filter. It is an in memory based implementation for storing * tps information. It internally use * * @see org.apache.dubbo.rpc.filter.TpsLimitFilter diff --git a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboInvoker.java b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboInvoker.java index 93343c0c26f1..ee2693589979 100644 --- a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboInvoker.java +++ b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/DubboInvoker.java @@ -97,7 +97,7 @@ protected Result doInvoke(final Invocation invocation) throws Throwable { Result result; if (isAsyncFuture) { - // register resultCallback, sometimes we need the asyn result being processed by the filter chain. + // register resultCallback, sometimes we need the async result being processed by the filter chain. result = new AsyncRpcResult(futureAdapter, futureAdapter.getResultFuture(), false); } else { result = new SimpleAsyncRpcResult(futureAdapter, futureAdapter.getResultFuture(), false); diff --git a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java index 2d35af427481..834711515f83 100644 --- a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java +++ b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java @@ -36,7 +36,7 @@ final class ReferenceCountExchangeClient implements ExchangeClient { private final URL url; - private final AtomicInteger refenceCount = new AtomicInteger(0); + private final AtomicInteger referenceCount = new AtomicInteger(0); // private final ExchangeHandler handler; private final ConcurrentMap ghostClientMap; @@ -45,7 +45,7 @@ final class ReferenceCountExchangeClient implements ExchangeClient { public ReferenceCountExchangeClient(ExchangeClient client, ConcurrentMap ghostClientMap) { this.client = client; - refenceCount.incrementAndGet(); + referenceCount.incrementAndGet(); this.url = client.getUrl(); if (ghostClientMap == null) { throw new IllegalStateException("ghostClientMap can not be null, url: " + url); @@ -148,7 +148,7 @@ public void close() { @Override public void close(int timeout) { - if (refenceCount.decrementAndGet() <= 0) { + if (referenceCount.decrementAndGet() <= 0) { if (timeout == 0) { client.close(); } else { @@ -189,6 +189,6 @@ public boolean isClosed() { } public void incrementAndGetCount() { - refenceCount.incrementAndGet(); + referenceCount.incrementAndGet(); } } diff --git a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/telnet/ListTelnetHandler.java b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/telnet/ListTelnetHandler.java index 5a933814de3b..94337623de93 100644 --- a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/telnet/ListTelnetHandler.java +++ b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/telnet/ListTelnetHandler.java @@ -46,7 +46,7 @@ public String telnet(Channel channel, String message) { detail = true; } else { if (service != null && service.length() > 0) { - return "Invaild parameter " + part; + return "Invalid parameter " + part; } service = part; }