-#include "communicator.h"
-
#include <algorithm>
#include <tr1/functional>
#include <sstream>
#include <msg/msg.h>
#include <xbt/log.h>
+
+XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(comm);
+
#include "misc.h"
#include "options.h"
-XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(comm);
+#include "communicator.h"
std::string message::to_string()
{
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()) {