Home | History | Annotate | Download | only in librumpclient

Lines Matching defs:rw

220 cliwaitresp(struct spclient *spc, struct respwait *rw, sigset_t *mask,
231 	rw->rw_error = 0;
232 	while (!rw->rw_done && rw->rw_error == 0) {
314 					    rw->rw_reqno;
340 			pthread_cond_wait(&rw->rw_cv, &spc->spc_mtx);
343 	TAILQ_REMOVE(&spc->spc_respwait, rw, rw_entries);
345 	pthread_cond_destroy(&rw->rw_cv);
350 	return rw->rw_error;
358 	struct respwait rw;
371 		putwait(spc, &rw, &rhdr);
373 			unputwait(spc, &rw);
377 		rv = cliwaitresp(spc, &rw, omask, false);
382 	*resp = rw.rw_data;
393 	struct respwait rw;
439 		putwait_locked(spc, &rw, &rhdr);
441 		putwait(spc, &rw, &rhdr);
452 			unputwait_locked(spc, &rw);
454 			unputwait(spc, &rw);
459 		rv = cliwaitresp(spc, &rw, &omask, haslock);
464 	rv = *(int *)rw.rw_data;
465 	free(rw.rw_data);
476 	struct respwait rw;
488 		putwait(spc, &rw, &rhdr);
491 			unputwait(spc, &rw);
495 		rv = cliwaitresp(spc, &rw, omask, false);
500 	*resp = rw.rw_data;
751 	struct respwait rw;
769 	putwait_locked(&clispc, &rw, &rhdr);
777 		pthread_cond_wait(&rw.rw_cv, &clispc.spc_mtx);
788 	unputwait_locked(&clispc, &rw);