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

[#864] Switch to single decoding mode on the protocol upgrade to prevent races

Browse Source
This commit is contained in:
Norman Maurer 2013-01-18 08:21:09 +01:00
parent f2d84f75d6
commit e8636050ca
4 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
codec-http/src/main/java/io/netty/handler/codec/http/websocketx/WebSocketClientHandshaker00.java
View File

@ -173,6 +173,8 @@ public class WebSocketClientHandshaker00 extends WebSocketClientHandshaker {
headers.set(Names.CONTENT_LENGTH, key3.length);
request.data().writeBytes(key3);
channel.pipeline().get(HttpResponseDecoder.class).setSingleDecode(true);
ChannelFuture future = channel.write(request);
future.addListener(new ChannelFutureListener() {
@Override

2
codec-http/src/main/java/io/netty/handler/codec/http/websocketx/WebSocketClientHandshaker07.java
View File

@ -152,6 +152,8 @@ public class WebSocketClientHandshaker07 extends WebSocketClientHandshaker {
headers.add(customHeaders);
}
channel.pipeline().get(HttpResponseDecoder.class).setSingleDecode(true);
ChannelFuture future = channel.write(request);
future.addListener(new ChannelFutureListener() {
@Override

2
codec-http/src/main/java/io/netty/handler/codec/http/websocketx/WebSocketClientHandshaker08.java
View File

@ -152,6 +152,8 @@ public class WebSocketClientHandshaker08 extends WebSocketClientHandshaker {
headers.add(customHeaders);
}
channel.pipeline().get(HttpResponseDecoder.class).setSingleDecode(true);
ChannelFuture future = channel.write(request);
future.addListener(new ChannelFutureListener() {
@Override

2
codec-http/src/main/java/io/netty/handler/codec/http/websocketx/WebSocketClientHandshaker13.java
View File

@ -152,6 +152,8 @@ public class WebSocketClientHandshaker13 extends WebSocketClientHandshaker {
headers.add(customHeaders);
}
channel.pipeline().get(HttpResponseDecoder.class).setSingleDecode(true);
ChannelFuture future = channel.write(request);
future.addListener(new ChannelFutureListener() {
@Override