XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(comm);
#include "misc.h"
-#include "options.h"
#include "simgrid_features.h"
#include "tracing.h"
msg_comm_t communicator::real_send(const char* dest, message* msg)
{
XBT_DEBUG("send %s to %s", msg->to_string().c_str(), dest);
- double msg_size = sizeof *msg;
- if (msg->get_type() == message::LOAD)
- msg_size += opt::comm_cost(msg->get_amount());
- m_task_t task = MSG_task_create("message", 0.0, msg_size, msg);
+ m_task_t task = MSG_task_create("message", 0.0, msg->get_size(), msg);
TRACE_msg_set_task_category(task,
msg->get_type() == message::LOAD ?
TRACE_CAT_DATA : TRACE_CAT_CTRL);
void communicator::real_flush(sent_comm_type& sent_comm, bool wait)
{
- sent_comm_type::iterator bound;
- bound = std::remove_if(sent_comm.begin(), sent_comm.end(),
- comm_test_n_destroy);
+ sent_comm_type::iterator bound =
+ std::remove_if(sent_comm.begin(), sent_comm.end(),
+ comm_test_n_destroy);
sent_comm.erase(bound, sent_comm.end());
if (wait && !sent_comm.empty()) {
size_t size = sent_comm.size();