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

Do not write compressed SPDY frames out-of-band in another thread

Browse Source
This commit is contained in:
Jaen Saul 2012-08-20 21:39:28 +03:00
parent a93ada2031
commit 4e351f7399
1 changed files with 3 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/main/java/org/jboss/netty/handler/codec/spdy/SpdyFrameEncoder.java
View File

@ -159,11 +159,7 @@ public class SpdyFrameEncoder implements ChannelDownstreamHandler {
}
// Writes of compressed data must occur in order
final ChannelBuffer buffer = ChannelBuffers.wrappedBuffer(frame, data);
e.getChannel().getPipeline().execute(new Runnable() {
public void run() {
Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
}
});
Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
}
return;
@ -197,11 +193,7 @@ public class SpdyFrameEncoder implements ChannelDownstreamHandler {
}
// Writes of compressed data must occur in order
final ChannelBuffer buffer = ChannelBuffers.wrappedBuffer(frame, data);
e.getChannel().getPipeline().execute(new Runnable() {
public void run() {
Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
}
});
Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
}
return;
@ -323,11 +315,7 @@ public class SpdyFrameEncoder implements ChannelDownstreamHandler {
}
// Writes of compressed data must occur in order
final ChannelBuffer buffer = ChannelBuffers.wrappedBuffer(frame, data);
e.getChannel().getPipeline().execute(new Runnable() {
public void run() {
Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
}
});
Channels.write(ctx, e.getFuture(), buffer, e.getRemoteAddress());
}
return;