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

Fixed ClosedChannelException caused by previous 'chunk end mark' fix

Browse Source
This commit is contained in:
Trustin Lee 2009-04-29 01:08:05 +00:00
parent fee1515818
commit d809046987
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/org/jboss/netty/channel/socket/http/HttpTunnelingClientSocketChannel.java
View File

@ -212,18 +212,20 @@ class HttpTunnelingClientSocketChannel extends AbstractChannel
} }
void closeSocket() { void closeSocket() {
// Send the end of chunk. if (setClosed()) {
synchronized (writeLock) { // Send the end of chunk.
ChannelFuture future = channel.write(ChannelBuffers.copiedBuffer( synchronized (writeLock) {
"0" + ChannelFuture future = channel.write(ChannelBuffers.copiedBuffer(
HttpTunnelingClientSocketPipelineSink.LINE_TERMINATOR + "0" +
HttpTunnelingClientSocketPipelineSink.LINE_TERMINATOR, HttpTunnelingClientSocketPipelineSink.LINE_TERMINATOR +
"ASCII")); HttpTunnelingClientSocketPipelineSink.LINE_TERMINATOR,
future.awaitUninterruptibly(); "ASCII"));
future.awaitUninterruptibly();
}
closed = true;
channel.close();
} }
setClosed();
closed = true;
channel.close();
} }
void bindSocket(SocketAddress localAddress) { void bindSocket(SocketAddress localAddress) {