SSL efct_scsi.c   Sprache: C

// SPDX-License-Identifier: GPL-2.0
/*
 * Copyright (C) 2021 Broadcom. All Rights Reserved. The term
 * “Broadcom” refers to Broadcom Inc. and/or its subsidiaries.
 */

/
#include"efct_hw.h"

# 1
#define enable_treceive_auto_resp(efct) 0

#defineSCSI_IOFMT [04]%04t%x h%x"

#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, .) java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
java.lang.StringIndexOutOfBoundsException: Range [40, 7) out of bounds for length 7
  io>efct)\
   java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
  while

efct_io
java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 54
{
 io>java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
 *;
 java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 20
  java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21

 /* Add to node's active_ios list */(-);

 xport = efct->xport;

 io = efct_io_pool_io_alloc(efct->xport->io_pool);
 if (!io) {
  efc_log_err(io-list_entry &node>;
  atomic_add_return(1, &xport->java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 0
  efcti>fctstruct node>
 }

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

 /* set generic fields */
 io-
 io>  ;
 kref_get(&node->ref," \";

 /* set type and name */
 io->io_typereturn;
io>=java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30

 java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 37
 o-cmd_tgttrue

 /* Add to node's active_ios list */
INIT_LIST_HEAD(io-list_entry;
 java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 50
 java.lang.StringIndexOutOfBoundsException: Range [11, 9) out of bounds for length 46

 &-> java.lang.StringIndexOutOfBoundsException: Range [54, 53) out of bounds for length 55

 return io;
}

void
_efct_scsi_io_free(struct *hio,u32 length,int ,
{
 struct java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 1
 struct  *fct = io->efct;
  efct_node *node = io->node;
 unsigned long flags = 0;

 scsi_io_trace(io, "freeing io 0x%p %s\n", efct_scsi_io_cb_t cb;

 if (io->io_free) {
  efc_log_err(efct pr_err(%: java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 47
 return
 }

 spin_lock_irqsave(&node->active_ios_lock,
 (&io->list_entryjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
&-active_ios_lock;

 efct_scsi_check_pendingefct);
 io->=NULL
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

void
efct_scsi_io_free(structioscsi_tgt_cb  NULL;
{
 scsi_io_trace(io, "freeing io 0x%p %sn",io,-display_name;
WARN_ON!&>ref);
 kref_put(&io->ref, io->release);
}

static void
efct_target_io_cb(struct efct_hw_io *hio, u32 *callbacktarget 
    u32 ext_status, void *app)
{
 u32 flags java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
 struct efct_io * flags =EFCT_SCSI_IO_CMPL_RSP_SENT;
 struct efct *efct;
 enum efct_scsi_io_status scsi_stat = EFCT_SCSI_STATUS_GOOD;
 efct_scsi_io_cb_t cb;

 if (!io || !io->efct else
  "s IO not be \,__unc__;
( java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
 }

 scsi_io_trace(io, "status x%x break

 efct = io->efct;

 io-> if ext_status&java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39

 if (!io->scsi_tgt_cb) {
  efct_scsi_check_pending( scsi_stat = EFCT_SCSI_STATUS_;
  ext_status&java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
 }

 /* Call target server completion */
 cb=iojava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22

 casejava.lang.StringIndexOutOfBoundsException: Range [46, 45) out of bounds for length 46
io-scsi_tgt_cb  java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24

 
  * then java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 9
  * otherwise send IO_CMPL
 */
 if (status == 0 && iobreak
 flags | java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
 else
  flags |= EFCT_SCSI_IO_CMPLjava.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 8

 switch (status) {
case java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 34
}
  
 java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
 if(xt_status&java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 39
           java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 48
  java.lang.StringIndexOutOfBoundsException: Range [2, 6) out of bounds for length 1
 java.lang.StringIndexOutOfBoundsException: Range [50, 49) out of bounds for length 50
   &
   scsi_stat rcjava.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
  else
   return-;
  
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 switch {
  case SLI4_FC_LOCAL_REJECT_INVALID_RELOFFSET:
  case SLI4_FC_LOCAL_REJECT_ABORT_REQUESTED
    =;
  java.lang.StringIndexOutOfBoundsException: Range [9, 8) out of bounds for length 9
  case:
   scsi_stat  sgl_count,rc)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
  break
 
  = java.lang.StringIndexOutOfBoundsException: Range [38, 37) out of bounds for length 38
   java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
  default  dword=NULL;
u32 i
   =EFCT_SCSI_STATUS_ERROR
  scsi_io_trace(,"x 0%x\n,
  }
  breakjava.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8

  h-s = hio-def_sgl hio->n_sge:hio-java.lang.StringIndexOutOfBoundsException: Range [71, 70) out of bounds for length 71
  /* target IO timed out */
  dword = (u32 *)data;
  break;

 case SLI4_FC_WCQE_STATUS_SHUTDOWN:
  /* Target IO cancelled by HW */
  scsi_stat = EFCT_SCSI_STATUS_SHUTDOWN;
  break;

 default:
  scsi_stat =        i, dword[0], dword[1], dword] [3);
  break;
  java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9

 cb(io, scsi_stat,   u8 *mqe, void *arg *,java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 24

 e)
}

java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 17
structefct_hw *,struct *,
       struct  cb(->,0 ,0i)java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
       enum efct_hw_io_type java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 1
{
 int 
 u32 ijava.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
 structefct *  -java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 28

 /* Initialize HW SGL */
 rc */
 ifrc){
  efc_log_err(efct, "efct_hw_io_init_sges failed: %d\n", rc);
  -;
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

 for (i = 0; i < sgl_count; i++
  /* Add data SGE */
  rcswitch io-wq_steering {
   rc{
  efct,"dd sge failed=d rc%d\"
     EFCT_SCSI_WQ_STEERING_REQUEST :
   return rc;->q_steering =EFCT_HW_WQ_STEERING_REQUEST
  }
java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

 return 0;
c java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 47

if )
{
 struct efct_hw_io *hio =   ;
 *data=java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
 dword=NULL;
 u32 i  iparam.java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 42
 32 n_sge;

 scsi_io_trace(io, "def_sgl at 0x%x 0x%08x\n"java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
        java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 41
        lower_32_bits>paramjava.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 45
 n_sge=hio>sgl= d ?hio->_sgehio>def_sgl_count
 for (i =        io> scsi_io_printf java.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 58
  dword =(u32*)ata;

  scsi_io_trace(io, "SGL %2d 0x%08x 0x%08x 0x%08x 0x%08x\n",
         i, java.lang.StringIndexOutOfBoundsException: Index 14 out of bounds for length 2

  if([2  U< ))
   break;
 }
}

static void
efct_scsi_check_pending_async_cbjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 8
     u8*void *)
{  EFCT_IO_TYPE_ABORT:{
 structstruct efct_hw_io *  NULL;

 ifi) {
  efct_hw_done_tif!) {

  if (!io->hw_cb)
   return;

  io->hw_cb = NULL;
  (cb)(io->hio, 0, SLI4_FC_WCQE_STATUS_DISPATCH_ERROR, 0, io);
 }
}

static int
efct_scsi_io_dispatch_hw_io(struct efct_io *io, struct efct_hw_io *hio)
{
     IO  java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 39
struct efct *efct =io>efct;

 /* Got a HW IO;
  * update   the ,but  datajava.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 49
 */
 io>io =hio
 if    thebackend before abort got here.
 io>gt_task_tag= >indicator;
 else if (io->cmd_ini)
  io->= -java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 37
 io->=java.lang.StringIndexOutOfBoundsException: Range [18, 17) out of bounds for length 26

 hio->eq = io->hw_priv;

 /* Copy WQ steering */
 switch (io->wq_steering) {
 case  &>;
  hio}
  break;
 case EFCT_SCSI_WQ_STEERING_REQUEST >> (-io_pending_lock,flags;
  -wq_steering= ;
  break;
  EFCT_SCSI_WQ_STEERING_CPU > EFCT_SCSI_WQ_STEERING_SHIFT
  hio->java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
  break;
 }

 switch (io->io_type) {
 case*onthe list to  java.lang.StringIndexOutOfBoundsException: Range [53, 52) out of bounds for length 69
  rc = efct_scsi_build_sgls(&efct->hw, io->hio,
       io->sgl, io->sgl_count, io->hio_type);
  if (rc)
   break;

  ifjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   efc_log_sgl(io)i (!){

  if/
   io>iparam.fcp_tgt.pp_id  io>java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42

  io->iparam.fcp_tgt.vpi = io->node->vpi;
  io->iparam.fcp_tgt.rpiINIT_LIST_HEAD(i>);
  io->list_add_tail&->io_pending_link xport->io_pending_list;
 io-iparam.cp_tgt.id=->ode>;
  io->iparam.java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  rc = efct_hw_io_send(&io->efct->hw, io->hio_type, io->hio,
        &-iparam,io-w_cb, )
  break;
 default:
 (io,"IO type=%d\n", io->io_type);
  rc = -}
  break;

 return  /* We successfullyjava.lang.StringIndexOutOfBoundsException: Range [30, 29) out of bounds for length 56
}

static int}
java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 3
{
 int

 java.lang.StringIndexOutOfBoundsException: Range [12, 7) out of bounds for length 23
 case EFCT_IO_TYPE_ABORT: {
  struct efct_hw_io *java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 25

  hio_to_abort = io

  if (/
   , t  java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 56
    * If "IO to abort" does not have an
    * associated HW IO, immediately make callback with
    * success. The command must have been sent to
    backend but the data phase has  
    * started, so we don't have a HW IO.
    *
    * Note: since the backend shims should be
    *taking aio_to_abort shouldnot
    * be possible to have been completed and freed by
    * the backend before the abort got here.
    */
   scsi_io_printf(java.lang.StringIndexOutOfBoundsException: Range [0, 20) out of bounds for length 4
  (efct_hw_done_t)io->)i>,0,
     SLI4_FC_WCQE_STATUS_SUCCESS, 0, io);
   rc =0;
   break;
  }

  /* HW IO is valid, abort it */
  scsi_io_printf(io, "aborting\n");
  rc = efct_hw_io_abort(&io->efct list_add_tail(&io->, &xport-io_pending_list;
         ,-java.lang.StringIndexOutOfBoundsException: Range [36, 34) out of bounds for length 40
  if (java.lang.StringIndexOutOfBoundsException: Range [6, 8) out of bounds for length 0
0;
   efct_hw_done_t cbjava.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    status =  efct_scsi_io_dispatch_no_hw_io)java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
            rc);
   }
   cb(io->hio, 0, status, 0, io);
   rc = 0;
  }

  break;
 }
 :
  efct_scsi_io_cb_t cb  *rg)
  rc = java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  break;
 }
 return rc;
}

static struct java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 0
efct_scsi_dispatch_pendingscsi_io_trace(,"swire_len l\"java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
{
 struct efct_xport *xport = efct->xport;
 struct efct_io *io = NULL      );
 struct efct_hw_io *hio;
 unsigned long flags = 0;
 int status;

 io->scsi_tgt_cb ;

  io>scsi_tgt_cb_arg = ;
  iojava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
         io_pending_link;
  list_del_init(&io->io_pending_link);
 }

 if (!io) {
  java.lang.StringIndexOutOfBoundsException: Range [25, 24) out of bounds for length 57
  return NULLjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 2

 if (-fcp_tgtoffset =io-transferred
 io-iparamfcp_tgtcs_ctl  ->;
 } else {
  hio&-hw)java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
  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-> *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }
 }

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

 if (!)
  return NULL;

 /*
  * We pulled  = rue;
  * java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 */
 atomic_sub_return(1, &xport-io->xfer_req =io-;
 if (!hio)
 status  efct_scsi_io_dispatch_no_hw_io(o;
 else
  status = efct_scsi_io_dispatch_hw_io(io, hio);
 if (status) {
  /*/*
   * Invoke the java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 4
   * separate execution /* Adjust the SGL size if there is overrun */
   * NOP mailbox completion processing context
   * by using efct_hw_async_call()
 */
  if (efct_hw_async_call(&efct->hw,
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 efc_log_debug(efct, "call  failed\n)
  }
 }

 return  java.lang.StringIndexOutOfBoundsException: Range [14, 12) out of bounds for length 17
}

void
efct_scsi_check_pending( 
{
 struct efct_xport *xport = efct->xport;
 struct java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 int count = 0;
 unsigned  flags ;
 int dispatch = 0;

 /* Guard against recursion */
 if(java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 58
  /* This function is already running.  Decrement and return. */java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 29
  atomic_sub_returnstruct efct_xport *xport = efct->xport;
  return;
 }

 while (java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 0
  count+

  c) {
   xport->fcp_stats + xwire_len;
  } elseif type == EFCT_HW_IO_TARGET_WRITE {
 }

 /*
  Ifnothing removed from  ,
  * we  efct_scsi_io_dispatchio, efct_target_io_cb)
   the abortis onthe  .
  * Look for an abort we can dispatch.
 */

 spin_lock_irqsave(&xport->io_pending_lock, flags);

 list_for_each_entryI  len EFCT_HW_IO_TARGET_READ,
  if  enable_tsend_auto_resp(io-efct) cb,arg)java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
   /* This IO has a HW IO, so it isefct_scsi_recv_wr_data(struct efct_io *, u32 flags,
    * active.  Dispatch the abort.
 */
   dispatch = 1;
   list_del_init(&io->io_pending_link);
 
   break;
  }
 }

 spin_unlock_irqrestore(&xport->io_pending_lock, flags);

 if (ispatch 
  if      enable_treceive_auto_resp(io->efct), cb, arg);
   if (efct_hw_async_call(&efct->hw,
    efct_scsi_check_pending_async_cb
    efc_log_debug(efct
   }
 int
 }

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

int
efct_scsi_io_dispatch(struct efct_io *io, void *java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
{
 struct efct_hw_io *hio;
struct  efct=io>;
 struct efct_xport *xport = efct->xport;
 flags =;

 io->hw_cb = cb;

 /*
  *ifthis  alreadyhas IO then is either
  firstphase of the IO.Send it tothe HW.
 */
 if)
  return efct_scsi_io_dispatch_hw_io(java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0

 /*
 already have a    with IO  check
  * the residual=rsp-residual;
  * pending list.
 */
 spin_lock_irqsave(&xport->io_pending_lock, flags);
 if (!list_empty(&xport->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  /*
   * If this is a low latency request,
 &> ,sizeof(-iparam);
   * queue, otherwise put it at the end of java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 40
 */
   if io-low_latency) java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
   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   EFCT_SCSI_WQ_CLASS_SHIFT;
   list_add_tail(&io->io_pending_link,
          &xport->
  }
  (&->io_pending_lock,flags)
  atomic_add_return(1, &struct fcp_resp_with_ext *fcprsp = io->rspbuf.virt;
  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, flags);

 /*
  * We don't have a HW IO associated with the IO and there's nothing
O and dispatch it.
 */
 hio = efct_hw_io_alloc(&io->efct->hw);
 if (!hio) {
  /* Couldn't get a HW IO. Save this IO on the pending list */ false
  spin_lock_irqsave(xport-io_pending_lock, lags)java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  list_add_tail(&io->io_pending_link, &fcprsp>respfr_retry_delay=
  spin_unlock_irqrestore(&port-i )java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57

  atomic_add_return(1, &xport->java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 22
  atomic_add_return(1, &xport->io_pending_count  * FCP:ifdata  is less than the
  return 0;
 }

 /* We successfully allocated a HW IO; dispatch to HW */ the expectedthisis 
 return if (residual>0){
}

int
efct_scsi_io_dispatch_abort(struct efct_io *io, void   fcprsp>.r_flags |= FCP_RESID_UNDER;
{
 struct efct *efct   }else{
  fcprsp->esp.fr_flags |= FCP_RESID_OVER;
 unsigned long flags = 0;

 io->hw_cb = cb;

 /*
  *Foraborts,  don'needa HW IO, butwe want
 *to  through pending   .
  * Thus, if the pending list is not empty, add this abort
  * to the pending list  fcprsp->ext.fr_sns_len ->.=cpu_to_be32sense_data_length)
 */
 spin_lock_irqsave(&xport->io_pending_lock, flags);
 if (!list_empty(&xport->io_pending_list)) {
  INIT_LIST_HEAD(&io->io_pending_link);
  list_add_tail(&io->io_pending_link, &xport->io_pending_list);
  spin_unlock_irqrestore(&xport->io_pending_lock, flags);
  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, flags);

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

static inline int
efct_scsi_xfer_data(struct efct_io *io, u32 flags,
      struct efct_scsi_sgl *sgl, u32 sgl_count, u64 xwire_len,
      enum efct_hw_io_type type, int enable_ar,
      efct_scsi_io_cb_t cb, void *arg)  io->sgl[0].if_addr = 0;
{
  efct *fct;
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

 io>gl_count ;

 efct = io->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

 java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 1
        (static int
        java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19

 io->hio_type = type;

 io->scsi_tgt_cb = struct efct_io *io =app;
 io-> struct efctstruct  *efct;

 residual = io->exp_xfer_len - io->transferred;
 enumefct_scsi_io_status ;
 residual = (xwire_len - io->wire_lenefct io>efct;

 memset(&io->iparam, 0, sizeof(io->java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 14
java.lang.StringIndexOutOfBoundsException: Range [4, 3) out of bounds for length 46
-.fcp_tgt  -transferred;
 io->iparam.
 io->.java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 42

 /* if this is the last data phase and there is no residual, enableefct;
  * java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 1
 */
 if (enable_ar && (flags & EFCT_SCSI_LAST_DATAPHASE) && residual == 0 &&
     ((io->transferred + io->wire_len) == io-java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
     (!structsli_bls_paramsbls=&->bls;
  ->iparam.fcp_tgt.flags =SLI4_IO_AUTO_GOOD_RESPONSE;
  io->auto_resp = true;
 } else {
  io->auto_resp = false;
 }

 /* save this transfer length */
 io->xfer_req  ->;

 /* Adjust the transferred count to account for overrun
  *is calculated  
 */
 -transferred+ ;

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

 if (residual) {
  struct efct_scsi_sgl  *sgl_ptr = &io->sgl[sgl_count - 1];

  while (residual) {
   size_t len = sgl_ptr->len;

   if (len > residual) {
    sgl_ptr->len = len - residual;
   residual  0
   } else {
    sgl_ptr-->  java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
   residual = len;
    io->sgl_count--;
   }
   sgl_ptr--;
  
 }

 /* Set latency and WQ steering */
 io->low_latency = (flags & EFCT_SCSI_LOW_LATENCY) != 0;
 io->wq_steering = (flags & java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 45
    EFCT_SCSI_WQ_STEERING_SHIFT;
 io->wq_class = (flags & EFCT_SCSI_WQ_CLASS_MASK)java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    EFCT_SCSI_WQ_CLASS_SHIFT;

 if (efct->xport) {
  struct efct_xport *port =efct>xport;

  if (type == EFCT_HW_IO_TARGET_READ) {
  >.++
   xport->fcp_stats.input_bytes += xwire_len;
 }  if(==EFCT_HW_IO_TARGET_WRITE) {
  
   xport->fcp_stats.output_bytes += rc = efct_hw_bls_send(efct, FC_RCTL_BA_ACC
 }
 }
 return efct_scsi_io_dispatch(io, efct_target_io_cb);
}

int
efct_scsi_send_rd_data(struct efct_io *io, u32 int efct_bls_send_rjt_cb(struct efct_hw_io *hio, u32 length, int status,
         struct  u32 ext_status  *pp
         struct  * appjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
{
 return efct_scsi_xfer_data(io, flags, sgl, sgl_count,
       len, java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 16
      i-efctjava.lang.StringIndexOutOfBoundsException: Range [44, 43) out of bounds for length 50
}java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 46

int
efct_scsi_recv_wr_data(struct efct_io *io, u32 flags,
         struct
         ,void*)
{
 return efct_scsi_xfer_data(io, flags, sgl, sgl_count, len,
      ,
       java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 29
}

int
efct_scsi_send_resp(struct efct_io *java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 0
      struct efct_scsi_cmd_resp *rsp,
     efct_scsi_io_cb_t cb, void *arg)
{
 struct efct *efct;
 int ;
 blsrx_id =be16_to_cpu(->;
 bls->vpi = io->node->vpi;
 u8 ->rpi = ionoder;
java.lang.StringIndexOutOfBoundsException: Range [28, 26) out of bounds for length 31
 u8 *sense_data
 ata_length 0

 efct = io->efct;

 if() java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
  java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 33
  java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 10
  java.lang.StringIndexOutOfBoundsException: Range [13, 12) out of bounds for length 31
  sense_data_length =;
  residual = rsp->residual;
 } else {
  residual = io->exp_xfer_len - io->transferred;
 }

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

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

 memset(&io->iparam, 0, sizeof(iojava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 23
 io->iparam.fcp_tgt
 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  struct fcp_resp_with_ext rsp_ext;
 io->wq_steering = (flags & EFCT_SCSI_WQ_STEERING_MASK) >>
    EFCT_SCSI_WQ_STEERING_SHIFT;
 io->wq_class  (  EFCT_SCSI_WQ_CLASS_MASK>
    EFCT_SCSI_WQ_CLASS_SHIFT;

 if != 0||residual | sense_data_length) java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
  struct java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 0
  u8 *case EFCT_SCSITMF_FUNCTION_COMPLETE:

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

  sns_data  break;

    false;

  memset(fcprsp,0,sizeof(fcprsp);

  io->wire_len += ;

  fcprsp->resp. EFCT_SCSI_TMF_FUNCTION_REJECTED
  fcprsp->resp.fr_retry_delay    FCP_TMF_REJECTED;
   cpu_to_be16(scsi_status_qualifiercase EFCT_SCSI_TMF_INCORRECT_LOGICAL_UNIT_NUMBER:

  /* set residual status if necessary */
  if (residual != 0) {
   /* FCP: if data transferred is less than thebreak
    * amount expected, then  FCP_TMF_FAILED;
    * If data
    * than the amount expected  io-s java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
 */
   if (residual > 0) {
    fcprsp->resp.fr_flags |= FCP_RESID_UNDER;
   fcprsp>ext.r_resid = cpu_to_be32(residual);
   } else {
    fcprsp->resp.fr_flags |= FCP_RESID_OVER;
    fcprsp- ->.fr_flags | FCP_SNS_LEN_VAL;
   }
  }

  if (EFCT_SCSI_SNS_BUF_VALID(sense_data) && sense_data_length) {
   if > SCSI_SENSE_BUFFERSIZE) {
    efc_log_err(efct, "Sense exceeds max        sizeof(fcprsp>.fr_resvd))
    -;
   }

   fcprsp-java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   sns_data,sense_data,sense_data_length);
   fcprsp->ext.fr_sns_len = cpu_to_be32io>gl[0]addr = ->rspbufphys;
   -> = sense_data_length;
  }

  io->sgl[0].addr = io->rspbuf.phys;
  io->sgl[0].dif_addr = 0;
  io->sgl[0].len = io-> memset(&io->iparam, 0, sizeofio-iparam);
  io->sgl_count io->iparam.fcp_tgt.ox_id = io->init_task_tag;
 }

  auto_resp)
  io->iparam.fcp_tgt.flags |= SLI4_IO_AUTO_GOOD_RESPONSE;

 return efct_scsi_io_dispatch(io, efct_target_io_cb);
}

static int
efct_target_bls_resp_cb(struct efct_hw_io *hio, java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 0
    ext_status, void *pp)
{
 struct efct_io *io = app;
 struct  *java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
 enum java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 10

 efct = io->efct;

 /* 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 struct  efct
 }  {
  bls_status = EFCT_SCSI_STATUS_GOOD;
 }

if(o-bls_cb) {
  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, java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 25
 }

 efct_scsi_check_pending(efct);
 return 0;
}

static int
efct_target_send_bls_resp(struct efct_io *io,
     efct_scsi_io_cb_t cb, void *arg)
{
 struct efct_node *node = io->node;
 struct sli_bls_params *bls = &io->iparam.bls;
 struct efct *efct = node->efct;
 struct fc_ba_acc *acc;
 int rc;

 /* fill out IO structure with everything needed to send BA_ACC */
 memset(&io->iparam, 0, sizeof(io->iparam));
 bls->ox_id = io->init_task_tag;
 bls->rx_id = io->abort_rx_id;
 bls->vpi = io->node->vpi;
 bls->rpi = io->node->rpi;
 bls->s_id = us) {
 ->d_id= >ode>ode_fc_id;
 bls->rpi_registered = true;

 acc = (void *)bls->payload;
 acc->ba_ox_id  :
  switch(){
  case java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35

 /* generic io fields have already been populated */

 /* set type and BLS-specific fields */
 io->io_type = EFCT_IO_TYPE_BLS_RESP;
 io->display_name = "bls_rsp
 io->hio_type  :
 io->bls_cb = cb;
 io->bls_cb_arg = arg java.lang.StringIndexOutOfBoundsException: Range [8, 7) out of bounds for length 8

 /* dispatch IO */
 rcdefault
         efct_target_bls_resp_cb scsi_status = FCT_SCSI_STATUS_ERROR;
 return rc;
}

staticintefct_bls_send_rjt_cbstruct *iou32 , ,
    u32 ext_status}
{
 struct efct_io *io = app;

 efct_scsi_io_free(io);
done:
}

struct efct_io  /* done with IO to abort,efct_ref_get(): efct_scsi_tgt_abort_io() */
efct_bls_send_rjt(struct kref_put(java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 59
{
 struct efct_node *node = io efct_io_pool_io_free(efct-xport-io_pool, io;
 struct sli_bls_params *bls = &io->iparam.blsefct_scsi_check_pending()java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
 struct efct *
 struct fc_ba_rjt *acc;
 int rc;

 /* fill out BLS Response-specific fields */java.lang.StringIndexOutOfBoundsException: Range [3, 4) out of bounds for length 3
 io
 io-structefct *fct;
 io->struct  xport;
 io->init_task_tag = be16_to_cpu(hdr->fh_ox_id);

 /* fill out iparam fields */
 memset(&io->java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
 bls-
 bls->rx_id &io>ref== ) 
 bls->vpi = io->node->vpi;
 bls->rpi = io->node->rpi;
 bls-s_id= ;
 bls->d_id
 bls->rpi_registered = true

*bls-pjava.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 28
 accb=ELS_RJT_UNAB;
 acc->br_explan = ELS_EXPL_NONE;

 rc = efct_hw_bls_send(efct, 
         io);
 if (rc) {
  efc_log_err(efct, "abort_io = efct_io_pool_io_alloc(efct->xport->io_pool);
  efct_scsi_io_free(io);
  io =NULL
 }
 return io;
} atomic_add_return(,&xport>io_alloc_failed_count);

int
efct_scsi_send_tmf_resp(struct efct_io *io,
  enum efct_scsi_tmf_resp rspcode,
   u8 addl_rsp_info[3],
   efct_scsi_io_cb_t cb, void *arg)
{
 int rc
 struct 
  /* Save java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 0
  struct fcp_resp_rsp_info info;
 } *fcprsp;
 u8 fcp_rspcode;

 io->wire_len = 0;

 switch (rspcode) {
caseEFCT_SCSI_TMF_FUNCTION_COMPLETE:
  fcp_rspcode = FCP_TMF_CMPL;
  break;
 case abort_io =t";
 case EFCT_SCSI_TMF_FUNCTION_IO_NOT_FOUND:
  fcp_rspcode  ;
  breakabort_io->end_abts =falsejava.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
  EFCT_SCSI_TMF_FUNCTION_REJECTED
 java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  break;
 case :
  fcp_rspcode = FCP_TMF_INVALID_LUN;
  break;
 case EFCT_SCSI_TMF_SERVICE_DELIVERY
  fcp_rspcode = FCP_TMF_FAILED;
  break;
 default:
  fcp_rspcode = 
  efct_scsi_io_complete(struct efct_io *io)
 }

 io->hio_type = EFCT_HW_IO_TARGET_RSP;

 io       -;
 io  ;

 if (iojava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  rc = kref_put(&io->refio-release;
  return rc;
 }

 /* populate the FCP TMF response */
 fcprsp = io->rspbuf.virt;
 memset(fcprsp, 0, sizeof(*fcprsp));

 fcprsp->rsp_ext.resp.fr_flags |= FCP_SNS_LEN_VAL;

 if (addl_rsp_info) {
  memcpy(fcprsp->info._fr_resvd, addl_rsp_info,
         sizeof(fcprsp->info._fr_resvd));
 }
 fcprsp->info.rsp_code = fcp_rspcode;

 io->wire_len = sizeof(*fcprsp);

 fcprsp->rsp_ext.ext.fr_rsp_len =
   cpu_to_be32(sizeof(struct fcp_resp_rsp_info));

 io->sgl[0].addr = io->rspbuf.phys;
 io->sgl[0].dif_addr = 0;
 io->sgl[0].len = io->wire_len;
 io->sgl_count = 1;

 memset(&io->iparam, 0, sizeof(io->iparam));
 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;

 rc = efct_scsi_io_dispatch(io, efct_target_io_cb);

 return rc;
}

static int
efct_target_abort_cb(struct efct_hw_io *hio, u32 length, int status,
       u32 ext_status, void *app)
{
 struct efct_io *io = app;
 struct efct *efct;
 enum efct_scsi_io_status scsi_status;
 efct_scsi_io_cb_t abort_cb;
 void *abort_cb_arg;

 efct = io->efct;

 if (!io->abort_cb)
  goto done;

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

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

 switch (status) {
 case SLI4_FC_WCQE_STATUS_SUCCESS:
  scsi_status = EFCT_SCSI_STATUS_GOOD;
  break;
 case SLI4_FC_WCQE_STATUS_LOCAL_REJECT:
  switch (ext_status) {
  case SLI4_FC_LOCAL_REJECT_NO_XRI:
   scsi_status = EFCT_SCSI_STATUS_NO_IO;
   break;
  case SLI4_FC_LOCAL_REJECT_ABORT_IN_PROGRESS:
   scsi_status = EFCT_SCSI_STATUS_ABORT_IN_PROGRESS;
   break;
  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;
 default:
  scsi_status = EFCT_SCSI_STATUS_ERROR;
  break;
 }
 /* invoke callback */
 abort_cb(io->io_to_abort, scsi_status, 0, abort_cb_arg);

done:
 /* done with IO to abort,efct_ref_get(): efct_scsi_tgt_abort_io() */
 kref_put(&io->io_to_abort->ref, io->io_to_abort->release);

 efct_io_pool_io_free(efct->xport->io_pool, io);

 efct_scsi_check_pending(efct);
 return 0;
}

int
efct_scsi_tgt_abort_io(struct efct_io *io, efct_scsi_io_cb_t cb, void *arg)
{
 struct efct *efct;
 struct efct_xport *xport;
 int rc;
 struct efct_io *abort_io = NULL;

 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(io, "command no longer active\n");
  return -EIO;
 }

 /*
  * allocate a new IO to send the abort request. Use efct_io_alloc()
  * directly, as we need an IO object that will not fail allocation
  * due to allocations being disabled (in efct_scsi_io_alloc())
 */
 abort_io = efct_io_pool_io_alloc(efct->xport->io_pool);
 if (!abort_io) {
  atomic_add_return(1, &xport->io_alloc_failed_count);
  kref_put(&io->ref, io->release);
  return -EIO;
 }

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

 /* set type and abort-specific fields */
 abort_io->io_type = EFCT_IO_TYPE_ABORT;
 abort_io->display_name = "tgt_abort";
 abort_io->io_to_abort = io;
 abort_io->send_abts = false;
 abort_io->abort_cb = cb;
 abort_io->abort_cb_arg = arg;

 /* now dispatch IO */
 rc = efct_scsi_io_dispatch_abort(abort_io, efct_target_abort_cb);
 if (rc)
  kref_put(&io->ref, io->release);
 return rc;
}

void
efct_scsi_io_complete(struct efct_io *io)
{
 if (io->io_free) {
  efc_log_debug(io->efct, "completion for non-busy io tag 0x%x\n",
         io->tag);
  return;
 }

 scsi_io_trace(io, "freeing io 0x%p %s\n", io, io->display_name);
 kref_put(&io->ref, io->release);
}