59 	struct _ti_user *tiptr;  in _tx_rcv()  local
63 	if ((tiptr = _t_checkfd(fd, 0, api_semantics)) == NULL)  in _tx_rcv()
65 	sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcv()
67 	if (tiptr->ti_servtype == T_CLTS) {  in _tx_rcv()
69 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
78 		if (!(tiptr->ti_state == T_DATAXFER ||  in _tx_rcv()
79 			tiptr->ti_state == T_OUTREL)) {  in _tx_rcv()
81 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
89 	if (tiptr->ti_lookcnt > 0) {  in _tx_rcv()
120 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
136 			tlbs = &tiptr->ti_lookbufs;  in _tx_rcv()
142 					sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
154 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
163 	if (_t_acquire_ctlbuf(tiptr, &ctlbuf, &didalloc) < 0) {  in _tx_rcv()
165 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
182 	sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
189 		sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcv()
193 	sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcv()
214 				tiptr->ti_flags |= EXPEDITED;  in _tx_rcv()
222 			    (tiptr->ti_lookcnt > 0)) {  in _tx_rcv()
236 				tiptr->ti_flags |= MORE;  in _tx_rcv()
243 			_T_TX_NEXTSTATE(T_RCV, tiptr,  in _tx_rcv()
248 				tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcv()
249 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
253 			if (tiptr->ti_lookcnt > 0) {  in _tx_rcv()
270 			if (_t_register_lookevent(tiptr, databuf.buf,  in _tx_rcv()
293 					tiptr->ti_rcvsize - databuf.len;  in _tx_rcv()
297 					tiptr->ti_lookbufs.tl_lookdbuf +  in _tx_rcv()
298 					tiptr->ti_lookbufs.tl_lookdlen;  in _tx_rcv()
328 				tiptr->ti_lookbufs.tl_lookdlen +=  in _tx_rcv()
344 		if (!retval && (tiptr->ti_flags & MORE)) {  in _tx_rcv()
346 			tiptr->ti_flags &= ~MORE;  in _tx_rcv()
355 		if (tiptr->ti_flags & EXPEDITED) {  in _tx_rcv()
358 				tiptr->ti_flags &= ~EXPEDITED;  in _tx_rcv()
367 		_T_TX_NEXTSTATE(T_RCV, tiptr,  in _tx_rcv()
372 			tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcv()
373 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
383 		tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcv()
384 	sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()