// Queue of received messages
std::queue<m_task_t> received;
- // Control channel for receiving
- m_task_t ctrl_task; // receive buffer
- msg_comm_t ctrl_comm; // receive communication
-
- // Data channel for receiving
- m_task_t data_task; // receive buffer
- msg_comm_t data_comm; // receive communication
-
- const char* get_ctrl_mbox() const { return host->get_ctrl_mbox(); }
- const char* get_data_mbox() const { return host->get_data_mbox(); }
-
// Handling of receiving thread
xbt_mutex_t receiver_mutex;
xbt_cond_t receiver_cond;
m_process_t receiver_thread;
static int receiver_wrapper(int, char* []);
- void receiver1(msg_comm_t& comm, m_task_t& task, const char* mbox);
void receiver();
// Used to chek if a communication is successfull before destroying it