namespace simgrid::kernel::actor {
-ActivityTestanySimcall::ActivityTestanySimcall(ActorImpl* actor, const std::vector<activity::ActivityImpl*>& activities)
- : ResultingSimcall(actor, -1), activities_(activities)
+ActivityTestanySimcall::ActivityTestanySimcall(ActorImpl* actor, const std::vector<activity::ActivityImpl*>& activities,
+ std::string fun_call)
+ : ResultingSimcall(actor, -1), activities_(activities), fun_call_(fun_call)
{
indexes_.clear();
// list all the activities that are ready
serialize_activity_test(act, stream);
stream << ' ';
}
+ stream << fun_call_;
}
std::string ActivityTestanySimcall::to_string() const
{
void ActivityTestSimcall::serialize(std::stringstream& stream) const
{
serialize_activity_test(activity_, stream);
+ stream << ' ' << fun_call_;
}
std::string ActivityTestSimcall::to_string() const
{
void ActivityWaitSimcall::serialize(std::stringstream& stream) const
{
serialize_activity_wait(activity_, timeout_ > 0, stream);
+ stream << ' ' << fun_call_;
}
void ActivityWaitanySimcall::serialize(std::stringstream& stream) const
{
serialize_activity_wait(act, timeout_ > 0, stream);
stream << ' ';
}
+ stream << fun_call_;
}
std::string ActivityWaitSimcall::to_string() const
{
return buffer.str();
}
ActivityWaitanySimcall::ActivityWaitanySimcall(ActorImpl* actor, const std::vector<activity::ActivityImpl*>& activities,
- double timeout)
- : ResultingSimcall(actor, -1), activities_(activities), timeout_(timeout)
+ double timeout, std::string fun_call)
+ : ResultingSimcall(actor, -1), activities_(activities), timeout_(timeout), fun_call_(fun_call)
{
// list all the activities that are ready
indexes_.clear();
<< tag_;
XBT_DEBUG("SendObserver comm:%p mbox:%u buff:%p size:%zu tag:%d", comm_, mbox_->get_id(), src_buff_, src_buff_size_,
tag_);
+ stream << ' ' << fun_call_;
}
std::string CommIsendSimcall::to_string() const
{
stream << (short)mc::Transition::Type::COMM_ASYNC_RECV << ' ';
stream << (uintptr_t)comm_ << ' ' << mbox_->get_id() << ' ' << (uintptr_t)dst_buff_ << ' ' << tag_;
XBT_DEBUG("RecvObserver comm:%p mbox:%u buff:%p tag:%d", comm_, mbox_->get_id(), dst_buff_, tag_);
+ stream << ' ' << fun_call_;
}
std::string CommIrecvSimcall::to_string() const
{