Home | History | Annotate | Download | only in pth
      1 /*
      2     SDL - Simple DirectMedia Layer
      3     Copyright (C) 1997-2006 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 (at) 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 }
    104