X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/4ed2ded99f037e413c9008a324c85f8f95611bb5..f2850cc1d935992994177c2c266141d5304d4694:/communicator.h?ds=sidebyside diff --git a/communicator.h b/communicator.h index 091594f..c335920 100644 --- a/communicator.h +++ b/communicator.h @@ -52,23 +52,11 @@ private: // Queue of received messages std::queue received; - // Control channel for receiving - m_task_t ctrl_task; // receive buffer - msg_comm_t ctrl_comm; // receive communication - - // Data channel for receiving - m_task_t data_task; // receive buffer - msg_comm_t data_comm; // receive communication - - const char* get_ctrl_mbox() const { return host->get_ctrl_mbox(); } - const char* get_data_mbox() const { return host->get_data_mbox(); } - // Handling of receiving thread xbt_mutex_t receiver_mutex; xbt_cond_t receiver_cond; m_process_t receiver_thread; static int receiver_wrapper(int, char* []); - void receiver1(msg_comm_t& comm, m_task_t& task, const char* mbox); void receiver(); // Used to chek if a communication is successfull before destroying it