threadengine_pthread.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_PTHREAD_H
#define THREADENGINE_PTHREAD_H
 
#include <pthread.h>
#include "typedefs.h"
 
class CoreExport ThreadEngine
{
 public:
 
        ThreadEngine();
 
        virtual ~ThreadEngine();
 
        void Start(Thread* thread_to_init);
 
        const std::string GetName()
        {
                return "posix-thread";
        }
};
 
class CoreExport ThreadData
{
 public:
        pthread_t pthread_id;
        void FreeThread(Thread* toFree);
};
 
class CoreExport Mutex
{
 private:
        pthread_mutex_t putex;
 public:
        Mutex()
        {
                pthread_mutex_init(&putex, NULL);
        }
        void Lock()
        {
                pthread_mutex_lock(&putex);
        }
        void Unlock()
        {
                pthread_mutex_unlock(&putex);
        }
        ~Mutex()
        {
                pthread_mutex_destroy(&putex);
        }
};
 
class ThreadQueueData
{
        pthread_mutex_t mutex;
        pthread_cond_t cond;
 public:
        ThreadQueueData()
        {
                pthread_mutex_init(&mutex, NULL);
                pthread_cond_init(&cond, NULL);
        }
 
        ~ThreadQueueData()
        {
                pthread_mutex_destroy(&mutex);
                pthread_cond_destroy(&cond);
        }
 
        void Lock()
        {
                pthread_mutex_lock(&mutex);
        }
 
        void Unlock()
        {
                pthread_mutex_unlock(&mutex);
        }
 
        void Wakeup()
        {
                pthread_cond_signal(&cond);
        }
 
        void Wait()
        {
                pthread_cond_wait(&cond, &mutex);
        }
};
 
class ThreadSignalSocket;
class ThreadSignalData
{
 public:
        ThreadSignalSocket* sock;
};
 
 
#endif