Merge pull request #11 from foxtacles/isle-mxcriticalsection

lego1: Add MxCriticalSection implementation

LEGO1/mxcriticalsection.cpp

@@ -0,0 +1,73 @@
+#include "mxcriticalsection.h"
+
+#include <stdio.h>
+
+int g_useMutex = 0;
+
+MxCriticalSection::MxCriticalSection()
+{
+  HANDLE mutex;
+
+  if (g_useMutex != 0)
+  {
+    mutex = CreateMutexA(NULL, FALSE, NULL);
+    this->m_mutex = mutex;
+    return;
+  }
+
+  InitializeCriticalSection(&this->m_criticalSection);
+  this->m_mutex = NULL;
+}
+
+MxCriticalSection::~MxCriticalSection()
+{
+  if (this->m_mutex != NULL)
+  {
+    CloseHandle(this->m_mutex);
+    return;
+  }
+
+  DeleteCriticalSection(&this->m_criticalSection);
+}
+
+void MxCriticalSection::SetDoMutex()
+{
+  g_useMutex = 1;
+}
+
+void MxCriticalSection::Enter()
+{
+  DWORD result;
+  FILE *file;
+
+  if (this->m_mutex != NULL)
+  {
+    result = WaitForSingleObject(this->m_mutex, 5000);
+    if (result == WAIT_FAILED)
+    {
+      file = fopen("C:\\DEADLOCK.TXT", "a");
+      if (file != NULL)
+      {
+        fprintf(file, "mutex timeout occurred!\n");
+        fclose(file);
+      }
+
+      abort();
+    }
+  }
+  else
+  {
+    EnterCriticalSection(&this->m_criticalSection);
+  }
+}
+
+void MxCriticalSection::Leave()
+{
+  if (this->m_mutex != NULL)
+  {
+    ReleaseMutex(this->m_mutex);
+    return;
+  }
+
+  LeaveCriticalSection(&this->m_criticalSection);
+}

LEGO1/mxcriticalsection.h

@@ -1,12 +1,20 @@
 #ifndef MXCRITICALSECTION_H
 #define MXCRITICALSECTION_H
 
+#include <Windows.h>
+
 class MxCriticalSection
 {
 public:
   __declspec(dllexport) MxCriticalSection();
   __declspec(dllexport) ~MxCriticalSection();
   __declspec(dllexport) static void SetDoMutex();
+  void Enter();
+  void Leave();
+
+private:
+  CRITICAL_SECTION m_criticalSection;
+  HANDLE m_mutex;
 };
 
 #endif // MXCRITICALSECTION_H