Erlang/OTP Forums

=ERROR REPORT==== 5-Aug-2008::21:42:16 ===
** Generic server <0.22109.0> terminating
** Last message in was {tcp_closed,#Port<0.21371>}
** When Server state == {state,
                            {request,#Ref<0.0.1.250636>,<0.21236.0>,0,http,
                                {"127.0.0.1",5984},
                                "/",[],get,
                                {http_request_h,undefined,"keep-alive",
                                    undefined,undefined,undefined,undefined,
                                    undefined,undefined,undefined,undefined,
                                    undefined,undefined,undefined,undefined,
                                    undefined,undefined,"127.0.0.1",undefined,
                                    undefined,undefined,undefined,undefined,
                                    undefined,undefined,undefined,undefined,
                                    [],undefined,undefined,undefined,
                                    undefined,"0",undefined,undefined,
                                    undefined,undefined,undefined,undefined,
                                    []},
                                {[],[]},
                                {http_options,"HTTP/1.1",infinity,true,[],
                                    undefined,false},
                                "http://127.0.0.1:5984",[],none,[]},
                            {tcp_session,
                                {{"127.0.0.1",5984},<0.22109.0>},
                                false,http,#Port<0.21371>,1},
                            undefined,undefined,undefined,
                            {httpc_response,parse,[nolimit,false]},
                            {[],[]},
                            new,[],nolimit,nolimit,
                            {options,
                                {undefined,[]},
                                0,2,2,disabled,enabled,false},
                            {timers,[],undefined},
                            httpc_manager,undefined}
** Reason for termination ==
** session_remotly_closed

-module(dominatrix).
-export([torquemada/3]).
-export([strike/1,whip/2,inquisitor/0]).

%  Copyright 2008, Gnu Public License Version 3.0. Jonathan Hicks and Shawn Garbett

for(N, N, F) -> [F()];
for(I, N, F) -> [F()|for(I+1, N, F)].

strike(Site) ->
  case http:request(Site) of
    {ok, {{_, 200, _}, _, _}}  -> success;
    _                          -> failure
  end.

whip(Site, Inquisitor) ->
  receive
    stop -> true
  after 0 ->
    Inquisitor ! strike(Site),
    whip(Site, Inquisitor)
  end.
 
inquisitor() -> inquisitor({0,0}).
inquisitor({Successes, Failures}) ->
  receive
    success       -> inquisitor({Successes+1,Failures});
    failure       -> inquisitor({Successes,Failures+1});
    {results,Pid} -> Pid ! {Successes,Failures},
                     inquisitor({Successes,Failures});
    stop          -> true
  end.

%% Why does this die above 60 concurrent requests? This shouldn't happen!
torquemada(Site, Time, Concurrent) ->
  inets:start(),   
  Inquisitor = spawn(dominatrix, inquisitor, []),
  Torturers = for(1, Concurrent, fun() -> spawn(dominatrix, whip, [Site, Inquisitor]) end),
  timer:sleep(Time),
  Inquisitor ! {results, self()},
  lists:foreach(fun(Pid) -> Pid ! stop end, Torturers),
  receive
    {Confessions,Heretics} ->
        io:format("~w Successes and ~w Failures in ~w seconds with ~w concurrent users => ~w requests/second", [Confessions, Heretics, Time/1000, Concurrent, Confessions/Time*1000])
    end,
  Inquisitor ! stop.