From 6e96af2afdc875932c19685110c97ea7837944c6 Mon Sep 17 00:00:00 2001 From: Greg Burri Date: Thu, 2 Oct 2008 14:01:18 +0000 Subject: [PATCH] =?utf8?q?MOD=20am=C3=A9lioration=20de=20la=20complexit?= =?utf8?q?=C3=A9=20de=20la=20fonction=20euphorik=5Fbd:nouveau=5Fmessage/3?= =?utf8?q?=20mais=20elle=20n'est=20toujours=20pas=20en=20O(n)=20ou=20n=20e?= =?utf8?q?st=20le=20nombre=20de=20message=20existant=20dans=20la=20BD.?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- modules/erl/euphorik_bd.erl | 54 +++++++++++++++++++---------------- modules/erl/euphorik_test.erl | 13 ++++++--- tools/start_yaws.sh | 5 ++-- 3 files changed, 41 insertions(+), 31 deletions(-) diff --git a/modules/erl/euphorik_bd.erl b/modules/erl/euphorik_bd.erl index e5afe74..81a36a0 100755 --- a/modules/erl/euphorik_bd.erl +++ b/modules/erl/euphorik_bd.erl @@ -276,11 +276,14 @@ user_by_mess(Id) -> % retourne soit l'id du message soit {erreur, }. nouveau_message(Mess, Auteur_id, Repond_A_ids) -> % regarde si les id 'Repond_A' existent - F = fun() -> - Repond_a = e( - q([M || M <- mnesia:table(minichat), lists:member(M#minichat.id, Repond_A_ids)]), - [{tmpdir, ?KEY_SORT_TEMP_DIR}] - ), + F = fun() -> + Repond_a = lists:map( + fun(Repond_a_id) -> + [M] = mnesia:wread({minichat, Repond_a_id}), + M + end, + Repond_A_ids + ), Racine_id = case Repond_a of [] -> undefined; [M | _] -> @@ -297,37 +300,38 @@ nouveau_message(Mess, Auteur_id, Repond_A_ids) -> {erreur, E} -> {erreur, E}; _ -> % est-ce que l'auteur existe ? - case e(q([E || E <- mnesia:table(user), E#user.id =:= Auteur_id]), [{tmpdir, ?KEY_SORT_TEMP_DIR}]) of + case mnesia:wread({user, Auteur_id}) of [#user{profile = Profile} = Auteur] -> if length(Repond_a) =/= length(Repond_A_ids) -> {erreur, "Un ou plusieurs messages introuvable"}; true -> % comparaison entre la date du dernier poste et maintenant (gestion du flood) - Delta = euphorik_common:delta_date_ms(Auteur#user.date_derniere_connexion, now()), + Now = now(), + Delta = euphorik_common:delta_date_ms(Auteur#user.date_derniere_connexion, Now), Nouvel_indice_flood = Auteur#user.indice_flood + if Delta =< ?DUREE_SPAM -> 2; true -> -1 end, Auteur_maj = Auteur#user{ indice_flood = if Nouvel_indice_flood > ?INDICE_SPAM_MAX -> ?INDICE_SPAM_MAX; Nouvel_indice_flood < 0 -> 0; true -> Nouvel_indice_flood end, - date_derniere_connexion = now() + date_derniere_connexion = Now }, % est-ce que l'auteur à trop floodé ? if Auteur#user.indice_flood =/= ?INDICE_SPAM_MAX, Auteur_maj#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM -> - mnesia:write(Auteur#user{indice_flood = Auteur_maj#user.indice_flood}), - nouveau_message_sys("\"" ++ Profile#profile.pseudo ++ if Auteur#user.login =/= [] -> " (" ++ Auteur#user.login ++ ")"; true -> "" end ++ "\" est bloqué pour " ++ integer_to_list(trunc(?DUREE_BLOCAGE_SPAM / 1000)) ++ " secondes pour cause de flood."); - Auteur#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM -> - {erreur, "Bloqué pour cause de flood"}; - true -> - mnesia:write(Auteur_maj), - Id = nouvel_id(minichat), - inserer_reponses(Id, Repond_A_ids), - mnesia:write(#minichat{ - id = Id, - auteur_id = Auteur#user.id, - date = now(), - pseudo = Profile#profile.pseudo, - contenu = Mess, - racine_id = if Racine_id =:= undefined -> Id; true -> Racine_id end - }), - Id + mnesia:write(Auteur#user{indice_flood = Auteur_maj#user.indice_flood}), + nouveau_message_sys("\"" ++ Profile#profile.pseudo ++ if Auteur#user.login =/= [] -> " (" ++ Auteur#user.login ++ ")"; true -> "" end ++ "\" est bloqué pour " ++ integer_to_list(trunc(?DUREE_BLOCAGE_SPAM / 1000)) ++ " secondes pour cause de flood."); + Auteur#user.indice_flood =:= ?INDICE_SPAM_MAX, Delta =< ?DUREE_BLOCAGE_SPAM -> + {erreur, "Bloqué pour cause de flood"}; + true -> + mnesia:write(Auteur_maj), + Id = nouvel_id(minichat), + inserer_reponses(Id, Repond_A_ids), + mnesia:write(#minichat{ + id = Id, + auteur_id = Auteur#user.id, + date = Now, + pseudo = Profile#profile.pseudo, + contenu = Mess, + racine_id = if Racine_id =:= undefined -> Id; true -> Racine_id end + }), + Id end end; _ -> diff --git a/modules/erl/euphorik_test.erl b/modules/erl/euphorik_test.erl index f07941c..c1bf49b 100644 --- a/modules/erl/euphorik_test.erl +++ b/modules/erl/euphorik_test.erl @@ -28,7 +28,11 @@ bench_get_messages_avec_2_conversations/0 ]). -include("../include/euphorik_bd.hrl"). - + +% les intervalles en seconde min en max entre deux postes de message d'un utilisateur +% le temps d'attente est choisi au hasard entre ces deux valeurs +-define(INTERVALLE_MIN, 2). +-define(INTERVALLE_MAX, 5). % N est le nombre d'utilisateur % M est le nombre de message que chaque utilisateur va poster @@ -163,10 +167,11 @@ tire_element_rand(N, L, Elements) -> loop(User_id, 0) -> io:format("~p a fini~n", [User_id]); loop(User_id, M) -> - % attend un temp aléatoire compris entre 2 sec et 10 sec - timer:sleep(2000 * random:uniform(10)), + % attend un temp aléatoire compris entre INTERVALLE_MIN sec et INTERVALLE_MAX sec + timer:sleep(1000 * (random:uniform(?INTERVALLE_MAX - ?INTERVALLE_MIN + 1) + ?INTERVALLE_MIN - 1)), % poste un message aléatoire par une personne aléatoire répondant à des messages aléatoires - {Message, Repond_a} = {message_rand(), messages_id_rand()}, + {Message, Repond_a} = {message_rand(), messages_id_rand()}, + %{Message, Repond_a} = {"blablablablablabla", []}, io:format("~p poste ~p et repond a ~w~n", [User_id, Message, Repond_a]), case euphorik_bd:nouveau_message(Message, User_id, Repond_a) of {erreur, E} -> diff --git a/tools/start_yaws.sh b/tools/start_yaws.sh index 1a2a144..87e6e4e 100755 --- a/tools/start_yaws.sh +++ b/tools/start_yaws.sh @@ -1,2 +1,3 @@ -#!/bin/bash -screen -S yaws_preprod yaws --conf ./yaws.conf --sname yaws_dev --mnesiadir "../var/BD/" -I debian_yaws_dev +#!/bin/bash +# screen est utilisé par exemple pour lancé une version de preproduction et permettre de la faire tourner après un délog +screen -S yawspreprod yaws --conf ./yaws.conf --sname yaws_dev --mnesiadir "../var/BD/" -I debian_yaws_dev -- 2.45.2