X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/5ea4e2d40842a43c9a5c2c4d360f928e5dbd3532..2c8da5a553c6f0c6cd07dcbfbb8f09d4f5a2f389:/communicator.h?ds=sidebyside diff --git a/communicator.h b/communicator.h index 0d47ca0..cae340c 100644 --- a/communicator.h +++ b/communicator.h @@ -46,10 +46,6 @@ private: // Myself const hostdata* host; - // Used to synchronize main and receiver thread - xbt_mutex_t mutex; - xbt_cond_t cond; - // List of pending send communications std::list sent_comm; @@ -68,7 +64,9 @@ private: const char* get_data_mbox() const { return host->get_data_mbox(); } // Handling of receiving thread - m_process_t receiver_process; + 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); int receiver();