#include <queue>
#include <string>
-#include <msg/msg.h>
+#include <simgrid/msg.h>
+#include "simgrid_features.h"
#include "synchro.h"
#include "sync_queue.h"
class message {
public:
- enum message_type { INFO, LOAD, CTRL_CLOSE, DATA_CLOSE };
+ enum class message_type { CTRL, DATA, CTRL_CLOSE, DATA_CLOSE };
message(message_type t, double a, double c = 0.0);
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(); }
private:
mutex_t mutex;
condition_t cond;
- sync_queue<m_task_t> queue;
+ sync_queue<msg_task_t> queue;
};
#endif // !MESSAGES_H