diogo/yap-6.3
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix thread creation.

Browse Source
This commit is contained in:
Vitor Santos Costa 2010-07-30 12:08:00 +01:00
parent 8d5aa09e05
commit 6834ac544b
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
C/threads.c
View File

@ -157,13 +157,16 @@ thread_die(int wid, int always_die)
} }
static void static void
setup_engine(int myworker_id) setup_engine(int myworker_id, int init_thread)
{ {
REGSTORE *standard_regs; REGSTORE *standard_regs;
standard_regs = (REGSTORE *)calloc(1,sizeof(REGSTORE)); standard_regs = (REGSTORE *)calloc(1,sizeof(REGSTORE));
/* create the YAAM descriptor */ /* create the YAAM descriptor */
FOREIGN_ThreadHandle(myworker_id).default_yaam_regs = standard_regs; FOREIGN_ThreadHandle(myworker_id).default_yaam_regs = standard_regs;
if (init_thread) {
pthread_setspecific(Yap_yaamregs_key, (void *)FOREIGN_ThreadHandle(myworker_id).default_yaam_regs);
}
worker_id = myworker_id; worker_id = myworker_id;
Yap_InitExStacks(FOREIGN_ThreadHandle(myworker_id).tsize, FOREIGN_ThreadHandle(myworker_id).ssize); Yap_InitExStacks(FOREIGN_ThreadHandle(myworker_id).tsize, FOREIGN_ThreadHandle(myworker_id).ssize);
CurrentModule = FOREIGN_ThreadHandle(myworker_id).cmod; CurrentModule = FOREIGN_ThreadHandle(myworker_id).cmod;
@ -182,8 +185,7 @@ setup_engine(int myworker_id)
static void static void
start_thread(int myworker_id) start_thread(int myworker_id)
{ {
pthread_setspecific(Yap_yaamregs_key, (void *)FOREIGN_ThreadHandle(myworker_id).default_yaam_regs); setup_engine(myworker_id, TRUE);
worker_id = myworker_id;
} }
static void * static void *
@ -399,7 +401,7 @@ Yap_thread_create_engine(thread_attr *ops)
FOREIGN_ThreadHandle(new_id).pthread_handle = 0L; FOREIGN_ThreadHandle(new_id).pthread_handle = 0L;
FOREIGN_ThreadHandle(new_id).id = new_id; FOREIGN_ThreadHandle(new_id).id = new_id;
FOREIGN_ThreadHandle(new_id).ref_count = 0; FOREIGN_ThreadHandle(new_id).ref_count = 0;
setup_engine(new_id); setup_engine(new_id, FALSE);
if (pthread_self() != Yap_master_thread) { if (pthread_self() != Yap_master_thread) {
pthread_setspecific(Yap_yaamregs_key, NULL); pthread_setspecific(Yap_yaamregs_key, NULL);
pthread_mutex_unlock(&(FOREIGN_ThreadHandle(0).tlock)); pthread_mutex_unlock(&(FOREIGN_ThreadHandle(0).tlock));