Lines Matching refs:pq
232 int isc_sendPDU(isc_session_t *sp, pduq_t *pq);
233 int isc_qout(isc_session_t *sp, pduq_t *pq);
234 int i_prepPDU(isc_session_t *sp, pduq_t *pq);
248 void ism_recv(isc_session_t *sp, pduq_t *pq);
253 int scsi_decap(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
254 void iscsi_r2t(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
255 void iscsi_done(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
256 void iscsi_reject(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
257 void iscsi_async(isc_session_t *sp, pduq_t *pq);
298 pduq_t *pq; in pdu_alloc() local
301 if((pq = TAILQ_FIRST(&isc->freepdu)) == NULL) { in pdu_alloc()
303 pq = objcache_get(isc->pdu_zone, wait /* M_WAITOK or M_NOWAIT*/); in pdu_alloc()
306 TAILQ_REMOVE(&isc->freepdu, pq, pq_link); in pdu_alloc()
310 if(pq == NULL) { in pdu_alloc()
321 memset(pq, 0, sizeof(pduq_t)); in pdu_alloc()
323 return pq; in pdu_alloc()
327 pdu_free(struct isc_softc *isc, pduq_t *pq) in pdu_free() argument
329 if(pq->mp) in pdu_free()
330 m_freem(pq->mp); in pdu_free()
332 if(pq->buf != NULL) in pdu_free()
333 kfree(pq->buf, M_ISCSI); in pdu_free()
336 TAILQ_INSERT_TAIL(&isc->freepdu, pq, pq_link); in pdu_free()
344 i_nqueue_rsp(isc_session_t *sp, pduq_t *pq) in i_nqueue_rsp() argument
349 TAILQ_INSERT_TAIL(&sp->rsp, pq, pq_link); in i_nqueue_rsp()
356 pduq_t *pq; in i_dqueue_rsp() local
359 if((pq = TAILQ_FIRST(&sp->rsp)) != NULL) { in i_dqueue_rsp()
361 TAILQ_REMOVE(&sp->rsp, pq, pq_link); in i_dqueue_rsp()
365 return pq; in i_dqueue_rsp()
369 i_nqueue_rsv(isc_session_t *sp, pduq_t *pq) in i_nqueue_rsv() argument
374 TAILQ_INSERT_TAIL(&sp->rsv, pq, pq_link); in i_nqueue_rsv()
381 pduq_t *pq; in i_dqueue_rsv() local
384 if((pq = TAILQ_FIRST(&sp->rsv)) != NULL) { in i_dqueue_rsv()
386 TAILQ_REMOVE(&sp->rsv, pq, pq_link); in i_dqueue_rsv()
390 return pq; in i_dqueue_rsv()
394 i_nqueue_csnd(isc_session_t *sp, pduq_t *pq) in i_nqueue_csnd() argument
399 TAILQ_INSERT_TAIL(&sp->csnd, pq, pq_link); in i_nqueue_csnd()
406 pduq_t *pq; in i_dqueue_csnd() local
409 if((pq = TAILQ_FIRST(&sp->csnd)) != NULL) { in i_dqueue_csnd()
411 TAILQ_REMOVE(&sp->csnd, pq, pq_link); in i_dqueue_csnd()
415 return pq; in i_dqueue_csnd()
419 i_nqueue_isnd(isc_session_t *sp, pduq_t *pq) in i_nqueue_isnd() argument
424 TAILQ_INSERT_TAIL(&sp->isnd, pq, pq_link); in i_nqueue_isnd()
431 pduq_t *pq; in i_dqueue_isnd() local
434 if((pq = TAILQ_FIRST(&sp->isnd)) != NULL) { in i_dqueue_isnd()
436 TAILQ_REMOVE(&sp->isnd, pq, pq_link); in i_dqueue_isnd()
440 return pq; in i_dqueue_isnd()
444 i_nqueue_wsnd(isc_session_t *sp, pduq_t *pq) in i_nqueue_wsnd() argument
449 TAILQ_INSERT_TAIL(&sp->wsnd, pq, pq_link); in i_nqueue_wsnd()
456 pduq_t *pq; in i_dqueue_wsnd() local
459 if((pq = TAILQ_FIRST(&sp->wsnd)) != NULL) { in i_dqueue_wsnd()
461 TAILQ_REMOVE(&sp->wsnd, pq, pq_link); in i_dqueue_wsnd()
465 return pq; in i_dqueue_wsnd()
471 pduq_t *pq; in i_dqueue_snd() local
473 pq = NULL; in i_dqueue_snd()
475 if((which & BIT(0)) && (pq = TAILQ_FIRST(&sp->isnd)) != NULL) { in i_dqueue_snd()
477 TAILQ_REMOVE(&sp->isnd, pq, pq_link); in i_dqueue_snd()
478 pq->pduq = &sp->isnd; // remember where you came from in i_dqueue_snd()
480 if((which & BIT(1)) && (pq = TAILQ_FIRST(&sp->wsnd)) != NULL) { in i_dqueue_snd()
482 TAILQ_REMOVE(&sp->wsnd, pq, pq_link); in i_dqueue_snd()
483 pq->pduq = &sp->wsnd; // remember where you came from in i_dqueue_snd()
485 if((which & BIT(2)) && (pq = TAILQ_FIRST(&sp->csnd)) != NULL) { in i_dqueue_snd()
487 TAILQ_REMOVE(&sp->csnd, pq, pq_link); in i_dqueue_snd()
488 pq->pduq = &sp->csnd; // remember where you came from in i_dqueue_snd()
492 return pq; in i_dqueue_snd()
496 i_rqueue_pdu(isc_session_t *sp, pduq_t *pq) in i_rqueue_pdu() argument
499 KASSERT(pq->pduq != NULL, ("pq->pduq is NULL")); in i_rqueue_pdu()
500 TAILQ_INSERT_TAIL(pq->pduq, pq, pq_link); in i_rqueue_pdu()
508 i_nqueue_hld(isc_session_t *sp, pduq_t *pq) in i_nqueue_hld() argument
510 getmicrouptime(&pq->ts); in i_nqueue_hld()
514 TAILQ_INSERT_TAIL(&sp->hld, pq, pq_link); in i_nqueue_hld()
520 i_remove_hld(isc_session_t *sp, pduq_t *pq) in i_remove_hld() argument
524 TAILQ_REMOVE(&sp->hld, pq, pq_link); in i_remove_hld()
531 pduq_t *pq; in i_dqueue_hld() local
534 if((pq = TAILQ_FIRST(&sp->hld)) != NULL) { in i_dqueue_hld()
536 TAILQ_REMOVE(&sp->hld, pq, pq_link); in i_dqueue_hld()
540 return pq; in i_dqueue_hld()
546 pduq_t *pq, *tmp; in i_search_hld() local
548 pq = NULL; in i_search_hld()
551 TAILQ_FOREACH_MUTABLE(pq, &sp->hld, pq_link, tmp) { in i_search_hld()
552 if(pq->pdu.ipdu.bhs.itt == itt) { in i_search_hld()
555 TAILQ_REMOVE(&sp->hld, pq, pq_link); in i_search_hld()
562 return pq; in i_search_hld()