101 isc_sendPDU(isc_session_t *sp, pduq_t *pq)  in isc_sendPDU()  argument
104      pdu_t		*pp = &pq->pdu;  in isc_sendPDU()
119 	  pq->pdu.hdr_dig = sp->hdrDigest(&pp->ipdu, sizeof(union ipdu_u), 0);  in isc_sendPDU()
130 	       pq->pdu.hdr_dig = sp->hdrDigest(&pp->ahs, pp->ahs_len, pq->pdu.hdr_dig);  in isc_sendPDU()
133 	  debug(2, "hdr_dig=%x", pq->pdu.hdr_dig);  in isc_sendPDU()
143      if(pq->pdu.ds) {  in isc_sendPDU()
154 	       pq->refcnt++;  in isc_sendPDU()
157 	       debug(5, "setting ext_free(arg=%p len/l=%d/%d)", pq->buf, len, l);  in isc_sendPDU()
158 	       md->m_ext.ext_buf = pq->buf;  in isc_sendPDU()
161 	       md->m_ext.ext_arg = pq;  in isc_sendPDU()
197 isc_sendPDU(isc_session_t *sp, pduq_t *pq)  in isc_sendPDU()  argument
199      struct uio *uio = &pq->uio;  in isc_sendPDU()
201      pdu_t	*pp = &pq->pdu;  in isc_sendPDU()
210      uio->uio_iov = iv = pq->iov;  in isc_sendPDU()
214      uio->uio_resid = pq->len;  in isc_sendPDU()
217 	  pq->pdu.hdr_dig = sp->hdrDigest(&pp->ipdu, sizeof(union ipdu_u), 0);  in isc_sendPDU()
224 	       pq->pdu.hdr_dig = sp->hdrDigest(&pp->ahs, pp->ahs_len, pq->pdu.hdr_dig);  in isc_sendPDU()
227 	  debug(2, "hdr_dig=%x", pq->pdu.hdr_dig);  in isc_sendPDU()
232      if(pq->pdu.ds) {  in isc_sendPDU()
245      uio->uio_iovcnt	= iv - pq->iov;  in isc_sendPDU()
365 so_recv(isc_session_t *sp, pduq_t *pq)  in so_recv()  argument
369      struct uio		*uio = &pq->uio;  in so_recv()
382      pp = &pq->pdu;  in so_recv()
438 		    opq = i_search_hld(sp, pq->pdu.ipdu.bhs.itt, 1);  in so_recv()
444 			 data_in_t *rcmd		= &pq->pdu.ipdu.data_in;  in so_recv()
450 			    && (ntohl(cmd->edtlen) >= pq->pdu.ds_len)) {  in so_recv()
451 			      struct iovec *iov = pq->iov;  in so_recv()
453 			      iov->iov_len = pq->pdu.ds_len;  in so_recv()
459 			      if(len > pq->pdu.ds_len) {  in so_recv()
460 				   pq->iov[1].iov_base = &r;  in so_recv()
461 				   pq->iov[1].iov_len = len - pq->pdu.ds_len;  in so_recv()
467 				     ntohl(pq->pdu.ipdu.bhs.itt),  in so_recv()
468 				     csio->data_ptr, ntohl(rcmd->bo), ntohl(cmd->edtlen), pq->pdu.ds_len);  in so_recv()
481 	  pq->mp = sbp.sb_mb;  in so_recv()
488      pq->len += len;  in so_recv()
490 	    pq->len, bhs->opcode, pp->ahs_len, pp->ds_len);  in so_recv()
515      pdu_free(sp->isc, pq);  in so_recv()
528      pduq_t		*pq;  in so_input()  local
540 	  pq = pdu_alloc(sp->isc, M_NOWAIT);  in so_input()
541 	  if(pq == NULL) { // XXX: might cause a deadlock ...  in so_input()
543 	       pq = pdu_alloc(sp->isc, M_NOWAIT);  // OK to WAIT  in so_input()
545 	  pq->pdu.ipdu.bhs = sp->bhs;  in so_input()
546 	  pq->len = sizeof(bhs_t);	// so far only the header was read  in so_input()
547 	  error = so_recv(sp, pq);  in so_input()
556 	       ism_recv(sp, pq);  in so_input()