XBT_PUBLIC void simcall_process_suspend(smx_actor_t process);
/* Getters and Setters */
-XBT_PUBLIC void simcall_process_set_data(smx_actor_t process, void* data);
XBT_PUBLIC void simcall_process_set_kill_time(smx_actor_t process, double kill_time);
XBT_PUBLIC void simcall_process_join(smx_actor_t process, double timeout);
/* Sleep control */
int (*match_fun)(void*, void*, simgrid::kernel::activity::CommImpl*),
void* data);
#endif
-XBT_PUBLIC void simcall_comm_cancel(smx_activity_t comm);
/* FIXME: waitany is going to be a vararg function, and should take a timeout */
XBT_PUBLIC unsigned int simcall_comm_waitany(xbt_dynar_t comms, double timeout);
if (simdata->compute) {
simgrid::simix::simcall([simdata] { simdata->compute->cancel(); });
} else if (simdata->comm) {
- simcall_comm_cancel(simdata->comm);
+ simgrid::simix::simcall([simdata] { simdata->comm->cancel(); });
}
simdata->setNotUsed();
return MSG_OK;
simcall_BODY_process_suspend(process);
}
-/**
- * @ingroup simix_process_management
- * @brief Set the user data of a #smx_actor_t.
- *
- * This functions sets the user data associated to @a process.
- * @param process SIMIX process
- * @param data User data
- */
-void simcall_process_set_data(smx_actor_t process, void *data)
-{
- simgrid::simix::simcall([process, data] { process->set_user_data(data); });
-}
-
/**
* @ingroup simix_process_management
* @brief Set the kill time of a process.
return simcall_BODY_comm_iprobe(mbox, type, match_fun, data);
}
-/**
- * @ingroup simix_comm_management
- */
-void simcall_comm_cancel(smx_activity_t synchro)
-{
- simgrid::simix::simcall([synchro] {
- simgrid::kernel::activity::CommImplPtr comm =
- boost::static_pointer_cast<simgrid::kernel::activity::CommImpl>(synchro);
- comm->cancel();
- });
-}
-
/**
* @ingroup simix_comm_management
*/