From 4e351f7399ffe737682b67d888bcbadfe0a868fa Mon Sep 17 00:00:00 2001
From: Jaen Saul <jaen@saul.ee>
Date: Mon, 20 Aug 2012 21:39:28 +0300
Subject: [PATCH] Do not write compressed SPDY frames out-of-band in another
 thread

---
 .../handler/codec/spdy/SpdyFrameEncoder.java   | 18 +++---------------
 1 file changed, 3 insertions(+), 15 deletions(-)

diff --git a/src/main/java/org/jboss/netty/handler/codec/spdy/SpdyFrameEncoder.java b/src/main/java/org/jboss/netty/handler/codec/spdy/SpdyFrameEncoder.java
index d8bdd9b62c..e6ed2ff325 100644
--- a/src/main/java/org/jboss/netty/handler/codec/spdy/SpdyFrameEncoder.java
+++ b/src/main/java/org/jboss/netty/handler/codec/spdy/SpdyFrameEncoder.java
@@ -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;