natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

去掉不必要的Wrapper 

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@45 1a56cb94-b969-4eaa-88fa-be21384802f2
This commit is contained in:
ding.lid 2011-10-25 09:40:33 +00:00
parent 472e91a4e9
commit 33a7e60f9b
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dubbo-rpc/src/main/java/com/alibaba/dubbo/rpc/dubbo/LazyConnectExchangeClient.java
View File

@ -29,7 +29,6 @@ import com.alibaba.dubbo.remoting.exchange.ExchangeClient;
import com.alibaba.dubbo.remoting.exchange.ExchangeHandler;
import com.alibaba.dubbo.remoting.exchange.Exchangers;
import com.alibaba.dubbo.remoting.exchange.ResponseFuture;
import com.alibaba.dubbo.remoting.exchange.support.header.HeaderExchangeClient;
import com.alibaba.dubbo.rpc.RpcConstants;
/**
@ -43,7 +42,7 @@ final class LazyConnectExchangeClient implements ExchangeClient {
private final URL url;
private final ExchangeHandler requestHandler;
private volatile HeaderExchangeClient client;
private volatile ExchangeClient client;
private final Lock connectLock = new ReentrantLock();
//lazy connect 如果没有初始化时的连接状态
private final boolean initialState ;
@ -65,8 +64,7 @@ final class LazyConnectExchangeClient implements ExchangeClient {
try {
if (client != null)
return;
this.client = new HeaderExchangeClient(Exchangers.connect(url, requestHandler));
// if (client == )
this.client = Exchangers.connect(url, requestHandler);
} finally {
connectLock.unlock();
}