Little fixes.

This commit is contained in:
rsc 2004-04-30 02:16:28 +00:00
parent be36ff6885
commit b1455f33a8
10 changed files with 68 additions and 15 deletions

View file

@ -45,14 +45,17 @@ _p9uproc(int inhandler)
h = 0;
}
if(inhandler)
sysfatal("did not find uproc in signal handler");
if(inhandler){
fprint(2, "%s: did not find uproc for pid %d in signal handler\n", argv0, pid);
abort();
}
/* need to allocate */
while((up = mallocz(sizeof(Uproc), 1)) == nil)
sleep(1000);
up = mallocz(sizeof(Uproc), 1);
fprint(2, "alloc uproc for pid %d\n", pid);
up->pid = pid;
lock(&uproclock);
h = pid%PIDHASH;
for(i=0; i<PIDHASH; i++){
@ -79,6 +82,7 @@ _p9uprocdie(void)
int pid, i, h;
pid = getpid();
fprint(2, "reap uproc for pid %d\n", pid);
h = pid%PIDHASH;
for(i=0; i<PIDHASH; i++){
up = alluproc[h];

View file

@ -4,14 +4,19 @@ extern int __isthreaded;
int
ffork(int flags, void(*fn)(void*), void *arg)
{
int pid;
void *p;
_p9uproc(0);
__isthreaded = 1;
p = malloc(16384);
if(p == nil)
return -1;
memset(p, 0xFE, 16384);
return rfork_thread(RFPROC|flags, (char*)p+16000, (int(*)(void*))fn, arg);
pid = rfork_thread(RFPROC|flags, (char*)p+16000, (int(*)(void*))fn, arg);
if(pid == 0)
_p9uproc(0);
return pid;
}
/*

View file

@ -1,18 +1,41 @@
#include <u.h>
#include <sched.h>
#include <signal.h>
#include <lib9.h>
#include <libc.h>
#include "9proc.h"
int fforkstacksize = 16384;
static int
tramp(void *v)
{
void (*fn)(void*), *arg;
void **v2;
_p9uproc(0);
v2 = v;
fn = v2[0];
arg = v2[1];
free(v2);
fn(arg);
return 0;
}
int
ffork(int flags, void (*fn)(void*), void *arg)
{
void **v;
char *p;
int cloneflag, pid;
_p9uproc(0);
p = malloc(fforkstacksize);
if(p == nil)
v = malloc(sizeof(void*)*2);
if(p==nil || v==nil){
free(p);
free(v);
return -1;
}
cloneflag = 0;
flags &= ~RFPROC;
if(flags&RFMEM){
@ -29,9 +52,13 @@ ffork(int flags, void (*fn)(void*), void *arg)
flags &= ~RFNOWAIT;
if(flags){
fprint(2, "unknown rfork flags %x\n", flags);
free(p);
free(v);
return -1;
}
pid = clone((int(*)(void*))fn, p+fforkstacksize-16, cloneflag, arg);
v[0] = fn;
v[1] = arg;
pid = clone(tramp, p+fforkstacksize-16, cloneflag, v);
if(pid < 0)
free(p);
return pid;

View file

@ -14,8 +14,11 @@ ffork(int flags, void(*fn)(void*), void *arg)
return -1;
}
_p9uproc(0);
if(pthread_create(&tid, NULL, (void*(*)(void*))fn, arg) < 0)
return -1;
if((int)tid == 0)
_p9uproc(0);
return (int)tid;
}

View file

@ -7,6 +7,7 @@ extern void p9main(int, char**);
int
main(int argc, char **argv)
{
_p9uproc(0);
p9main(argc, argv);
exits("main");
return 99;