1 files changed, 65 insertions, 0 deletions
diff --git a/lib/base/timer.hpp b/lib/base/timer.hpp
new file mode 100644
index 0000000..db0f0b7
--- /dev/null
+++ b/lib/base/timer.hpp
@@ -0,0 +1,65 @@
+/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
+
+#ifndef TIMER_H
+#define TIMER_H
+
+#include "base/i2-base.hpp"
+#include <boost/signals2.hpp>
+#include <memory>
+
+namespace icinga {
+
+class TimerHolder;
+
+/**
+ * A timer that periodically triggers an event.
+ *
+ * @ingroup base
+ */
+class Timer final
+{
+public:
+	typedef std::shared_ptr<Timer> Ptr;
+
+	static Ptr Create();
+
+	~Timer();
+
+	static void Initialize();
+	static void Uninitialize();
+	static void InitializeThread();
+	static void UninitializeThread();
+
+	void SetInterval(double interval);
+	double GetInterval() const;
+
+	static void AdjustTimers(double adjustment);
+
+	void Start();
+	void Stop(bool wait = false);
+
+	void Reschedule(double next = -1);
+	double GetNext() const;
+
+	boost::signals2::signal<void(const Timer * const&)> OnTimerExpired;
+
+private:
+	double m_Interval{0}; /**< The interval of the timer. */
+	double m_Next{0}; /**< When the next event should happen. */
+	bool m_Started{false}; /**< Whether the timer is enabled. */
+	bool m_Running{false}; /**< Whether the timer proc is currently running. */
+	std::weak_ptr<Timer> m_Self;
+
+	Timer() = default;
+	void Call();
+	void InternalReschedule(bool completed, double next = -1);
+	void InternalRescheduleUnlocked(bool completed, double next = -1);
+
+	static void TimerThreadProc();
+
+	friend class TimerHolder;
+};
+
+}
+
+#endif /* TIMER_H */