Lines Matching refs:pq
61 iscsi_r2t(isc_session_t *sp, pduq_t *opq, pduq_t *pq) in iscsi_r2t() argument
67 r2t_t *r2t = &pq->pdu.ipdu.r2t; in iscsi_r2t()
141 getSenseData(u_int status, union ccb *ccb, pduq_t *pq) in getSenseData() argument
143 pdu_t *pp = &pq->pdu; in getSenseData()
146 struct mbuf *m = pq->mp; in getSenseData()
151 bp = mtod(pq->mp, caddr_t); in getSenseData()
162 i_mbufcopy(pq->mp, bp, sense_len); in getSenseData()
186 _scsi_done(struct isc_softc *isp, u_int response, u_int status, union ccb *ccb, pduq_t *pq) in _scsi_done() argument
193 debug(3, "response=%x status=%x ccb=%p pq=%p", response, status, ccb, pq); in _scsi_done()
194 if(pq != NULL) in _scsi_done()
195 debug(3, "mp=%p buf=%p len=%d", pq->mp, pq->buf, pq->len); in _scsi_done()
206 if((pq != NULL) && (pq->mp != NULL) && getSenseData(status, ccb, pq)) in _scsi_done()
250 pduq_t *pq; in iscsi_requeue() local
257 while((pq = i_dqueue_hld(sp)) != NULL) { in iscsi_requeue()
259 _scsi_done(sp->isc, 0, 0x28, pq->ccb, NULL); in iscsi_requeue()
260 n = ntohl(pq->pdu.ipdu.bhs.CmdSN); in iscsi_requeue()
264 pdu_free(sp->isc, pq); in iscsi_requeue()
274 pduq_t *pq; in i_pdu_flush() local
277 while((pq = i_dqueue_rsp(sp)) != NULL) { in i_pdu_flush()
278 pdu_free(sp->isc, pq); in i_pdu_flush()
281 while((pq = i_dqueue_rsv(sp)) != NULL) { in i_pdu_flush()
282 pdu_free(sp->isc, pq); in i_pdu_flush()
285 while((pq = i_dqueue_snd(sp, -1)) != NULL) { in i_pdu_flush()
286 pdu_free(sp->isc, pq); in i_pdu_flush()
289 while((pq = i_dqueue_hld(sp)) != NULL) { in i_pdu_flush()
290 pdu_free(sp->isc, pq); in i_pdu_flush()
293 while((pq = i_dqueue_wsnd(sp)) != NULL) { in i_pdu_flush()
294 pdu_free(sp->isc, pq); in i_pdu_flush()
307 pduq_t *pq, *pqtmp; in iscsi_cleanup() local
311 TAILQ_FOREACH_MUTABLE(pq, &sp->hld, pq_link, pqtmp) { in iscsi_cleanup()
312 sdebug(3, "hld pq=%p", pq); in iscsi_cleanup()
313 if(pq->ccb) in iscsi_cleanup()
314 _scsi_done(sp->isc, 1, 0x40, pq->ccb, NULL); in iscsi_cleanup()
315 TAILQ_REMOVE(&sp->hld, pq, pq_link); in iscsi_cleanup()
316 pdu_free(sp->isc, pq); in iscsi_cleanup()
318 while((pq = i_dqueue_snd(sp, BIT(0)|BIT(1)|BIT(2))) != NULL) { in iscsi_cleanup()
319 sdebug(3, "pq=%p", pq); in iscsi_cleanup()
320 if(pq->ccb) in iscsi_cleanup()
321 _scsi_done(sp->isc, 1, 0x40, pq->ccb, NULL); in iscsi_cleanup()
322 pdu_free(sp->isc, pq); in iscsi_cleanup()
329 iscsi_done(isc_session_t *sp, pduq_t *opq, pduq_t *pq) in iscsi_done() argument
331 pdu_t *pp = &pq->pdu; in iscsi_done()
336 _scsi_done(sp->isc, cmd->response, cmd->status, opq->ccb, pq); in iscsi_done()
351 iscsi_async(isc_session_t *sp, pduq_t *pq) in iscsi_async() argument
353 pdu_t *pp = &pq->pdu; in iscsi_async()
384 iscsi_reject(isc_session_t *sp, pduq_t *opq, pduq_t *pq) in iscsi_reject() argument
448 pduq_t *pq; in scsi_encap() local
456 if((pq = pdu_alloc(isp, M_NOWAIT)) == NULL) { in scsi_encap()
460 while((pq = pdu_alloc(sp->isc, M_NOWAIT)) == NULL) { in scsi_encap()
479 cmd = &pq->pdu.ipdu.scsi_req; in scsi_encap()
518 pq->ccb = ccb; in scsi_encap()
522 if(isc_qout(sp, pq) == 0) in scsi_encap()
526 pdu_free(isp, pq); in scsi_encap()
531 scsi_decap(isc_session_t *sp, pduq_t *opq, pduq_t *pq) in scsi_decap() argument
540 pq, opq, bhp->opcode, pq->pdu.ds_len); in scsi_decap()
543 ntohl(pq->pdu.ipdu.bhs.itt), in scsi_decap()
544 pq, opq, bhp->opcode, pq->pdu.ds_len); in scsi_decap()
548 if(pq->pdu.ds_len != 0) { in scsi_decap()
553 ntohl(pq->pdu.ipdu.bhs.itt), in scsi_decap()
554 pq->pdu.ipdu.bhs.opcode, cmd->R); in scsi_decap()
556 switch(pq->pdu.ipdu.bhs.opcode) { in scsi_decap()
560 data_in_t *rcmd = &pq->pdu.ipdu.data_in; in scsi_decap()
564 csio->data_ptr, bp? mtod(pq->mp, caddr_t): 0, in scsi_decap()
565 ntohl(cmd->edtlen), pq->pdu.ds_len, pq->mp); in scsi_decap()
566 if(ntohl(cmd->edtlen) >= pq->pdu.ds_len) { in scsi_decap()
567 int offset, len = pq->pdu.ds_len; in scsi_decap()
569 if(pq->mp != NULL) { in scsi_decap()
574 i_mbufcopy(pq->mp, dp, len); in scsi_decap()
579 ntohl(cmd->edtlen), pq->pdu.ds_len); in scsi_decap()