From 473436a2715f22bb3dda2e8c5246ec4a5472d423 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=BF=9C=E6=96=B9=E5=A4=95=E9=98=B3?= <3979434@qq.com>
Date: Thu, 11 Oct 2018 21:30:08 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9java=20sdk=E4=B8=80=E5=A4=84?=
 =?UTF-8?q?=E7=AC=94=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/com/farsunset/cim/sdk/client/CIMConnectorManager.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java b/cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java
index bfc0234..f0038a7 100644
--- a/cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java
+++ b/cim_for_netty/cim-java-sdk/src/com/farsunset/cim/sdk/client/CIMConnectorManager.java
@@ -129,8 +129,8 @@ class CIMConnectorManager extends SimpleChannelInboundHandler<Object> {
 
 					@Override
 					public void operationComplete(ChannelFuture future) throws Exception {
+						semaphore.release();
 						future.removeListener(this);
-						semaphore.acquire();
 						if(!future.isSuccess() && future.cause() != null) {
 							handleConnectFailure(future.cause(),remoteAddress);
 						}