dev/iscsi_initiator/iscsivar.h

49      	printf("%d] %s: " fmt "\n", sp->sid, __func__ , ##args);} while(0)
225 void	isc_start_receiver(isc_session_t *sp);
226 void	isc_stop_receiver(isc_session_t *sp);
228 int	isc_sendPDU(isc_session_t *sp, pduq_t *pq);
229 int	isc_qout(isc_session_t *sp, pduq_t *pq);
230 int	i_prepPDU(isc_session_t *sp, pduq_t *pq);
235 int	i_setopt(isc_session_t *sp, isc_opt_t *opt);
238 int	ic_init(isc_session_t *sp);
239 void	ic_destroy(isc_session_t *sp);
240 void	ic_lost_target(isc_session_t *sp, int target);
241 int	ic_getCamVals(isc_session_t *sp, iscsi_cam_t *cp);
243 void	ism_recv(isc_session_t *sp, pduq_t *pq);
244 int	ism_start(isc_session_t *sp);
245 void	ism_restart(isc_session_t *sp);
246 void	ism_stop(isc_session_t *sp);
249 int	scsi_decap(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
250 void	iscsi_r2t(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
251 void	iscsi_done(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
252 void	iscsi_reject(isc_session_t *sp, pduq_t *opq, pduq_t *pq);
253 void	iscsi_async(isc_session_t *sp,  pduq_t *pq);
254 void	iscsi_cleanup(isc_session_t *sp);
255 int	iscsi_requeue(isc_session_t *sp);
273 XPT_DONE(isc_session_t *sp, union ccb *ccb)
284 XPT_DONE(isc_session_t *sp, union ccb *ccb)
286      CAM_LOCK(sp);
288      CAM_UNLOCK(sp);
339 i_nqueue_rsp(isc_session_t *sp, pduq_t *pq)
341      mtx_lock(&sp->rsp_mtx);
342      if(++sp->stats.nrsp > sp->stats.max_rsp)
343 	  sp->stats.max_rsp = sp->stats.nrsp;
344      TAILQ_INSERT_TAIL(&sp->rsp, pq, pq_link);
345      mtx_unlock(&sp->rsp_mtx);
349 i_dqueue_rsp(isc_session_t *sp)
353      mtx_lock(&sp->rsp_mtx);
354      if((pq = TAILQ_FIRST(&sp->rsp)) != NULL) {
355 	  sp->stats.nrsp--;
356 	  TAILQ_REMOVE(&sp->rsp, pq, pq_link);
358      mtx_unlock(&sp->rsp_mtx);
364 i_nqueue_rsv(isc_session_t *sp, pduq_t *pq)
366      mtx_lock(&sp->rsv_mtx);
367      if(++sp->stats.nrsv > sp->stats.max_rsv)
368 	  sp->stats.max_rsv = sp->stats.nrsv;
369      TAILQ_INSERT_TAIL(&sp->rsv, pq, pq_link);
370      mtx_unlock(&sp->rsv_mtx);
374 i_dqueue_rsv(isc_session_t *sp)
378      mtx_lock(&sp->rsv_mtx);
379      if((pq = TAILQ_FIRST(&sp->rsv)) != NULL) {
380 	  sp->stats.nrsv--;
381 	  TAILQ_REMOVE(&sp->rsv, pq, pq_link);
383      mtx_unlock(&sp->rsv_mtx);
389 i_nqueue_csnd(isc_session_t *sp, pduq_t *pq)
391      mtx_lock(&sp->snd_mtx);
392      if(++sp->stats.ncsnd > sp->stats.max_csnd)
393 	  sp->stats.max_csnd = sp->stats.ncsnd;
394      TAILQ_INSERT_TAIL(&sp->csnd, pq, pq_link);
395      mtx_unlock(&sp->snd_mtx);
399 i_dqueue_csnd(isc_session_t *sp)
403      mtx_lock(&sp->snd_mtx);
404      if((pq = TAILQ_FIRST(&sp->csnd)) != NULL) {
405 	  sp->stats.ncsnd--;
406 	  TAILQ_REMOVE(&sp->csnd, pq, pq_link);
408      mtx_unlock(&sp->snd_mtx);
414 i_nqueue_isnd(isc_session_t *sp, pduq_t *pq)
416      mtx_lock(&sp->snd_mtx);
417      if(++sp->stats.nisnd > sp->stats.max_isnd)
418 	  sp->stats.max_isnd = sp->stats.nisnd;
419      TAILQ_INSERT_TAIL(&sp->isnd, pq, pq_link);
420      mtx_unlock(&sp->snd_mtx);
424 i_dqueue_isnd(isc_session_t *sp)
428      mtx_lock(&sp->snd_mtx);
429      if((pq = TAILQ_FIRST(&sp->isnd)) != NULL) {
430 	  sp->stats.nisnd--;
431 	  TAILQ_REMOVE(&sp->isnd, pq, pq_link);
433      mtx_unlock(&sp->snd_mtx);
439 i_nqueue_wsnd(isc_session_t *sp, pduq_t *pq)
441      mtx_lock(&sp->snd_mtx);
442      if(++sp->stats.nwsnd > sp->stats.max_wsnd)
443 	  sp->stats.max_wsnd = sp->stats.nwsnd;
444      TAILQ_INSERT_TAIL(&sp->wsnd, pq, pq_link);
445      mtx_unlock(&sp->snd_mtx);
449 i_dqueue_wsnd(isc_session_t *sp)
453      mtx_lock(&sp->snd_mtx);
454      if((pq = TAILQ_FIRST(&sp->wsnd)) != NULL) {
455 	  sp->stats.nwsnd--;
456 	  TAILQ_REMOVE(&sp->wsnd, pq, pq_link);
458      mtx_unlock(&sp->snd_mtx);
464 i_dqueue_snd(isc_session_t *sp, int which)
469      mtx_lock(&sp->snd_mtx);
470      if((which & BIT(0)) && (pq = TAILQ_FIRST(&sp->isnd)) != NULL) {
471 	  sp->stats.nisnd--;
472 	  TAILQ_REMOVE(&sp->isnd, pq, pq_link);
473 	  pq->pduq = &sp->isnd;	// remember where you came from
475      if((which & BIT(1)) && (pq = TAILQ_FIRST(&sp->wsnd)) != NULL) {
476 	  sp->stats.nwsnd--;
477 	  TAILQ_REMOVE(&sp->wsnd, pq, pq_link);
478 	  pq->pduq = &sp->wsnd;	// remember where you came from
480      if((which & BIT(2)) && (pq = TAILQ_FIRST(&sp->csnd)) != NULL) {
481 	  sp->stats.ncsnd--;
482 	  TAILQ_REMOVE(&sp->csnd, pq, pq_link);
483 	  pq->pduq = &sp->csnd;	// remember where you came from
485      mtx_unlock(&sp->snd_mtx);
491 i_rqueue_pdu(isc_session_t *sp, pduq_t *pq)
493      mtx_lock(&sp->snd_mtx);
496      mtx_unlock(&sp->snd_mtx);
503 i_nqueue_hld(isc_session_t *sp, pduq_t *pq)
506      mtx_lock(&sp->hld_mtx);
507      if(++sp->stats.nhld > sp->stats.max_hld)
508 	  sp->stats.max_hld = sp->stats.nhld;
509      TAILQ_INSERT_TAIL(&sp->hld, pq, pq_link);
510      mtx_unlock(&sp->hld_mtx);
515 i_remove_hld(isc_session_t *sp, pduq_t *pq)
517      mtx_lock(&sp->hld_mtx);
518      sp->stats.nhld--;
519      TAILQ_REMOVE(&sp->hld, pq, pq_link);
520      mtx_unlock(&sp->hld_mtx);
524 i_dqueue_hld(isc_session_t *sp)
528      mtx_lock(&sp->hld_mtx);
529      if((pq = TAILQ_FIRST(&sp->hld)) != NULL) {
530 	  sp->stats.nhld--;
531 	  TAILQ_REMOVE(&sp->hld, pq, pq_link);
533      mtx_unlock(&sp->hld_mtx);
539 i_search_hld(isc_session_t *sp, int itt, int keep)
545      mtx_lock(&sp->hld_mtx);
546      TAILQ_FOREACH_SAFE(pq, &sp->hld, pq_link, tmp) {
549 		    sp->stats.nhld--;
550 		    TAILQ_REMOVE(&sp->hld, pq, pq_link);
555      mtx_unlock(&sp->hld_mtx);
561 i_acked_hld(isc_session_t *sp, pdu_t *op)
564      u_int exp = sp->sn.expCmd;
567      mtx_lock(&sp->hld_mtx);
568      TAILQ_FOREACH_SAFE(pq, &sp->hld, pq_link, tmp) {
573 	       sp->stats.nhld--;
574 	       TAILQ_REMOVE(&sp->hld, pq, pq_link);
575 	       pdu_free(sp->isc, pq);
578      mtx_unlock(&sp->hld_mtx);