X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/892e36c1af3105e5f548a4ef8b9f777b95d47fc2..e9c3c48dfa8ea8ebddb2550a1cdd9981c8874bf8:/communicator.h?ds=inline diff --git a/communicator.h b/communicator.h index 7cb1efc..ce74f07 100644 --- a/communicator.h +++ b/communicator.h @@ -3,11 +3,11 @@ #ifndef COMMUNICATOR_H #define COMMUNICATOR_H -#include +#include #include #include "hostdata.h" #include "messages.h" -#include "synchro.h" +#include "msg_thread.h" class communicator { public: @@ -31,16 +31,14 @@ private: const hostdata* host; // List of pending send communications - std::list sent_comm; + typedef std::vector sent_comm_type; + sent_comm_type sent_comm; // Queue of received messages message_queue received; // Handling of receiving thread - mutex_t receiver_mutex; - condition_t receiver_cond; - m_process_t receiver_thread; - static int receiver_wrapper(int, char* []); + msg_thread* receiver_thread; void receiver(); // Used to chek if a communication is successfull before destroying it