X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/fd769219531a772284d75320187a0ef9f8118afd..609b277351c837356a7b284127eed888eca3620d:/include/xbt/signal.hpp diff --git a/include/xbt/signal.hpp b/include/xbt/signal.hpp index 714ae0d17d..ef4ec9cf35 100644 --- a/include/xbt/signal.hpp +++ b/include/xbt/signal.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2014-2015. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2014-2021. 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. */ @@ -6,52 +6,45 @@ #ifndef SIMGRID_XBT_SIGNAL_HPP #define SIMGRID_XBT_SIGNAL_HPP -#if SIMGRID_HAVE_LIBSIG -#include -#else -#include -#endif +#include +#include +#include namespace simgrid { namespace xbt { -#if SIMGRID_HAVE_LIBSIG - - // Wraps sigc++ signals with the interface of boost::signals2: - template class signal; - template - class signal { - private: - sigc::signal sig_; - public: - template XBT_ALWAYS_INLINE - void connect(U&& slot) - { - sig_.connect(std::forward(slot)); - } - template XBT_ALWAYS_INLINE - void connect(Res(*slot)(Args...)) - { - sig_.connect(sigc::ptr_fun(slot)); - } - template XBT_ALWAYS_INLINE - R operator()(Args&&... args) const - { - return sig_.emit(std::forward(args)...); - } - void disconnect_all_slots() - { - sig_.clear(); - } - }; - -#else - - template - using signal = ::boost::signals2::signal; - -#endif - +template class signal; + +/** @brief + * A signal/slot mechanism, where you can attach callbacks to a given signal, and then fire the signal. + * + * The template parameter is the function signature of the signal (the return value currently ignored). + */ +template class signal { + using callback_type = std::function; + std::map handlers_; + unsigned int callback_sequence_id = 0; + +public: + /** Add a new callback to this signal */ + template unsigned int connect(U slot) + { + handlers_.insert({callback_sequence_id, std::move(slot)}); + return callback_sequence_id++; + } + /** Fire that signal, invoking all callbacks */ + R operator()(P... args) const + { + for (auto const& handler : handlers_) + handler.second(args...); + } + /** Remove a callback */ + void disconnect(unsigned int id) { handlers_.erase(id); } + /** Remove all callbacks */ + void disconnect_slots() { handlers_.clear(); } + /** Get the amount of callbacks */ + int get_slot_count() { return handlers_.size(); } +}; } }