src/thread/pth/SDL_systhread.c

   1 /*
   2     SDL - Simple DirectMedia Layer
   3     Copyright (C) 1997-2009 Sam Lantinga
   4
   5     This library is free software; you can redistribute it and/or
   6     modify it under the terms of the GNU Lesser General Public
   7     License as published by the Free Software Foundation; either
   8     version 2.1 of the License, or (at your option) any later version.
   9
  10     This library is distributed in the hope that it will be useful,
  11     but WITHOUT ANY WARRANTY; without even the implied warranty of
  12     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13     Lesser General Public License for more details.
  14
  15     You should have received a copy of the GNU Lesser General Public
  16     License along with this library; if not, write to the Free Software
  17     Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
  18
  19     Sam Lantinga
  20     slouken@libsdl.org
  21 */
  22 #include "SDL_config.h"
  23
  24 /*
  25  *      GNU pth threads
  26  *
  27  *      Patrice Mandin
  28  */
  29
  30 #include <pth.h>
  31 #include <signal.h>
  32
  33 #include "SDL_thread.h"
  34 #include "../SDL_thread_c.h"
  35 #include "../SDL_systhread.h"
  36
  37 /* List of signals to mask in the subthreads */
  38 static int sig_list[] = {
  39         SIGHUP, SIGINT, SIGQUIT, SIGPIPE, SIGALRM, SIGTERM, SIGCHLD, SIGWINCH,
  40         SIGVTALRM, SIGPROF, 0
  41 };
  42
  43 static void *RunThread(void *data)
  44 {
  45         SDL_RunThread(data);
  46         pth_exit((void*)0);
  47         return((void *)0);              /* Prevent compiler warning */
  48 }
  49
  50 int SDL_SYS_CreateThread(SDL_Thread *thread, void *args)
  51 {
  52         pth_attr_t type;
  53
  54         /* Create a new attribute */
  55         type = pth_attr_new();
  56         if ( type == NULL ) {
  57                 SDL_SetError("Couldn't initialize pth attributes");
  58                 return(-1);
  59         }
  60         pth_attr_set(type, PTH_ATTR_JOINABLE, TRUE);
  61
  62         /* Create the thread and go! */
  63         thread->handle = pth_spawn(type, RunThread, args);
  64         if ( thread->handle == NULL ) {
  65                 SDL_SetError("Not enough resources to create thread");
  66                 return(-1);
  67         }
  68         return(0);
  69 }
  70
  71 void SDL_SYS_SetupThread(void)
  72 {
  73         int i;
  74         sigset_t mask;
  75         int oldstate;
  76
  77         /* Mask asynchronous signals for this thread */
  78         sigemptyset(&mask);
  79         for ( i=0; sig_list[i]; ++i ) {
  80                 sigaddset(&mask, sig_list[i]);
  81         }
  82         pth_sigmask(SIG_BLOCK, &mask, 0);
  83
  84         /* Allow ourselves to be asynchronously cancelled */
  85         pth_cancel_state(PTH_CANCEL_ASYNCHRONOUS, &oldstate);
  86 }
  87
  88 /* WARNING:  This may not work for systems with 64-bit pid_t */
  89 Uint32 SDL_ThreadID(void)
  90 {
  91         return((Uint32)pth_self());
  92 }
  93
  94 void SDL_SYS_WaitThread(SDL_Thread *thread)
  95 {
  96         pth_join(thread->handle, NULL);
  97 }
  98
  99 void SDL_SYS_KillThread(SDL_Thread *thread)
 100 {
 101         pth_cancel(thread->handle);
 102         pth_join(thread->handle, NULL);
 103 }