提交 ea8d5179 编写于 作者: D dongeforever

Merge develop

Apache RocketMQ Apache RocketMQ
Copyright 2016-2017 The Apache Software Foundation Copyright 2016-2018 The Apache Software Foundation
This product includes software developed at This product includes software developed at
The Apache Software Foundation (http://www.apache.org/). The Apache Software Foundation (http://www.apache.org/).
\ No newline at end of file
...@@ -262,6 +262,7 @@ ...@@ -262,6 +262,7 @@
<exclude>src/main/resources/META-INF/service/*</exclude> <exclude>src/main/resources/META-INF/service/*</exclude>
<exclude>*/target/**</exclude> <exclude>*/target/**</exclude>
<exclude>*/*.iml</exclude> <exclude>*/*.iml</exclude>
<exclude>docs/**</exclude>
</excludes> </excludes>
</configuration> </configuration>
</plugin> </plugin>
......
...@@ -446,7 +446,8 @@ public abstract class NettyRemotingAbstract { ...@@ -446,7 +446,8 @@ public abstract class NettyRemotingAbstract {
final SemaphoreReleaseOnlyOnce once = new SemaphoreReleaseOnlyOnce(this.semaphoreAsync); final SemaphoreReleaseOnlyOnce once = new SemaphoreReleaseOnlyOnce(this.semaphoreAsync);
long costTime = System.currentTimeMillis() - beginStartTime; long costTime = System.currentTimeMillis() - beginStartTime;
if (timeoutMillis < costTime) { if (timeoutMillis < costTime) {
throw new RemotingTooMuchRequestException("invokeAsyncImpl call timeout"); once.release();
throw new RemotingTimeoutException("invokeAsyncImpl call timeout");
} }
final ResponseFuture responseFuture = new ResponseFuture(channel, opaque, timeoutMillis - costTime, invokeCallback, once); final ResponseFuture responseFuture = new ResponseFuture(channel, opaque, timeoutMillis - costTime, invokeCallback, once);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册