Add FlowControlHandler

Author: DaveCTurner

modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/Netty4HttpServerTransport.java

@@ -429,6 +429,7 @@ protected Result beginEncode(HttpResponse httpResponse, String acceptEncoding) t
             if (ResourceLeakDetector.isEnabled()) {
                 ch.pipeline().addLast(new Netty4LeakDetectionHandler());
             }
+            ch.pipeline().addLast(new FlowControlHandler());
             ch.pipeline()
                 .addLast(
                     "pipelining",

server/src/main/java/org/elasticsearch/rest/RestController.java

@@ -855,6 +855,11 @@ public boolean detailedErrorsEnabled() {
         public void sendResponse(RestResponse response) {
             delegate.sendResponse(response);
         }
+
+        @Override
+        public String toString() {
+            return delegate.toString();
+        }
     }
 
     private static final class MeteringRestChannelDecorator extends DelegatingRestChannel {
@@ -942,6 +947,11 @@ public void sendResponse(RestResponse response) {
         private static long rawRelativeTimeInMillis() {
             return TimeValue.nsecToMSec(System.nanoTime());
         }
+
+        @Override
+        public String toString() {
+            return "ResourceHandlingHttpChannel[" + super.toString() + "]";
+        }
     }
 
     private static class ResponseLengthRecorder extends AtomicReference<HttpRouteStatsTracker> implements Releasable {