1 files changed, 116 insertions, 0 deletions
diff --git a/src/lib/arch/win32/ArchMultithreadWindows.h b/src/lib/arch/win32/ArchMultithreadWindows.h
new file mode 100644
index 0000000..99aa640
--- /dev/null
+++ b/src/lib/arch/win32/ArchMultithreadWindows.h
@@ -0,0 +1,116 @@
+/*
+ * barrier -- mouse and keyboard sharing utility
+ * Copyright (C) 2012-2016 Symless Ltd.
+ * Copyright (C) 2002 Chris Schoeneman
+ * 
+ * This package is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU General Public License
+ * found in the file LICENSE that should have accompanied this file.
+ * 
+ * This package is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#pragma once
+
+#include "arch/IArchMultithread.h"
+#include "common/stdlist.h"
+
+#define WIN32_LEAN_AND_MEAN
+#include <Windows.h>
+
+#define ARCH_MULTITHREAD ArchMultithreadWindows
+
+class ArchCondImpl {
+public:
+    enum { kSignal = 0, kBroadcast };
+
+    HANDLE                m_events[2];
+    mutable int            m_waitCount;
+    ArchMutex            m_waitCountMutex;
+};
+
+class ArchMutexImpl {
+public:
+    CRITICAL_SECTION    m_mutex;
+};
+
+//! Win32 implementation of IArchMultithread
+class ArchMultithreadWindows : public IArchMultithread {
+public:
+    ArchMultithreadWindows();
+    virtual ~ArchMultithreadWindows();
+
+    //! @name manipulators
+    //@{
+
+    void                setNetworkDataForCurrentThread(void*);
+
+    //@}
+    //! @name accessors
+    //@{
+
+    HANDLE                getCancelEventForCurrentThread();
+
+    void*                getNetworkDataForThread(ArchThread);
+
+    static ArchMultithreadWindows*    getInstance();
+
+    //@}
+
+    // IArchMultithread overrides
+    virtual ArchCond    newCondVar();
+    virtual void        closeCondVar(ArchCond);
+    virtual void        signalCondVar(ArchCond);
+    virtual void        broadcastCondVar(ArchCond);
+    virtual bool        waitCondVar(ArchCond, ArchMutex, double timeout);
+    virtual ArchMutex    newMutex();
+    virtual void        closeMutex(ArchMutex);
+    virtual void        lockMutex(ArchMutex);
+    virtual void        unlockMutex(ArchMutex);
+    virtual ArchThread    newThread(ThreadFunc, void*);
+    virtual ArchThread    newCurrentThread();
+    virtual ArchThread    copyThread(ArchThread);
+    virtual void        closeThread(ArchThread);
+    virtual void        cancelThread(ArchThread);
+    virtual void        setPriorityOfThread(ArchThread, int n);
+    virtual void        testCancelThread();
+    virtual bool        wait(ArchThread, double timeout);
+    virtual bool        isSameThread(ArchThread, ArchThread);
+    virtual bool        isExitedThread(ArchThread);
+    virtual void*        getResultOfThread(ArchThread);
+    virtual ThreadID    getIDOfThread(ArchThread);
+    virtual void        setSignalHandler(ESignal, SignalFunc, void*);
+    virtual void        raiseSignal(ESignal);
+
+private:
+    ArchThreadImpl*    find(DWORD id);
+    ArchThreadImpl*    findNoRef(DWORD id);
+    ArchThreadImpl*    findNoRefOrCreate(DWORD id);
+    void                insert(ArchThreadImpl* thread);
+    void                erase(ArchThreadImpl* thread);
+
+    void                refThread(ArchThreadImpl* rep);
+    void                testCancelThreadImpl(ArchThreadImpl* rep);
+
+    void                doThreadFunc(ArchThread thread);
+    static unsigned int __stdcall    threadFunc(void* vrep);
+
+private:
+    typedef std::list<ArchThread> ThreadList;
+
+    static ArchMultithreadWindows*    s_instance;
+
+    ArchMutex            m_threadMutex;
+
+    ThreadList            m_threadList;
+    ArchThread            m_mainThread;
+
+    SignalFunc            m_signalFunc[kNUM_SIGNALS];
+    void*                m_signalUserData[kNUM_SIGNALS];
+};