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/zyppng/base/eventdispatcher.h>
#include <glib.h>
#include <thread>
#include <unordered_map>
#include <queue>
 
namespace zyppng {
 
struct GUnixPollFD
{
  GIOCondition reqEvents;
  int pollfd   = -1;
  gpointer tag = nullptr;
};
 
struct GAbstractEventSource
{
  GSource source;
  AbstractEventSource *eventSource;
  EventDispatcherPrivate *_ev;
  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 );
};
 
class EventDispatcherPrivate : public BasePrivate
{
public:
  ZYPP_DECLARE_PUBLIC(EventDispatcher)
  EventDispatcherPrivate( GMainContext *ctx );
  virtual ~EventDispatcherPrivate();
 
  bool runIdleTasks();
  void enableIdleSource ();
 
  std::thread::id _myThreadId;
  GMainLoop *_loop = nullptr;
  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;
};
 
}
 
 
#endif