You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by rn...@apache.org on 2016/08/22 11:19:33 UTC
[07/50] ibrowse commit: updated refs/heads/upstream to b28542d
Added basic test for show_dest_status
Project: http://git-wip-us.apache.org/repos/asf/couchdb-ibrowse/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-ibrowse/commit/5b8993e1
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-ibrowse/tree/5b8993e1
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-ibrowse/diff/5b8993e1
Branch: refs/heads/upstream
Commit: 5b8993e10ba76bfd76cd7b992dfcf33cec4de938
Parents: 4b0fb6b
Author: benjaminplee <ya...@gmail.com>
Authored: Thu Nov 20 18:01:51 2014 +0000
Committer: benjaminplee <ya...@gmail.com>
Committed: Thu Nov 20 18:01:51 2014 +0000
----------------------------------------------------------------------
test/ibrowse_functional_tests.erl | 17 ++++++++++++++++-
1 file changed, 16 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/couchdb-ibrowse/blob/5b8993e1/test/ibrowse_functional_tests.erl
----------------------------------------------------------------------
diff --git a/test/ibrowse_functional_tests.erl b/test/ibrowse_functional_tests.erl
index 0e43f6a..8df662b 100644
--- a/test/ibrowse_functional_tests.erl
+++ b/test/ibrowse_functional_tests.erl
@@ -39,7 +39,8 @@ running_server_fixture_test_() ->
?TIMEDTEST("Pipeline depth goes down with responses", pipeline_depth),
?TIMEDTEST("Timeout closes pipe", closing_pipes),
?TIMEDTEST("Requests are balanced over connections", balanced_connections),
- ?TIMEDTEST("Pipeline too small signals retries", small_pipeline)
+ ?TIMEDTEST("Pipeline too small signals retries", small_pipeline),
+ ?TIMEDTEST("Dest status can be gathered", status)
]
}.
@@ -127,6 +128,20 @@ small_pipeline() ->
?assertEqual({error, retry_later}, Response).
+status() ->
+ MaxSessions = 10,
+ MaxPipeline = 10,
+ RequestsSent = 100,
+
+ Fun = fun() -> ibrowse:send_req(?BASE_URL ++ "/never_respond", [], get, [], [{max_sessions, MaxSessions}, {max_pipeline_size, MaxPipeline}], ?SHORT_TIMEOUT_MS) end,
+ times(RequestsSent, fun() -> spawn(Fun) end),
+
+ timer:sleep(?PAUSE_FOR_CONNECTIONS_MS), %% Wait for everyone to get in line
+
+ ibrowse:show_dest_status(),
+ ibrowse:show_dest_status("http://localhost:8181").
+
+
times(0, _) ->
ok;
times(X, Fun) ->