commit 59680d47d3930a1a0db523d9e27a2374a45903a3
author Simone Bordet <simone.bordet@gmail.com> Wed Dec 23 16:19:08 2015 +0100
committer Simone Bordet <simone.bordet@gmail.com> Wed Dec 23 16:19:08 2015 +0100
tree ca367f4a98e429d6b8d242f676810bbb76647e3d
parent 7a33efdf662eb03883cea91c94cfa213b6b4d6c6

484818 - Expose interesting HTTP/2 attributes and operations via JMX.

Exposed number of session stalls.

jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/AbstractFlowControlStrategy.java

diff --git a/jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/AbstractFlowControlStrategy.java b/jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/AbstractFlowControlStrategy.java
index b024132..b290810 100644
--- a/jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/AbstractFlowControlStrategy.java
+++ b/jetty-http2/http2-common/src/main/java/org/eclipse/jetty/http2/AbstractFlowControlStrategy.java
@@ -18,10 +18,13 @@
 
 package org.eclipse.jetty.http2;
 
+import java.util.concurrent.atomic.AtomicLong;
+
 import org.eclipse.jetty.http2.api.Stream;
 import org.eclipse.jetty.http2.frames.WindowUpdateFrame;
 import org.eclipse.jetty.util.annotation.ManagedAttribute;
 import org.eclipse.jetty.util.annotation.ManagedObject;
+import org.eclipse.jetty.util.annotation.ManagedOperation;
 import org.eclipse.jetty.util.log.Log;
 import org.eclipse.jetty.util.log.Logger;
 
@@ -30,6 +33,7 @@
 {
     protected static final Logger LOG = Log.getLogger(FlowControlStrategy.class);
 
+    private final AtomicLong sessionStalls = new AtomicLong();
     private int initialStreamSendWindow;
     private int initialStreamRecvWindow;
 
@@ -172,6 +176,7 @@
     {
         if (LOG.isDebugEnabled())
             LOG.debug("Session stalled {}", session);
+        sessionStalls.incrementAndGet();
     }
 
     protected void onStreamStalled(IStream stream)
@@ -191,4 +196,16 @@
         if (LOG.isDebugEnabled())
             LOG.debug("Stream unstalled {}", stream);
     }
+
+    @ManagedAttribute(value = "The number of times the session flow control has stalled", readonly = true)
+    public long getSessionStallCount()
+    {
+        return sessionStalls.get();
+    }
+
+    @ManagedOperation(value = "Resets the statistics", impact = "ACTION")
+    public void reset()
+    {
+        sessionStalls.set(0);
+    }
 }