57 	struct _ti_user *tiptr;  in _tx_rcv()  local
61 	if ((tiptr = _t_checkfd(fd, 0, api_semantics)) == NULL)  in _tx_rcv()
63 	sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcv()
65 	if (tiptr->ti_servtype == T_CLTS) {  in _tx_rcv()
67 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
76 		if (!(tiptr->ti_state == T_DATAXFER ||  in _tx_rcv()
77 			tiptr->ti_state == T_OUTREL)) {  in _tx_rcv()
79 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
87 	if (tiptr->ti_lookcnt > 0) {  in _tx_rcv()
118 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
134 			tlbs = &tiptr->ti_lookbufs;  in _tx_rcv()
140 					sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
152 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
161 	if (_t_acquire_ctlbuf(tiptr, &ctlbuf, &didalloc) < 0) {  in _tx_rcv()
163 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
180 	sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
187 		sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcv()
191 	sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcv()
212 				tiptr->ti_flags |= EXPEDITED;  in _tx_rcv()
220 			    (tiptr->ti_lookcnt > 0)) {  in _tx_rcv()
234 				tiptr->ti_flags |= MORE;  in _tx_rcv()
241 			_T_TX_NEXTSTATE(T_RCV, tiptr,  in _tx_rcv()
246 				tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcv()
247 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
251 			if (tiptr->ti_lookcnt > 0) {  in _tx_rcv()
268 			if (_t_register_lookevent(tiptr, databuf.buf,  in _tx_rcv()
291 					tiptr->ti_rcvsize - databuf.len;  in _tx_rcv()
295 					tiptr->ti_lookbufs.tl_lookdbuf +  in _tx_rcv()
296 					tiptr->ti_lookbufs.tl_lookdlen;  in _tx_rcv()
326 				tiptr->ti_lookbufs.tl_lookdlen +=  in _tx_rcv()
342 		if (!retval && (tiptr->ti_flags & MORE)) {  in _tx_rcv()
344 			tiptr->ti_flags &= ~MORE;  in _tx_rcv()
353 		if (tiptr->ti_flags & EXPEDITED) {  in _tx_rcv()
356 				tiptr->ti_flags &= ~EXPEDITED;  in _tx_rcv()
365 		_T_TX_NEXTSTATE(T_RCV, tiptr,  in _tx_rcv()
370 			tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcv()
371 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()
381 		tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcv()
382 	sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcv()