57 	struct _ti_user *tiptr;  in _tx_rcvv()  local
63 	if ((tiptr = _t_checkfd(fd, 0, api_semantics)) == NULL)  in _tx_rcvv()
65 	sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcvv()
67 	if (tiptr->ti_servtype == T_CLTS) {  in _tx_rcvv()
69 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
77 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
81 	if (!(tiptr->ti_state == T_DATAXFER ||  in _tx_rcvv()
82 		tiptr->ti_state == T_OUTREL)) {  in _tx_rcvv()
84 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
91 	if (tiptr->ti_lookcnt > 0) {  in _tx_rcvv()
121 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
137 			tlbs = &tiptr->ti_lookbufs;  in _tx_rcvv()
143 					sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
155 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
164 	if (_t_acquire_ctlbuf(tiptr, &ctlbuf, &didalloc) < 0) {  in _tx_rcvv()
166 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
179 			tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcvv()
180 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
197 	sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
204 		sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcvv()
208 	sig_mutex_lock(&tiptr->ti_lock);  in _tx_rcvv()
229 				tiptr->ti_flags |= EXPEDITED;  in _tx_rcvv()
237 			    (tiptr->ti_lookcnt > 0)) {  in _tx_rcvv()
251 				tiptr->ti_flags |= MORE;  in _tx_rcvv()
258 			_T_TX_NEXTSTATE(T_RCV, tiptr,  in _tx_rcvv()
263 				tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcvv()
267 			sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
271 			if (tiptr->ti_lookcnt > 0) {  in _tx_rcvv()
288 			if (_t_register_lookevent(tiptr, databuf.buf,  in _tx_rcvv()
311 					tiptr->ti_rcvsize - databuf.len;  in _tx_rcvv()
315 					tiptr->ti_lookbufs.tl_lookdbuf +  in _tx_rcvv()
316 					tiptr->ti_lookbufs.tl_lookdlen;  in _tx_rcvv()
346 				tiptr->ti_lookbufs.tl_lookdlen +=  in _tx_rcvv()
362 		if (!retval && (tiptr->ti_flags & MORE)) {  in _tx_rcvv()
364 			tiptr->ti_flags &= ~MORE;  in _tx_rcvv()
373 		if (tiptr->ti_flags & EXPEDITED) {  in _tx_rcvv()
376 				tiptr->ti_flags &= ~EXPEDITED;  in _tx_rcvv()
385 		_T_TX_NEXTSTATE(T_RCV, tiptr,  in _tx_rcvv()
390 			tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcvv()
394 		sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()
404 		tiptr->ti_ctlbuf = ctlbuf.buf;  in _tx_rcvv()
407 	sig_mutex_unlock(&tiptr->ti_lock);  in _tx_rcvv()