1 b2cfc4e2 2003-09-30 devnull #include <lib9.h>
  2 b2cfc4e2 2003-09-30 devnull 
  3 b2cfc4e2 2003-09-30 devnull static struct {
  4 b2cfc4e2 2003-09-30 devnull 	QLp	*p;
  5 b2cfc4e2 2003-09-30 devnull 	QLp	x[1024];
  6 b2cfc4e2 2003-09-30 devnull } ql = {
  7 b2cfc4e2 2003-09-30 devnull 	ql.x
  8 b2cfc4e2 2003-09-30 devnull };
  9 b2cfc4e2 2003-09-30 devnull 
 10 b2cfc4e2 2003-09-30 devnull enum
 11 b2cfc4e2 2003-09-30 devnull {
 12 b2cfc4e2 2003-09-30 devnull 	Queuing,
 13 b2cfc4e2 2003-09-30 devnull 	QueuingR,
 14 b2cfc4e2 2003-09-30 devnull 	QueuingW,
 15 b2cfc4e2 2003-09-30 devnull 	Sleeping,
 16 b2cfc4e2 2003-09-30 devnull };
 17 b2cfc4e2 2003-09-30 devnull 
 18 b2cfc4e2 2003-09-30 devnull static ulong	(*_rendezvousp)(ulong, ulong) = rendezvous;
 19 b2cfc4e2 2003-09-30 devnull 
 20 b2cfc4e2 2003-09-30 devnull /* this gets called by the thread library ONLY to get us to use its rendezvous */
 21 b2cfc4e2 2003-09-30 devnull void
 22 b2cfc4e2 2003-09-30 devnull _qlockinit(ulong (*r)(ulong, ulong))
 23 b2cfc4e2 2003-09-30 devnull {
 24 b2cfc4e2 2003-09-30 devnull 	_rendezvousp = r;
 25 b2cfc4e2 2003-09-30 devnull }
 26 b2cfc4e2 2003-09-30 devnull 
 27 b2cfc4e2 2003-09-30 devnull /* find a free shared memory location to queue ourselves in */
 28 b2cfc4e2 2003-09-30 devnull static QLp*
 29 b2cfc4e2 2003-09-30 devnull getqlp(void)
 30 b2cfc4e2 2003-09-30 devnull {
 31 b2cfc4e2 2003-09-30 devnull 	QLp *p, *op;
 32 b2cfc4e2 2003-09-30 devnull 
 33 b2cfc4e2 2003-09-30 devnull 	op = ql.p;
 34 b2cfc4e2 2003-09-30 devnull 	for(p = op+1; ; p++){
 35 b2cfc4e2 2003-09-30 devnull 		if(p == &ql.x[nelem(ql.x)])
 36 b2cfc4e2 2003-09-30 devnull 			p = ql.x;
 37 b2cfc4e2 2003-09-30 devnull 		if(p == op)
 38 b2cfc4e2 2003-09-30 devnull 			abort();
 39 b2cfc4e2 2003-09-30 devnull 		if(_tas(&(p->inuse)) == 0){
 40 b2cfc4e2 2003-09-30 devnull 			ql.p = p;
 41 b2cfc4e2 2003-09-30 devnull 			p->next = nil;
 42 b2cfc4e2 2003-09-30 devnull 			break;
 43 b2cfc4e2 2003-09-30 devnull 		}
 44 b2cfc4e2 2003-09-30 devnull 	}
 45 b2cfc4e2 2003-09-30 devnull 	return p;
 46 b2cfc4e2 2003-09-30 devnull }
 47 b2cfc4e2 2003-09-30 devnull 
 48 b2cfc4e2 2003-09-30 devnull void
 49 b2cfc4e2 2003-09-30 devnull qlock(QLock *q)
 50 b2cfc4e2 2003-09-30 devnull {
 51 b2cfc4e2 2003-09-30 devnull 	QLp *p, *mp;
 52 b2cfc4e2 2003-09-30 devnull 
 53 b2cfc4e2 2003-09-30 devnull 	lock(&q->lock);
 54 b2cfc4e2 2003-09-30 devnull 	if(!q->locked){
 55 b2cfc4e2 2003-09-30 devnull 		q->locked = 1;
 56 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
 57 b2cfc4e2 2003-09-30 devnull 		return;
 58 b2cfc4e2 2003-09-30 devnull 	}
 59 b2cfc4e2 2003-09-30 devnull 
 60 b2cfc4e2 2003-09-30 devnull 
 61 b2cfc4e2 2003-09-30 devnull 	/* chain into waiting list */
 62 b2cfc4e2 2003-09-30 devnull 	mp = getqlp();
 63 b2cfc4e2 2003-09-30 devnull 	p = q->tail;
 64 b2cfc4e2 2003-09-30 devnull 	if(p == nil)
 65 b2cfc4e2 2003-09-30 devnull 		q->head = mp;
 66 b2cfc4e2 2003-09-30 devnull 	else
 67 b2cfc4e2 2003-09-30 devnull 		p->next = mp;
 68 b2cfc4e2 2003-09-30 devnull 	q->tail = mp;
 69 b2cfc4e2 2003-09-30 devnull 	mp->state = Queuing;
 70 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
 71 b2cfc4e2 2003-09-30 devnull 
 72 b2cfc4e2 2003-09-30 devnull 	/* wait */
 73 b2cfc4e2 2003-09-30 devnull 	while((*_rendezvousp)((ulong)mp, 1) == ~0)
 74 b2cfc4e2 2003-09-30 devnull 		;
 75 b2cfc4e2 2003-09-30 devnull 	mp->inuse = 0;
 76 b2cfc4e2 2003-09-30 devnull }
 77 b2cfc4e2 2003-09-30 devnull 
 78 b2cfc4e2 2003-09-30 devnull void
 79 b2cfc4e2 2003-09-30 devnull qunlock(QLock *q)
 80 b2cfc4e2 2003-09-30 devnull {
 81 b2cfc4e2 2003-09-30 devnull 	QLp *p;
 82 b2cfc4e2 2003-09-30 devnull 
 83 b2cfc4e2 2003-09-30 devnull 	lock(&q->lock);
 84 b2cfc4e2 2003-09-30 devnull 	p = q->head;
 85 b2cfc4e2 2003-09-30 devnull 	if(p != nil){
 86 b2cfc4e2 2003-09-30 devnull 		/* wakeup head waiting process */
 87 b2cfc4e2 2003-09-30 devnull 		q->head = p->next;
 88 b2cfc4e2 2003-09-30 devnull 		if(q->head == nil)
 89 b2cfc4e2 2003-09-30 devnull 			q->tail = nil;
 90 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
 91 b2cfc4e2 2003-09-30 devnull 		while((*_rendezvousp)((ulong)p, 0x12345) == ~0)
 92 b2cfc4e2 2003-09-30 devnull 			;
 93 b2cfc4e2 2003-09-30 devnull 		return;
 94 b2cfc4e2 2003-09-30 devnull 	}
 95 b2cfc4e2 2003-09-30 devnull 	q->locked = 0;
 96 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
 97 b2cfc4e2 2003-09-30 devnull }
 98 b2cfc4e2 2003-09-30 devnull 
 99 b2cfc4e2 2003-09-30 devnull int
100 b2cfc4e2 2003-09-30 devnull canqlock(QLock *q)
101 b2cfc4e2 2003-09-30 devnull {
102 b2cfc4e2 2003-09-30 devnull 	if(!canlock(&q->lock))
103 b2cfc4e2 2003-09-30 devnull 		return 0;
104 b2cfc4e2 2003-09-30 devnull 	if(!q->locked){
105 b2cfc4e2 2003-09-30 devnull 		q->locked = 1;
106 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
107 b2cfc4e2 2003-09-30 devnull 		return 1;
108 b2cfc4e2 2003-09-30 devnull 	}
109 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
110 b2cfc4e2 2003-09-30 devnull 	return 0;
111 b2cfc4e2 2003-09-30 devnull }
112 b2cfc4e2 2003-09-30 devnull 
113 b2cfc4e2 2003-09-30 devnull void
114 b2cfc4e2 2003-09-30 devnull rlock(RWLock *q)
115 b2cfc4e2 2003-09-30 devnull {
116 b2cfc4e2 2003-09-30 devnull 	QLp *p, *mp;
117 b2cfc4e2 2003-09-30 devnull 
118 b2cfc4e2 2003-09-30 devnull 	lock(&q->lock);
119 b2cfc4e2 2003-09-30 devnull 	if(q->writer == 0 && q->head == nil){
120 b2cfc4e2 2003-09-30 devnull 		/* no writer, go for it */
121 b2cfc4e2 2003-09-30 devnull 		q->readers++;
122 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
123 b2cfc4e2 2003-09-30 devnull 		return;
124 b2cfc4e2 2003-09-30 devnull 	}
125 b2cfc4e2 2003-09-30 devnull 
126 b2cfc4e2 2003-09-30 devnull 	mp = getqlp();
127 b2cfc4e2 2003-09-30 devnull 	p = q->tail;
128 b2cfc4e2 2003-09-30 devnull 	if(p == 0)
129 b2cfc4e2 2003-09-30 devnull 		q->head = mp;
130 b2cfc4e2 2003-09-30 devnull 	else
131 b2cfc4e2 2003-09-30 devnull 		p->next = mp;
132 b2cfc4e2 2003-09-30 devnull 	q->tail = mp;
133 b2cfc4e2 2003-09-30 devnull 	mp->next = nil;
134 b2cfc4e2 2003-09-30 devnull 	mp->state = QueuingR;
135 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
136 b2cfc4e2 2003-09-30 devnull 
137 b2cfc4e2 2003-09-30 devnull 	/* wait in kernel */
138 b2cfc4e2 2003-09-30 devnull 	while((*_rendezvousp)((ulong)mp, 1) == ~0)
139 b2cfc4e2 2003-09-30 devnull 		;
140 b2cfc4e2 2003-09-30 devnull 	mp->inuse = 0;
141 b2cfc4e2 2003-09-30 devnull }
142 b2cfc4e2 2003-09-30 devnull 
143 b2cfc4e2 2003-09-30 devnull int
144 b2cfc4e2 2003-09-30 devnull canrlock(RWLock *q)
145 b2cfc4e2 2003-09-30 devnull {
146 b2cfc4e2 2003-09-30 devnull 	lock(&q->lock);
147 b2cfc4e2 2003-09-30 devnull 	if (q->writer == 0 && q->head == nil) {
148 b2cfc4e2 2003-09-30 devnull 		/* no writer; go for it */
149 b2cfc4e2 2003-09-30 devnull 		q->readers++;
150 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
151 b2cfc4e2 2003-09-30 devnull 		return 1;
152 b2cfc4e2 2003-09-30 devnull 	}
153 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
154 b2cfc4e2 2003-09-30 devnull 	return 0;
155 b2cfc4e2 2003-09-30 devnull }
156 b2cfc4e2 2003-09-30 devnull 
157 b2cfc4e2 2003-09-30 devnull void
158 b2cfc4e2 2003-09-30 devnull runlock(RWLock *q)
159 b2cfc4e2 2003-09-30 devnull {
160 b2cfc4e2 2003-09-30 devnull 	QLp *p;
161 b2cfc4e2 2003-09-30 devnull 
162 b2cfc4e2 2003-09-30 devnull 	lock(&q->lock);
163 b2cfc4e2 2003-09-30 devnull 	if(q->readers <= 0)
164 b2cfc4e2 2003-09-30 devnull 		abort();
165 b2cfc4e2 2003-09-30 devnull 	p = q->head;
166 b2cfc4e2 2003-09-30 devnull 	if(--(q->readers) > 0 || p == nil){
167 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
168 b2cfc4e2 2003-09-30 devnull 		return;
169 b2cfc4e2 2003-09-30 devnull 	}
170 b2cfc4e2 2003-09-30 devnull 
171 b2cfc4e2 2003-09-30 devnull 	/* start waiting writer */
172 b2cfc4e2 2003-09-30 devnull 	if(p->state != QueuingW)
173 b2cfc4e2 2003-09-30 devnull 		abort();
174 b2cfc4e2 2003-09-30 devnull 	q->head = p->next;
175 b2cfc4e2 2003-09-30 devnull 	if(q->head == 0)
176 b2cfc4e2 2003-09-30 devnull 		q->tail = 0;
177 b2cfc4e2 2003-09-30 devnull 	q->writer = 1;
178 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
179 b2cfc4e2 2003-09-30 devnull 
180 b2cfc4e2 2003-09-30 devnull 	/* wakeup waiter */
181 b2cfc4e2 2003-09-30 devnull 	while((*_rendezvousp)((ulong)p, 0) == ~0)
182 b2cfc4e2 2003-09-30 devnull 		;
183 b2cfc4e2 2003-09-30 devnull }
184 b2cfc4e2 2003-09-30 devnull 
185 b2cfc4e2 2003-09-30 devnull void
186 b2cfc4e2 2003-09-30 devnull wlock(RWLock *q)
187 b2cfc4e2 2003-09-30 devnull {
188 b2cfc4e2 2003-09-30 devnull 	QLp *p, *mp;
189 b2cfc4e2 2003-09-30 devnull 
190 b2cfc4e2 2003-09-30 devnull 	lock(&q->lock);
191 b2cfc4e2 2003-09-30 devnull 	if(q->readers == 0 && q->writer == 0){
192 b2cfc4e2 2003-09-30 devnull 		/* noone waiting, go for it */
193 b2cfc4e2 2003-09-30 devnull 		q->writer = 1;
194 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
195 b2cfc4e2 2003-09-30 devnull 		return;
196 b2cfc4e2 2003-09-30 devnull 	}
197 b2cfc4e2 2003-09-30 devnull 
198 b2cfc4e2 2003-09-30 devnull 	/* wait */
199 b2cfc4e2 2003-09-30 devnull 	p = q->tail;
200 b2cfc4e2 2003-09-30 devnull 	mp = getqlp();
201 b2cfc4e2 2003-09-30 devnull 	if(p == nil)
202 b2cfc4e2 2003-09-30 devnull 		q->head = mp;
203 b2cfc4e2 2003-09-30 devnull 	else
204 b2cfc4e2 2003-09-30 devnull 		p->next = mp;
205 b2cfc4e2 2003-09-30 devnull 	q->tail = mp;
206 b2cfc4e2 2003-09-30 devnull 	mp->next = nil;
207 b2cfc4e2 2003-09-30 devnull 	mp->state = QueuingW;
208 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
209 b2cfc4e2 2003-09-30 devnull 
210 b2cfc4e2 2003-09-30 devnull 	/* wait in kernel */
211 b2cfc4e2 2003-09-30 devnull 	while((*_rendezvousp)((ulong)mp, 1) == ~0)
212 b2cfc4e2 2003-09-30 devnull 		;
213 b2cfc4e2 2003-09-30 devnull 	mp->inuse = 0;
214 b2cfc4e2 2003-09-30 devnull }
215 b2cfc4e2 2003-09-30 devnull 
216 b2cfc4e2 2003-09-30 devnull int
217 b2cfc4e2 2003-09-30 devnull canwlock(RWLock *q)
218 b2cfc4e2 2003-09-30 devnull {
219 b2cfc4e2 2003-09-30 devnull 	lock(&q->lock);
220 b2cfc4e2 2003-09-30 devnull 	if (q->readers == 0 && q->writer == 0) {
221 b2cfc4e2 2003-09-30 devnull 		/* no one waiting; go for it */
222 b2cfc4e2 2003-09-30 devnull 		q->writer = 1;
223 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
224 b2cfc4e2 2003-09-30 devnull 		return 1;
225 b2cfc4e2 2003-09-30 devnull 	}
226 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
227 b2cfc4e2 2003-09-30 devnull 	return 0;
228 b2cfc4e2 2003-09-30 devnull }
229 b2cfc4e2 2003-09-30 devnull 
230 b2cfc4e2 2003-09-30 devnull void
231 b2cfc4e2 2003-09-30 devnull wunlock(RWLock *q)
232 b2cfc4e2 2003-09-30 devnull {
233 b2cfc4e2 2003-09-30 devnull 	QLp *p;
234 b2cfc4e2 2003-09-30 devnull 
235 b2cfc4e2 2003-09-30 devnull 	lock(&q->lock);
236 b2cfc4e2 2003-09-30 devnull 	if(q->writer == 0)
237 b2cfc4e2 2003-09-30 devnull 		abort();
238 b2cfc4e2 2003-09-30 devnull 	p = q->head;
239 b2cfc4e2 2003-09-30 devnull 	if(p == nil){
240 b2cfc4e2 2003-09-30 devnull 		q->writer = 0;
241 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
242 b2cfc4e2 2003-09-30 devnull 		return;
243 b2cfc4e2 2003-09-30 devnull 	}
244 b2cfc4e2 2003-09-30 devnull 	if(p->state == QueuingW){
245 b2cfc4e2 2003-09-30 devnull 		/* start waiting writer */
246 b2cfc4e2 2003-09-30 devnull 		q->head = p->next;
247 b2cfc4e2 2003-09-30 devnull 		if(q->head == nil)
248 b2cfc4e2 2003-09-30 devnull 			q->tail = nil;
249 b2cfc4e2 2003-09-30 devnull 		unlock(&q->lock);
250 b2cfc4e2 2003-09-30 devnull 		while((*_rendezvousp)((ulong)p, 0) == ~0)
251 b2cfc4e2 2003-09-30 devnull 			;
252 b2cfc4e2 2003-09-30 devnull 		return;
253 b2cfc4e2 2003-09-30 devnull 	}
254 b2cfc4e2 2003-09-30 devnull 
255 b2cfc4e2 2003-09-30 devnull 	if(p->state != QueuingR)
256 b2cfc4e2 2003-09-30 devnull 		abort();
257 b2cfc4e2 2003-09-30 devnull 
258 b2cfc4e2 2003-09-30 devnull 	/* wake waiting readers */
259 b2cfc4e2 2003-09-30 devnull 	while(q->head != nil && q->head->state == QueuingR){
260 b2cfc4e2 2003-09-30 devnull 		p = q->head;
261 b2cfc4e2 2003-09-30 devnull 		q->head = p->next;
262 b2cfc4e2 2003-09-30 devnull 		q->readers++;
263 b2cfc4e2 2003-09-30 devnull 		while((*_rendezvousp)((ulong)p, 0) == ~0)
264 b2cfc4e2 2003-09-30 devnull 			;
265 b2cfc4e2 2003-09-30 devnull 	}
266 b2cfc4e2 2003-09-30 devnull 	if(q->head == nil)
267 b2cfc4e2 2003-09-30 devnull 		q->tail = nil;
268 b2cfc4e2 2003-09-30 devnull 	q->writer = 0;
269 b2cfc4e2 2003-09-30 devnull 	unlock(&q->lock);
270 b2cfc4e2 2003-09-30 devnull }
271 b2cfc4e2 2003-09-30 devnull 
272 b2cfc4e2 2003-09-30 devnull void
273 b2cfc4e2 2003-09-30 devnull rsleep(Rendez *r)
274 b2cfc4e2 2003-09-30 devnull {
275 b2cfc4e2 2003-09-30 devnull 	QLp *t, *me;
276 b2cfc4e2 2003-09-30 devnull 
277 b2cfc4e2 2003-09-30 devnull 	if(!r->l)
278 b2cfc4e2 2003-09-30 devnull 		abort();
279 b2cfc4e2 2003-09-30 devnull 	lock(&r->l->lock);
280 b2cfc4e2 2003-09-30 devnull 	/* we should hold the qlock */
281 b2cfc4e2 2003-09-30 devnull 	if(!r->l->locked)
282 b2cfc4e2 2003-09-30 devnull 		abort();
283 b2cfc4e2 2003-09-30 devnull 
284 b2cfc4e2 2003-09-30 devnull 	/* add ourselves to the wait list */
285 b2cfc4e2 2003-09-30 devnull 	me = getqlp();
286 b2cfc4e2 2003-09-30 devnull 	me->state = Sleeping;
287 b2cfc4e2 2003-09-30 devnull 	if(r->head == nil)
288 b2cfc4e2 2003-09-30 devnull 		r->head = me;
289 b2cfc4e2 2003-09-30 devnull 	else
290 b2cfc4e2 2003-09-30 devnull 		r->tail->next = me;
291 b2cfc4e2 2003-09-30 devnull 	me->next = nil;
292 b2cfc4e2 2003-09-30 devnull 	r->tail = me;
293 b2cfc4e2 2003-09-30 devnull 
294 b2cfc4e2 2003-09-30 devnull 	/* pass the qlock to the next guy */
295 b2cfc4e2 2003-09-30 devnull 	t = r->l->head;
296 b2cfc4e2 2003-09-30 devnull 	if(t){
297 b2cfc4e2 2003-09-30 devnull 		r->l->head = t->next;
298 b2cfc4e2 2003-09-30 devnull 		if(r->l->head == nil)
299 b2cfc4e2 2003-09-30 devnull 			r->l->tail = nil;
300 b2cfc4e2 2003-09-30 devnull 		unlock(&r->l->lock);
301 b2cfc4e2 2003-09-30 devnull 		while((*_rendezvousp)((ulong)t, 0x12345) == ~0)
302 b2cfc4e2 2003-09-30 devnull 			;
303 b2cfc4e2 2003-09-30 devnull 	}else{
304 b2cfc4e2 2003-09-30 devnull 		r->l->locked = 0;
305 b2cfc4e2 2003-09-30 devnull 		unlock(&r->l->lock);
306 b2cfc4e2 2003-09-30 devnull 	}
307 b2cfc4e2 2003-09-30 devnull 
308 b2cfc4e2 2003-09-30 devnull 	/* wait for a wakeup */
309 b2cfc4e2 2003-09-30 devnull 	while((*_rendezvousp)((ulong)me, 0x23456) == ~0)
310 b2cfc4e2 2003-09-30 devnull 		;
311 b2cfc4e2 2003-09-30 devnull 	me->inuse = 0;
312 b2cfc4e2 2003-09-30 devnull 	if(!r->l->locked)
313 b2cfc4e2 2003-09-30 devnull 		abort();
314 b2cfc4e2 2003-09-30 devnull }
315 b2cfc4e2 2003-09-30 devnull 
316 b2cfc4e2 2003-09-30 devnull int
317 b2cfc4e2 2003-09-30 devnull rwakeup(Rendez *r)
318 b2cfc4e2 2003-09-30 devnull {
319 b2cfc4e2 2003-09-30 devnull 	QLp *t;
320 b2cfc4e2 2003-09-30 devnull 
321 b2cfc4e2 2003-09-30 devnull 	/*
322 b2cfc4e2 2003-09-30 devnull 	 * take off wait and put on front of queue
323 b2cfc4e2 2003-09-30 devnull 	 * put on front so guys that have been waiting will not get starved
324 b2cfc4e2 2003-09-30 devnull 	 */
325 b2cfc4e2 2003-09-30 devnull 	
326 b2cfc4e2 2003-09-30 devnull 	if(!r->l)
327 b2cfc4e2 2003-09-30 devnull 		abort();
328 b2cfc4e2 2003-09-30 devnull 	lock(&r->l->lock);
329 b2cfc4e2 2003-09-30 devnull 	if(!r->l->locked)
330 b2cfc4e2 2003-09-30 devnull 		abort();
331 b2cfc4e2 2003-09-30 devnull 
332 b2cfc4e2 2003-09-30 devnull 	t = r->head;
333 b2cfc4e2 2003-09-30 devnull 	if(t == nil){
334 b2cfc4e2 2003-09-30 devnull 		unlock(&r->l->lock);
335 b2cfc4e2 2003-09-30 devnull 		return 0;
336 b2cfc4e2 2003-09-30 devnull 	}
337 b2cfc4e2 2003-09-30 devnull 
338 b2cfc4e2 2003-09-30 devnull 	r->head = t->next;
339 b2cfc4e2 2003-09-30 devnull 	if(r->head == nil)
340 b2cfc4e2 2003-09-30 devnull 		r->tail = nil;
341 b2cfc4e2 2003-09-30 devnull 
342 b2cfc4e2 2003-09-30 devnull 	t->next = r->l->head;
343 b2cfc4e2 2003-09-30 devnull 	r->l->head = t;
344 b2cfc4e2 2003-09-30 devnull 	if(r->l->tail == nil)
345 b2cfc4e2 2003-09-30 devnull 		r->l->tail = t;
346 b2cfc4e2 2003-09-30 devnull 
347 b2cfc4e2 2003-09-30 devnull 	t->state = Queuing;
348 b2cfc4e2 2003-09-30 devnull 	unlock(&r->l->lock);
349 b2cfc4e2 2003-09-30 devnull 	return 1;
350 b2cfc4e2 2003-09-30 devnull }
351 b2cfc4e2 2003-09-30 devnull 
352 b2cfc4e2 2003-09-30 devnull int
353 b2cfc4e2 2003-09-30 devnull rwakeupall(Rendez *r)
354 b2cfc4e2 2003-09-30 devnull {
355 b2cfc4e2 2003-09-30 devnull 	int i;
356 b2cfc4e2 2003-09-30 devnull 
357 b2cfc4e2 2003-09-30 devnull 	for(i=0; rwakeup(r); i++)
358 b2cfc4e2 2003-09-30 devnull 		;
359 b2cfc4e2 2003-09-30 devnull 	return i;
360 b2cfc4e2 2003-09-30 devnull }