1 files changed, 95 insertions, 0 deletions
diff --git a/client/event_sources.h b/client/event_sources.h
new file mode 100644
index 00000000..a7b39aee
--- /dev/null
+++ b/client/event_sources.h
@@ -0,0 +1,95 @@
+/*
+   Copyright (C) 2009 Red Hat, Inc.
+
+   This program is free software; you can redistribute it and/or
+   modify it under the terms of the GNU General Public License as
+   published by the Free Software Foundation; either version 2 of
+   the License, or (at your option) any later version.
+
+   This program 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 General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program.  If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#ifndef _H_EVENT_SOURCES
+#define _H_EVENT_SOURCES
+
+#include "common.h"
+#include "event_sources_p.h"
+
+class EventSource;
+
+// TODO: the class is not thread safe
+class EventSources: public EventSources_p {
+public:
+    class Trigger;
+    class Socket;
+    class File;
+    class Handle;
+
+    EventSources();
+    virtual ~EventSources();
+
+    void add_trigger(Trigger& trigger);
+    void remove_trigger(Trigger& trigger);
+    void add_socket(Socket& socket);
+    void remove_socket(Socket& socket);
+    void add_file(File& file);
+    void remove_file(File& file);
+    void add_handle(Handle& handle);
+    void remove_handle(Handle& handle);
+
+    /* return true if the events loop should quit */
+    bool wait_events(int timeout_ms = INFINITE);
+};
+
+class EventSource {
+public:
+    virtual ~EventSource() {}
+    virtual void on_event() = 0;
+
+private:
+    virtual void action() {on_event();}
+
+    friend class EventSources;
+};
+
+class EventSources::Trigger: public EventSource, private Trigger_p {
+public:
+    Trigger();
+    virtual ~Trigger();
+    virtual void trigger();
+    virtual void reset();
+
+private:
+    virtual void action();
+
+    friend class EventSources;
+};
+
+class EventSources::Socket: public EventSource {
+protected:
+    virtual int get_socket() = 0;
+
+    friend class EventSources;
+};
+
+
+class EventSources::File: public EventSource {
+protected:
+    virtual int get_fd() = 0;
+
+    friend class EventSources;
+};
+
+class EventSources::Handle: public EventSource, public Handle_p {
+
+     friend class EventSources;
+};
+
+#endif
+