dev/iscsi_initiator/iscsi.c

101 static int	i_setsoc(isc_session_t *sp, int fd, struct thread *td);
139      isc_session_t	*sp;
148      sp = dev->si_drv2;
149      if(sp != NULL) {
150 	  sdebug(3, "sp->flags=%x", sp->flags );
159 	  if(sp->flags & ISC_FFPHASE)
161 	       tsleep(sp, PRIBIO, "isc-cls", 60*hz);
162 	  ism_stop(sp);
172      isc_session_t	*sp;
201      sp = dev->si_drv2;
202      if(sp == NULL)
209 	  error = i_setsoc(sp, *(u_int *)arg, td);
214 	  error = i_setopt(sp, opt);
230 	  error = sp->soc == NULL? ENOTCONN: i_fullfeature(dev, 1);
232 	       sp->proc = td->td_proc;
233 	       SYSCTL_ADD_INT(&sp->clist, SYSCTL_CHILDREN(sp->oid),
235 			       &sp->proc->p_pid, sizeof(pid_t), "control process id");
240 	  error = sp->soc == NULL? ENOTCONN: i_fullfeature(dev, 2);
253 		sp->signal = sig;
260 	  error = ic_getCamVals(sp, cp);
276      isc_session_t	*sp;
281      sp = dev->si_drv2;
287 	  TAILQ_FOREACH(sp, &sc->isc_sess, sp_link) {
290 	       sprintf(buf, "%03d] '%s' '%s'\n", i++, sp->opt.targetAddress, sp->opt.targetName);
298 	  struct socket	*so = sp->soc;
307 	  sprintf(buf, "%d/%d /---- hld -----/\n", sp->stats.nhld, sp->stats.max_hld);
309 	  TAILQ_FOREACH(pq, &sp->hld, pq_link) {
315 	  sprintf(buf, "%d/%d /---- rsp -----/\n", sp->stats.nrsp, sp->stats.max_rsp);
318 	  TAILQ_FOREACH(pq, &sp->rsp, pq_link) {
324 	  sprintf(buf, "%d/%d /---- csnd -----/\n", sp->stats.ncsnd, sp->stats.max_csnd);
327 	  TAILQ_FOREACH(pq, &sp->csnd, pq_link) {
333 	  sprintf(buf, "%d/%d /---- wsnd -----/\n", sp->stats.nwsnd, sp->stats.max_wsnd);
336 	  TAILQ_FOREACH(pq, &sp->wsnd, pq_link) {
342 	  sprintf(buf, "%d/%d /---- isnd -----/\n", sp->stats.nisnd, sp->stats.max_isnd);
345 	  TAILQ_FOREACH(pq, &sp->isnd, pq_link) {
355 	  sprintf(buf, "recv=%d sent=%d\n", sp->stats.nrecv, sp->stats.nsent);
359 		  sp->flags, sc->npdu_alloc, sc->npdu_max);
363 		  sp->cws, sp->sn.cmd, sp->sn.expCmd, sp->sn.maxCmd, sp->sn.stat, sp->sn.itt);
383 i_setsoc(isc_session_t *sp, int fd, struct thread *td)
388      if(sp->soc != NULL)
389 	  isc_stop_receiver(sp);
391      error = fget(td, fd, cap_rights_init(&rights, CAP_SOCK_CLIENT), &sp->fp);
396         &sp->soc, 0);
398 	  sp->td = td;
399 	  isc_start_receiver(sp);
402 	  fdrop(sp->fp, td);
403 	  sp->fp = NULL;
412      isc_session_t	*sp = dev->si_drv2;
420      if(sp->soc == NULL)
423      if((pq = pdu_alloc(sp->isc, M_NOWAIT)) == NULL)
427      if((error = i_prepPDU(sp, pq)) != 0)
470      error = isc_qout(sp, pq);
472 	  wakeup(&sp->flags); // XXX: to 'push' proc_out ...
475 	  pdu_free(sp->isc, pq);
483      isc_session_t	*sp = dev->si_drv2;
492      if(sp == NULL)
495      if(sp->soc == NULL)
498      mtx_lock(&sp->rsp_mtx);
499      while((pq = TAILQ_FIRST(&sp->rsp)) == NULL) {
500 	  msleep(&sp->rsp, &sp->rsp_mtx, PRIBIO, "isc_rsp", hz*10);
504 	  sp->stats.nrsp--;
505 	  TAILQ_REMOVE(&sp->rsp, pq, pq_link);
507      mtx_unlock(&sp->rsp_mtx);
513 	  sdebug(3, "error=%d sp->flags=%x ", error, sp->flags);
570      pdu_free(sp->isc, pq);
578      isc_session_t	*sp = dev->si_drv2;
586          sp->flags &= ~ISC_FFPHASE;
589          sp->flags |= ISC_FFPHASE;
590          error = ic_init(sp);
593          sp->flags |= ISC_FFPHASE;
594          ism_restart(sp);
604      isc_session_t	*sp;
609      sp = malloc(sizeof(isc_session_t), M_ISCSI, M_WAITOK | M_ZERO);
610      if(sp == NULL)
616 	  free(sp, M_ISCSI);
623      TAILQ_INSERT_TAIL(&sc->isc_sess, sp, sp_link);
627      sp->dev = make_dev(&iscsi_cdevsw, n, UID_ROOT, GID_WHEEL, 0600, "iscsi%d", n);
628      *ndev = sp->sid = n;
629      sp->isc = sc;
630      sp->dev->si_drv1 = sc;
631      sp->dev->si_drv2 = sp;
633      sp->opt.maxRecvDataSegmentLength = 8192;
634      sp->opt.maxXmitDataSegmentLength = 8192;
635      sp->opt.maxBurstLength = 65536;	// 64k
636      sp->opt.maxluns = ISCSI_MAX_LUNS;
638      error = ism_start(sp);
645 iscsi_counters(isc_session_t *sp)
658      TAILQ_FOREACH(pq, &sp->hld, pq_link) {
662      TAILQ_FOREACH(pq, &sp->rsp, pq_link) r++;
663      TAILQ_FOREACH(pq, &sp->csnd, pq_link) s++;
664      TAILQ_FOREACH(pq, &sp->wsnd, pq_link) s++;
665      TAILQ_FOREACH(pq, &sp->isnd, pq_link) s++;
674      isc_session_t	*sp;
691      TAILQ_FOREACH(sp, &sc->isc_sess, sp_link) {
692 	  debug(2, "%2d] sp->flags=0x%08x", n, sp->flags);
796      isc_session_t	*sp, *sp_tmp;
804      TAILQ_FOREACH_SAFE(sp, &isc->isc_sess, sp_link, sp_tmp) {
806 	  ism_stop(sp);