X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/b4d90a50ce65a5efb75c0a28b269120ea51d57cf..cf0d125a496f82b6831925b514bc5b40717ee9ca:/process.h diff --git a/process.h b/process.h index 14d514f..81e68d9 100644 --- a/process.h +++ b/process.h @@ -5,6 +5,7 @@ //#undef USE_UNORDERED_MAP #include +#include #include #ifdef USE_UNORDERED_MAP # include @@ -16,12 +17,12 @@ #include #include #include -#include "atomic_compat.h" #include "communicator.h" #include "misc.h" #include "msg_thread.h" #include "neighbor.h" #include "options.h" +#include "simgrid_features.h" #include "synchro.h" class process { @@ -102,10 +103,10 @@ private: static std::atomic convergence_counter; - typedef MAP_TEMPLATE rev_neigh_type; + typedef MAP_TEMPLATE rev_neigh_type; neigh_type neigh; // list of neighbors (do not alter // after construction!) - rev_neigh_type rev_neigh; // map m_host_t -> neighbor + rev_neigh_type rev_neigh; // map msg_host_t -> neighbor communicator comm; // communicator for this process int ctrl_close_pending; // number of "close" messages to wait @@ -198,7 +199,7 @@ private: // infinite waiting, or any positive timeout. void ctrl_receive(double timeout); void data_receive(double timeout); - void handle_message(message* msg, m_host_t from); + void handle_message(message* msg, msg_host_t from); }; template