threadengine_win32.h

/*
 * InspIRCd -- Internet Relay Chat Daemon
 *
 *   Copyright (C) 2014 Attila Molnar <[email protected]>
 *   Copyright (C) 2013 Sadie Powell <[email protected]>
 *   Copyright (C) 2012 Robby <[email protected]>
 *   Copyright (C) 2012 ChrisTX <[email protected]>
 *   Copyright (C) 2009 Daniel De Graaf <[email protected]>
 *   Copyright (C) 2008-2010 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/>.
 */
 
 
#pragma once
 
#include "config.h"
#include "base.h"
 
class Thread;
 
class CoreExport ThreadEngine
{
 public:
        struct ThreadState
        {
                HANDLE handle;
        };
 
        static DWORD WINAPI Entry(void* parameter);
 
        void Start(Thread* thread_to_init);
 
        void Stop(Thread* thread);
};
 
class CoreExport Mutex
{
 private:
        CRITICAL_SECTION wutex;
 public:
        Mutex()
        {
                InitializeCriticalSection(&wutex);
        }
        void Lock()
        {
                EnterCriticalSection(&wutex);
        }
        void Unlock()
        {
                LeaveCriticalSection(&wutex);
        }
        ~Mutex()
        {
                DeleteCriticalSection(&wutex);
        }
};
 
class ThreadQueueData : public Mutex
{
        HANDLE event;
 public:
        ThreadQueueData()
        {
                event = CreateEvent(NULL, false, false, NULL);
                if (event == NULL)
                        throw CoreException("CreateEvent() failed in ThreadQueueData::ThreadQueueData()!");
        }
 
        ~ThreadQueueData()
        {
                CloseHandle(event);
        }
 
        void Wakeup()
        {
                PulseEvent(event);
        }
 
        void Wait()
        {
                Unlock();
                WaitForSingleObject(event, INFINITE);
                Lock();
        }
};
 
class ThreadSignalData
{
 public:
        int connFD;
        ThreadSignalData()
        {
                connFD = -1;
        }
};