#include <string>
#include <msg/msg.h>
#include "hostdata.h"
+#include "synchro.h"
class message {
public:
std::queue<m_task_t> received;
// Handling of receiving thread
- xbt_mutex_t receiver_mutex;
- xbt_cond_t receiver_cond;
+ mutex_t receiver_mutex;
+ condition_t receiver_cond;
m_process_t receiver_thread;
static int receiver_wrapper(int, char* []);
void receiver();