%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 2009. All Rights Reserved.
%%
%% The contents of this file are subject to the Erlang Public License,
%% Version 1.1, (the "License"); you may not use this file except in
%% compliance with the License. You should have received a copy of the
%% Erlang Public License along with this software. If not, it can be
%% retrieved online at http://www.erlang.org/.
%%
%% Software distributed under the License is distributed on an "AS IS"
%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
%% the License for the specific language governing rights and limitations
%% under the License.
%%
%% %CopyrightEnd%

%% Author  : Björn-Egil Dahlberg
%% Created : 16 April 2010

-module(parallel).

-export([bench_args/2, run/3]).

bench_args(Version, Conf) ->
    {_,Cores} = lists:keyfind(number_of_cores, 1, Conf),
	[F1, F2] = case Version of
		short -> [313, 4];
		intermediate -> [469, 8];
		long -> [1094, 10]
	end,
    [[N,M] || N <- [F1 * Cores], M <- [F2 * Cores]].

run([N,M|_], _, _) ->
	Me   = self(),
	Base = [ok || _ <- lists:seq(1, M)],
	Pids = [spawn_link(fun() -> loop(Me, N, []) end) || _ <- lists:seq(1, M)],
	Res  = [receive {Pid, What} -> What end || Pid <- Pids],
	Base = Res,
	ok.

loop(Pid, 0, Out) -> Pid ! {self(), check_now(Out)};
loop(Pid, N, Out) -> loop(Pid, N - 1, [erlang:timestamp()|Out]).

check_now([_,_]) -> ok;
check_now([_|Ts]) -> check_now(Ts).