src/threadengines/threadengine_pthread.cpp

   1 /*       +------------------------------------+
   2  *       | Inspire Internet Relay Chat Daemon |
   3  *       +------------------------------------+
   4  *
   5  *  InspIRCd: (C) 2002-2009 InspIRCd Development Team
   6  * See: http://wiki.inspircd.org/Credits
   7  *
   8  * This program is free but copyrighted software; see
   9  *          the file COPYING for details.
  10  *
  11  * ---------------------------------------------------
  12  */
  13
  14 #include "inspircd.h"
  15 #include "threadengines/threadengine_pthread.h"
  16 #include <pthread.h>
  17 #include <signal.h>
  18
  19 ThreadEngine::ThreadEngine(InspIRCd* Instance)
  20 {
  21 }
  22
  23 static void* entry_point(void* parameter)
  24 {
  25         /* Recommended by nenolod, signal safety on a per-thread basis */
  26         sigset_t set;
  27         sigemptyset(&set);
  28         sigaddset(&set, SIGPIPE);
  29         pthread_sigmask(SIG_BLOCK, &set, NULL);
  30
  31         Thread* pt = reinterpret_cast<Thread*>(parameter);
  32         pt->Run();
  33         return parameter;
  34 }
  35
  36
  37 void ThreadEngine::Start(Thread* thread)
  38 {
  39         ThreadData* data = new ThreadData;
  40         thread->state = data;
  41
  42         if (pthread_create(&data->pthread_id, NULL, entry_point, thread) != 0)
  43         {
  44                 thread->state = NULL;
  45                 delete data;
  46                 throw CoreException("Unable to create new thread: " + std::string(strerror(errno)));
  47         }
  48 }
  49
  50 ThreadEngine::~ThreadEngine()
  51 {
  52 }
  53
  54 void ThreadData::FreeThread(Thread* thread)
  55 {
  56         thread->SetExitFlag(true);
  57         pthread_join(pthread_id, NULL);
  58 }