X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Ftime%2Ftimer.h;fp=source%2Ftime%2Ftimer.h;h=8b4e5957ebd17257e55bf8a5e2979dc99f75868f;hp=cfa00bb0d1511f42f09591b04dbc5527ee8deb91;hb=bb49a2de46849a9ffa509148661d4c574c43fe24;hpb=7d8e623512c2cf33eef000cf99af97386dfe6d59

diff --git a/source/time/timer.h b/source/time/timer.h
index cfa00bb..8b4e595 100644
--- a/source/time/timer.h
+++ b/source/time/timer.h
@@ -7,7 +7,7 @@ Distributed under the LGPL
 #ifndef MSP_TIME_TIMER_H_
 #define MSP_TIME_TIMER_H_
 
-#include <queue>
+#include <set>
 #include <sigc++/sigc++.h>
 #include "../core/mutex.h"
 #include "../core/semaphore.h"
@@ -41,18 +41,22 @@ public:
 		Slot(const TimeStamp &);
 		const TimeStamp &get_timeout() const { return timeout; }
 		bool increment();
-		bool operator<(const Slot &) const;
 	};
 
 private:
-	typedef bool (*fSlotCompare)(Slot *, Slot *);
+	struct SlotProxy
+	{
+		Slot *slot;
+
+		SlotProxy(Slot *);
+		bool operator<(const SlotProxy &) const;
+	};
 
-	std::priority_queue<Slot *, std::vector<Slot *>, fSlotCompare> slots;
+	std::set<SlotProxy> slots;
 	Semaphore sem;
 	Mutex mutex;
 
 public:
-	Timer();
 	~Timer();
 
 	/**
@@ -67,6 +71,11 @@ public:
 	*/
 	Slot &add(const TimeStamp &);
 
+	/**
+	Cancels a previously added timer.
+	*/
+	void cancel(Slot &);
+
 	/**
 	Checks all timers, executing any that have timed out.  If block is true,
 	waits until one times out.
@@ -75,8 +84,8 @@ public:
 	won't return until a timer is added from another thread.
 	*/
 	void tick(bool block=true);
-private:
-	static bool slot_compare(Slot *, Slot *);
+
+	TimeStamp get_next_timeout() const;
 };
 
 } // namespace Time