return oss.str();
}
-const int communicator::send_count_before_flush = 16;
+const int communicator::send_count_before_flush = 4;
communicator::communicator()
: host((hostdata* )MSG_host_get_data(MSG_host_self()))
void communicator::flush(bool wait)
{
- using namespace std::tr1;
- using namespace std::tr1::placeholders;
+ using std::tr1::bind;
+ using std::tr1::placeholders::_1;
sent_comm.remove_if(comm_test_n_destroy);
if (wait && !sent_comm.empty()) {