2 % Copyright 2008 Grégory Burri
4 % This file is part of Euphorik.
6 % Euphorik is free software: you can redistribute it and/or modify
7 % it under the terms of the GNU General Public License as published by
8 % the Free Software Foundation, either version 3 of the License, or
9 % (at your option) any later version.
11 % Euphorik is distributed in the hope that it will be useful,
12 % but WITHOUT ANY WARRANTY; without even the implied warranty of
13 % MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 % GNU General Public License for more details.
16 % You should have received a copy of the GNU General Public License
17 % along with Euphorik. If not, see <http://www.gnu.org/licenses/>.
19 % Module de test de euphorik.
20 % Crée un certain nombre d'utilisateur et post des messages aléatoire.
23 -module(euphorik_test
).
25 bench_write_minichat
/1,
29 bench_get_messages_avec_2_conversations
/0
31 -include("../include/euphorik_bd.hrl").
33 % les intervalles en seconde min en max entre deux postes de message d'un utilisateur
34 % le temps d'attente est choisi au hasard entre ces deux valeurs
35 -define(INTERVALLE_MIN
, 2).
36 -define(INTERVALLE_MAX
, 5).
39 % N est le nombre d'utilisateur
40 % M est le nombre de message que chaque utilisateur va poster
49 random:seed(A1
, A2
, A3
),
58 lists:foreach(fun(Pid
) -> exit(Pid
, kill
) end, Pids
).
60 % des trucs qui trainent
61 bench_get_messages() ->
64 {cookie
,"5G84A5CJXMCPEHNI8T5A9"},
68 {conversations
,{array
,[]}}
70 moyenne_temps(euphorik_protocole
, wait_event
, [T
], 20).
71 bench_get_messages_avec_2_conversations() ->
74 {cookie
,"5G84A5CJXMCPEHNI8T5A9"},
78 {conversations
,{array
, [
91 moyenne_temps(euphorik_protocole
, wait_event
, [T
], 20).
92 moyenne_temps(Module
, Fun
, Args
, N
) ->
93 moyenne_temps(Module
, Fun
, Args
, N
, N
, 0).
94 moyenne_temps(_
, _
, _
, 0, Total
, Temps_acc
) ->
96 moyenne_temps(Module
, Fun
, Args
, N
, Total
, Temps_acc
) ->
97 {Temps
, _
} = timer:tc(Module
, Fun
, Args
),
98 moyenne_temps(Module
, Fun
, Args
, N
- 1, Total
, Temps_acc
+ Temps
).
101 % Crée N user avec des noms aléatoires et renvoie la liste des id.
104 creer_users(0, Ids
) -> lists:map(fun(#user
{id
= Id
}) -> Id
end, Ids
);
105 creer_users(N
, Ids
) ->
106 creer_users(N
- 1, [euphorik_bd:nouveau_user(mot_rand(random:uniform(4) + 4), "", "", #profile
{}) | Ids
]).
109 % crée un message aléatoire et le renvoie
111 lists:flatten(message_rand(random:uniform(10), [])).
112 message_rand(0, Mots
) -> Mots
;
113 message_rand(N
, Mots
) ->
114 message_rand(N
- 1, [mot_rand(random:uniform(2) + 5), $
| Mots
]).
117 % Renvoie une succession de lettre aléatoire
120 mot_rand(0, Mot
) -> Mot
;
122 mot_rand(L
- 1, [random:uniform($z
- $a
+ 1) + $a
- 1 | Mot
]).
125 % Tire au hasard de 0 à 3 messages sur les 10 derniers postés, renvoie une liste de int()
131 messages_id_rand() ->
132 R
= random:uniform(),
136 Messages
= lists:map(fun(#minichat
{id
= Id
}) -> Id
end, euphorik_bd:messages(8)),
138 R
> 0.1 andalso R
=< 0.95 ->
139 tire_element_rand(1, Messages
);
140 R
> 0.95 andalso R
=< 0.99 ->
141 tire_element_rand(2, Messages
);
143 tire_element_rand(3, Messages
)
148 % tire N element distinct parmis la liste L proposée
149 tire_element_rand(N
, L
) when N
=< length(L
) ->
150 tire_element_rand(N
, L
, []);
151 tire_element_rand(_
, _
) ->
153 tire_element_rand(0, _
, Elements
) -> Elements
;
154 tire_element_rand(N
, L
, Elements
) ->
155 E
= lists:nth(random:uniform(length(L
)), L
),
156 E_se_trouve_dans_Elements
= lists:any(fun(E2
) -> E2
=:= E
end, Elements
),
157 if E_se_trouve_dans_Elements
-> % si E a déjà été tiré on recommence sans rien changer
158 tire_element_rand(N
, L
, Elements
);
160 tire_element_rand(N
-1, L
, [E
| Elements
])
164 io:format("~p a fini~n", [User_id
]);
166 % attend un temp aléatoire compris entre INTERVALLE_MIN sec et INTERVALLE_MAX sec
167 timer:sleep(1000 * (random:uniform(?INTERVALLE_MAX
- ?INTERVALLE_MIN
+ 1) + ?INTERVALLE_MIN
- 1)),
168 % poste un message aléatoire par une personne aléatoire répondant à des messages aléatoires
169 {Message
, Repond_a
} = {message_rand(), messages_id_rand()},
170 % io:format("~p poste ~p et repond a ~w~n", [User_id, Message, Repond_a]),
171 case euphorik_bd:nouveau_message(Message
, User_id
, Repond_a
) of
173 io:format("~p : erreur : ~p~n", [User_id
, E
]),
180 % Permet de tester la vitesse d'écriture en fonction de la
182 % voir : http://erlang.org/pipermail/erlang-questions/2008-October/038697.html
183 bench_write_minichat(Filename
) ->
184 Times
= bench_write_minichat(1, []),
185 {ok
, File
} = file:open(Filename
, [write
]),
188 io:format(File
, "~w ~w~n", [Id
, Time
])
193 bench_write_minichat(100000, Temps
) -> Temps
;
194 bench_write_minichat(N
, Temps
) ->
195 {T
, _
} = timer:tc(mnesia
, transaction
, [fun() ->
196 Id
= mnesia:dirty_update_counter(counter
, minichat
, 1),
197 mnesia:write(#minichat
{
199 auteur_id
= random:uniform(10000),
202 contenu
= "Blabla blabla bla.",
203 racine_id
= random:uniform(10000)
206 bench_write_minichat(N
+ 1, if N rem
500 =:= 0 -> [{N
, T
} | Temps
]; true
-> Temps
end).