-/* Copyright (c) 2019-2022. The SimGrid Team. All rights reserved. */
+/* Copyright (c) 2019-2023. The SimGrid Team. All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
* under the terms of the license (GNU LGPL) which comes with this package. */
}
std::string MutexObserver::to_string() const
{
- return std::string(mc::Transition::to_c_str(type_)) + "(mutex_id: " + std::to_string(get_mutex()->get_id()) +
- "owner:" + std::to_string(get_mutex()->get_owner()->get_pid()) + ")";
+ return std::string(mc::Transition::to_c_str(type_)) + "(mutex_id:" + std::to_string(get_mutex()->get_id()) +
+ " owner:" +
+ (get_mutex()->get_owner() == nullptr ? "none" : std::to_string(get_mutex()->get_owner()->get_pid())) + ")";
}
bool MutexObserver::is_enabled()
void SemaphoreObserver::serialize(std::stringstream& stream) const
{
- stream << (short)type_ << ' ' << get_sem()->get_id() << ' ' << false /* Granted is ignored for LOCK/UNLOCK */;
+ stream << (short)type_ << ' ' << get_sem()->get_id() << ' ' << false /* Granted is ignored for LOCK/UNLOCK */ << ' '
+ << get_sem()->get_capacity();
}
std::string SemaphoreObserver::to_string() const
{
- return std::string(mc::Transition::to_c_str(type_)) + "(sem_id: " + std::to_string(get_sem()->get_id()) + ")";
+ return std::string(mc::Transition::to_c_str(type_)) + "(sem_id:" + std::to_string(get_sem()->get_id()) + ")";
}
SemaphoreAcquisitionObserver::SemaphoreAcquisitionObserver(ActorImpl* actor, mc::Transition::Type type,
}
void SemaphoreAcquisitionObserver::serialize(std::stringstream& stream) const
{
- stream << (short)type_ << ' ' << acquisition_->semaphore_->get_id() << ' ' << acquisition_->granted_;
+ stream << (short)type_ << ' ' << acquisition_->semaphore_->get_id() << ' ' << acquisition_->granted_ << ' '
+ << acquisition_->semaphore_->get_capacity();
}
std::string SemaphoreAcquisitionObserver::to_string() const
{
return std::string(mc::Transition::to_c_str(type_)) +
- "(sem_id: " + std::to_string(acquisition_->semaphore_->get_id()) + ' ' +
+ "(sem_id:" + std::to_string(acquisition_->semaphore_->get_id()) + ' ' +
(acquisition_->granted_ ? "granted)" : "not granted)");
}
std::string BarrierObserver::to_string() const
{
return std::string(mc::Transition::to_c_str(type_)) +
- "(barrier_id: " + std::to_string(barrier_ != nullptr ? barrier_->get_id() : acquisition_->barrier_->get_id()) +
+ "(barrier_id:" + std::to_string(barrier_ != nullptr ? barrier_->get_id() : acquisition_->barrier_->get_id()) +
")";
}
bool BarrierObserver::is_enabled()
(type_ == mc::Transition::Type::BARRIER_WAIT && acquisition_ != nullptr && acquisition_->granted_);
}
+bool ConditionVariableObserver::is_enabled()
+{
+ if (static bool warned = false; not warned) {
+ XBT_INFO("Using condition variables in model-checked code is still experimental. Use at your own risk");
+ warned = true;
+ }
+ return true;
+}
+void ConditionVariableObserver::serialize(std::stringstream& stream) const
+{
+ THROW_UNIMPLEMENTED;
+}
+std::string ConditionVariableObserver::to_string() const
+{
+ return "ConditionWait(cond_id:" + ptr_to_id<activity::ConditionVariableImpl const>(get_cond()) +
+ " mutex_id:" + std::to_string(get_mutex()->get_id()) + ")";
+}
+
} // namespace simgrid::kernel::actor