X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/92cd12d0b61dd5a17500ef7d38f7b95a80301037..e1b4987a80f98fb1266086561cefef20c1993a6b:/src/s4u/s4u_ConditionVariable.cpp diff --git a/src/s4u/s4u_ConditionVariable.cpp b/src/s4u/s4u_ConditionVariable.cpp index 0e9683f9db..c95fc4f6d7 100644 --- a/src/s4u/s4u_ConditionVariable.cpp +++ b/src/s4u/s4u_ConditionVariable.cpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2006-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2006-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. */ @@ -20,7 +20,7 @@ ConditionVariablePtr ConditionVariable::create() { kernel::activity::ConditionVariableImpl* cond = kernel::actor::simcall([] { return new kernel::activity::ConditionVariableImpl(); }); - return ConditionVariablePtr(&cond->cond_, false); + return ConditionVariablePtr(cond->get_iface(), false); } /** @@ -31,12 +31,12 @@ void ConditionVariable::wait(MutexPtr lock) simcall_cond_wait(cond_, lock->pimpl_); } -void ConditionVariable::wait(std::unique_lock& lock) +void ConditionVariable::wait(const std::unique_lock& lock) { simcall_cond_wait(cond_, lock.mutex()->pimpl_); } -std::cv_status s4u::ConditionVariable::wait_for(std::unique_lock& lock, double timeout) +std::cv_status s4u::ConditionVariable::wait_for(const std::unique_lock& lock, double timeout) { // The simcall uses -1 for "any timeout" but we don't want this: if (timeout < 0) @@ -51,7 +51,7 @@ std::cv_status s4u::ConditionVariable::wait_for(std::unique_lock& lock, d } } -std::cv_status ConditionVariable::wait_until(std::unique_lock& lock, double timeout_time) +std::cv_status ConditionVariable::wait_until(const std::unique_lock& lock, double timeout_time) { double now = SIMIX_get_clock(); double timeout; @@ -75,12 +75,12 @@ void ConditionVariable::notify_all() simgrid::kernel::actor::simcall([this]() { cond_->broadcast(); }); } -void intrusive_ptr_add_ref(ConditionVariable* cond) +void intrusive_ptr_add_ref(const ConditionVariable* cond) { intrusive_ptr_add_ref(cond->cond_); } -void intrusive_ptr_release(ConditionVariable* cond) +void intrusive_ptr_release(const ConditionVariable* cond) { intrusive_ptr_release(cond->cond_); } @@ -118,7 +118,7 @@ void sg_cond_notify_all(sg_cond_t cond) cond->notify_all(); } -void sg_cond_destroy(sg_cond_t cond) +void sg_cond_destroy(const_sg_cond_t cond) { delete cond; }