1 files changed, 54 insertions, 0 deletions
diff --git a/libodb/odb/details/win32/condition.cxx b/libodb/odb/details/win32/condition.cxx
new file mode 100644
index 0000000..3a4b605
--- /dev/null
+++ b/libodb/odb/details/win32/condition.cxx
@@ -0,0 +1,54 @@
+// file      : odb/details/win32/condition.cxx
+// license   : GNU GPL v2; see accompanying LICENSE file
+
+#include <odb/details/win32/windows.hxx>
+#include <odb/details/win32/condition.hxx>
+#include <odb/details/win32/exceptions.hxx>
+
+namespace odb
+{
+  namespace details
+  {
+    void condition::
+    signal ()
+    {
+      mutex_.lock ();
+
+      if (waiters_ > signals_)
+      {
+        if (signals_++ == 0)
+        {
+          if (SetEvent (event_) == 0)
+            throw win32_exception ();
+        }
+      }
+
+      mutex_.unlock ();
+    }
+
+    void condition::
+    wait (lock&)
+    {
+      // When we enter this functions the mutex is locked. When we
+      // return from this function the mutex must be locked.
+      //
+      waiters_++;
+      mutex_.unlock ();
+
+      if (WaitForSingleObject (event_, INFINITE) != 0)
+        throw win32_exception ();
+
+      mutex_.lock ();
+      waiters_--;
+      signals_--;
+
+      if (signals_ > 0)
+      {
+        // Wake up the next thread.
+        //
+        if (SetEvent (event_) == 0)
+          throw win32_exception ();
+      }
+    }
+  }
+}