X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/c86e5ff42db3495538c8b48cb7ea0943a13702b7..d8bc41619b280838934e13bef30f911715259fc9:/communicator.cpp diff --git a/communicator.cpp b/communicator.cpp index 0808426..0b06d6c 100644 --- a/communicator.cpp +++ b/communicator.cpp @@ -64,11 +64,11 @@ communicator::~communicator() if (data_comm) XBT_WARN("data_comm is pending!"); if (!received.empty()) - XBT_WARN("lost %lu received message%s!", - (unsigned long )received.size(), ESSE(received.size())); + XBT_WARN("lost %zu received message%s!", + received.size(), ESSE(received.size())); if (!sent_comm.empty()) - XBT_WARN("lost %lu sent message%s!", - (unsigned long )sent_comm.size(), ESSE(sent_comm.size())); + XBT_WARN("lost %zu sent message%s!", + sent_comm.size(), ESSE(sent_comm.size())); xbt_cond_destroy(cond); xbt_mutex_destroy(mutex); @@ -164,6 +164,25 @@ int communicator::receiver_wrapper(int, char* []) return result; } +void communicator::receiver1(msg_comm_t& comm, m_task_t& task, const char* mbox) +{ + MSG_comm_destroy(comm); + if (strcmp(MSG_task_get_name(task), "finalize")) { + XBT_DEBUG("received message on %s", mbox); + xbt_mutex_acquire(mutex); + received.push(task); + xbt_cond_signal(cond); + xbt_mutex_release(mutex); + task = NULL; + comm = MSG_task_irecv(&task, mbox); + } else { + XBT_DEBUG("received finalize on %s", mbox); + MSG_task_destroy(task); + task = NULL; + comm = NULL; + } +} + int communicator::receiver() { ctrl_comm = MSG_task_irecv(&ctrl_task, get_ctrl_mbox()); @@ -180,44 +199,18 @@ int communicator::receiver() xbt_dynar_push(comms, &ctrl_comm); if (data_comm) xbt_dynar_push(comms, &data_comm); - MSG_comm_waitany(comms); + int recvd = MSG_comm_waitany(comms); + msg_comm_t comm = xbt_dynar_get_as(comms, recvd, msg_comm_t); xbt_dynar_reset(comms); - if (ctrl_comm && comm_test_n_destroy(ctrl_comm)) { - if (strcmp(MSG_task_get_name(ctrl_task), "finalize")) { - XBT_DEBUG("received message from ctrl"); - xbt_mutex_acquire(mutex); - received.push(ctrl_task); - xbt_mutex_release(mutex); - ctrl_task = NULL; - ctrl_comm = MSG_task_irecv(&ctrl_task, get_ctrl_mbox()); - } else { - XBT_DEBUG("received finalize from ctrl"); - MSG_task_destroy(ctrl_task); - ctrl_task = NULL; - ctrl_comm = NULL; - } - } - - if (data_comm && comm_test_n_destroy(data_comm)) { - if (strcmp(MSG_task_get_name(data_task), "finalize")) { - XBT_DEBUG("received message from data"); - xbt_mutex_acquire(mutex); - received.push(data_task); - xbt_mutex_release(mutex); - data_task = NULL; - data_comm = MSG_task_irecv(&data_task, get_data_mbox()); - } else { - XBT_DEBUG("received finalize from data"); - MSG_task_destroy(data_task); - data_task = NULL; - data_comm = NULL; - } + if (comm == ctrl_comm) + receiver1(ctrl_comm, ctrl_task, get_ctrl_mbox()); + else if (comm == data_comm) + receiver1(data_comm, data_task, get_data_mbox()); + else { + XBT_ERROR("Handling unknown comm -- %p", comm); + MSG_comm_destroy(comm); } - xbt_mutex_acquire(mutex); - if (!received.empty()) - xbt_cond_signal(cond); - xbt_mutex_release(mutex); } xbt_dynar_free(&comms); return 0;