X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/d105e05a38d60fa6ac512c3158d3af1372f7c75d..3cbf54871089cc3dc50b6832652b5765e1601039:/src/simix/smx_synchro_private.hpp diff --git a/src/simix/smx_synchro_private.hpp b/src/simix/smx_synchro_private.hpp index 7123a0f4c9..76f8a9cfc3 100644 --- a/src/simix/smx_synchro_private.hpp +++ b/src/simix/smx_synchro_private.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2012-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2012-2018. 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. */ @@ -10,67 +10,23 @@ #include "src/simix/ActorImpl.hpp" #include -namespace simgrid { -namespace simix { - -typedef boost::intrusive::list, - &ActorImpl::smx_synchro_hook>> - SynchroList; - -class XBT_PUBLIC() MutexImpl { -public: - MutexImpl(); - ~MutexImpl(); - MutexImpl(MutexImpl const&) = delete; - MutexImpl& operator=(MutexImpl const&) = delete; - - void lock(smx_actor_t issuer); - bool try_lock(smx_actor_t issuer); - void unlock(smx_actor_t issuer); - - bool locked = false; - smx_actor_t owner = nullptr; - // List of sleeping processes: - simgrid::simix::SynchroList sleeping; - - // boost::intrusive_ptr support: - friend void intrusive_ptr_add_ref(MutexImpl* mutex) - { - XBT_ATTRIB_UNUSED auto previous = mutex->refcount_.fetch_add(1); - xbt_assert(previous != 0); - } - friend void intrusive_ptr_release(MutexImpl* mutex) - { - if (mutex->refcount_.fetch_sub(1) == 1) - delete mutex; - } - - simgrid::s4u::Mutex& mutex() { return mutex_; } - -private: - std::atomic_int_fast32_t refcount_{1}; - simgrid::s4u::Mutex mutex_; -}; -} -} +smx_activity_t SIMIX_synchro_wait(sg_host_t smx_host, double timeout); struct s_smx_cond_t { s_smx_cond_t() : cond_(this) {} std::atomic_int_fast32_t refcount_{1}; smx_mutex_t mutex = nullptr; - simgrid::simix::SynchroList sleeping; /* list of sleeping processes */ + simgrid::kernel::actor::SynchroList sleeping; /* list of sleeping processes */ simgrid::s4u::ConditionVariable cond_; }; struct s_smx_sem_t { unsigned int value; - simgrid::simix::SynchroList sleeping; /* list of sleeping processes */ + simgrid::kernel::actor::SynchroList sleeping; /* list of sleeping processes */ }; -XBT_PRIVATE void SIMIX_post_synchro(smx_activity_t synchro); XBT_PRIVATE void SIMIX_synchro_stop_waiting(smx_actor_t process, smx_simcall_t simcall); -XBT_PRIVATE void SIMIX_synchro_destroy(smx_activity_t synchro); XBT_PRIVATE void SIMIX_synchro_finish(smx_activity_t synchro); XBT_PRIVATE smx_cond_t SIMIX_cond_init();