X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/124a609e80fa7bb5b7a7a698df9c6abef910d83e..eed18917aff57d3045fdf6cfecbf6fb99d1e9c7b:/messages.h diff --git a/messages.h b/messages.h index 1886301..cc6efbc 100644 --- a/messages.h +++ b/messages.h @@ -4,6 +4,7 @@ #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