signal.hpp

Go to the documentation of this file.

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
/*
 * Copyright (c) 2013-2023 Regents of the University of California.
 *
 * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
 *
 * ndn-cxx library is free software: you can redistribute it and/or modify it under the
 * terms of the GNU Lesser General Public License as published by the Free Software
 * Foundation, either version 3 of the License, or (at your option) any later version.
 *
 * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY
 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
 * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
 *
 * You should have received copies of the GNU General Public License and GNU Lesser
 * General Public License along with ndn-cxx, e.g., in COPYING.md file.  If not, see
 * <http://www.gnu.org/licenses/>.
 *
 * See AUTHORS.md for complete list of ndn-cxx authors and contributors.
 */
 
#ifndef NDN_CXX_UTIL_SIGNAL_SIGNAL_HPP
#define NDN_CXX_UTIL_SIGNAL_SIGNAL_HPP
 
#include "ndn-cxx/util/scope.hpp"
#include "ndn-cxx/util/signal/connection.hpp"
 
#include <list>
 
namespace ndn::signal {
 
class DummyExtraArg;
 
template<typename Owner, typename... TArgs>
class Signal : noncopyable
{
public: // API for anyone
#ifndef BOOST_ASSERT_IS_VOID
  ~Signal() noexcept
  {
    BOOST_ASSERT(!m_isExecuting);
  }
#endif
 
  using Handler = std::function<void(const TArgs&...)>;
 
  Connection
  connect(Handler handler);
 
  Connection
  connectSingleShot(Handler handler);
 
private: // API for owner
  bool
  isEmpty() const;
 
  void
  operator()(const TArgs&... args);
 
  void
  operator()(const TArgs&... args, const DummyExtraArg&);
 
  // make Owner a friend of Signal<Owner, ...> so that API for owner can be called
  friend Owner;
 
private: // internal implementation
  using Self = Signal<Owner, TArgs...>;
 
  struct Slot
  {
    Handler handler;
 
    shared_ptr<DisconnectFunction> disconnect;
  };
 
  using SlotList = std::list<Slot>;
  SlotList m_slots;
 
  bool m_isExecuting = false;
 
  typename SlotList::iterator m_currentSlot;
 
  void
  disconnect(typename SlotList::iterator it);
};
 
template<typename Owner, typename... TArgs>
Connection
Signal<Owner, TArgs...>::connect(Handler handler)
{
  auto it = m_slots.insert(m_slots.end(), {std::move(handler), nullptr});
  it->disconnect = make_shared<DisconnectFunction>([=] { disconnect(it); });
 
  return signal::Connection(it->disconnect);
}
 
template<typename Owner, typename... TArgs>
Connection
Signal<Owner, TArgs...>::connectSingleShot(Handler handler)
{
  auto it = m_slots.insert(m_slots.end(), {nullptr, nullptr});
  it->disconnect = make_shared<DisconnectFunction>([=] { disconnect(it); });
  signal::Connection conn(it->disconnect);
 
  it->handler = [conn, handler = std::move(handler)] (const TArgs&... args) mutable {
    handler(args...);
    conn.disconnect();
  };
 
  return conn;
}
 
template<typename Owner, typename... TArgs>
void
Signal<Owner, TArgs...>::disconnect(typename SlotList::iterator it)
{
  if (m_isExecuting) {
    // during signal emission, only the currently executing handler can be disconnected
    BOOST_ASSERT_MSG(it == m_currentSlot, "cannot disconnect another handler from a handler");
 
    // this serves to indicate that the current slot needs to be erased from the list
    // after it finishes executing; we cannot do it here because of bug #2333
    m_currentSlot = m_slots.end();
 
    // expire all weak_ptrs, to prevent double disconnections
    it->disconnect.reset();
  }
  else {
    m_slots.erase(it);
  }
}
 
template<typename Owner, typename... TArgs>
bool
Signal<Owner, TArgs...>::isEmpty() const
{
  return !m_isExecuting && m_slots.empty();
}
 
template<typename Owner, typename... TArgs>
void
Signal<Owner, TArgs...>::operator()(const TArgs&... args)
{
  BOOST_ASSERT_MSG(!m_isExecuting, "cannot emit signal from a handler");
 
  if (m_slots.empty()) {
    return;
  }
 
  auto guard = make_scope_exit([this] { m_isExecuting = false; });
  m_isExecuting = true;
 
  auto it = m_slots.begin();
  auto last = std::prev(m_slots.end());
  bool isLast = false;
  while (!isLast) {
    m_currentSlot = it;
    isLast = it == last;
 
    m_currentSlot->handler(args...);
 
    if (m_currentSlot == m_slots.end())
      it = m_slots.erase(it);
    else
      ++it;
  }
}
 
template<typename Owner, typename... TArgs>
void
Signal<Owner, TArgs...>::operator()(const TArgs&... args, const DummyExtraArg&)
{
  this->operator()(args...);
}
 
} // namespace ndn::signal
 
#endif // NDN_CXX_UTIL_SIGNAL_SIGNAL_HPP