andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fixed indentation

Browse Source
This commit is contained in:
Trustin Lee 2009-02-17 07:17:03 +00:00
parent 5281ef6aa7
commit 4bd06dfdb1
1 changed files with 14 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/main/java/org/jboss/netty/channel/socket/http/HttpTunnelClientSocketChannel.java
View File

@ -189,26 +189,23 @@ class HttpTunnelClientSocketChannel extends AbstractChannel
void reconnect() throws Exception {
if (closed) {
throw new IllegalStateException("channel closed");
}
if (reconnectLock.tryLock()) {
try {
awaitingInitialResponse = true;
throw new IllegalStateException("channel closed");
}
if (reconnectLock.tryLock()) {
try {
awaitingInitialResponse = true;
connectAndSendHeaders(true, remoteAddress);
}
finally {
reconnectLock.unlock();
}
connectAndSendHeaders(true, remoteAddress);
} finally {
reconnectLock.unlock();
}
else {
try {
reconnectLock.lock();
}
finally {
reconnectLock.unlock();
}
} else {
try {
reconnectLock.lock();
} finally {
reconnectLock.unlock();
}
}
}
public void closeSocket() {
@ -258,7 +255,6 @@ class HttpTunnelClientSocketChannel extends AbstractChannel
nextChunkSize = -1;
}
}
}
@Override