get the number of running connections

GET /_stats/httpd/connections
rcouch · Sep 25, 2013 · e394ea3 · e394ea3
1 parent 1c1df4d
commit e394ea3
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 2 deletions.
diff --git a/apps/couch_httpd/src/couch_httpd_protocol.erl b/apps/couch_httpd/src/couch_httpd_protocol.erl
@@ -148,7 +148,7 @@ after_response(Body, Req) ->
     case Req:should_close() of
         true ->
             mochiweb_socket:close(Socket),
-            ok;
+            exit(normal);
         false ->
             Req:cleanup(),
             erlang:garbage_collect(),
@@ -169,4 +169,4 @@ mochiweb_socket(#hstate{transport=Transport, socket=Socket}) ->
 
 terminate(#hstate{transport=Transport, socket=Socket}) ->
     Transport:close(Socket),
-    ok.
+    exit(normal).
diff --git a/apps/couch_httpd/src/couch_httpd_stats_handlers.erl b/apps/couch_httpd/src/couch_httpd_stats_handlers.erl
@@ -56,6 +56,18 @@ handle_stats_req(#httpd{method='GET',
                         path_parts=[_, <<"vm">>, <<"dets">>]}=Req) ->
     flush(Req),
     send_vm_json(Req, couch_stats_vm:get_dets_info());
+handle_stats_req(#httpd{method='GET',
+                        path_parts=[_, <<"httpd">>, <<"connections">>]}=Req) ->
+    flush(Req),
+
+    NbConns = lists:foldl(fun(Ref, Sum) ->
+                    N = ranch_server:count_connections(Ref),
+                    Sum + N
+            end, 0, couch_httpd:get_bindings()),
+
+    send_json(Req, {[{<<"httpd">>, {[{<<"connections">>, NbConns}]}}]});
+
+
 handle_stats_req(#httpd{method='GET', path_parts=[_, Mod, Key]}=Req) ->
     flush(Req),
     Stats = couch_stats_aggregator:get_json({list_to_atom(binary_to_list(Mod)),
@@ -70,6 +82,7 @@ handle_stats_req(Req) ->
 
 
 
+
 send_vm_json(Req, Value) ->
     couch_httpd:initialize_jsonp(Req),
     Headers = [