X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5178c3d78c741bc724a439f407d441300355c40d..8d18cbc2b336bfe9a64a789e22c39f45a1cbd696:/src/gras/Virtu/sg_emul.c diff --git a/src/gras/Virtu/sg_emul.c b/src/gras/Virtu/sg_emul.c index e44614f640..cf38124083 100644 --- a/src/gras/Virtu/sg_emul.c +++ b/src/gras/Virtu/sg_emul.c @@ -7,37 +7,64 @@ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ -#include /* sprintf */ +#include /* sprintf */ #include "gras/emul.h" #include "gras/Virtu/virtu_sg.h" #include "gras_modinter.h" -#include "xbt/xbt_os_time.h" /* timers */ +#include "xbt/xbt_os_time.h" /* timers */ #include "xbt/dict.h" #include "xbt/ex.h" -XBT_LOG_NEW_DEFAULT_SUBCATEGORY(gras_virtu_emul,gras_virtu,"Emulation support"); +XBT_LOG_NEW_DEFAULT_SUBCATEGORY(gras_virtu_emul, gras_virtu, + "Emulation support"); +/*** CPU burning */ +void gras_cpu_burn(double flops) { + smx_action_t act; + smx_cond_t cond; + smx_mutex_t mutex; + if (flops>0) { + cond = SIMIX_cond_init(); + mutex = SIMIX_mutex_init(); + + SIMIX_mutex_lock(mutex); + act = + SIMIX_action_execute(SIMIX_host_self(), "task", flops); + + SIMIX_register_action_to_condition(act, cond); + SIMIX_cond_wait(cond, mutex); + SIMIX_unregister_action_to_condition(act, cond); + + SIMIX_action_destroy(act); + SIMIX_mutex_unlock(mutex); + + SIMIX_cond_destroy(cond); + SIMIX_mutex_destroy(mutex); + } +} /*** Timing macros ***/ static xbt_os_timer_t timer; static int benchmarking = 0; static xbt_dict_t benchmark_set = NULL; -static double reference = .00000000523066250047108838; /* FIXME: we should benchmark host machine to set this; unit=s/flop */ +static double reference = .00000000523066250047108838; /* FIXME: we should benchmark host machine to set this; unit=s/flop */ static double duration = 0.0; -static char* locbuf = NULL; -static int locbufsize; +static char *locbuf = NULL; +static unsigned int locbufsize; void gras_emul_init(void) { - if(!benchmark_set) { + if (!benchmark_set) { benchmark_set = xbt_dict_new(); timer = xbt_os_timer_new(); } } -void gras_emul_exit(void) { - if (locbuf) free(locbuf); +void gras_emul_exit(void) +{ + if (locbuf) + free(locbuf); xbt_dict_free(&benchmark_set); xbt_os_timer_free(timer); } @@ -49,72 +76,55 @@ static void store_in_dict(xbt_dict_t dict, const char *key, double value) ir = xbt_dict_get_or_null(dict, key); if (!ir) { - ir = xbt_new0(double,1); + ir = xbt_new0(double, 1); xbt_dict_set(dict, key, ir, xbt_free_f); } *ir = value; } -static double get_from_dict(xbt_dict_t dict, const char *key) { +static double get_from_dict(xbt_dict_t dict, const char *key) +{ double *ir = xbt_dict_get(dict, key); return *ir; } -int gras_bench_always_begin(const char *location,int line) +int gras_bench_always_begin(const char *location, int line) { - xbt_assert0(!benchmarking,"Already benchmarking"); + xbt_assert0(!benchmarking, "Already benchmarking"); benchmarking = 1; if (!timer) - xbt_os_timer_start(timer); + xbt_os_timer_start(timer); return 0; } -int gras_bench_always_end(void) -{ - smx_action_t act; - smx_cond_t cond; - smx_mutex_t mutex; - - xbt_assert0(benchmarking,"Not benchmarking yet"); +int gras_bench_always_end(void) { + xbt_assert0(benchmarking, "Not benchmarking yet"); benchmarking = 0; xbt_os_timer_stop(timer); duration = xbt_os_timer_elapsed(timer); - cond = SIMIX_cond_init(); - mutex = SIMIX_mutex_init(); - - SIMIX_mutex_lock(mutex); - act = SIMIX_action_execute(SIMIX_host_self(), (char*) "task", (duration)/reference); - - SIMIX_register_action_to_condition(act,cond); - SIMIX_cond_wait(cond, mutex); - SIMIX_unregister_action_to_condition(act,cond); - - SIMIX_action_destroy(act); - SIMIX_mutex_unlock(mutex); - - SIMIX_cond_destroy(cond); - SIMIX_mutex_destroy(mutex); + gras_cpu_burn(duration/reference); return 0; } -int gras_bench_once_begin(const char *location,int line) { +int gras_bench_once_begin(const char *location, int line) +{ double *ir = NULL; - xbt_assert0(!benchmarking,"Already benchmarking"); + xbt_assert0(!benchmarking, "Already benchmarking"); benchmarking = 1; if (!locbuf || locbufsize < strlen(location) + 64) { - locbufsize = strlen(location) + 64; - locbuf = xbt_realloc(locbuf,locbufsize); + locbufsize = strlen(location) + 64; + locbuf = xbt_realloc(locbuf, locbufsize); } - sprintf(locbuf,"%s:%d",location, line); - + sprintf(locbuf, "%s:%d", location, line); + ir = xbt_dict_get_or_null(benchmark_set, locbuf); - if(!ir) { - DEBUG1("%s",locbuf); + if (!ir) { + DEBUG1("%s", locbuf); duration = 1; xbt_os_timer_start(timer); return 1; @@ -124,47 +134,30 @@ int gras_bench_once_begin(const char *location,int line) { } } -int gras_bench_once_end(void) -{ - smx_action_t act; - smx_cond_t cond; - smx_mutex_t mutex; - - xbt_assert0(benchmarking,"Not benchmarking yet"); +int gras_bench_once_end(void) { + xbt_assert0(benchmarking, "Not benchmarking yet"); benchmarking = 0; - if(duration>0) { + if (duration > 0) { xbt_os_timer_stop(timer); duration = xbt_os_timer_elapsed(timer); store_in_dict(benchmark_set, locbuf, duration); } else { - duration = get_from_dict(benchmark_set,locbuf); + duration = get_from_dict(benchmark_set, locbuf); } - DEBUG2("Simulate the run of a task of %f sec for %s",duration,locbuf); - cond = SIMIX_cond_init(); - mutex = SIMIX_mutex_init(); - - SIMIX_mutex_lock(mutex); - act = SIMIX_action_execute(SIMIX_host_self(), (char*)"task", (duration)/reference); - - SIMIX_register_action_to_condition(act,cond); - SIMIX_cond_wait(cond, mutex); - SIMIX_unregister_action_to_condition(act,cond); - - SIMIX_action_destroy(act); - SIMIX_mutex_unlock(mutex); - - SIMIX_cond_destroy(cond); - SIMIX_mutex_destroy(mutex); + DEBUG2("Simulate the run of a task of %f sec for %s", duration, locbuf); + gras_cpu_burn(duration/reference); return 0; } /*** Conditional execution support ***/ -int gras_if_RL(void) { - return 0; +int gras_if_RL(void) +{ + return 0; } -int gras_if_SG(void) { - return 1; +int gras_if_SG(void) +{ + return 1; }