X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/cfc676704bebcd57e5ea98bb43154245a150948f..b7191e0a0c80df374d7bc4d00696578d106bd03c:/src/surf/surf_interface.cpp diff --git a/src/surf/surf_interface.cpp b/src/surf/surf_interface.cpp index 2f785d08d7..1dcc7540a1 100644 --- a/src/surf/surf_interface.cpp +++ b/src/surf/surf_interface.cpp @@ -4,7 +4,7 @@ /* 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 "src/portable.h" +#include "src/internal_config.h" #include "surf_private.h" #include "surf_interface.hpp" #include "network_interface.hpp" @@ -62,7 +62,7 @@ s_surf_model_description_t surf_network_model_description[] = { surf_network_model_init_IB}, {"CM02", "Legacy network analytic model (Very similar to LV08, but without corrective factors. The timings of small messages are thus poorly modeled).", surf_network_model_init_CM02}, -#ifdef HAVE_NS3 +#if HAVE_NS3 {"NS3", "Network pseudo-model using the NS3 tcp model instead of an analytic model", surf_network_model_init_NS3}, #endif {"Reno", "Model from Steven H. Low using lagrange_solve instead of lmm_solve (experts only; check the code for more info).", @@ -103,7 +103,7 @@ s_surf_model_description_t surf_storage_model_description[] = { {NULL, NULL, NULL} /* this array must be NULL terminated */ }; -#ifdef HAVE_THREAD_CONTEXTS +#if HAVE_THREAD_CONTEXTS static xbt_parmap_t surf_parmap = NULL; /* parallel map on models */ #endif @@ -342,7 +342,7 @@ void surf_exit(void) future_evt_set = nullptr; } -#ifdef HAVE_THREAD_CONTEXTS +#if HAVE_THREAD_CONTEXTS xbt_parmap_destroy(surf_parmap); #endif @@ -360,32 +360,32 @@ namespace simgrid { namespace surf { Model::Model() - : p_maxminSystem(NULL) + : maxminSystem_(NULL) { - p_readyActionSet = new ActionList(); - p_runningActionSet = new ActionList(); - p_failedActionSet = new ActionList(); - p_doneActionSet = new ActionList(); + readyActionSet_ = new ActionList(); + runningActionSet_ = new ActionList(); + failedActionSet_ = new ActionList(); + doneActionSet_ = new ActionList(); - p_modifiedSet = NULL; - p_actionHeap = NULL; - p_updateMechanism = UM_UNDEFINED; - m_selectiveUpdate = 0; + modifiedSet_ = NULL; + actionHeap_ = NULL; + updateMechanism_ = UM_UNDEFINED; + selectiveUpdate_ = 0; } Model::~Model(){ - delete p_readyActionSet; - delete p_runningActionSet; - delete p_failedActionSet; - delete p_doneActionSet; + delete readyActionSet_; + delete runningActionSet_; + delete failedActionSet_; + delete doneActionSet_; } double Model::next_occuring_event(double now) { //FIXME: set the good function once and for all - if (p_updateMechanism == UM_LAZY) + if (updateMechanism_ == UM_LAZY) return next_occuring_event_lazy(now); - else if (p_updateMechanism == UM_FULL) + else if (updateMechanism_ == UM_FULL) return next_occuring_event_full(now); else xbt_die("Invalid cpu update mechanism!"); @@ -399,20 +399,20 @@ double Model::next_occuring_event_lazy(double now) XBT_DEBUG ("Before share resources, the size of modified actions set is %zd", - p_modifiedSet->size()); + modifiedSet_->size()); - lmm_solve(p_maxminSystem); + lmm_solve(maxminSystem_); XBT_DEBUG ("After share resources, The size of modified actions set is %zd", - p_modifiedSet->size()); + modifiedSet_->size()); - while(!p_modifiedSet->empty()) { - action = &(p_modifiedSet->front()); - p_modifiedSet->pop_front(); + while(!modifiedSet_->empty()) { + action = &(modifiedSet_->front()); + modifiedSet_->pop_front(); int max_dur_flag = 0; - if (action->getStateSet() != p_runningActionSet) + if (action->getStateSet() != runningActionSet_) continue; /* bogus priority, skip it */ @@ -451,15 +451,15 @@ double Model::next_occuring_event_lazy(double now) action->getMaxDuration()); if (min != -1) { - action->heapUpdate(p_actionHeap, min, max_dur_flag ? MAX_DURATION : NORMAL); + action->heapUpdate(actionHeap_, min, max_dur_flag ? MAX_DURATION : NORMAL); XBT_DEBUG("Insert at heap action(%p) min %f now %f", action, min, now); } else DIE_IMPOSSIBLE; } //hereafter must have already the min value for this resource model - if (xbt_heap_size(p_actionHeap) > 0) - min = xbt_heap_maxkey(p_actionHeap) - now; + if (xbt_heap_size(actionHeap_) > 0) + min = xbt_heap_maxkey(actionHeap_) - now; else min = -1; @@ -529,9 +529,9 @@ double Model::shareResourcesMaxMin(ActionList *running_actions, void Model::updateActionsState(double now, double delta) { - if (p_updateMechanism == UM_FULL) + if (updateMechanism_ == UM_FULL) updateActionsStateFull(now, delta); - else if (p_updateMechanism == UM_LAZY) + else if (updateMechanism_ == UM_LAZY) updateActionsStateLazy(now, delta); else xbt_die("Invalid cpu update mechanism!");