From b06074a559b33b0cabe33fc0f0cc4991c8da7848 Mon Sep 17 00:00:00 2001
From: von gosling <vongosling@apache.org>
Date: Fri, 14 Dec 2018 20:35:21 +0800
Subject: [PATCH] Revert "Release semaphore when timeout"

This reverts commit d4d02b5e017ebf8c7d3405516264645280cf57fa.
---
 .../apache/rocketmq/remoting/netty/NettyRemotingAbstract.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
index 9b026403..8dccebc0 100644
--- a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
+++ b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
@@ -410,8 +410,7 @@ public abstract class NettyRemotingAbstract {
             final SemaphoreReleaseOnlyOnce once = new SemaphoreReleaseOnlyOnce(this.semaphoreAsync);
             long costTime = System.currentTimeMillis() - beginStartTime;
             if (timeoutMillis < costTime) {
-                once.release();
-                throw new RemotingTimeoutException("invokeAsyncImpl call timeout");
+                throw new RemotingTooMuchRequestException("invokeAsyncImpl call timeout");
             }
 
             final ResponseFuture responseFuture = new ResponseFuture(channel, opaque, timeoutMillis - costTime, invokeCallback, once);
-- 
GitLab