| /* | |
| * $Id:$ | |
| * sproc version | |
| * by Wolfram Gloger 2001, 2004, 2006 | |
| */ | |
| #include <stdio.h> | |
| #include <sys/wait.h> | |
| #include <sys/types.h> | |
| #include <sys/prctl.h> | |
| #ifndef STACKSIZE | |
| #define STACKSIZE 32768 | |
| #endif | |
| struct thread_st { | |
| char *sp; /* stack pointer, can be 0 */ | |
| void (*func)(struct thread_st* st); /* must be set by user */ | |
| int id; | |
| int flags; | |
| struct user_data u; | |
| }; | |
| static void | |
| thread_init(void) | |
| { | |
| printf("Using sproc() threads.\n"); | |
| } | |
| static void | |
| thread_wrapper(void *ptr, size_t stack_len) | |
| { | |
| struct thread_st *st = (struct thread_st*)ptr; | |
| /*printf("begin %p\n", st->sp);*/ | |
| st->func(st); | |
| /*printf("end %p\n", st->sp);*/ | |
| } | |
| /* Create a thread. */ | |
| static int | |
| thread_create(struct thread_st *st) | |
| { | |
| st->flags = 0; | |
| if(!st->sp) | |
| st->sp = malloc(STACKSIZE); | |
| if(!st->sp) return -1; | |
| st->id = sprocsp(thread_wrapper, PR_SALL, st, st->sp+STACKSIZE, STACKSIZE); | |
| if(st->id < 0) { | |
| return -1; | |
| } | |
| return 0; | |
| } | |
| /* Wait for one of several subthreads to finish. */ | |
| static void | |
| wait_for_thread(struct thread_st st[], int n_thr, | |
| int (*end_thr)(struct thread_st*)) | |
| { | |
| int i; | |
| int id; | |
| int status = 0; | |
| id = wait(&status); | |
| if(status != 0) { | |
| if(WIFSIGNALED(status)) | |
| printf("thread %id terminated by signal %d\n", | |
| id, WTERMSIG(status)); | |
| else | |
| printf("thread %id exited with status %d\n", | |
| id, WEXITSTATUS(status)); | |
| } | |
| for(i=0; i<n_thr; i++) | |
| if(id == st[i].id) { | |
| if(end_thr) | |
| end_thr(&st[i]); | |
| break; | |
| } | |
| } | |
| /* | |
| * Local variables: | |
| * tab-width: 4 | |
| * End: | |
| */ |