-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)
stream << ' ' << (uintptr_t)comm->src_buff_ << ' ' << (uintptr_t)comm->dst_buff_ << ' ' << comm->src_buff_size_;
} else {
stream << (short)mc::Transition::Type::UNKNOWN;
stream << ' ' << (uintptr_t)comm->src_buff_ << ' ' << (uintptr_t)comm->dst_buff_ << ' ' << comm->src_buff_size_;
} else {
stream << (short)mc::Transition::Type::UNKNOWN;
void ActivityTestSimcall::serialize(std::stringstream& stream) const
{
serialize_activity_test(activity_, stream);
void ActivityTestSimcall::serialize(std::stringstream& stream) const
{
serialize_activity_test(activity_, stream);
void ActivityWaitSimcall::serialize(std::stringstream& stream) const
{
serialize_activity_wait(activity_, timeout_ > 0, stream);
void ActivityWaitSimcall::serialize(std::stringstream& stream) const
{
serialize_activity_wait(activity_, timeout_ > 0, stream);
return buffer.str();
}
ActivityWaitanySimcall::ActivityWaitanySimcall(ActorImpl* actor, const std::vector<activity::ActivityImpl*>& activities,
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)
<< src_buff_size_ << ' ' << tag_;
XBT_DEBUG("SendObserver comm:%p mbox:%u buff:%p size:%zu tag:%d", comm_, mbox_->get_id(), src_buff_, src_buff_size_,
tag_);
<< src_buff_size_ << ' ' << 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 << (short)mc::Transition::Type::COMM_ASYNC_RECV << ' ';
stream << (comm_ ? comm_->get_id() : 0) << ' ' << 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 << (short)mc::Transition::Type::COMM_ASYNC_RECV << ' ';
stream << (comm_ ? comm_->get_id() : 0) << ' ' << 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_);