Lines Matching refs:pq
69 _async(isc_session_t *sp, pduq_t *pq) in _async() argument
73 iscsi_async(sp, pq); in _async()
75 pdu_free(sp->isc, pq); in _async()
79 _reject(isc_session_t *sp, pduq_t *pq) in _reject() argument
87 pdu = mtod(pq->mp, pdu_t *); in _reject()
89 reject = &pq->pdu.ipdu.reject; in _reject()
93 iscsi_reject(sp, opq, pq); in _reject()
95 switch(pq->pdu.ipdu.bhs.opcode) { in _reject()
101 sp->sid, ntohl(pq->pdu.ipdu.bhs.itt)); in _reject()
104 pdu_free(sp->isc, pq); in _reject()
108 _r2t(isc_session_t *sp, pduq_t *pq) in _r2t() argument
113 opq = i_search_hld(sp, pq->pdu.ipdu.bhs.itt, 1); in _r2t()
115 iscsi_r2t(sp, opq, pq); in _r2t()
118 r2t_t *r2t = &pq->pdu.ipdu.r2t; in _r2t()
121 sp->sid, ntohl(pq->pdu.ipdu.bhs.itt), in _r2t()
124 pdu_free(sp->isc, pq); in _r2t()
128 _scsi_rsp(isc_session_t *sp, pduq_t *pq) in _scsi_rsp() argument
133 opq = i_search_hld(sp, pq->pdu.ipdu.bhs.itt, 0); in _scsi_rsp()
134 debug(5, "itt=%x pq=%p opq=%p", ntohl(pq->pdu.ipdu.bhs.itt), pq, opq); in _scsi_rsp()
136 iscsi_done(sp, opq, pq); in _scsi_rsp()
139 sp->sid, ntohl(pq->pdu.ipdu.bhs.itt)); in _scsi_rsp()
140 pdu_free(sp->isc, pq); in _scsi_rsp()
144 _read_data(isc_session_t *sp, pduq_t *pq) in _read_data() argument
149 opq = i_search_hld(sp, pq->pdu.ipdu.bhs.itt, 1); in _read_data()
151 if(scsi_decap(sp, opq, pq) != 1) { in _read_data()
158 sp->sid, ntohl(pq->pdu.ipdu.bhs.itt)); in _read_data()
159 pdu_free(sp->isc, pq); in _read_data()
168 pduq_t *pq; in _nop_out() local
178 if((pq = pdu_alloc(sp->isc, M_NOWAIT)) == NULL) in _nop_out()
181 nop_out = &pq->pdu.ipdu.nop_out; in _nop_out()
187 if(isc_qout(sp, pq) != 0) { in _nop_out()
189 pdu_free(sp->isc, pq); in _nop_out()
195 _nop_in(isc_session_t *sp, pduq_t *pq) in _nop_in() argument
197 pdu_t *pp = &pq->pdu; in _nop_in()
228 (void)isc_qout(sp, pq); //XXX: should check return? in _nop_in()
245 i_nqueue_rsp(sp, pq); in _nop_in()
255 pdu_free(sp->isc, pq); in _nop_in()
260 i_prepPDU(isc_session_t *sp, pduq_t *pq) in i_prepPDU() argument
263 pdu_t *pp = &pq->pdu; in i_prepPDU()
291 pq->len = len; in i_prepPDU()
303 isc_qout(isc_session_t *sp, pduq_t *pq) in isc_qout() argument
309 if(pq->len == 0 && (error = i_prepPDU(sp, pq))) in isc_qout()
312 if(pq->pdu.ipdu.bhs.I) in isc_qout()
313 i_nqueue_isnd(sp, pq); in isc_qout()
315 if(pq->pdu.ipdu.data_out.opcode == ISCSI_WRITE_DATA) in isc_qout()
316 i_nqueue_wsnd(sp, pq); in isc_qout()
318 i_nqueue_csnd(sp, pq); in isc_qout()
320 sdebug(5, "enqued: pq=%p", pq); in isc_qout()
379 ism_recv(isc_session_t *sp, pduq_t *pq) in ism_recv() argument
386 bhs = &pq->pdu.ipdu.bhs; in ism_recv()
420 data_in_t *cmd = &pq->pdu.ipdu.data_in; in ism_recv()
439 i_nqueue_rsp(sp, pq); in ism_recv()
444 case ISCSI_NOP_IN: _nop_in(sp, pq); break; in ism_recv()
445 case ISCSI_SCSI_RSP: _scsi_rsp(sp, pq); break; in ism_recv()
446 case ISCSI_READ_DATA: _read_data(sp, pq); break; in ism_recv()
447 case ISCSI_R2T: _r2t(sp, pq); break; in ism_recv()
448 case ISCSI_REJECT: _reject(sp, pq); break; in ism_recv()
449 case ISCSI_ASYNC: _async(sp, pq); break; in ism_recv()
468 pduq_t *pq; in proc_out() local
490 if((pq = i_dqueue_snd(sp, which)) == NULL) in proc_out()
492 sdebug(4, "pq=%p", pq); in proc_out()
494 pp = &pq->pdu; in proc_out()
527 if(pq->ccb) in proc_out()
528 i_nqueue_hld(sp, pq); in proc_out()
530 if((error = isc_sendPDU(sp, pq)) == 0) { in proc_out()
532 if(pq->ccb == NULL) in proc_out()
533 pdu_free(sp->isc, pq); in proc_out()
537 error, ndone, bhs->opcode, pq->ccb, ntohl(bhs->itt)); in proc_out()
538 if(pq->ccb) in proc_out()
539 i_remove_hld(sp, pq); in proc_out()
546 i_rqueue_pdu(sp, pq); in proc_out()
550 if(pq->ccb) { in proc_out()
552 pq->ccb->ccb_h.status |= CAM_REQUEUE_REQ; // some better error? in proc_out()
553 XPT_DONE(sp->isc, pq->ccb); in proc_out()
554 pdu_free(sp->isc, pq); in proc_out()