{
return &maxpid;
}
-ActorImpl* ActorImpl::by_PID(aid_t PID)
+ActorImpl* ActorImpl::by_pid(aid_t pid)
{
- auto item = simix_global->process_list.find(PID);
+ auto item = simix_global->process_list.find(pid);
if (item != simix_global->process_list.end())
return item->second;
// Search the trash
for (auto& a : simix_global->actors_to_destroy)
- if (a.get_pid() == PID)
+ if (a.get_pid() == pid)
return &a;
return nullptr; // Not found, even in the trash
}
}
/** @brief Returns the process from PID. */
-smx_actor_t SIMIX_process_from_PID(aid_t PID)
+smx_actor_t SIMIX_process_from_PID(aid_t pid)
{
- return simgrid::kernel::actor::ActorImpl::by_PID(PID);
+ return simgrid::kernel::actor::ActorImpl::by_pid(pid);
}
void SIMIX_process_on_exit(smx_actor_t actor,
}
void AppSide::handle_simcall(const s_mc_message_simcall_handle_t* message) const
{
- kernel::actor::ActorImpl* process = kernel::actor::ActorImpl::by_PID(message->pid_);
+ kernel::actor::ActorImpl* process = kernel::actor::ActorImpl::by_pid(message->pid_);
xbt_assert(process != nullptr, "Invalid pid %lu", message->pid_);
process->simcall_handle(message->times_considered_);
if (channel_.send(MessageType::WAITING))
void AppSide::handle_actor_enabled(const s_mc_message_actor_enabled_t* msg) const
{
- bool res = simgrid::mc::actor_is_enabled(kernel::actor::ActorImpl::by_PID(msg->aid));
+ bool res = simgrid::mc::actor_is_enabled(kernel::actor::ActorImpl::by_pid(msg->aid));
s_mc_message_int_t answer{MessageType::ACTOR_ENABLED_REPLY, res};
channel_.send(answer);
}
case MessageType::SIMCALL_IS_VISIBLE: {
assert_msg_size("SIMCALL_IS_VISIBLE", s_mc_message_simcall_is_visible_t);
auto msg_simcall = (s_mc_message_simcall_is_visible_t*)message_buffer.data();
- const kernel::actor::ActorImpl* actor = kernel::actor::ActorImpl::by_PID(msg_simcall->aid);
+ const kernel::actor::ActorImpl* actor = kernel::actor::ActorImpl::by_pid(msg_simcall->aid);
xbt_assert(actor != nullptr, "Invalid pid %d", msg_simcall->aid);
xbt_assert(actor->simcall_.observer_, "The transition of %s has no observer", actor->get_cname());
bool value = actor->simcall_.observer_->is_visible();
case MessageType::SIMCALL_TO_STRING: {
assert_msg_size("SIMCALL_TO_STRING", s_mc_message_simcall_to_string_t);
auto msg_simcall = (s_mc_message_simcall_to_string_t*)message_buffer.data();
- const kernel::actor::ActorImpl* actor = kernel::actor::ActorImpl::by_PID(msg_simcall->aid);
+ const kernel::actor::ActorImpl* actor = kernel::actor::ActorImpl::by_pid(msg_simcall->aid);
xbt_assert(actor != nullptr, "Invalid pid %d", msg_simcall->aid);
xbt_assert(actor->simcall_.observer_, "The transition of %s has no observer", actor->get_cname());
std::string value = actor->simcall_.observer_->to_string(msg_simcall->time_considered);
case MessageType::SIMCALL_DOT_LABEL: {
assert_msg_size("SIMCALL_DOT_LABEL", s_mc_message_simcall_to_string_t);
auto msg_simcall = (s_mc_message_simcall_to_string_t*)message_buffer.data();
- const kernel::actor::ActorImpl* actor = kernel::actor::ActorImpl::by_PID(msg_simcall->aid);
+ const kernel::actor::ActorImpl* actor = kernel::actor::ActorImpl::by_pid(msg_simcall->aid);
xbt_assert(actor != nullptr, "Invalid pid %d", msg_simcall->aid);
xbt_assert(actor->simcall_.observer_, "The transition of %s has no observer", actor->get_cname());
std::string value = actor->simcall_.observer_->dot_label();