o5r/plan9port
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Various little fixes.

Browse source
This commit is contained in:
rsc 2004-03-05 03:13:13 +00:00
parent c91bd3283a
commit 4da83e7cce
7 changed files with 13 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

1
src/libthread/channel.c
View file

@ -201,7 +201,6 @@ _threadnalt++;
}else{
altexec(a, s); /* unlocks chanlock, does splx */
}
_sched();
t->chan = Channone;
_threadnalt++;
return a - alts;

5
src/libthread/fdwait.c
View file

@ -146,10 +146,11 @@ pollidle(void *v)
for(i=0; i<npoll; i++)
if(pfd[i].fd != -1 && pfd[i].revents){
//fprint(2, " %d", pfd[i].fd);
nbsendul(polls[i].c, 1);
pfd[i].fd = -1;
pfd[i].events = 0;
pfd[i].revents = 0;
nbsendul(polls[i].c, 1);
//fprint(2, " x%d", pfd[i].fd);
}
//fprint(2, "\n");
}
@ -192,7 +193,7 @@ _threadfdwait(int fd, int rw, ulong pc)
pfd[i].fd = fd;
pfd[i].events = rw=='r' ? POLLIN : POLLOUT;
polls[i].c = &s.c;
//fprint(2, "%s [%3d] fdwait %d %c list *0x%lux\n",
if(0) fprint(2, "%s [%3d] fdwait %d %c list *0x%lux\n",
argv0, threadid(), fd, rw, pc);
recvul(&s.c);
}