X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/5089a0a98b27f5eeee62321dff4f025f1648f025..77a41b7646e3b7f3e278940e64a06c6bfa08c73f:/src/kernel/activity/ConditionVariableImpl.cpp diff --git a/src/kernel/activity/ConditionVariableImpl.cpp b/src/kernel/activity/ConditionVariableImpl.cpp index 027ef16d18..fdc1def05a 100644 --- a/src/kernel/activity/ConditionVariableImpl.cpp +++ b/src/kernel/activity/ConditionVariableImpl.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2007-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2020. 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. */ @@ -21,6 +21,7 @@ void simcall_HANDLER_cond_wait(smx_simcall_t simcall, smx_cond_t cond, smx_mutex /** @brief Handle a condition waiting simcall with timeouts */ void simcall_HANDLER_cond_wait_timeout(smx_simcall_t simcall, smx_cond_t cond, smx_mutex_t mutex, double timeout) { + simcall_cond_wait_timeout__set__result(simcall, 0); // default result, will be set to 1 on timeout cond->wait(mutex, timeout, simcall->issuer_); } @@ -28,9 +29,6 @@ namespace simgrid { namespace kernel { namespace activity { -ConditionVariableImpl::ConditionVariableImpl() : cond_(this) {} -ConditionVariableImpl::~ConditionVariableImpl() = default; - /** * @brief Signalizes a condition. * @@ -48,10 +46,10 @@ void ConditionVariableImpl::signal() sleeping_.pop_front(); /* Destroy waiter's synchronization */ - proc.waiting_synchro = nullptr; + proc.waiting_synchro_ = nullptr; /* Now transform the cond wait simcall into a mutex lock one */ - smx_simcall_t simcall = &proc.simcall; + smx_simcall_t simcall = &proc.simcall_; MutexImpl* simcall_mutex; if (simcall->call_ == SIMCALL_COND_WAIT) simcall_mutex = simcall_cond_wait__get__mutex(simcall); @@ -85,7 +83,7 @@ void ConditionVariableImpl::wait(smx_mutex_t mutex, double timeout, actor::Actor /* If there is a mutex unlock it */ if (mutex != nullptr) { - xbt_assert(mutex->owner_ == issuer, + xbt_assert(mutex->get_owner() == issuer, "Actor %s cannot wait on ConditionVariable %p since it does not own the provided mutex %p", issuer->get_cname(), this, mutex); mutex_ = mutex; @@ -94,7 +92,7 @@ void ConditionVariableImpl::wait(smx_mutex_t mutex, double timeout, actor::Actor RawImplPtr synchro(new RawImpl()); synchro->set_host(issuer->get_host()).set_timeout(timeout).start(); - synchro->register_simcall(&issuer->simcall); + synchro->register_simcall(&issuer->simcall_); sleeping_.push_back(*issuer); }