return oss.str();
}
-void message_queue::push(m_task_t task)
+void message_queue::push(msg_task_t task)
{
if (queue.push(task)) {
// list was empty, the push must be signaled
}
}
-bool message_queue::pop(message*& msg, m_host_t& from, double timeout)
+bool message_queue::pop(message*& msg, msg_host_t& from, double timeout)
{
- m_task_t task;
+ msg_task_t task;
if (!queue.try_pop(task)) {
if (timeout == 0.0)
return false;
if (!queue.try_pop(task)) {
xbt_ex_t e;
XBT_DEBUG("waiting for a message to come");
- TRY_FAST {
+ TRY {
if (timeout > 0)
cond.timedwait(mutex, timeout);
else