eventdispatcher_glib_p.h

Go to the documentation of this file.

#ifndef ZYPP_BASE_EVENTDISPATCHER_GLIB_P_DEFINED
#define ZYPP_BASE_EVENTDISPATCHER_GLIB_P_DEFINED
 
#include "base_p.h"
#include <zypp-core/ng/base/eventdispatcher.h>
#include <glib.h>
#include <thread>
#include <unordered_map>
#include <queue>
 
namespace zyppng {
 
  ZYPP_FWD_DECL_TYPE_WITH_REFS ( UnixSignalSource );
 
struct GUnixPollFD
{
  GIOCondition reqEvents;
  int pollfd   = -1;
  gpointer tag = nullptr;
};

struct GAbstractEventSource
{
  GSource source;
  EventDispatcherPrivate *_ev;
  AbstractEventSource *eventSource;
  std::vector<GUnixPollFD> pollfds;
 
  static gboolean prepare(GSource *, gint *timeout);
  static gboolean check(GSource *source);
  static gboolean dispatch(GSource *source, GSourceFunc, gpointer);
 
  static GAbstractEventSource *create (EventDispatcherPrivate *ev);
  static void destruct ( GAbstractEventSource *src );
};

struct GLibTimerSource
{
  GSource source;
  Timer   *_t = nullptr;
 
  static gboolean prepare(GSource *src, gint *timeout);
  static gboolean check(GSource *source);
  static gboolean dispatch(GSource *source, GSourceFunc, gpointer);
 
  static GLibTimerSource *create ();
  static void destruct ( GLibTimerSource *src );
};
 
struct GlibWaitPIDData
{
  GlibWaitPIDData( GPid pid );
  GlibWaitPIDData( GlibWaitPIDData &&other ) noexcept;
  ~GlibWaitPIDData();
 
  GlibWaitPIDData & operator= ( GlibWaitPIDData &&other ) noexcept;
 
  guint tag = 0;
  GSource *source = nullptr;
  EventDispatcher::WaitPidCallback callback;
};
 
struct GlibTimeoutData {
    std::function<bool()> _callback;
};
 
class EventDispatcherPrivate : public BasePrivate
{
  ZYPP_DECLARE_PUBLIC(EventDispatcher)
public:
  EventDispatcherPrivate( GMainContext *ctx, EventDispatcher &p );
  ~EventDispatcherPrivate() override;
 
  bool runIdleTasks();
  void enableIdleSource ();
 
  static std::shared_ptr<EventDispatcher> create ( );
  static void waitPidCallback ( GPid pid, gint status, gpointer user_data );
 
  static bool timeoutCallback ( gpointer user_data );
  static void timeoutDestroyCallback( gpointer user_data );
 
  std::thread::id _myThreadId;
  GMainContext *_ctx = nullptr;
 
  GSource *_idleSource  = nullptr;
 
  std::vector<GLibTimerSource *> _runningTimers;
  std::vector<GAbstractEventSource *> _eventSources;
  std::vector< std::shared_ptr<void> > _unrefLater;
  std::queue< EventDispatcher::IdleFunction > _idleFuncs;
  std::unordered_map<int, GlibWaitPIDData> _waitPIDs;
  UnixSignalSourceWeakRef _signalSource;
};
 
}
 
 
#endif