Home | History | Annotate | Download | only in fifofs

Lines Matching defs:rso

130 	struct socket	*rso, *wso;
138 		error = socreate(AF_LOCAL, &rso, SOCK_STREAM, 0, l, NULL);
143 		fip->fi_readsock = rso;
144 		error = socreate(AF_LOCAL, &wso, SOCK_STREAM, 0, l, rso);
146 			(void)soclose(rso);
152 		if ((error = unp_connect2(wso, rso)) != 0) {
155 			(void)soclose(rso);
170 		rso->so_rcv.sb_lowat = 1;
179 		rso->so_state |= SS_CANTSENDMORE;
185 		rso = fip->fi_readsock;
197 			rso->so_state &= ~SS_CANTRCVMORE;
204 			while (!soreadable(rso) && fip->fi_writers == 0) {
257 	struct socket	*rso;
262 	rso = ap->a_vp->v_fifoinfo->fi_readsock;
272 	error = (*rso->so_receive)(rso, NULL, uio, NULL, NULL, &sflags);
277 		rso->so_state &= ~SS_CANTRCVMORE;
358 	struct socket	*rso = ap->a_vp->v_fifoinfo->fi_readsock;
370 	if (rso != NULL) {
371 		lso = rso;
381 	KASSERT(rso == NULL || lso->so_lock == rso->so_lock);
386 	if (rso != NULL) {
388 		if (events != 0 && soreadable(rso)) {
391 		if (rso->so_state & SS_CANTRCVMORE) {
400 			selrecord(curlwp, &rso->so_rcv.sb_sel);
401 			rso->so_rcv.sb_flags |= SB_NOTIFY;
485 	struct socket *wso, *rso;
492 	rso = fip->fi_readsock;
501 			fifo_socantrcvmore(rso);
507 			fifo_socantrcvmore(rso);
511 		(void) soclose(rso);