X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/431784fbebda861a137730be550d1981776e686d..5c7ecee696b69e6177921d0077a2b1875f6e3f00:/communicator.cpp diff --git a/communicator.cpp b/communicator.cpp index 867d19e..5abb543 100644 --- a/communicator.cpp +++ b/communicator.cpp @@ -1,12 +1,11 @@ #include -#include +#include #include #include XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(comm); #include "misc.h" -#include "simgrid_features.h" #include "tracing.h" #include "communicator.h" @@ -24,15 +23,14 @@ namespace { communicator::communicator() : host(static_cast(MSG_host_get_data(MSG_host_self()))) { - using std::tr1::bind; receiver_thread = new_msg_thread("receiver", - bind(&communicator::receiver, this)); + std::bind(&communicator::receiver, this)); receiver_thread->start(); } communicator::~communicator() { - m_task_t task; + msg_task_t task; XBT_DEBUG("send finalize to receiver/ctrl"); task = MSG_task_create("finalize", 0.0, 0, NULL); @@ -54,10 +52,10 @@ communicator::~communicator() msg_comm_t communicator::real_send(const char* dest, message* msg) { XBT_DEBUG("send %s to %s", msg->to_string().c_str(), dest); - m_task_t task = MSG_task_create("message", 0.0, msg->get_size(), msg); - TRACE_msg_set_task_category(task, - msg->get_type() == message::LOAD ? - TRACE_CAT_DATA : TRACE_CAT_CTRL); + msg_task_t task = MSG_task_create("message", 0.0, msg->get_size(), msg); + // MSG_task_set_category(task, + // msg->get_type() == message::DATA ? + // TRACE_CAT_DATA : TRACE_CAT_CTRL); return MSG_task_isend(task, dest); } @@ -83,7 +81,7 @@ void communicator::receiver() xbt_dynar_t comms = xbt_dynar_new(sizeof(msg_comm_t), NULL); struct channel { msg_comm_t comm; - m_task_t task; + msg_task_t task; const char* mbox; message_queue& received; };