eventdispatcher.h

Go to the documentation of this file.

/*---------------------------------------------------------------------\
|                          ____ _   __ __ ___                          |
|                         |__  / \ / / . \ . \                         |
|                           / / \ V /|  _/  _/                         |
|                          / /__ | | | | | |                           |
|                         /_____||_| |_| |_|                           |
|                                                                      |
\----------------------------------------------------------------------/
*
* This file contains private API, this might break at any time between releases.
* You have been warned!
*
*/
#ifndef ZYPP_BASE_EVENTDISPATCHER_DEFINED
#define ZYPP_BASE_EVENTDISPATCHER_DEFINED
 
#include <zypp/zyppng/base/zyppglobal.h>
#include <zypp/zyppng/base/Signals>
#include <zypp/zyppng/base/Base>
#include <zypp/zyppng/base/AbstractEventSource>
#include <memory>
#include <functional>
 
namespace zyppng {
 
class SocketNotifier;
class Timer;
class EventDispatcher;
 
 
class EventDispatcherPrivate;
 
class LIBZYPP_NG_EXPORT EventDispatcher : public Base
{
  ZYPP_DECLARE_PRIVATE(EventDispatcher)
  friend class AbstractEventSource;
  friend class Timer;
 
public:
 
  using Ptr = std::shared_ptr<EventDispatcher>;
  using WeakPtr = std::shared_ptr<EventDispatcher>;
  using IdleFunction = std::function<bool ()>;
 
  static std::shared_ptr<EventDispatcher> createMain ( );
 
  static std::shared_ptr<EventDispatcher> createForThread ( );
 
  virtual ~EventDispatcher();
 
  virtual bool run_once();
 
  virtual void run ();
 
  virtual void quit ();
 
  template< typename T = IdleFunction >
  static void invokeOnIdle ( T &&callback )
  {
    auto ev = instance();
    if ( ev )
      ev->invokeOnIdleImpl( std::forward<T>(callback) );
  }
 
  template< typename T >
  static void unrefLater ( T &&ptr ) {
    auto ev = instance();
    if ( ev )
      ev->unrefLaterImpl( std::static_pointer_cast<void>( std::forward<T>(ptr) ) );
  }
 
  ulong runningTimers() const;
 
  static std::shared_ptr<EventDispatcher> instance();
 
protected:
 
  EventDispatcher( void *ctx = nullptr );
 
  void unrefLaterImpl ( std::shared_ptr<void> &&ptr );
 
  void invokeOnIdleImpl ( IdleFunction &&callback );
 
  virtual void updateEventSource ( AbstractEventSource *notifier, int fd, int mode );
 
  virtual void removeEventSource   ( AbstractEventSource *notifier, int fd = -1 );
 
  virtual void registerTimer ( Timer *timer );
 
  virtual void removeTimer ( Timer *timer );
};
 
}
 
#endif