X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ad4713b96ec5af50a401b396dfe74b26f49ce72d..84402e8e2ee2a2d0bef25fdceb0a263ed8b471f6:/src/surf/network_ib.hpp diff --git a/src/surf/network_ib.hpp b/src/surf/network_ib.hpp index ceab7b9d08..8df5bc0135 100644 --- a/src/surf/network_ib.hpp +++ b/src/surf/network_ib.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2014-2015. The SimGrid Team. +/* Copyright (c) 2014-2020. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it @@ -10,56 +10,53 @@ #include "src/surf/network_smpi.hpp" #include "xbt/base.h" -#include +#include +#include namespace simgrid { - namespace surf { - - class XBT_PRIVATE IBNode; - - class XBT_PRIVATE ActiveComm{ - public : - //IBNode* origin; - IBNode* destination; - NetworkAction *action; - double init_rate; - ActiveComm() : destination(nullptr),action(nullptr),init_rate(-1){}; - virtual ~ActiveComm() = default; - }; - - class IBNode{ - public : - int id; - //store related links, to ease computation of the penalties - std::vector ActiveCommsUp; - //store the number of comms received from each node - std::map ActiveCommsDown; - //number of comms the node is receiving - int nbActiveCommsDown; - explicit IBNode(int id) : id(id),nbActiveCommsDown(0){}; - virtual ~IBNode() = default; - }; - - class XBT_PRIVATE NetworkIBModel : public NetworkSmpiModel { - private: - void updateIBfactors_rec(IBNode *root, bool* updatedlist); - void computeIBfactors(IBNode *root); - public: - NetworkIBModel(); - explicit NetworkIBModel(const char *name); - ~NetworkIBModel() override; - void updateIBfactors(NetworkAction *action, IBNode *from, IBNode * to, int remove); - - std::unordered_map active_nodes; - std::unordered_map> active_comms; - - double Bs; - double Be; - double ys; - - }; - - } -} - +namespace kernel { +namespace resource { + +class XBT_PRIVATE IBNode; + +struct XBT_PRIVATE ActiveComm { + IBNode* destination = nullptr; + NetworkAction* action = nullptr; + double init_rate = -1; +}; + +class IBNode { +public: + int id; + // store related links, to ease computation of the penalties + std::vector ActiveCommsUp; + // store the number of comms received from each node + std::map ActiveCommsDown; + // number of comms the node is receiving + int nbActiveCommsDown = 0; + explicit IBNode(int id) : id(id){}; + virtual ~IBNode() = default; +}; + +class XBT_PRIVATE NetworkIBModel : public NetworkSmpiModel { + double Bs; + double Be; + double ys; + void updateIBfactors_rec(IBNode* root, std::vector& updatedlist); + void computeIBfactors(IBNode* root); + +public: + NetworkIBModel(); + explicit NetworkIBModel(const char* name); + NetworkIBModel(const NetworkIBModel&) = delete; + NetworkIBModel& operator=(const NetworkIBModel&) = delete; + void updateIBfactors(NetworkAction* action, IBNode* from, IBNode* to, int remove); + + std::unordered_map active_nodes; + std::unordered_map> active_comms; + +}; +} // namespace resource +} // namespace kernel +} // namespace simgrid #endif