oss << "; " << credit << " (credit)";
break;
case DATA:
- oss << "DATA: " << amount << " (load)";
+ oss << "DATA: " << amount << " (load)";
break;
case CTRL_CLOSE:
oss << "CTRL_CLOSE";
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;