spice client: creating a general process loop.

The process loop is responsible for: 1) waiting for events 2) timers 3) events queue for
actions that should be performed in the context of the thread and are pushed from other threads.
The benefits:
1) remove duplicity: till now, there was one implementaion of events loop for the channels and
another one for the main thread.
2) timers can be executed on each thread and not only on the main thread.
3) events can be pushed to each thread and not only to the main thread.
In this commit, only the main thread was modified to use the new process loop.

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
+