namespace kernel {
namespace activity {
-MutexImpl::MutexImpl() : piface_(this)
-{
- XBT_IN("(%p)", this);
- XBT_OUT();
-}
-
-MutexImpl::~MutexImpl()
-{
- XBT_IN("(%p)", this);
- XBT_OUT();
-}
-
void MutexImpl::lock(actor::ActorImpl* issuer)
{
XBT_IN("(%p; %p)", this, issuer);
/* mutex free */
locked_ = true;
owner_ = issuer;
- SIMIX_simcall_answer(&issuer->simcall);
+ issuer->simcall_answer();
}
XBT_OUT();
}
void MutexImpl::unlock(actor::ActorImpl* issuer)
{
XBT_IN("(%p, %p)", this, issuer);
- if (not locked_)
- THROWF(mismatch_error, 0, "Cannot release that mutex: it was not locked.");
-
- /* If the mutex is not owned by the issuer, that's not good */
- if (issuer != owner_)
- THROWF(mismatch_error, 0, "Cannot release that mutex: it was locked by %s (pid:%ld), not by you.",
- owner_->get_cname(), owner_->get_pid());
+ xbt_assert(locked_, "Cannot release that mutex: it was not locked.");
+ xbt_assert(issuer == owner_, "Cannot release that mutex: it was locked by %s (pid:%ld), not by you.",
+ owner_->get_cname(), owner_->get_pid());
if (not sleeping_.empty()) {
- /*process to wake up */
- actor::ActorImpl* p = &sleeping_.front();
+ /* pick one actor to wake up */
+ actor::ActorImpl* act = &sleeping_.front();
sleeping_.pop_front();
- p->waiting_synchro = nullptr;
- owner_ = p;
- SIMIX_simcall_answer(&p->simcall);
+ act->waiting_synchro = nullptr;
+ owner_ = act;
+ act->simcall_answer();
} else {
/* nobody to wake up */
locked_ = false;