Actor* Comm::get_sender() const
{
- return sender_ ? sender_->ciface() : nullptr;
+ kernel::actor::ActorImplPtr sender = nullptr;
+ if (pimpl_)
+ sender = boost::static_pointer_cast<kernel::activity::CommImpl>(pimpl_)->src_actor_;
+ return sender ? sender->ciface() : nullptr;
}
} // namespace s4u
} // namespace simgrid
/* **************************** Public C interface *************************** */
+void sg_comm_detach(sg_comm_t comm, void (*clean_function)(void*))
+{
+ comm->detach(clean_function);
+ comm->unref();
+}
+void sg_comm_unref(sg_comm_t comm)
+{
+ comm->unref();
+}
int sg_comm_test(sg_comm_t comm)
{
bool finished = comm->test();