threadengine_win32.h

/*
 * InspIRCd -- Internet Relay Chat Daemon
 *
 *   Copyright (C) 2009 Daniel De Graaf <[email protected]>
 *   Copyright (C) 2008 Craig Edwards <[email protected]>
 *
 * This file is part of InspIRCd.  InspIRCd is free software: you can
 * redistribute it and/or modify it under the terms of the GNU General Public
 * License as published by the Free Software Foundation, version 2.
 *
 * This program 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/>.
 */
 
 
#ifndef THREADENGINE_WIN32_H
#define THREADENGINE_WIN32_H
 
#include "inspircd_config.h"
#include "base.h"
 
class Thread;
 
class CoreExport ThreadEngine
{
 public:
 
        ThreadEngine();
 
        virtual ~ThreadEngine();
 
        static DWORD WINAPI Entry(void* parameter);
 
        void Start(Thread* thread_to_init);
 
        const std::string GetName()
        {
                return "windows-thread";
        }
};
 
class CoreExport ThreadData
{
 public:
        HANDLE handle;
        void FreeThread(Thread* toFree);
};
 
class CoreExport Mutex
{
 private:
        CRITICAL_SECTION wutex;
 public:
        Mutex()
        {
                InitializeCriticalSection(&wutex);
        }
        void Lock()
        {
                EnterCriticalSection(&wutex);
        }
        void Unlock()
        {
                LeaveCriticalSection(&wutex);
        }
        ~Mutex()
        {
                DeleteCriticalSection(&wutex);
        }
};
 
class ThreadQueueData
{
        CRITICAL_SECTION mutex;
        HANDLE event;
 public:
        ThreadQueueData()
        {
                event = CreateEvent(NULL, false, false, NULL);
                if (event == NULL)
                        throw CoreException("CreateEvent() failed in ThreadQueueData::ThreadQueueData()!");
                InitializeCriticalSection(&mutex);
        }
 
        ~ThreadQueueData()
        {
                CloseHandle(event);
                DeleteCriticalSection(&mutex);
        }
 
        void Lock()
        {
                EnterCriticalSection(&mutex);
        }
 
        void Unlock()
        {
                LeaveCriticalSection(&mutex);
        }
 
        void Wakeup()
        {
                PulseEvent(event);
        }
 
        void Wait()
        {
                LeaveCriticalSection(&mutex);
                WaitForSingleObject(event, INFINITE);
                EnterCriticalSection(&mutex);
        }
};
 
class ThreadSignalData
{
 public:
        int connFD;
        ThreadSignalData()
        {
                connFD = -1;
        }
};
 
#endif