X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/124a609e80fa7bb5b7a7a698df9c6abef910d83e..20ee10ed13aee7d9fb9c844648d5159ed4a054d2:/messages.h diff --git a/messages.h b/messages.h index 1886301..925047d 100644 --- a/messages.h +++ b/messages.h @@ -3,7 +3,8 @@ #include #include -#include +#include +#include "simgrid_features.h" #include "synchro.h" #include "sync_queue.h" @@ -30,12 +31,12 @@ private: class message_queue { public: // Push a message on queue - void push(m_task_t task); + void push(msg_task_t task); // Try to pop a message. Returns true on success. // Parameter "timeout" may be 0 for non-blocking operation, -1 for // infinite waiting, or any positive timeout. - bool pop(message*& msg, m_host_t& from, double timeout); + bool pop(message*& msg, msg_host_t& from, double timeout); bool empty() const { return queue.empty(); } size_t size() const { return queue.size(); } @@ -43,7 +44,7 @@ public: private: mutex_t mutex; condition_t cond; - sync_queue queue; + sync_queue queue; }; #endif // !MESSAGES_H