#include <algorithm>
-#include <tr1/functional>
+#include <functional>
#include <msg/msg.h>
#include <xbt/log.h>
communicator::communicator()
: host(static_cast<hostdata*>(MSG_host_get_data(MSG_host_self())))
{
- using std::tr1::bind;
receiver_thread = new_msg_thread("receiver",
- bind(&communicator::receiver, this));
+ std::bind(&communicator::receiver, this));
receiver_thread->start();
}
std::copy(sent_comm.begin(), sent_comm.end(), comms);
sent_comm.clear();
MSG_comm_waitall(comms, size, -1.0);
- if (!MSG_WAIT_DESTROYS_COMMS)
- std::for_each(comms, comms + size, comm_check_n_destroy);
+ std::for_each(comms, comms + size, comm_check_n_destroy);
delete[] comms;
}
}