X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/198b09ec16ca1b8fc05053bcae9e75c0ad689711..afd3a47e007a0f91d206cc2e47b69b4b86970fc2:/src/surf/network_ib.cpp diff --git a/src/surf/network_ib.cpp b/src/surf/network_ib.cpp index 9023115b3b..41fa93c82c 100644 --- a/src/surf/network_ib.cpp +++ b/src/surf/network_ib.cpp @@ -6,36 +6,35 @@ #include -#include "network_ib.hpp" - -#include "src/surf/HostImpl.hpp" #include "simgrid/sg_config.h" -#include "maxmin_private.hpp" +#include "src/surf/HostImpl.hpp" +#include "src/surf/maxmin_private.hpp" +#include "src/surf/network_ib.hpp" +#include "src/surf/xml/platf.hpp" XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(surf_network); static void IB_create_host_callback(simgrid::s4u::Host& host){ - using namespace simgrid::surf; + using simgrid::surf::NetworkIBModel; + using simgrid::surf::IBNode; static int id=0; // pour t->id -> rajouter une nouvelle struct dans le dict, pour stocker les comms actives if(((NetworkIBModel*)surf_network_model)->active_nodes==nullptr) - ((NetworkIBModel*)surf_network_model)->active_nodes=xbt_dict_new(); + ((NetworkIBModel*)surf_network_model)->active_nodes = xbt_dict_new_homogeneous(nullptr); IBNode* act = new IBNode(id); id++; - xbt_dict_set(((NetworkIBModel*)surf_network_model)->active_nodes, - host.name().c_str(), act, nullptr); - + xbt_dict_set(((NetworkIBModel*)surf_network_model)->active_nodes, host.cname(), act, nullptr); } -static void IB_action_state_changed_callback( - simgrid::surf::NetworkAction *action, - simgrid::surf::Action::State statein, simgrid::surf::Action::State stateout) +static void IB_action_state_changed_callback(simgrid::surf::NetworkAction* action) { - using namespace simgrid::surf; - if(statein!=simgrid::surf::Action::State::running || stateout!=simgrid::surf::Action::State::done) + using simgrid::surf::NetworkIBModel; + using simgrid::surf::IBNode; + + if (action->getState() != simgrid::surf::Action::State::done) return; std::pair pair = ((NetworkIBModel*)surf_network_model)->active_comms[action]; XBT_DEBUG("IB callback - action %p finished", action); @@ -46,16 +45,15 @@ static void IB_action_state_changed_callback( } - -static void IB_action_init_callback( - simgrid::surf::NetworkAction *action, simgrid::routing::NetCard *src, simgrid::routing::NetCard *dst) +static void IB_action_init_callback(simgrid::surf::NetworkAction* action, simgrid::s4u::Host* src, + simgrid::s4u::Host* dst) { simgrid::surf::NetworkIBModel* ibModel = (simgrid::surf::NetworkIBModel*)surf_network_model; - simgrid::surf::IBNode* act_src= (simgrid::surf::IBNode*) xbt_dict_get_or_null(ibModel->active_nodes, src->name()); + simgrid::surf::IBNode* act_src = (simgrid::surf::IBNode*)xbt_dict_get_or_null(ibModel->active_nodes, src->cname()); xbt_assert(act_src, "could not find src node active comms !"); - simgrid::surf::IBNode* act_dst= (simgrid::surf::IBNode*) xbt_dict_get_or_null(ibModel->active_nodes, dst->name()); + simgrid::surf::IBNode* act_dst = (simgrid::surf::IBNode*)xbt_dict_get_or_null(ibModel->active_nodes, dst->cname()); xbt_assert(act_dst, "could not find dst node active comms !"); ibModel->active_comms[action]=std::make_pair(act_src, act_dst); @@ -77,24 +75,20 @@ static void IB_action_init_callback( /* month=june, */ /* year={2010} */ /* } */ -void surf_network_model_init_IB(void) +void surf_network_model_init_IB() { - using simgrid::surf::networkActionStateChangedCallbacks; - if (surf_network_model) return; surf_network_model = new simgrid::surf::NetworkIBModel(); - xbt_dynar_push(all_existing_models, &surf_network_model); - networkActionStateChangedCallbacks.connect(IB_action_state_changed_callback); - Link::onCommunicate.connect(IB_action_init_callback); + all_existing_models->push_back(surf_network_model); + simgrid::s4u::Link::onCommunicationStateChange.connect(IB_action_state_changed_callback); + simgrid::s4u::Link::onCommunicate.connect(IB_action_init_callback); simgrid::s4u::Host::onCreation.connect(IB_create_host_callback); xbt_cfg_setdefault_double("network/weight-S", 8775); } -#include "src/surf/xml/platf.hpp" // FIXME: move that back to the parsing area - namespace simgrid { namespace surf {