From 098ed91a48df9fef58590b22fe34225ed1f44cfa Mon Sep 17 00:00:00 2001
From: Tycho Bickerstaff <work.tycho@gmail.com>
Date: Tue, 31 Dec 2013 16:13:13 +0000
Subject: fogot to add promise classes

---
 src/OSSupport/Promise.cpp | 54 +++++++++++++++++++++++++++++++++++++++++++++++
 src/OSSupport/Promise.h   | 38 +++++++++++++++++++++++++++++++++
 2 files changed, 92 insertions(+)
 create mode 100644 src/OSSupport/Promise.cpp
 create mode 100644 src/OSSupport/Promise.h

diff --git a/src/OSSupport/Promise.cpp b/src/OSSupport/Promise.cpp
new file mode 100644
index 000000000..b31869334
--- /dev/null
+++ b/src/OSSupport/Promise.cpp
@@ -0,0 +1,54 @@
+
+#include "Globals.h"
+
+#include "Promise.h"
+
+cPromise * cPromise::WaitFor(cPromise * a_Promise) 
+{
+	return new cCombinedPromise(this, a_Promise);
+}
+
+cPromise * cPromise::CancelOn(volatile bool& cancelation) 
+{
+	return new cCancelablePromise(this, cancelation);
+}
+
+void cPromise::Wait()
+{
+	while(!IsCompleted()){}; //busywait best we can do until waitany
+}
+
+
+cCombinedPromise::cCombinedPromise(cPromise* a_left, cPromise* a_right) : 
+	cPromise(), 
+	m_left(a_left), 
+	m_right(a_right)
+{
+}
+
+cCombinedPromise::~cCombinedPromise()
+{
+}
+
+bool cCombinedPromise::IsCompleted()
+{
+	return m_left->IsCompleted() || m_right->IsCompleted();
+}
+
+cCancelablePromise::cCancelablePromise(cPromise* a_wrapped, volatile bool& a_cancel) : 
+	cPromise(), 
+	m_cancel(a_cancel),
+	m_wrapped(a_wrapped)
+{
+}
+
+cCancelablePromise::~cCancelablePromise ()
+{
+}
+
+bool cCancelablePromise::IsCompleted() 
+{
+	return m_cancel || m_wrapped->IsCompleted();
+}
+
+
diff --git a/src/OSSupport/Promise.h b/src/OSSupport/Promise.h
new file mode 100644
index 000000000..83d04860b
--- /dev/null
+++ b/src/OSSupport/Promise.h
@@ -0,0 +1,38 @@
+#pragma once
+
+class cCombinedPromise;
+
+
+class cPromise {
+	public:
+		cPromise() {}
+		virtual ~cPromise () {}
+		cPromise * WaitFor(cPromise * a_Promise);
+		cPromise * CancelOn(volatile bool& cancelationtoken);
+		void Wait();
+		virtual bool IsCompleted() = 0;
+		//TODO:Expose Events for waiting on
+};
+
+class cCombinedPromise : public cPromise {
+public:
+	cCombinedPromise(cPromise*, cPromise*);
+	~cCombinedPromise();
+	virtual bool IsCompleted();
+private:
+	cPromise* m_left;
+	cPromise* m_right;
+};
+
+class cCancelablePromise : public cPromise {
+public:
+	cCancelablePromise(cPromise*, volatile bool&);
+	~cCancelablePromise();
+	virtual bool IsCompleted();
+private:
+	volatile bool& m_cancel;
+	cPromise* m_wrapped;
+};
+
+
+
-- 
cgit v1.2.3