X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fcore%2Fpoller.h;fp=source%2Fcore%2Fpoller.h;h=dcd36587054b2d10599918adc84a0c6ef10f880c;hb=e1ea831a640fba534e7e42e399f04cdf681ef8d3;hp=0000000000000000000000000000000000000000;hpb=0bcb8d4d6f33cbdad7b921cac787740bfe8e212e;p=libs%2Fcore.git

diff --git a/source/core/poller.h b/source/core/poller.h
new file mode 100644
index 0000000..dcd3658
--- /dev/null
+++ b/source/core/poller.h
@@ -0,0 +1,56 @@
+/*
+This file is part of libmspframework
+Copyright © 2006 Mikko Rasa, Mikkosoft Productions
+Distributed under the LGPL
+*/
+#ifndef MSP_FRAMEWORK_POLLER_H_
+#define MSP_FRAMEWORK_POLLER_H_
+
+#ifdef WIN32
+#include "win32poll.h"
+#else
+#include <sys/poll.h>
+#endif
+#include <vector>
+#include <sigc++/sigc++.h>
+#include "mutex.h"
+
+namespace Msp {
+
+class Pollable;
+
+class Poller
+{
+public:
+	class Slot
+	{
+	public:
+		sigc::signal<void, short> signal_event;
+
+		Slot(Pollable *, short);
+		Pollable *get_object() const { return obj; }
+		short    get_events() const  { return events; }
+	private:
+		Pollable *obj;
+		short    events;
+		
+		void obj_deleted() { obj=0; }
+	};
+
+	Slot &add_pollable(Pollable *, short);
+	int  poll(int =0);
+private:
+	std::list<Slot *>   slots;
+	std::vector<pollfd> pfd;
+	Mutex               slots_mutex;
+	Mutex               pfd_mutex;
+	bool                dirty;
+
+	void remove_stale_slots();
+	void rebuild_pfd();
+	void pollable_deleted(Pollable *);
+};
+
+};
+
+#endif