Lines Matching refs:rv
28 #define ABTS_SUCCESS(rv) ABTS_INT_EQUAL(tc, APR_SUCCESS, rv)
50 apr_status_t rv;
54 rv = apr_thread_mutex_create(&mutex, APR_THREAD_MUTEX_DEFAULT, p);
55 ABTS_SUCCESS(rv);
58 rv = apr_thread_cond_create(&cond, p);
59 ABTS_SUCCESS(rv);
62 rv = apr_thread_cond_signal(cond);
63 ABTS_SUCCESS(rv);
65 rv = apr_thread_mutex_lock(mutex);
66 ABTS_SUCCESS(rv);
68 rv = apr_thread_cond_timedwait(cond, mutex, 10000);
69 ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_TIMEUP(rv));
71 rv = apr_thread_mutex_unlock(mutex);
72 ABTS_SUCCESS(rv);
74 rv = apr_thread_cond_broadcast(cond);
75 ABTS_SUCCESS(rv);
77 rv = apr_thread_mutex_lock(mutex);
78 ABTS_SUCCESS(rv);
80 rv = apr_thread_cond_timedwait(cond, mutex, 10000);
81 ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_TIMEUP(rv));
83 rv = apr_thread_mutex_unlock(mutex);
84 ABTS_SUCCESS(rv);
86 rv = apr_thread_cond_destroy(cond);
87 ABTS_SUCCESS(rv);
89 rv = apr_thread_mutex_destroy(mutex);
90 ABTS_SUCCESS(rv);
106 apr_status_t rv;
109 rv = apr_thread_mutex_lock(box->mutex);
110 ABTS_SUCCESS(rv);
112 rv = apr_thread_cond_signal(box->cond);
113 ABTS_SUCCESS(rv);
115 rv = apr_thread_mutex_unlock(box->mutex);
116 ABTS_SUCCESS(rv);
122 apr_status_t rv;
128 rv = apr_thread_cond_create(&cond, p);
129 ABTS_SUCCESS(rv);
133 rv = apr_thread_mutex_create(&mutex[i], APR_THREAD_MUTEX_DEFAULT, p);
134 ABTS_SUCCESS(rv);
136 rv = apr_thread_mutex_lock(mutex[i]);
137 ABTS_SUCCESS(rv);
144 rv = apr_thread_create(&thread[i], NULL, thread_routine, &box[i], p);
145 ABTS_SUCCESS(rv);
153 rv = apr_thread_cond_wait(cond, mutex[i]);
154 ABTS_SUCCESS(rv);
158 rv = apr_thread_cond_timedwait(cond, mutex[i], 10000);
159 ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_TIMEUP(rv));
161 rv = apr_thread_mutex_unlock(mutex[i]);
162 ABTS_SUCCESS(rv);
167 rv = apr_thread_join(&retval, thread[i]);
168 ABTS_SUCCESS(rv);
171 rv = apr_thread_cond_destroy(cond);
172 ABTS_SUCCESS(rv);
175 rv = apr_thread_mutex_destroy(mutex[i]);
176 ABTS_SUCCESS(rv);
182 apr_status_t rv;
186 rv = apr_thread_mutex_lock(box->mutex);
187 ABTS_SUCCESS(rv);
191 rv = apr_thread_cond_wait(box->cond, box->mutex);
192 ABTS_SUCCESS(rv);
196 rv = apr_thread_mutex_unlock(box->mutex);
197 ABTS_SUCCESS(rv);
204 apr_status_t rv;
210 rv = apr_thread_cond_create(&cond, p);
211 ABTS_SUCCESS(rv);
214 rv = apr_thread_mutex_create(&mutex, APR_THREAD_MUTEX_DEFAULT, p);
215 ABTS_SUCCESS(rv);
218 rv = apr_thread_mutex_lock(mutex);
219 ABTS_SUCCESS(rv);
228 rv = apr_thread_create(&thread[i], NULL, thread_routine, &box, p);
229 ABTS_SUCCESS(rv);
233 rv = apr_thread_mutex_unlock(mutex);
234 ABTS_SUCCESS(rv);
236 rv = apr_thread_mutex_lock(mutex);
237 ABTS_SUCCESS(rv);
240 rv = apr_thread_cond_broadcast(cond);
241 ABTS_SUCCESS(rv);
243 rv = apr_thread_mutex_unlock(mutex);
244 ABTS_SUCCESS(rv);
248 rv = apr_thread_join(&retval, thread[i]);
249 ABTS_SUCCESS(rv);
254 rv = apr_thread_cond_destroy(cond);
255 ABTS_SUCCESS(rv);
257 rv = apr_thread_mutex_destroy(mutex);
258 ABTS_SUCCESS(rv);
263 apr_status_t rv;
266 rv = apr_thread_mutex_lock(box->mutex);
267 ABTS_SUCCESS(rv);
269 rv = apr_thread_mutex_lock(box->mutex);
270 ABTS_SUCCESS(rv);
272 rv = apr_thread_mutex_lock(box->mutex);
273 ABTS_SUCCESS(rv);
275 rv = apr_thread_cond_wait(box->cond, box->mutex);
276 ABTS_SUCCESS(rv);
281 apr_status_t rv;
284 rv = apr_thread_mutex_lock(box->mutex);
285 ABTS_SUCCESS(rv);
287 rv = apr_thread_mutex_lock(box->mutex);
288 ABTS_SUCCESS(rv);
290 rv = apr_thread_mutex_lock(box->mutex);
291 ABTS_SUCCESS(rv);
293 rv = apr_thread_cond_timedwait(box->cond, box->mutex, 2000000);
294 ABTS_SUCCESS(rv);
296 rv = apr_thread_mutex_unlock(box->mutex);
297 ABTS_SUCCESS(rv);
299 rv = apr_thread_mutex_unlock(box->mutex);
300 ABTS_SUCCESS(rv);
307 apr_status_t rv, retval;
312 rv = apr_thread_mutex_create(&mutex, APR_THREAD_MUTEX_NESTED, p);
313 ABTS_SUCCESS(rv);
316 rv = apr_thread_cond_create(&cond, p);
317 ABTS_SUCCESS(rv);
320 rv = apr_thread_mutex_lock(mutex);
321 ABTS_SUCCESS(rv);
328 rv = apr_thread_create(&thread, NULL, thread_routine, &box, p);
329 ABTS_SUCCESS(rv);
331 rv = apr_thread_mutex_unlock(mutex);
332 ABTS_SUCCESS(rv);
337 rv = apr_thread_cond_signal(cond);
338 ABTS_SUCCESS(rv);
340 rv = apr_thread_join(&retval, thread);
341 ABTS_SUCCESS(rv);
343 rv = apr_thread_mutex_trylock(mutex);
344 ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_EBUSY(rv));
346 rv = apr_thread_mutex_trylock(mutex);
347 ABTS_INT_EQUAL(tc, 1, APR_STATUS_IS_EBUSY(rv));
356 apr_status_t rv;
363 rv = apr_thread_mutex_lock(box->mutex);
364 ABTS_SUCCESS(rv);
367 rv = apr_thread_cond_wait(box->cond, box->mutex);
368 ABTS_SUCCESS(rv);
372 rv = apr_thread_mutex_unlock(box->mutex);
373 ABTS_SUCCESS(rv);
380 rv = apr_thread_mutex_unlock(box->mutex);
381 ABTS_SUCCESS(rv);
383 rv = apr_file_read_full(out, &ch, 1, &nbytes);
384 ABTS_SUCCESS(rv);
397 apr_status_t rv;
402 rv = apr_file_write_full(in, &ch, 1, &nbytes);
403 ABTS_SUCCESS(rv);
406 rv = apr_thread_mutex_lock(box->mutex);
407 ABTS_SUCCESS(rv);
410 rv = apr_thread_cond_signal(box->cond);
411 ABTS_SUCCESS(rv);
416 rv = apr_thread_mutex_unlock(box->mutex);
417 ABTS_SUCCESS(rv);
431 apr_status_t rv;
439 rv = apr_file_pipe_create(&in, &out, p);
440 ABTS_SUCCESS(rv);
442 rv = apr_thread_mutex_create(&mutex, APR_THREAD_MUTEX_DEFAULT, p);
443 ABTS_SUCCESS(rv);
446 rv = apr_thread_cond_create(&cond, p);
447 ABTS_SUCCESS(rv);
457 rv = apr_thread_create(&thread[i], NULL, thread_routine, &boxcons, p);
458 ABTS_SUCCESS(rv);
468 rv = apr_thread_create(&thread[i], NULL, thread_routine, &boxprod, p);
469 ABTS_SUCCESS(rv);
474 rv = apr_thread_join(&retval, thread[i]);
475 ABTS_SUCCESS(rv);
478 rv = apr_thread_mutex_lock(mutex);
479 ABTS_SUCCESS(rv);
483 rv = apr_thread_cond_broadcast(cond);
484 ABTS_SUCCESS(rv);
486 rv = apr_thread_mutex_unlock(mutex);
487 ABTS_SUCCESS(rv);
491 rv = apr_thread_join(&retval, thread[i]);
492 ABTS_SUCCESS(rv);
495 rv = apr_thread_cond_destroy(cond);
496 ABTS_SUCCESS(rv);
498 rv = apr_thread_mutex_destroy(mutex);
499 ABTS_SUCCESS(rv);
501 rv = apr_file_close(in);
502 ABTS_SUCCESS(rv);
504 rv = apr_file_close(out);
505 ABTS_SUCCESS(rv);
517 apr_status_t rv;
520 rv = apr_thread_mutex_lock(box->mutex);
521 ABTS_SUCCESS(rv);
527 rv = apr_thread_cond_signal(box->cond);
528 ABTS_SUCCESS(rv);
532 rv = apr_thread_cond_wait(box->cond, box->mutex);
533 ABTS_SUCCESS(rv);
538 rv = apr_thread_mutex_unlock(box->mutex);
539 ABTS_SUCCESS(rv);
541 rv = apr_thread_cond_broadcast(box->cond);
542 ABTS_SUCCESS(rv);
547 apr_status_t rv;
550 rv = apr_thread_mutex_lock(box->mutex);
551 ABTS_SUCCESS(rv);
557 rv = apr_thread_cond_signal(box->cond);
558 ABTS_SUCCESS(rv);
562 rv = apr_thread_cond_wait(box->cond, box->mutex);
563 ABTS_SUCCESS(rv);
568 rv = apr_thread_mutex_unlock(box->mutex);
569 ABTS_SUCCESS(rv);
571 rv = apr_thread_cond_broadcast(box->cond);
572 ABTS_SUCCESS(rv);
577 apr_status_t rv, retval;
583 rv = apr_thread_mutex_create(&mutex, APR_THREAD_MUTEX_DEFAULT, p);
584 ABTS_SUCCESS(rv);
587 rv = apr_thread_cond_create(&cond, p);
588 ABTS_SUCCESS(rv);
591 rv = apr_thread_mutex_lock(mutex);
592 ABTS_SUCCESS(rv);
600 rv = apr_thread_create(&thr_ping, NULL, thread_routine, &box_ping, p);
601 ABTS_SUCCESS(rv);
609 rv = apr_thread_create(&thr_pong, NULL, thread_routine, &box_pong, p);
610 ABTS_SUCCESS(rv);
614 rv = apr_thread_mutex_unlock(mutex);
615 ABTS_SUCCESS(rv);
619 rv = apr_thread_mutex_lock(mutex);
620 ABTS_SUCCESS(rv);
624 rv = apr_thread_mutex_unlock(mutex);
625 ABTS_SUCCESS(rv);
627 rv = apr_thread_join(&retval, thr_ping);
628 ABTS_SUCCESS(rv);
630 rv = apr_thread_join(&retval, thr_pong);
631 ABTS_SUCCESS(rv);
633 rv = apr_thread_cond_destroy(cond);
634 ABTS_SUCCESS(rv);
636 rv = apr_thread_mutex_destroy(mutex);
637 ABTS_SUCCESS(rv);