diff options
Diffstat (limited to 'jetty-spdy/spdy-client/src/main/java/org/eclipse/jetty/spdy/client/SPDYConnection.java')
-rw-r--r-- | jetty-spdy/spdy-client/src/main/java/org/eclipse/jetty/spdy/client/SPDYConnection.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/jetty-spdy/spdy-client/src/main/java/org/eclipse/jetty/spdy/client/SPDYConnection.java b/jetty-spdy/spdy-client/src/main/java/org/eclipse/jetty/spdy/client/SPDYConnection.java index 33ed4c66c4..b057b8a923 100644 --- a/jetty-spdy/spdy-client/src/main/java/org/eclipse/jetty/spdy/client/SPDYConnection.java +++ b/jetty-spdy/spdy-client/src/main/java/org/eclipse/jetty/spdy/client/SPDYConnection.java @@ -44,20 +44,21 @@ public class SPDYConnection extends AbstractConnection implements Controller, Id private volatile ISession session; private volatile boolean idle = false; - - public SPDYConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, Executor executor) + public SPDYConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, Executor executor, + boolean executeOnFillable) { - this(endPoint, bufferPool, parser, executor, 8192); + this(endPoint, bufferPool, parser, executor, executeOnFillable, 8192); } - public SPDYConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, Executor executor, int bufferSize) + public SPDYConnection(EndPoint endPoint, ByteBufferPool bufferPool, Parser parser, Executor executor, + boolean executeOnFillable, int bufferSize) { // Since SPDY is multiplexed, onFillable() must never block // while calling application code. In fact, onFillable() // always dispatches to a new thread when calling application // code, so here we can safely pass false as last parameter, // and avoid to dispatch to onFillable(). - super(endPoint, executor, !EXECUTE_ONFILLABLE); + super(endPoint, executor, executeOnFillable); this.bufferPool = bufferPool; this.parser = parser; onIdle(true); |