X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/091dd5b6c0cca95b33f18645981aeaaf6585f1ad..be6ecad742f6daa971c70b04ddb4db64bad52f58:/src/surf/maxmin.cpp diff --git a/src/surf/maxmin.cpp b/src/surf/maxmin.cpp index a09b2e5aac..e5006daa3d 100644 --- a/src/surf/maxmin.cpp +++ b/src/surf/maxmin.cpp @@ -6,6 +6,7 @@ /* \file callbacks.h */ #include "maxmin_private.hpp" +#include "xbt/backtrace.hpp" #include "xbt/log.h" #include "xbt/mallocator.h" #include "xbt/sysdep.h" @@ -153,13 +154,6 @@ static void lmm_var_free(lmm_system_t sys, lmm_variable_t var) lmm_on_disabled_var(sys, elem.constraint); } - // Check if we can enable new variables going through the constraints where var was. - // Do it after removing all elements, so the first disabled variables get priority over those with smaller requirement - for (s_lmm_element_t& elem : var->cnsts) { - if (xbt_swag_size(&(elem.constraint->disabled_element_set))) - lmm_on_disabled_var(sys, elem.constraint); - } - var->cnsts.clear(); lmm_check_concurrency(sys); @@ -209,12 +203,9 @@ void lmm_system_free(lmm_system_t sys) return; while ((var = (lmm_variable_t) extract_variable(sys))) { - int status; - char* demangled = abi::__cxa_demangle(typeid(*var->id).name(), 0, 0, &status); - - XBT_WARN("Probable bug: a %s variable (#%d) not removed before the LMM system destruction.", demangled, + auto demangled = simgrid::xbt::demangle(typeid(*var->id).name()); + XBT_WARN("Probable bug: a %s variable (#%d) not removed before the LMM system destruction.", demangled.get(), var->id_int); - xbt_free(demangled); lmm_var_free(sys, var); } while ((cnst = (lmm_constraint_t) extract_constraint(sys))) @@ -867,29 +858,26 @@ void lmm_update_variable_bound(lmm_system_t sys, lmm_variable_t var, double boun lmm_update_modified_set(sys, var->cnsts[0].constraint); } -int lmm_concurrency_slack(lmm_constraint_t cnstr){ - //FIXME MARTIN: Replace by infinite value std::numeric_limits::(max)(), or something better within Simgrid? - if(cnstr->concurrency_limit<0) - return 666; - +int lmm_concurrency_slack(lmm_constraint_t cnstr) +{ + if (cnstr->concurrency_limit < 0) + return std::numeric_limits::max(); return cnstr->concurrency_limit - cnstr->concurrency_current; } /** \brief Measure the minimum concurrency slack across all constraints where the given var is involved */ -int lmm_cnstrs_min_concurrency_slack(lmm_variable_t var){ +int lmm_cnstrs_min_concurrency_slack(lmm_variable_t var) +{ int minslack = std::numeric_limits::max(); for (s_lmm_element_t const& elem : var->cnsts) { int slack = lmm_concurrency_slack(elem.constraint); - - //This is only an optimization, to avoid looking at more constraints when slack is already zero - //Disable it when debugging to let lmm_concurrency_slack catch nasty things - if (not slack && not XBT_LOG_ISENABLED(surf_maxmin, xbt_log_priority_debug)) - return 0; - - if(minslack>slack) - minslack=slack; + if (slack < minslack) { + // This is only an optimization, to avoid looking at more constraints when slack is already zero + if (slack == 0) + return 0; + minslack = slack; + } } - return minslack; } @@ -906,7 +894,7 @@ int lmm_can_enable_var(lmm_variable_t var){ //A priori not a big performance issue, but we might do better by calling lmm_update_modified_set within the for loops // (after doing the first for enabling==1, and before doing the last for disabling==1) void lmm_enable_var(lmm_system_t sys, lmm_variable_t var){ - xbt_assert(lmm_can_enable_var(var)); + xbt_assert(not XBT_LOG_ISENABLED(surf_maxmin, xbt_log_priority_debug) || lmm_can_enable_var(var)); var->sharing_weight = var->staged_weight; var->staged_weight = 0; @@ -975,13 +963,11 @@ void lmm_on_disabled_var(lmm_system_t sys, lmm_constraint_t cnstr){ lmm_element_t nextelem = (lmm_element_t)xbt_swag_getNext(elem, cnstr->disabled_element_set.offset); - if (elem->variable->staged_weight>0 ){ + if (elem->variable->staged_weight > 0 && lmm_can_enable_var(elem->variable)) { //Found a staged variable //TODOLATER: Add random timing function to model reservation protocol fuzziness? Then how to make sure that //staged variables will eventually be called? - if(lmm_can_enable_var(elem->variable)){ - lmm_enable_var(sys,elem->variable); - } + lmm_enable_var(sys, elem->variable); } xbt_assert(cnstr->concurrency_current<=cnstr->concurrency_limit,"Concurrency overflow!"); @@ -1053,16 +1039,6 @@ int lmm_constraint_used(lmm_system_t sys, lmm_constraint_t cnst) return xbt_swag_belongs(cnst, &(sys->active_constraint_set)); } -inline lmm_constraint_t lmm_get_first_active_constraint(lmm_system_t sys) -{ - return (lmm_constraint_t)xbt_swag_getFirst(&(sys->active_constraint_set)); -} - -inline lmm_constraint_t lmm_get_next_active_constraint(lmm_system_t sys, lmm_constraint_t cnst) -{ - return (lmm_constraint_t)xbt_swag_getNext(cnst, (sys->active_constraint_set).offset); -} - /** \brief Update the constraint set propagating recursively to other constraints so the system should not be entirely * computed. * @@ -1076,7 +1052,6 @@ static void lmm_update_modified_set_rec(lmm_system_t sys, lmm_constraint_t cnst) { void* _elem; - //TODOLATER: Why lmm_modified_set has been changed in git version 2392B5157...? Looks equivalent logically and less obvious.. xbt_swag_foreach(_elem, &cnst->enabled_element_set) { lmm_variable_t var = ((lmm_element_t)_elem)->variable; for (s_lmm_element_t const& elem : var->cnsts) {