Lines Matching refs:pq

299      pduq_t 		*pq;  in iscsi_read()  local
319 TAILQ_FOREACH(pq, &sc->freepdu, pq_link) { in iscsi_read()
322 ksprintf(buf, "%03d] %06x\n", i++, ntohl(pq->pdu.ipdu.bhs.itt)); in iscsi_read()
329 #define pukeit(i, pq) do {\ in iscsi_read() argument
331 i, ntohl( pq->pdu.ipdu.bhs.CmdSN), \ in iscsi_read()
332 pq->pdu.ipdu.bhs.opcode, ntohl(pq->pdu.ipdu.bhs.itt),\ in iscsi_read()
333 (long)pq->ts.tv_sec);\ in iscsi_read()
338 TAILQ_FOREACH(pq, &sp->hld, pq_link) { in iscsi_read()
341 pukeit(i, pq); i++; in iscsi_read()
347 TAILQ_FOREACH(pq, &sp->rsp, pq_link) { in iscsi_read()
350 pukeit(i, pq); i++; in iscsi_read()
356 TAILQ_FOREACH(pq, &sp->csnd, pq_link) { in iscsi_read()
359 pukeit(i, pq); i++; in iscsi_read()
365 TAILQ_FOREACH(pq, &sp->wsnd, pq_link) { in iscsi_read()
368 pukeit(i, pq); i++; in iscsi_read()
374 TAILQ_FOREACH(pq, &sp->isnd, pq_link) { in iscsi_read()
377 pukeit(i, pq); i++; in iscsi_read()
442 pduq_t *pq; in i_send() local
451 if((pq = pdu_alloc(sc, M_NOWAIT)) == NULL) in i_send()
453 pp = &pq->pdu; in i_send()
454 pq->pdu = *(pdu_t *)arg; in i_send()
455 pq->refcnt = 0; in i_send()
456 if((error = i_prepPDU(sp, pq)) != 0) in i_send()
459 sdebug(3, "len=%d ahs_len=%d ds_len=%d", pq->len, pp->ahs_len, pp->ds_len); in i_send()
461 pq->buf = bp = kmalloc(pq->len - sizeof(union ipdu_u), M_ISCSI, M_NOWAIT); in i_send()
462 if(pq->buf == NULL) { in i_send()
492 error = isc_qout(sp, pq); in i_send()
499 pdu_free(sc, pq); in i_send()
511 pduq_t *pq; in i_recv() local
527 while((pq = TAILQ_FIRST(&sp->rsp)) == NULL) { in i_recv()
532 if(pq != NULL) { in i_recv()
534 TAILQ_REMOVE(&sp->rsp, pq, pq_link); in i_recv()
540 if(pq == NULL) { in i_recv()
546 pp = &pq->pdu; in i_recv()
553 if(pq->mp) { in i_recv()
570 if(len > pq->mp->m_len) { in i_recv()
574 i_mbufcopy(pq->mp, bp, len); in i_recv()
577 bp = mtod(pq->mp, caddr_t); in i_recv()
605 sdebug(6, "len=%d ahs_len=%d ds_len=%d", pq->len, pp->ahs_len, pp->ds_len); in i_recv()
607 pdu_free(sp->isc, pq); in i_recv()
668 pduq_t *pq; in iscsi_counters() local
670 #define _puke(i, pq) do {\ in iscsi_counters() argument
672 i, ntohl( pq->pdu.ipdu.bhs.CmdSN), \ in iscsi_counters()
673 pq->pdu.ipdu.bhs.opcode, ntohl(pq->pdu.ipdu.bhs.itt),\ in iscsi_counters()
674 (long)pq->ts.sec, pq->ts.frac, pq->flags);\ in iscsi_counters()
678 TAILQ_FOREACH(pq, &sp->hld, pq_link) { in iscsi_counters()
679 _puke(h, pq); in iscsi_counters()
682 TAILQ_FOREACH(pq, &sp->rsp, pq_link) r++; in iscsi_counters()
683 TAILQ_FOREACH(pq, &sp->csnd, pq_link) s++; in iscsi_counters()
684 TAILQ_FOREACH(pq, &sp->wsnd, pq_link) s++; in iscsi_counters()
685 TAILQ_FOREACH(pq, &sp->isnd, pq_link) s++; in iscsi_counters()
739 pduq_t *pq; in free_pdus() local
744 TAILQ_FOREACH(pq, &sc->freepdu, pq_link) { in free_pdus()
745 TAILQ_REMOVE(&sc->freepdu, pq, pq_link); in free_pdus()
746 objcache_put(sc->pdu_zone, pq); in free_pdus()