diff options
author | Jesse McConnell | 2012-07-11 15:10:00 +0000 |
---|---|---|
committer | Jesse McConnell | 2012-07-11 15:10:00 +0000 |
commit | 0fa17c13b1c004951493e2d3199f75b557c5e480 (patch) | |
tree | fa9f2448df27984d7891b59ddda80d622e1b0577 /jetty-spdy/spdy-core/src/main/java/org/eclipse | |
parent | 96fe2d6c3fc1337d359a9900f176363d8c775b6c (diff) | |
parent | 5aeca2a138faad875a1a68e56676714b6bc480b9 (diff) | |
download | org.eclipse.jetty.project-0fa17c13b1c004951493e2d3199f75b557c5e480.tar.gz org.eclipse.jetty.project-0fa17c13b1c004951493e2d3199f75b557c5e480.tar.xz org.eclipse.jetty.project-0fa17c13b1c004951493e2d3199f75b557c5e480.zip |
Merge branch 'master' into jetty-8
Diffstat (limited to 'jetty-spdy/spdy-core/src/main/java/org/eclipse')
-rw-r--r-- | jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardSession.java | 27 | ||||
-rw-r--r-- | jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java | 2 |
2 files changed, 27 insertions, 2 deletions
diff --git a/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardSession.java b/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardSession.java index 446a9103e9..0ed914d709 100644 --- a/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardSession.java +++ b/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardSession.java @@ -16,9 +16,11 @@ package org.eclipse.jetty.spdy; +import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.InterruptedByTimeoutException; import java.util.ArrayList; +import java.util.Collections; import java.util.HashSet; import java.util.LinkedList; import java.util.List; @@ -66,10 +68,12 @@ import org.eclipse.jetty.spdy.frames.WindowUpdateFrame; import org.eclipse.jetty.spdy.generator.Generator; import org.eclipse.jetty.spdy.parser.Parser; import org.eclipse.jetty.util.Atomics; +import org.eclipse.jetty.util.component.AggregateLifeCycle; +import org.eclipse.jetty.util.component.Dumpable; import org.eclipse.jetty.util.log.Log; import org.eclipse.jetty.util.log.Logger; -public class StandardSession implements ISession, Parser.Listener, Handler<StandardSession.FrameBytes> +public class StandardSession implements ISession, Parser.Listener, Handler<StandardSession.FrameBytes>, Dumpable { private static final Logger logger = Log.getLogger(Session.class); private static final ThreadLocal<Integer> handlerInvocations = new ThreadLocal<Integer>() @@ -1092,6 +1096,27 @@ public class StandardSession implements ISession, Parser.Listener, Handler<Stand flowControlStrategy.setWindowSize(this, initialWindowSize); } + public String toString() + { + return String.format("%s@%x{v%d,queuSize=%d,windowSize=%d,streams=%d}", getClass().getSimpleName(), hashCode(), version, queue.size(), getWindowSize(), streams.size()); + } + + + @Override + public String dump() + { + return AggregateLifeCycle.dump(this); + } + + @Override + public void dump(Appendable out, String indent) throws IOException + { + AggregateLifeCycle.dumpObject(out,this); + AggregateLifeCycle.dump(out,indent,Collections.singletonList(controller),streams.values()); + } + + + public interface FrameBytes extends Comparable<FrameBytes> { public IStream getStream(); diff --git a/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java b/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java index d173140968..a99536fa1f 100644 --- a/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java +++ b/jetty-spdy/spdy-core/src/main/java/org/eclipse/jetty/spdy/StandardStream.java @@ -440,7 +440,7 @@ public class StandardStream implements IStream @Override public String toString() { - return String.format("stream=%d v%d %s", getId(), session.getVersion(), closeState); + return String.format("stream=%d v%d windowSize=%db reset=%s %s %s", getId(), session.getVersion(), getWindowSize(), isReset(), openState, closeState); } private boolean canSend() |