Lines Matching refs:pq
74 pduq_t *pq = b;
76 if(pq->buf != NULL) {
77 debug(3, "ou_refcnt=%d a=%p b=%p", ou_refcnt, a, pq->buf);
78 free(pq->buf, M_ISCSIBUF);
79 pq->buf = NULL;
84 isc_sendPDU(isc_session_t *sp, pduq_t *pq)
87 pdu_t *pp = &pq->pdu;
127 if(pp->ds_len && pq->pdu.ds_addr) {
138 debug(4, "setting ext_free(arg=%p len/l=%d/%d)", pq->buf, len, l);
143 pq, 0, EXT_EXTREF);
185 isc_sendPDU(isc_session_t *sp, pduq_t *pq)
187 struct uio *uio = &pq->uio;
189 pdu_t *pp = &pq->pdu;
198 uio->uio_iov = iv = pq->iov;
205 pq->pdu.hdr_dig = sp->hdrDigest(&pp->ipdu, sizeof(union ipdu_u), 0);
221 if(pq->pdu.ds_addr && pp->ds_len) {
236 uio->uio_iovcnt = iv - pq->iov;
237 sdebug(4, "pq->len=%d uio->uio_resid=%d uio->uio_iovcnt=%d", pq->len,
368 so_recv(isc_session_t *sp, pduq_t *pq)
371 struct uio *uio = &pq->uio;
372 pdu_t *pp = &pq->pdu;
374 struct iovec *iov = pq->iov;
442 pq->len += len; // XXX: who needs this?
476 pq->len += len; // XXX: do we need this?
477 error = soreceive(sp->soc, NULL, uio, &pq->mp, NULL, &flags);
487 m_copydata(pq->mp,
494 for(m = pq->mp; m != NULL; m = m->m_next) {
510 pq->len, bhs->opcode, pp->ahs_len, pp->ds_len);
542 pdu_free(sp->isc, pq);
555 pduq_t *pq;
567 pq = pdu_alloc(sp->isc, M_NOWAIT);
568 if(pq == NULL) { // XXX: might cause a deadlock ...
570 pq = pdu_alloc(sp->isc, M_WAITOK); // OK to WAIT
572 pq->pdu.ipdu.bhs = sp->bhs;
573 pq->len = sizeof(bhs_t); // so far only the header was read
574 error = so_recv(sp, pq);
583 ism_recv(sp, pq);