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