1 76193d7c 2003-09-30 devnull #include "threadimpl.h"
  2 76193d7c 2003-09-30 devnull 
  3 76193d7c 2003-09-30 devnull int	_threadnopasser;
  4 76193d7c 2003-09-30 devnull 
  5 76193d7c 2003-09-30 devnull #define	NFN		33
  6 76193d7c 2003-09-30 devnull #define	ERRLEN	48
  7 76193d7c 2003-09-30 devnull typedef struct Note Note;
  8 76193d7c 2003-09-30 devnull struct Note
  9 76193d7c 2003-09-30 devnull {
 10 76193d7c 2003-09-30 devnull 	Lock		inuse;
 11 76193d7c 2003-09-30 devnull 	Proc		*proc;		/* recipient */
 12 76193d7c 2003-09-30 devnull 	char		s[ERRMAX];	/* arg2 */
 13 76193d7c 2003-09-30 devnull };
 14 76193d7c 2003-09-30 devnull 
 15 76193d7c 2003-09-30 devnull static Note	notes[128];
 16 76193d7c 2003-09-30 devnull static Note	*enotes = notes+nelem(notes);
 17 76193d7c 2003-09-30 devnull static int		(*onnote[NFN])(void*, char*);
 18 76193d7c 2003-09-30 devnull static int		onnotepid[NFN];
 19 76193d7c 2003-09-30 devnull static Lock	onnotelock;
 20 76193d7c 2003-09-30 devnull 
 21 76193d7c 2003-09-30 devnull int
 22 76193d7c 2003-09-30 devnull threadnotify(int (*f)(void*, char*), int in)
 23 76193d7c 2003-09-30 devnull {
 24 76193d7c 2003-09-30 devnull 	int i, topid;
 25 76193d7c 2003-09-30 devnull 	int (*from)(void*, char*), (*to)(void*, char*);
 26 76193d7c 2003-09-30 devnull 
 27 76193d7c 2003-09-30 devnull 	if(in){
 28 76193d7c 2003-09-30 devnull 		from = nil;
 29 76193d7c 2003-09-30 devnull 		to = f;
 30 76193d7c 2003-09-30 devnull 		topid = _threadgetproc()->pid;
 31 76193d7c 2003-09-30 devnull 	}else{
 32 76193d7c 2003-09-30 devnull 		from = f;
 33 76193d7c 2003-09-30 devnull 		to = nil;
 34 76193d7c 2003-09-30 devnull 		topid = 0;
 35 76193d7c 2003-09-30 devnull 	}
 36 76193d7c 2003-09-30 devnull 	lock(&onnotelock);
 37 76193d7c 2003-09-30 devnull 	for(i=0; i<NFN; i++)
 38 76193d7c 2003-09-30 devnull 		if(onnote[i]==from){
 39 76193d7c 2003-09-30 devnull 			onnote[i] = to;
 40 76193d7c 2003-09-30 devnull 			onnotepid[i] = topid;
 41 76193d7c 2003-09-30 devnull 			break;
 42 76193d7c 2003-09-30 devnull 		}
 43 76193d7c 2003-09-30 devnull 	unlock(&onnotelock);
 44 76193d7c 2003-09-30 devnull 	return i<NFN;
 45 76193d7c 2003-09-30 devnull }
 46 76193d7c 2003-09-30 devnull 
 47 76193d7c 2003-09-30 devnull static void
 48 76193d7c 2003-09-30 devnull delayednotes(Proc *p, void *v)
 49 76193d7c 2003-09-30 devnull {
 50 76193d7c 2003-09-30 devnull 	int i;
 51 76193d7c 2003-09-30 devnull 	Note *n;
 52 76193d7c 2003-09-30 devnull 	int (*fn)(void*, char*);
 53 76193d7c 2003-09-30 devnull 
 54 76193d7c 2003-09-30 devnull 	if(!p->pending)
 55 76193d7c 2003-09-30 devnull 		return;
 56 76193d7c 2003-09-30 devnull 
 57 76193d7c 2003-09-30 devnull 	p->pending = 0;
 58 76193d7c 2003-09-30 devnull 	for(n=notes; n<enotes; n++){
 59 76193d7c 2003-09-30 devnull 		if(n->proc == p){
 60 76193d7c 2003-09-30 devnull 			for(i=0; i<NFN; i++){
 61 76193d7c 2003-09-30 devnull 				if(onnotepid[i]!=p->pid || (fn = onnote[i])==nil)
 62 76193d7c 2003-09-30 devnull 					continue;
 63 76193d7c 2003-09-30 devnull 				if((*fn)(v, n->s))
 64 76193d7c 2003-09-30 devnull 					break;
 65 76193d7c 2003-09-30 devnull 			}
 66 76193d7c 2003-09-30 devnull 			if(i==NFN){
 67 76193d7c 2003-09-30 devnull 				_threaddebug(DBGNOTE, "Unhandled note %s, proc %p\n", n->s, p);
 68 76193d7c 2003-09-30 devnull 				if(v != nil)
 69 76193d7c 2003-09-30 devnull 					noted(NDFLT);
 70 76193d7c 2003-09-30 devnull 				else if(strncmp(n->s, "sys:", 4)==0)
 71 76193d7c 2003-09-30 devnull 					abort();
 72 76193d7c 2003-09-30 devnull 				threadexitsall(n->s);
 73 76193d7c 2003-09-30 devnull 			}
 74 76193d7c 2003-09-30 devnull 			n->proc = nil;
 75 76193d7c 2003-09-30 devnull 			unlock(&n->inuse);
 76 76193d7c 2003-09-30 devnull 		}
 77 76193d7c 2003-09-30 devnull 	}
 78 76193d7c 2003-09-30 devnull }
 79 76193d7c 2003-09-30 devnull 
 80 76193d7c 2003-09-30 devnull void
 81 76193d7c 2003-09-30 devnull _threadnote(void *v, char *s)
 82 76193d7c 2003-09-30 devnull {
 83 76193d7c 2003-09-30 devnull 	Proc *p;
 84 76193d7c 2003-09-30 devnull 	Note *n;
 85 76193d7c 2003-09-30 devnull 
 86 76193d7c 2003-09-30 devnull 	_threaddebug(DBGNOTE, "Got note %s", s);
 87 32f69c36 2003-12-11 devnull 	if(strncmp(s, "sys:", 4) == 0 && strcmp(s, "sys: write on closed pipe") != 0)
 88 76193d7c 2003-09-30 devnull 		noted(NDFLT);
 89 76193d7c 2003-09-30 devnull 
 90 76193d7c 2003-09-30 devnull //	if(_threadexitsallstatus){
 91 76193d7c 2003-09-30 devnull //		_threaddebug(DBGNOTE, "Threadexitsallstatus = '%s'\n", _threadexitsallstatus);
 92 76193d7c 2003-09-30 devnull //		_exits(_threadexitsallstatus);
 93 76193d7c 2003-09-30 devnull //	}
 94 76193d7c 2003-09-30 devnull 
 95 76193d7c 2003-09-30 devnull 	if(strcmp(s, "threadint")==0)
 96 76193d7c 2003-09-30 devnull 		noted(NCONT);
 97 76193d7c 2003-09-30 devnull 
 98 76193d7c 2003-09-30 devnull 	p = _threadgetproc();
 99 76193d7c 2003-09-30 devnull 	if(p == nil)
100 76193d7c 2003-09-30 devnull 		noted(NDFLT);
101 76193d7c 2003-09-30 devnull 
102 76193d7c 2003-09-30 devnull 	for(n=notes; n<enotes; n++)
103 76193d7c 2003-09-30 devnull 		if(canlock(&n->inuse))
104 76193d7c 2003-09-30 devnull 			break;
105 76193d7c 2003-09-30 devnull 	if(n==enotes)
106 76193d7c 2003-09-30 devnull 		sysfatal("libthread: too many delayed notes");
107 76193d7c 2003-09-30 devnull 	utfecpy(n->s, n->s+ERRMAX, s);
108 76193d7c 2003-09-30 devnull 	n->proc = p;
109 76193d7c 2003-09-30 devnull 	p->pending = 1;
110 76193d7c 2003-09-30 devnull 	if(!p->splhi)
111 76193d7c 2003-09-30 devnull 		delayednotes(p, v);
112 76193d7c 2003-09-30 devnull 	noted(NCONT);
113 76193d7c 2003-09-30 devnull }
114 76193d7c 2003-09-30 devnull 
115 76193d7c 2003-09-30 devnull int
116 76193d7c 2003-09-30 devnull _procsplhi(void)
117 76193d7c 2003-09-30 devnull {
118 76193d7c 2003-09-30 devnull 	int s;
119 76193d7c 2003-09-30 devnull 	Proc *p;
120 76193d7c 2003-09-30 devnull 
121 76193d7c 2003-09-30 devnull 	p = _threadgetproc();
122 76193d7c 2003-09-30 devnull 	s = p->splhi;
123 76193d7c 2003-09-30 devnull 	p->splhi = 1;
124 76193d7c 2003-09-30 devnull 	return s;
125 76193d7c 2003-09-30 devnull }
126 76193d7c 2003-09-30 devnull 
127 76193d7c 2003-09-30 devnull void
128 76193d7c 2003-09-30 devnull _procsplx(int s)
129 76193d7c 2003-09-30 devnull {
130 76193d7c 2003-09-30 devnull 	Proc *p;
131 76193d7c 2003-09-30 devnull 
132 76193d7c 2003-09-30 devnull 	p = _threadgetproc();
133 76193d7c 2003-09-30 devnull 	p->splhi = s;
134 76193d7c 2003-09-30 devnull 	if(s)
135 76193d7c 2003-09-30 devnull 		return;
136 76193d7c 2003-09-30 devnull /*
137 76193d7c 2003-09-30 devnull 	if(p->pending)
138 76193d7c 2003-09-30 devnull 		delayednotes(p, nil);
139 76193d7c 2003-09-30 devnull */
140 76193d7c 2003-09-30 devnull }
141 76193d7c 2003-09-30 devnull