simgrid::s4u::Host* sender = comm->src_proc->host;
simgrid::s4u::Host* receiver = comm->dst_proc->host;
- XBT_DEBUG("Starting communication %p from '%s' to '%s'", synchro, sg_host_get_name(sender), sg_host_get_name(receiver));
+ XBT_DEBUG("Starting communication %p from '%s' to '%s'", synchro, sender->cname(), receiver->cname());
comm->surf_comm = surf_network_model->communicate(sender, receiver, comm->task_size, comm->rate);
comm->surf_comm->setData(synchro);
/* If a link is failed, detect it immediately */
if (comm->surf_comm->getState() == simgrid::surf::Action::State::failed) {
- XBT_DEBUG("Communication from '%s' to '%s' failed to start because of a link failure",
- sg_host_get_name(sender), sg_host_get_name(receiver));
+ XBT_DEBUG("Communication from '%s' to '%s' failed to start because of a link failure", sender->cname(),
+ receiver->cname());
comm->state = SIMIX_LINK_FAILURE;
comm->cleanupSurf();
}
it will be restarted when the sender process resume */
if (SIMIX_process_is_suspended(comm->src_proc) || SIMIX_process_is_suspended(comm->dst_proc)) {
if (SIMIX_process_is_suspended(comm->src_proc))
- XBT_DEBUG("The communication is suspended on startup because src (%s@%s) was suspended since it initiated the communication",
- comm->src_proc->name.c_str(), sg_host_get_name(comm->src_proc->host));
+ XBT_DEBUG("The communication is suspended on startup because src (%s@%s) was suspended since it initiated the "
+ "communication",
+ comm->src_proc->cname(), comm->src_proc->host->cname());
else
- XBT_DEBUG("The communication is suspended on startup because dst (%s@%s) was suspended since it initiated the communication",
- comm->dst_proc->name.c_str(), sg_host_get_name(comm->dst_proc->host));
+ XBT_DEBUG("The communication is suspended on startup because dst (%s@%s) was suspended since it initiated the "
+ "communication",
+ comm->dst_proc->cname(), comm->dst_proc->host->cname());
comm->surf_comm->suspend();
}
case SIMIX_LINK_FAILURE:
- XBT_DEBUG("Link failure in synchro %p between '%s' and '%s': posting an exception to the issuer: %s (%p) detached:%d",
- synchro,
- comm->src_proc ? sg_host_get_name(comm->src_proc->host) : nullptr,
- comm->dst_proc ? sg_host_get_name(comm->dst_proc->host) : nullptr,
- simcall->issuer->name.c_str(), simcall->issuer, comm->detached);
+ XBT_DEBUG(
+ "Link failure in synchro %p between '%s' and '%s': posting an exception to the issuer: %s (%p) detached:%d",
+ synchro, comm->src_proc ? comm->src_proc->host->cname() : nullptr,
+ comm->dst_proc ? comm->dst_proc->host->cname() : nullptr, simcall->issuer->cname(), simcall->issuer,
+ comm->detached);
if (comm->src_proc == simcall->issuer) {
XBT_DEBUG("I'm source");
} else if (comm->dst_proc == simcall->issuer) {
if (!comm->src_buff || !comm->dst_buff || comm->copied)
return;
- XBT_DEBUG("Copying comm %p data from %s (%p) -> %s (%p) (%zu bytes)",
- comm,
- comm->src_proc ? sg_host_get_name(comm->src_proc->host) : "a finished process",
- comm->src_buff,
- comm->dst_proc ? sg_host_get_name(comm->dst_proc->host) : "a finished process",
- comm->dst_buff, buff_size);
+ XBT_DEBUG("Copying comm %p data from %s (%p) -> %s (%p) (%zu bytes)", comm,
+ comm->src_proc ? comm->src_proc->host->cname() : "a finished process", comm->src_buff,
+ comm->dst_proc ? comm->dst_proc->host->cname() : "a finished process", comm->dst_buff, buff_size);
/* Copy at most dst_buff_size bytes of the message to receiver's buffer */
if (comm->dst_buff_size)