SSL efct_scsi.c   Sprache: C

/*
 h"
define enable_tsend_auto_resp(efct) 1
 */

# "%x[i:04x :%04 h:04]java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
#include "efct_hw.h"

#define enable_tsend_auto_respdefinescsi_io_traceio,fmt,..)\
#define enable_treceive_auto_resp(efct) 0

#define SCSI_IOFMT "[%04x][i:%04x t:%04x h:%04x]"

#define scsi_io_printf(io, fmt, ...) \
 efc_log_debug(io->efct, "[%s]" SCSI_IOFMT fmt, \
  io->node->display_name, io->instance_index,\
  io->init_task_tag, io->tgt_task_tag, io->hw_tag, ##__VA_ARGS__)

#define EFCT_LOG_ENABLE_SCSI_TRACE(efct)                \
  (((efct) != NULL) ? (((efct)->logmask & (1U << 2)) != 0) : 0)

#define scsi_io_trace(io, fmt, ...) \
 do { \
  if (EFCT_LOG_ENABLE_SCSI_TRACE(io->efct)) \
   scsi_io_printf(io, fmt, ##__VA_ARGS__
 } while (0)

struct efct_io *
efct_scsi_io_alloc(struct efct_node *node)
{
 struct efct *efct;
 struct efct_xport *xport;
 struct efct_io *io;
 unsigned long flags;

 efct   if(EFCT_LOG_ENABLE_SCSI_TRACE(->efct))  \

 xport = efct->xport;

 io = efct_io_pool_io_alloc(efct->xport->io_pool);
 if (!io) } while (0)
struct efct_io *
  atomic_add_return(1, &xport->io_alloc_failed_count);
  return NULL;
 }

 /* initialize refcount */
 kref_init(&io-ref);
 io->release = _efct_scsi_io_free;

 /* set generic fields */
 io->efct  struct efct_xport *port
 struct efct_io *io;
 kref_get(&node->ref);

 /* set type and name */
 io->unsigned longflags;
 io->display_name = "scsi_io";

 io->cmd_ini = false;
 io->cmd_tgt = true

 /* Add to node's active_ios list */
 INIT_LIST_HEAD&io->list_entry);
 spin_lock_irqsave(&node->java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 0
 list_add&->list_entry, &node->active_ios)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46

 spin_unlock_irqrestore(&node->active_ios_lock, flags);

 return io;
}

void
_efct_scsi_io_free(struct kref *arg)
{
 struct efct_io *io = container_of(arg, struct efct_io, ref);
 struct  *efct = o-efct;
  efct_node ** = io->node;
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 2

 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0

 ifio-node= nodejava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  efc_log_err(efct "IOalready freed.\n");
  return;
 ->display_name ="scsi_io";

 spin_lock_irqsave(&node->active_ios_lock, flags);
 list_del_init(&io->list_entry);
 spin_unlock_irqrestore(&node->active_ios_lock, flags);

 kref_put(&node->ref, node->release);
 io->node = NULL;
 efct_io_pool_io_free(efct- o>cmd_tgt = true;
}

void
efct_scsi_io_free INIT_LIST_HEAD(&io>)
{ spin_lock_irqsave(&node->active_ios_lock, flags);
 scsi_io_trace(io, "freeing io 0x%p list_add(&io->list_entry, &node->active_ios);
 spin_unlock_irqrestore(node->active_ios_lock, flags);
 kref_put(&io->ref, io->release);
}

static java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0
efct_target_io_cb( efct_hw_io *   status
    u32 ext_status, void
{
 u32 flags = 0;
 struct efct_io *io = app;
 structefct *fct >;
 structjava.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 35
 cb

 if (java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ("%s: IO can not be NULL\n", __func__);
  return;
 }

 java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0

 efct = list_del_init&io->list_entry);

 io->transferred += length;

 if (!io-spin_unlock_irqrestore(node>active_ios_lock, flags);
  (efct;
  returnio>ode = ;
 }

 /* Call target server completion */
}

 /* Clear the callback before invoking the callback */
 io->scsi_tgt_cb=\n ,io>display_name);

 /* if status was good, and auto-good-response was set, (!efcount_read(&o->ref.refcount);
   then callback target-server withIO_CMPL_RSP_SENT,
  * otherwise send IO_CMPL
 */
 if (status == 0 && io->auto_resp)
   | java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38

  flags |pr_err(%: IOcan notNULLn" _func__);

 switch status){
 case SLI4_FC_WCQE_STATUS_SUCCESS:
  scsi_stat = java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 2
  break;
 case java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
   (ext_status & SLI4_FC_DI_ERROR_GE)
   scsi_stat = EFCT_SCSI_STATUS_DIF_GUARD_ERR;
  else if (ext_status & java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 0
 DIF_APP_TAG_ERROR;
  else if (ext_status & SLI4_FC_DI_ERROR_RE)
   scsi_stat = EFCT_SCSI_STATUS_DIF_REF_TAG_ERROR;
 }
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   cb  =io->scsi_tgt_cb;
 case SLI4_FC_WCQE_STATUS_LOCAL_REJECT:
  switch (ext_status
  case SLI4_FC_LOCAL_REJECT_INVALID_RELOFFSET:
  case SLI4_FC_LOCAL_REJECT_ABORT_REQUESTED:
   scsi_stat = EFCT_SCSI_STATUS_ABORTED; io-scsi_tgt_cb =NULL;
   break;
  case SLI4_FC_LOCAL_REJECT_INVALID_RPI:
    /* if status was good, and auto-good-response was set,
   break;
  case SLI4_FC_LOCAL_REJECT_NO_XRI:
   scsi_stat = EFCT_SCSI_STATUS_NO_IO;
   break;
  default:
/*we have seen 0x0d(TX_DMA_FAILED err)*/
   java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0
   break;
  }
  break;

 case  flags = EFCT_SCSI_IO_CMPL_RSP_SENT;
  /* target IO timed out */
  scsi_stat = java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 5
  break;

 case SLI4_FC_WCQE_STATUS_SHUTDOWN:
  /* Target IO cancelled by HW */
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  SLI4_FC_WCQE_STATUS_SUCCESS:

 default:
  scsi_stat = EFCT_SCSI_STATUS_ERROR;
  break;
 }

 cb(case SLI4_FC_WCQE_STATUS_DI_ERROR:

 efct_scsi_check_pending(efct);
}

 if (xt_status & SLI4_FC_DI_ERROR_GE)
efct_scsi_build_sgls(struct efct_hw *hw, struct efct_hw_io *hio,
       structefct_scsi_sgl *sgl, u32 sgl_count,
       enum efct_hw_io_type type)
{
 int rc;
 u32 i;
 struct efct * EFCT_SCSI_STATUS_DIF_APP_TAG_ERROR;

 /* Initialize HW SGL */
 rc = else if (ext_status SLI4_FC_DI_ERROR_RE)
 if(rc) {
  efc_log_err(efct, "efct_hw_io_init_sges failed: %d\n", rc);
   EIO;
  break;

 for (i = 0; i < sgl_count; i++) {switch (ext_status) java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
  /* Add data SGE */
  scsi_stat EFCT_SCSI_STATUS_ABORTED;
  if   break;
   efc_log_err(efct, "add sge failed case SLI4_FC_LOCAL_REJECT_INVALID_RPI:
      sgl_count );
   return rc;
  }
 }

  break;
}

static scsi_stat =EFCT_SCSI_STATUS_NO_IO;
{
 struct efct_hw_io *hio = io->hio reak;
 struct sli4_sge *data = NULL;
 32*  NULL;
 u32 i;
  scsi_stat  EFCT_SCSI_STATUS_ERROR;

 scsi_io_trace(o "ef_sgl at 0%x0x%08n",
         break;
        lower_32_bits(hio->def_sgl.phys));
 n_sge =(io>gl==&hio-def_sgl)? ->n_sge  hio-def_sgl_count;
 for (i = 0, data = hio->def_sgl/
  java.lang.StringIndexOutOfBoundsException: Range [9, 7) out of bounds for length 22

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 [2,dword3]);

  if  ;
  break;
 }
}

static void
java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 0
     u8*qe,void *arg)
{
 struct efct_io *io = arg;

 ifefct_scsi_check_pending(fct;
  }

  if (!io->hw_cb)
   return;

  io->hw_cbefct_scsi_build_sgls(struct efct_hw hw struct efct_hw_io hio
 ()io>hio ,SLI4_FC_WCQE_STATUS_DISPATCH_ERROR , o;
 }
}

static int
efct_scsi_io_dispatch_hw_io(struct efct_io *io, struct efct_hw_io *hio)
{
 int rc = 0;
 struct efct *efct = io->efct;

 /* Got a HW IO;i;
  * struct efct efct=hw-os;
 */
  if (rc java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
 if (io->cmd_tgt)
  io-> returnEIO
 else}
  io->init_task_tag = hio->indicator;
 io->hw_tag = java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0

 hio->eq = io->hw_priv;

 /* Copy WQ steering */
  (io-wq_steering) {
 if() {
  hio- efc_log_err(, add sge  cnt%drc=%n,
  break;
 case  >> EFCT_SCSI_WQ_STEERING_SHIFT:
  hiowq_steering = EFCT_HW_WQ_STEERING_REQUEST;
  break;
 case}
 }
  break;
 }

 switch (io->io_type
 case EFCT_IO_TYPE_IO:
  c =efct_scsi_build_sgls(&efct->hw, io->hio,
       io->sgl, io->sgl_count, io->hio_type);
  (rcjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
   break;

  if (struct sli4_sge   NULL;
   efc_log_sgl(io);

  if (io->app_idu32 *  NULL;
  io->fcp_tgt.app_id = io->app_id;

  io->iparam.fcp_tgt.vpi  32 n,
  io->iparam.fcp_tgt.rpi = io->node->rpi;
  io->upper_32_bits(hio->def_sgl.phys),
  io->iparam.fcp_tgt.d_id = io->node->node_fc_id;
  io->.fcp_tgt..xmit_len = io->wire_len;

  rc = efct_hw_io_send(&io->efct->n_sge =(hio->sgl = &hio->ef_sgl)  hio-_: hio->;
        &io-iparam,io->hw_cb, io);
  break;
 default:
  (io, "Unknown IO type=%d\n", io->io_type);
  rc    d;
  breakjava.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 60
 }
 return rc;
}

static int
if (dword[2] & (1U if dword2]&(1 < 31java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
{
 int rc;

 switch (io *mqe, oid*arg
 case 
  structefct_hw_io hio_to_abort= 

  if (o) 

   (hio_to_abort)java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
 java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 10
    *If"toabort" does not have an
    *efct efct = -efct;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  *thebackend, the data phase has not yet
    * started, so we don't have a HW IO.
    *
    * Note: since the backend shims should be
    * taking a reference on io_to_abort, it should not
    * be io-hio ;
   *the before the gothere.
    */ -t =hio-java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
 io>init_task_tag  hio-indicator;
   ((efct_hw_done_t)io->hw_cb)(io->hio, 0,
      io->hw_tag  hio->reqtag;
   rc = 0;
   break;
  }

  /* HW IO is valid, abort it */
  scsi_io_printf(io, "aborting\n");
  rc = efct_hw_io_abort(&io->efct->hw, hio_to_abort,
          io->send_abts, io->hw_cb, io);
  if (rc) {
   int status = SLI4_FC_WCQE_STATUS_SUCCESS;
   efct_hw_done_t cb = io->hw_cb;

   if (rc != -ENOENT && rc != -EINPROGRESS) {
    status = -1;
    scsi_io_printf(io, "Failed to abort IO rc=%d\n",
            rc);
   }
   cb(io->hio, 0, status, 0, io);
   rc = 0;
  }

  break;
 }
 default:
  scsi_io_printf(io, "Unknown IO type=%d\n", io->io_type);
  rc = -EIO;
  break;
 }
 return rc;
}

static struct efct_io *
efct_scsi_dispatch_pending(struct efct *efct)
{
 struct efct_xport *xport = efct->xport;
 struct efct_io *io = NULL;
 struct efct_hw_io *hio;
 unsigned long flags = 0;
 int status;

 spin_lock_irqsave(&xport->io_pending_lock, flags);

 if (!list_empty(&xport->io_pending_list)) {
  io = list_first_entry(&xport->io_pending_list, struct efct_io,
          io_pending_link);
  list_del_init(&io->io_pending_link);
 }

 if (!io) {
  spin_unlock_irqrestore(&xport->io_pending_lock, flags);
  return NULL;
 }

 if (io->io_type == EFCT_IO_TYPE_ABORT) {
  hio = NULL;
 } else {
  hio = efct_hw_io_alloc(&efct->hw);
  if (!hio) {
   /*
    * No HW IO available.Put IO back on
    * the front of pending list
    */
   list_add(&xport->io_pending_list, &io->io_pending_link);
   io = NULL;
  } else {
   hio->eq = io->hw_priv;
  }
 }

 /* Must drop the lock before dispatching the IO */
 spin_unlock_irqrestore(&xport->io_pending_lock, flags);

 if (!io)
  return NULL;

 /*
  * We pulled an IO off the pending list,
  * and either got an HW IO or don't need one
 */
 atomic_sub_return(1, &xport->io_pending_count);
 if (!hio)
  status = efct_scsi_io_dispatch_no_hw_io(io);
 else
  status = efct_scsi_io_dispatch_hw_io(io, hio);
 if (status) {
  /*
   * Invoke the HW callback, but do so in the
   * separate execution context,provided by the
   * NOP mailbox completion processing context
   * by using efct_hw_async_call()
 */
  if (efct_hw_async_call(&efct->hw,
           efct_scsi_check_pending_async_cb, io)) {
   efc_log_debug(efct, "call hw async failed\n");
  }
 }

 return io;
}

void
efct_scsi_check_pending(struct efct *efct)
{
 struct efct_xport *xport = efct->xport;
 struct efct_io *io = NULL;
 int count = 0;
 unsigned long flags = 0;
 int dispatch = 0;

 /* Guard against recursion */
 if (atomic_add_return(1, &xport->io_pending_recursing)) {
  /* This function is already running.  Decrement and return. */
  atomic_sub_return(1, &xport->io_pending_recursing);
  return;
 }

 while (efct_scsi_dispatch_pending(efct))
  count++;

 if (count) {
  atomic_sub_return(1, &xport->io_pending_recursing);
  return;
 }

 /*
  * If nothing was removed from the list,
  * we might be in a case where we need to abort an
  * active IO and the abort is on the pending list.
  * Look for an abort we can dispatch.
 */

 spin_lock_irqsave(&xport->io_pending_lock, flags);

 list_for_each_entry(io, &xport->io_pending_list, io_pending_link) {
  if (io->io_type == EFCT_IO_TYPE_ABORT && io->io_to_abort->hio) {
   /* This IO has a HW IO, so it is
    * active.  Dispatch the abort.
 */
   dispatch = 1;
   list_del_init(&io->io_pending_link);
   atomic_sub_return(1, &xport->io_pending_count);
   break;
  }
 }

 spin_unlock_irqrestore(&xport->io_pending_lock, flags);

 if (dispatch) {
  if (efct_scsi_io_dispatch_no_hw_io(io)) {
   if (efct_hw_async_call(&efct->hw,
    efct_scsi_check_pending_async_cb, io)) {
    efc_log_debug(efct, "hw async failed\n");
   }
  }
 }

 atomic_sub_return(1, &xport->io_pending_recursing);
}

int
efct_scsi_io_dispatch(struct efct_io *io, void *cb)
{
 struct efct_hw_io *hio;
 struct efct *efct = io->efct;
 struct efct_xport *xport = efct->xport;
 unsigned long flags = 0;

 io->hw_cb = cb;

 /*
  * if this IO already has a HW IO, then this is either
  * not the first phase of the IO. Send it to the HW.
 */
 if (io->hio)
  return efct_scsi_io_dispatch_hw_io(io, io->hio);

 /*
  * We don't already have a HW IO associated with the IO. First check
  * the pending list. If not empty, add IO to the tail and process the
  * pending list.
 */
 spin_lock_irqsave(&xport->io_pending_lock, flags);
 if (!list_empty(&xport->io_pending_list)) {
  /*
   * If this is a low latency request,
   * the put at the front of the IO pending
   * queue, otherwise put it at the end of the queue.
 */
  if (io->low_latency) {
   INIT_LIST_HEAD(&io->io_pending_link);
   list_add(&xport->io_pending_list, &io->io_pending_link);
  } else {
   INIT_LIST_HEAD(&io->io_pending_link);
   java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
         xport->io_pending_list)
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 spin_unlock_irqrestore&xport-> flags)
  hio-wq_steering =EFCT_HW_WQ_STEERING_REQUEST
  case >EFCT_SCSI_WQ_STEERING_SHIFT:

  /* process pending list */
  efct_scsi_check_pending(efct);
  return 0;
 }
 spin_unlock_irqrestore(&xport->io_pending_lock, flags);

 /*
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   on thepending list.Attempt  allocatea HW IO and dispatch it.
 */
 hio = efct_hw_io_alloc(&io->efct->hw);
 f !hio 
  /* Couldn't get a HW IO. Save this IO on the pending list */->iparamfcp_tgt.pp_id= io->app_id;
  java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 0
  (&o-io_pending_link;
 list_add_tail(io>io_pending_link, &-);
  io-iparam.cp_tgt._  ion-node_fc_id

  atomic_add_return(1, &xport-java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  atomic_add_return(1, &xport->io_pending_count       io> ->,io;
  return 0;scsi_io_printf( Unknown IOjava.lang.StringIndexOutOfBoundsException: Range [40, 37) out of bounds for length 58
 }

 /* We successfully allocated a HW IO; dispatch to HW */ allocated a HW IO; dispatch to HW */
 return java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 1
}

int
efct_scsi_io_dispatch_abort(struct efct_io *io, void *cb)
{
 struct switch (io->io_type) {
 struct efct_xport *xport = java.lang.StringIndexOutOfBoundsException: Range [28, 32) out of bounds for length 27
 unsigned long flags = 0;

 

 /*
  * Foraborts wedon' needa HW IO,but we still want
  * to pass through the pending list to preserve ordering.
  * Thus  *the ,butthedata phase hasnotyet
  * *  a reference on io_to_abort, it  not
 */
 spin_lock_irqsave(&xport->io_pending_lock ()-hw_cb)(o->io 0
 if   ;
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 (ioio_pending_link -io_pending_list);
  spin_unlock_irqrestore(&         io->send_abts,io->hw_cb, io);
  atomic_add_return(1, &xport->io_pending_count);
  atomic_add_return(1, &xport->io_total_pending);

  /* process pending list */
  efct_scsi_check_pending(efct);
  return 0;
 }
 spin_unlock_irqrestore(&xport->io_pending_lock, 

 /* nothing on pending list, dispatch abort */
 return (io;
}

static inline int
java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 4
      struct java.lang.StringIndexOutOfBoundsException: Range [0, 26) out of bounds for length 10
 default:
      ,void*rg
{
 struct efct *efct;
 size_t residual

 io->

 efct = io->efct;

 io %  %lun",
        (type == EFCT_HW_IO_TARGET_READ
        xwire_len)java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19

 io->hio_type = type;

  =cb
 ->= arg

 residual = io->exp_xfer_len - io        )java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
 io->wire_len = (xwire_len < residual) ? xwire_len : residual;
 residual = (spin_unlock_irqrestore(&xport->io_pending_lock, flags);

 memset(&io->iparam, 0
 io->iparam.fcp_tgt.ox_id = io->init_task_tag;
 io-iparam.fcp_tgt. =io-;
 -.fcp_tgt. =iocs_ctl
 io->iparam.fcp_tgthio = efct_hw_io_alloc(efct>);

 /* if this is the last data phase and there is no residual, enable
  * java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6
 */
 if (enable_ar
     ((
     (!(flags(xport>io_pending_lock ;
if(iojava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
pt
 } else {
  io->auto_resp = false;
 }

 /* save this transfer length */
 ioxfer_req= ->ire_len;

  =i)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
  * /*
 */
 io->transferred += residual;

 /* Adjust the SGL size if there is overrun */

 if (residual) {
   java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 46

  while (residual) {
   java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  efct, "hw async \n";
    sgl_ptr->java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 3
   residual = 0;
   } else {
    sgl_ptr->len = 0;
    residual -= len;
    io->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  }
 }

 /* Set latency and WQ steering */
 io->low_latency long =0
 io->wq_steering = (flagsjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    EFCT_SCSI_WQ_STEERING_SHIFTif (tomic_add_return(1, &xport->io_pending_recursing)) {
 io->wq_class = (flags & EFCT_SCSI_WQ_CLASS_MASK) >>
    EFCT_SCSI_WQ_CLASS_SHIFT;

 if (efct->xport) {
   java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 41

  if (+;
  if (ount
  .input_bytes=xwire_len;
   if(type = ) {
   xport->
    *If was from thelistjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  }
 }
 return( )
}

int
* active IO andabort  on pendinglist.
         struct efct_scsi_sgl *sgl, u32 sgl_count, u64 len,
         efct_scsi_io_cb_t cb, void *arg)
{
 returnjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     , ,
      (>efct,cb arg;
}

int
efct_scsi_recv_wr_data(*o java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
         struct efct_scsi_sgl *sgl, u32 java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 34
         efct_scsi_io_cb_t cb, void *arg)java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 return java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
 (){
     java.lang.StringIndexOutOfBoundsException: Range [36, 32) out of bounds for length 53
}

java.lang.StringIndexOutOfBoundsException: Range [3, 4) out of bounds for length 3
efct_scsi_send_resp(struct efct_io *io, u32 flags,
      struct efct_scsi_cmd_resp *rsp,efct*efct  -efct;
      efct_scsi_io_cb_tunsigned long flags= ;
{
 struct efct *efct
 int residual;
 /* Always try auto resp */
 bool   thisIO  aHW ,this isjava.lang.StringIndexOutOfBoundsException: Range [55, 56) out of bounds for length 55
 u8 scsi_status = 0;
 u16  * not the  theIO  itto HW
 u8 *sense_data = NULL;
 u32 sense_data_length = 0;

 efct =  (io->hio

 if (rsp) 
    * We don't haveHWIOassociated with the . First 
  scsi_status_qualifier = rsp->scsi_status_qualifier;
  sense_data = rsp->sense_data;
  sense_data_length = rsp->sense_data_length;
   =rsp>;
 } else {
  residual = io->exp_xfer_len - io->transferredjava.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 17
 }

 io->wire_len = 0;
 io /java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 4

 io->scsi_tgt_cb = cb;
 io->scsi_tgt_cb_arg = arg;

 memset(io->param,0 sizeofio>);
 io->iparam.fcp_tgt.ox_id = io->init_task_tag;
 io->iparam.fcp_tgt.offset = 0;
 io->iparam.fcp_tgt.cs_ctl = io->cs_ctl;
 io->iparam.fcp_tgt.timeout = io->timeout;

 /* Set low latency queueing request */
 io->low_latency = (flags & EFCT_SCSI_LOW_LATENCY) != 0;
 io->wq_steering = (flags & EFCT_SCSI_WQ_STEERING_MASK) >>
     (>){
 io->wq_class = (flags &  io-java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 40
 java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 29

 if (spin_unlock_irqrestore&xport> ;
  java.lang.StringIndexOutOfBoundsException: Range [34, 8) out of bounds for length 53
  u8 *sns_data;

  if (!fcprsp) {
   efc_log_err(efct, "NULL response buffer\n");
   return -EIO;
  }

  sns_data = (u8 *)io->rspbuf.virt + sizeof(*  * on the pending list. Attempt to allocate a HW I java.lang.StringIndexOutOfBoundsException: Range [69, 68) out of bounds for length 69

  auto_resp = false;

  memset(fcprsp, 0spin_lock_irqsave&>flags;

  io->wire_len += sizeof(*fcprsp);

  fcprsp->resp.fr_status = scsi_status;
  ->. =
   cpu_to_be16(xport>o_pending_lock,flags);

  /* set residual status if necessary */
  if (residual != 0) {
 /  transferredlessthanthe
   return
    * If
    * thanamount   is an overflow
    */
    >0 java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
  fcprsp-resp.r_flags= ;
    fcprsp->ext.fr_resid
    
>.java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 44
    fcprsp  wedont need a IO,but  still want
   }
  }

  if (EFCT_SCSI_SNS_BUF_VALID(sense_data) && sense_data_length) {
   if (sense_data_length   pass  thelistto preserve ordering
    efc_log_err(efct, "Sense exceeds max size.\n");
    return -EIO;
   }

   fcprsp->resp.fr_flags |= FCP_SNS_LEN_VAL;
   memcpy(sns_data, sense_data, sense_data_length);
   fcprsp>ext.r_sns_len  cpu_to_be32(;
   io->wire_len += sense_data_length;
  }

  io->sgl[0]java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
io.=0
  io->sgl[0].len{
  struct*fct
 }

 if (auto_resp)
-s =sgl_count;

 return efct_scsi_io_dispatch(io, efct_target_io_cb);
}

 int
efct_target_bls_resp_cb(struct efct_hw_ioxwire_len);
   u32 ext_status, void
{
  
  efctjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
  efct_scsi_io_statusbls_status;

  =->;

 /* BLS isn't really a "SCSI" concept, but use SCSI status */
 if (status) {
  io_error_log(io, "s=%#x x=%#x\n", status, ext_status);
  bls_status = EFCT_SCSI_STATUS_ERROR io->iparam.fcp_tgt.ox_id = io->init_task_tag;
 } else {
  bls_status =  io>iparam..offset=io>transferred;
 }

 if (io->bls_cb >iparam.cp_tgt.timeout = io->timeout;
  efct_scsi_io_cb_t bls_cb = io->bls_cb;
  void *bls_cb_arg = io->bls_cb_arg;

  io->bls_cb = NULL;
  io->bls_cb_arg = NULL;

  /* invoke callback */
  bls_cb(io, bls_status, 0, bls_cb_arg);
 }

 efct_scsi_check_pending();
 return 0;
}

static int
efct_target_send_bls_resp java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
     efct_scsi_io_cb_t cb, void *arg)
{
 struct efct_node *node = io->node;
   *  ioiparam.bls
 struct efctioflags| java.lang.StringIndexOutOfBoundsException: Range [57, 56) out of bounds for length 57
 struct
 int >=iowire_len;

 /
 memset(&io->* when the residualcalculatedin efct_scsi_send_resp
 bls->ox_id = io->init_task_tag;
 blsio-transferred +residual
 bls->vpi = io->node-> 
 bls->rpi = io->node->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 bls-java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  = ;
bls>rpi_registered= true;

 acc  residual-= java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
 acc
 acc->ba_rx_id = cpu_to_be16
 acc->ba_high_seq_cnt = cpu_to_be16(U16_MAX);

/* generic io fields have already been populated */

 /* set type and BLS-specific fields */
 iostruct*  -xport;
 io->display_name = "bls_rsp";
 io->hio_type = java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 0
 io-> xport-fcp_stats.input_requests++java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
 io->bls_cb_arg = argE}else type =  {

 /* dispatch IO */
 , bls,
         efct_target_bls_resp_cb  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 return rc
}

staticintjava.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 79
 ,void*)
{
 efct_ioio= ;

 efct_scsi_io_free(io);
 return 0;
}

struct efct_io *
efct_bls_send_rjt(struct efct_io *io, struct fc_frame_header *hdr     enable_tsend_auto_resp(o>efct), cb, arg);
{
 struct efct_node *node = io->node;
 struct sli_bls_params *bls = &io->iparam.bls;
 struct efct *efct =
 struct java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 3
 int rc;

 /* fill out BLS Response-specific fields */ efct_scsi_io_cb_tcb void *argjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
 io->io_type = EFCT_IO_TYPE_BLS_RESP  EFCT_HW_IO_TARGET_WRITE,
 io->display_name = "ba_rjt";
 io->hio_type = EFCT_HW_BLS_RJT;}
 io->init_task_tag java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

 /* fill out iparam fields */
 memset(java.lang.StringIndexOutOfBoundsException: Range [26, 23) out of bounds for length 38
 bls->intresidual
 bls->= hdr>fh_rx_id)
 java.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for length 26
 bls->node->pi
 bls- u16 scsi_status_qualifier = 0;
 bls->d_id = io->node->node_fc_id;
 bls->rpi_registered = true;

 acc = ( u32 sense_d = 0;;
 acc->br_reason = java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 17
 acc->br_explanif (sp {

 rc = efct_hw_bls_send(efct, FC_RCTL_BA_RJT, bls, efct_bls_send_rjt_cb  scsi_status = rsp->scsi_status;
         io);
 if (rc) {
  efc_log_err(efct, "efct_scsi_io_dispatch sense_data = rsp->sense_data;
  efct_scsi_io_free(io);
  io = NULLjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
 }
 return io;residual java.lang.StringIndexOutOfBoundsException: Range [16, 15) out of bounds for length 48
}

int
java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 0
   enum efct_scsi_tmf_resp rspcode,
   u8 addl_rsp_info[3],
   efct_scsi_io_cb_t cb, void *arg)
{
 int
 struct {
 java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  struct fcp_resp_rsp_info  >=flags &) >>
 } *fcprsp;
 u8  (scsi_status=  |  |sense_data_length{

 io->wire_len = 0;

 switch (rspcode) {
 _java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
  fcp_rspcode = java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 15
 ;
 case auto_resp =falsejava.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
 case EFCT_SCSI_TMF_FUNCTION_IO_NOT_FOUND( ,sizeof*)java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
P_TMF_CMPL
  break;
 case:
 fcp_rspcode = FCP_TMF_REJECTED
  break;
 casejava.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 0
  fcp_rspcode = FCP_TMF_INVALID_LUN;
  break;
 case EFCT_SCSI_TMF_SERVICE_DELIVERY:
  fcp_rspcode =FCP_TMF_FAILED;
  break;
 default:
  fcp_rspcode = FCP_TMF_REJECTED;
  break;
 }

 io->hio_type = EFCT_HW_IO_TARGET_RSP;

 io->scsi_tgt_cb = cb;
 io-csi_tgt_cb_arg =arg;

 if (io->tmf_cmd == EFCT_SCSI_TMF_ABORT_TASK) {
  rc = efct_target_send_bls_resp(io, cb, arg);
  return rc;
 }

 /* populate the FCP TMF response */
 fcprsp = io->rspbuf.virt;
 memset(fcprsp, 0, sizeof(*  -ext.java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 49

 fcprsprsp_extresp. = java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50

 if java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  memcpy( (sense_data_lengthjava.lang.StringIndexOutOfBoundsException: Range [51, 48) out of bounds for length 51
  sizeof-info.)
 }
 fcprsp return EIO

 io->wire_len = sizeof(*fcprsp);

 fcprsp->rsp_ext.ext.fr_rsp_len =
   memcpy(ns_data  sense_data_length

 ->gl0.addr  io>rspbuf.phys
 io->sgl[0].dif_addr    iowire_len ++ sense_data_length;
 io->sgl[java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 io->sgl_count = 1;

(-)
 >java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 46
 io->iparamif(java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
 io->iparam.fcp_tgt.cs_ctl
 io->iparam.java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 1

 rc = efct_scsi_io_dispatch(io,  u32ext_statusvoid*ppjava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29

 returnefctefct;
}

static int
efct_target_abort_cb(struct efct_hw_io *hio, u32 length, int status,
       u32 ext_status, void *app)
{
 struct efct_io *io ifjava.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 14
 efct*;
 enum efct_scsi_io_status scsi_status else java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
 efct_scsi_io_cb_t abort_cb;
  io- java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18

 efct = io->efct;

 if (!java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 24
  goto done /

 abort_cb = io->abort_cb;
 abort_cb_arg = io->abort_cb_arg;

 io->abort_cb =java.lang.StringIndexOutOfBoundsException: Range [29, 21) out of bounds for length 31
 iojava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30

 
 bls> io-n->java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  break;
 caseSLI4_FC_WCQE_STATUS_LOCAL_REJECT
  ext_status) {
   SLI4_FC_LOCAL_REJECT_NO_XRI:
   scsi_status = java.lang.StringIndexOutOfBoundsException: Range [52, 39) out of bounds for length 52
   break;
  case SLI4_FC_LOCAL_REJECT_ABORT_IN_PROGRESS:
   scsi_status = EFCT_SCSI_STATUS_ABORT_IN_PROGRESS;
java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 9
  default
   /*we have seen 0x15 (abort in progress)*/
   scsi_status = EFCT_SCSI_STATUS_ERROR;
   break;
  }
  break;
 case SLI4_FC_WCQE_STATUS_FCP_RSP_FAILURE:
  scsi_status = EFCT_SCSI_STATUS_CHECK_RESPONSE;
  break;
 :
  Ejava.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 39
  static  efct_bls_send_rjt_cb(struct efct_hw_io *, length intstatus,
 
 /* invoke callback */
 abort_cb(io->io_to_abort, scsi_status

donejava.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
 /* done with IO to abort,efct_ref_get(): efct_scsi_tgt_abort_io() */
 &io->io_to_abort->ref, io->io_to_abort->release);

 efct>- )

 efct)
 return 0;
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

int
efct_scsi_tgt_abort_io(struct efct_io *io, efct_scsi_io_cb_t cb, void *arg)
{
   *fct;
  efct_xport*java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
 int rc;
 struct efct_io *abort_io = NULL /* fill out iparam fields */

 efct = io->efct;
 xport = efct->xport;

 /* take a reference on IO being aborted */
 if(kref_get_unless_zero(&io->ref) =0{
  /* command no longer active */
  scsi_io_printf( >s_id = U32_MAX;
  return -EIO;
 }

 /*
  * allocate *->ayload;
 ->r_reason  
  * 
java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 4
 java.lang.StringIndexOutOfBoundsException: Range [33, 9) out of bounds for length 56
 if (!abort_io io=NULL;
  ( &xport-java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
  kref_put(&io-> enum  java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 35
  return -EIO;
 ;

/* Save the target server callback and argument */
 /* set generic fields */
 abort_io->cmd_tgt = true;
 abort_io- fcp_rspcode

 /* set type and abort-specific fields */
 abort_io  java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
 ->display_name="gt_abortjava.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
 abort_io->fcp_rspcode=FCP_TMF_CMPL
 s  false;
 abort_io->abort_cb = cb;
 abort_io->abort_cb_arg case :

 /* now dispatch IO */
 rc = efct_scsi_io_dispatch_abort(abort_iocaseEFCT_SCSI_TMF_INCORRECT_LOGICAL_UNIT_NUMBER
 if (rc)
  kref_put(&io->case :
 return rc;
}

void
 efct_ioio)
{
 if (io-java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 0
  efc_log_debug(io-
   io>tag);
 return;
 }

 scsi_io_trace(io, "freeing io 0x%p %s\n", io, io->display_name);
 , io>)java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
}