xbt_fifo_remove_item(fifo, item);
xbt_fifo_free_item(item);
synchro->comm.refcount++;
-#ifdef HAVE_MC
+#if HAVE_MC
synchro->comm.rdv_cpy = synchro->comm.rdv;
#endif
synchro->comm.rdv = NULL;
synchro->comm.src_data=NULL;
synchro->comm.dst_data=NULL;
-
-#ifdef HAVE_LATENCY_BOUND_TRACKING
- //initialize with unknown value
- synchro->latency_limited = -1;
-#endif
-
synchro->category = NULL;
XBT_DEBUG("Create communicate synchro %p", synchro);
XBT_DEBUG("Really free communication %p; refcount is now %d", synchro,
synchro->comm.refcount);
-#ifdef HAVE_LATENCY_BOUND_TRACKING
- synchro->latency_limited = SIMIX_comm_is_latency_bounded( synchro ) ;
-#endif
-
xbt_free(synchro->name);
SIMIX_comm_destroy_internal_actions(synchro);
void SIMIX_comm_destroy_internal_actions(smx_synchro_t synchro)
{
if (synchro->comm.surf_comm){
-#ifdef HAVE_LATENCY_BOUND_TRACKING
- synchro->latency_limited = SIMIX_comm_is_latency_bounded(synchro);
-#endif
synchro->comm.surf_comm->unref();
synchro->comm.surf_comm = NULL;
}
synchro->state = SIMIX_RUNNING;
/* If a link is failed, detect it immediately */
- if (synchro->comm.surf_comm->getState() == SURF_ACTION_FAILED) {
+ if (synchro->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));
synchro->state = SIMIX_LINK_FAILURE;
{
/* Update synchro state */
if (synchro->comm.src_timeout &&
- synchro->comm.src_timeout->getState() == SURF_ACTION_DONE)
+ synchro->comm.src_timeout->getState() == simgrid::surf::Action::State::done)
synchro->state = SIMIX_SRC_TIMEOUT;
else if (synchro->comm.dst_timeout &&
- synchro->comm.dst_timeout->getState() == SURF_ACTION_DONE)
+ synchro->comm.dst_timeout->getState() == simgrid::surf::Action::State::done)
synchro->state = SIMIX_DST_TIMEOUT;
else if (synchro->comm.src_timeout &&
- synchro->comm.src_timeout->getState() == SURF_ACTION_FAILED)
+ synchro->comm.src_timeout->getState() == simgrid::surf::Action::State::failed)
synchro->state = SIMIX_SRC_HOST_FAILURE;
else if (synchro->comm.dst_timeout &&
- synchro->comm.dst_timeout->getState() == SURF_ACTION_FAILED)
+ synchro->comm.dst_timeout->getState() == simgrid::surf::Action::State::failed)
synchro->state = SIMIX_DST_HOST_FAILURE;
else if (synchro->comm.surf_comm &&
- synchro->comm.surf_comm->getState() == SURF_ACTION_FAILED) {
+ synchro->comm.surf_comm->getState() == simgrid::surf::Action::State::failed) {
XBT_DEBUG("Puta madre. Surf says that the link broke");
synchro->state = SIMIX_LINK_FAILURE;
} else
return synchro->comm.dst_proc;
}
-#ifdef HAVE_LATENCY_BOUND_TRACKING
-/**
- * \brief verify if communication is latency bounded
- * \param comm The communication
- */
-int SIMIX_comm_is_latency_bounded(smx_synchro_t synchro)
-{
- if(!synchro){
- return 0;
- }
- if (synchro->comm.surf_comm){
- XBT_DEBUG("Getting latency limited for surf_action (%p)", synchro->comm.surf_comm);
- synchro->latency_limited = surf_network_action_get_latency_limited(synchro->comm.surf_comm);
- XBT_DEBUG("synchro limited is %d", synchro->latency_limited);
- }
- return synchro->latency_limited;
-}
-#endif
-
/******************************************************************************/
/* SIMIX_comm_copy_data callbacks */
/******************************************************************************/