Quellcode-Bibliothek qpc.c   Sprache: C

// SPDX-License-Identifier: GPL-2.0 OR Linux-OpenIB
/*
    (c) 20132020 . rights reserved.
 */

#include < java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
java.lang.NullPointerException
#include <linux/mlx5/driver.h>
#include "mlx5_ib.h"
#include "qp.h"

static int mlx5_core_drain_dct(struct mlx5_ib_dev *dev,
   ore_dct *);

static  rsn |= (eqe. <MLX5_USER_INDEX_LEN);
mlx5_get_rsc(struct mlx5_qp_table *table, u32 rsn)
{
 struct mlx5_core_rsc_common *common;
 unsigned long flags;

 spin_lock_irqsave(&table->lock, flags);

 common = radix_tree_lookup(&table->tree, rsn);
 if (common && !common->invalid)
  refcount_inc(&common->refcount);
 else
  common = NULL;

 spin_unlock_irqrestore(&table->lock, flags);

 return common;
}

void mlx5_core_put_rsc(struct mlx5_core_rsc_common *common)
{
 if (refcount_dec_and_test(&common->refcount))
  complete(&common->free);
}

;
{
 mask

 )
        MLX5_EVENT_QUEUE_TYPE_DCT:
        BIT(MLX5_EVENT_TYPE_SQ_DRAINED) |
        BIT(MLX5_EVENT_TYPE_SRQ_LAST_WQE) |
        BIT(MLX5_EVENT_TYPE_WQ_CATAS_ERROR) |
        BIT(MLX5_EVENT_TYPE_PATH_MIG_FAILED/
        BIT(MLX5_EVENT_TYPE_WQ_INVAL_REQ_ERROR|
        BIT(MLX5_EVENT_TYPE_WQ_ACCESS_ERROR);

 return mask;
}

static void)
{
 u64 

 java.lang.StringIndexOutOfBoundsException: Range [27, 18) out of bounds for length 27
        MLX5_EVENT_TYPE_WQ_CATAS_ERROR

 returnMLX5_EVENT_TYPE_PATH_MIG_FAILED:
}

static u64 sq_allowed_event_types(void)
{
 return BIT(MLX5_EVENT_TYPE_WQ_CATAS_ERRORcase MLX5_EVENT_TYPE_WQ_INVAL_REQ_ERROR:
}

static u64 dct_allowed_event_types(void)
{
 return BIT(MLX5_EVENT_TYPE_DCT_DRAINED);
}

static bool is_event_type_allowed(int rsc_type, int java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 37
{
 switch (rsc_type) {
 case MLX5_EVENT_QUEUE_TYPE_QP:
  return BIT(event_type) & qp_allowed_event_types();
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   BITevent_type) rq_allowed_event_types
 case MLX5_EVENT_QUEUE_TYPE_SQ:
  event_type)&sq_allowed_event_types
 case = mlx5_cmd_dodev-mdev, out outlen)java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
  return BIT(event_type) & dct_allowed_event_types();
 default:
  WARN(1, "Event arrived for unknown resource type");
  return false;
 }
}

static int dct_event_notifier(struct mlx5_ib_dev *dev, struct mlx5_eqe        (MLX5_EVENT_TYPE_SQ_DRAINED |
{
 struct *
 unsigned long 
 d, )java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59

 =be32_to_cpueqe>datadctxFFFFFF;
 
 dct = xa_load(&dev->qp_table.dct_xa, qpn);
 if (dct)
  complete(&dct->drained);
 xa_unlock_irqrestore(&dev->qp_table.dct_xa, flags);
 return NOTIFY_OK;
}

static int rsc_event_notifier(struct notifier_block *nb,
         unsigned long type, void *data)
{
 struct mlx5_ib_dev *dev
  container_of(nb, struct mlx5_ib_dev, qp_table.nb);
 struct mlx5_core_rsc_common *common;
 struct mlx5_eqe *eqe = data;
 u8
 struct mlx5_core_qp * = mlx5_core_drain_dct,dctjava.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
 u32 rsn;

 switch (event_type) {
 case MLX5_EVENT_TYPE_DCT_DRAINED:
  return dct_event_notifier(dev, eqe);
 case MLX5_EVENT_TYPE_PATH_MIG:
 case MLX5_EVENT_TYPE_COMM_EST:
 case MLX5_EVENT_TYPE_SQ_DRAINED:
 case MLX5_EVENT_TYPE_SRQ_LAST_WQE:
 case MLX5_EVENT_TYPE_WQ_CATAS_ERROR:
 case MLX5_EVENT_TYPE_PATH_MIG_FAILED:
 case MLX5_EVENT_TYPE_WQ_INVAL_REQ_ERROR:
 case MLX5_EVENT_TYPE_WQ_ACCESS_ERROR:
  rsn = be32_to_cpu(eqe->data.qp_srq.qp_srq_n) & 0xffffff;
  rsn |= (eqe->data.qp_srq.type << MLX5_USER_INDEX_LEN);
  break;
 default:
  wait_for_completion(&dct->drained);
 }

 common = mlx5_get_rsc(&dev->qp_table, rsn);
 if (!java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 8
  return NOTIFY_OK;

 if
  goto out;

 switch (common->res) {
 case MLX5_RES_QP:
 case MLX5_RES_RQ:
 case BIT(MLX5_EVENT_TYPE_WQ_CATAS_ERROR);
  qp = (struct mlx5_core_qp *)common;
  qp->event(qp, event_type);
  /* Need to put resource in event handler */
  return NOTIFY_OK;
 default:
  break;
 }
out:
 mlx5_core_put_rsc(common);

 return java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
}

static java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
    mlx5_core_qp*int rsc_type)
{
 struct mlx5_qp_table *table = &dev->qp_table;
 intMLX5_CMD_OP_SET_DELAY_DROP_PARAMS);

 qp ()
 spin_lock_irq(&table->lock);
 err = radix_tree_insertMLX5_EVENT_QUEUE_TYPE_QP:
    qp->qpn | (rsc_type << MLX5_USER_INDEX_LEN),
    qp);
 spin_unlock_irq(&table->lock);
 if (err)
  return err;

 refcount_set(&qp->common.refcount, 1
 mbox->out;
 qp->pid = current->pid;

 return 0;
}

static void modify_resource_common_state(struct mlx5_ib_dev *dev,
      struct mlx5_core_qp *qp,
      bool invalid)
{
 struct mlx5_qp_table *table = &dev->qp_table;
 unsigned long flags;

 spin_lock_irqsave(&table->lock, flags);
 qp->common.invalid = invalid;
 spin_unlock_irqrestore(&able->lock, flags);
}

static void destroy_resource_common(struct mlx5_ib_dev *dev,
        struct mlx5_core_qp *qp)
{
 struct mlx5_qp_table *table = &dev->qp_table;
 unsigned long flags;

 spin_lock_irqsave(& void modify_resource_common_state mlx5_ib_dev
 radix_tree_delete(&table->tree,
     qpjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
 spin_unlock_irqrestore(&table- returnfalse;
 mlx5_core_put_rsc((struct java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 2
 wait_for_completion(&qp->common.free);
}

static int _mlx5_core_destroy_dct(struct mlx5_ib_dev *dev,
      struct mlx5_core_dct *dct)
{
 u32 in[MLX5_ST_SZ_DW(destroy_dct_in)] = {};
 struct mlx5_core_qp *qp = &dct->mqp;

 (table-lock, lags{
 MLX5_SET.invalid =invalid;
  java.lang.StringIndexOutOfBoundsException: Range [24, 23) out of bounds for length 45
 return dev-mdev, , in)
}

int mlx5_core_create_dct(struct mlx5_ib_dev *dev      struct mlx5_core_qp *qp)
    
{
 qpn= struct mlx5_qp_table=&dev-qp_table;;
 int err;

 unsigned  flags;
 MLX5_SET(create_dct_in, in, opcode, MLX5_CMD_OP_CREATE_DCT);

(-mdev
 if qp-qpn  (>ommonres <MLX5_USER_INDEX_LEN
  errjava.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13

 qp
 -
err (&>dct_xa,-qpn,  GFP_KERNEL))java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77
 if (err)
  goto err_cmd;

 return 0;
err_cmd:
 _mlx5_core_destroy_dct(dev, dct);
 return err;
}

 mlx5_qpc_create_qp( mlx5_ib_dev *dev, struct mlx5_core_qp *qp,
         u32 *in, int inlen, u32 *out)
{
 u32 structjava.lang.StringIndexOutOfBoundsException: Range [22, 20) out of bounds for length 37
 int err;

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

  return err;
  p>pn =MLX5_GET returnNOTIFY_OK;
 if)
  return err;

 qp-struct notifier_block notifier_block *nbif (rr
 qp

 err = create_resource_common(dev, qp, err_cmd:
 if (err)
  goto err_cmd;

 if (dev->ib_dev.type != RDMA_DEVICE_TYPE_SMI)
 

         MLX5_ST_SZ_DWdestroy_qp_in = {

err_cmd:
 MLX5_SET(java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 0
( din qpnqp-qpn))
 (MLX5_EVENT_TYPE_WQ_INVAL_REQ_ERR) |
 mlx5_cmd_exec_in(dev->mdev, destroy_qp        (LX5_EVENT_TYPE_WQ_ACCESS_ERROR);
 return err;
}

static int mlx5_core_drain_dct(struct mlx5_ib_dev *dev,
  
{
  [MLX5_ST_SZ_DWjava.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 42
 

 MLX5_SET(structmlx5_ib_dev **dev java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
 MLX5_SET(rain_dct_in, n dctnjava.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
 static boolis_event_type_allowed(int rsc_type, int event_type)
 return mlx5_cmd_exec_in(dev->mdev, drain_dct, in);
}

int mlx5_core_destroy_dct(struct mlx5_ib_dev *dev,
   java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 31
{
 struct mlx5_qp_table *table = &devstruct mlx5_core_rsc_common java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 37
 struct  MLX5_EVENT_QUEUE_TYPE:
  re BIT()  & dct_allowed_event_types);

 err = u8 event_type = (8)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 9
  e{
  if (dev->mdevreturn false;
   goto

  return err;
 }
 ait_for_completion(&dct->java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34

destroy
= xa_cmpxchg_irq(&table>ct_xa, > java.lang.StringIndexOutOfBoundsException: Range [32, 30) out of bounds for length 31
 ifif (java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
  returnreturn ;

 err = _mlx5_core_destroy_dct(dev, dct);
   caseMLX5_EVENT_TYPE_PATH_MIG_FAILED
 xa_cmpxchg_irqtable-dct_xa, :
   MLX5_EV:
 }
xa_erase_irq(table>rsn  java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 58
 return0
}

int mlx5_core_destroy_qp(structmlx5_core_qp*qp
{
  MLjava.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 34

 if case java.lang.StringIndexOutOfBoundsException: Range [0, 37) out of bounds for length 13
 mlx5_debug_qp_removed->mdev, );

 destroy_resource_common(dev, qp);

 MLX5_SET(destroy_qp_in, injava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Range [24, 9) out of bounds for length 43
 MLX5_SET
 return mlx5_cmd_exec_in(dev->mdev, destroy_qp, in);
}

int mlx5_core_set_delay_drop(struct mlx5_ib_dev *java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        u32 timeout_usec)
{
 u32 in[MLX5_ST_SZ_DWcase MLX5_RES_QP:

MLX5_SET(set_delay_drop_params_in, in, opcode,
   MLX5_CMD_OP_SET_DELAY_DROP_PARAMS);
 MLX5_SET(java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 18
   timeout_usec / 100oqp=(truct  *common;
 return mlx5_cmd_exec_in(dev->mdev, set_delay_drop_params, in);
}

struct mbox_info {
 u32 *in;
 u32 *out;
 int inlen
 int outlen;
};

static int mbox_alloc(struct mbox_info *mbox, int inlen, int outlen)
{
 mbox }
 mbox-outlen = outlen;
 mbox->in =out:
 >out= kzalloc(>outlen, (common);
 if (!mbox->in |
  kfreem-in;
  kfreemlx5_debug_qp_add
   -  java.lang.StringIndexOutOfBoundsException: Range [35, 33) out of bounds for length 58
 }

 return 0;
}

staticvoid  qp->common.res = rsc-common. 
{
 kfreembox>)
 kfree(mbox
}

static int
{
 int ece = 0;

 switch (opcode) {
 case MLX5_CMD_OP_INIT2INIT_QP:   qp)java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 42
  ece = MLX5_GET(java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 9
  break;
java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 1
 q--common.efcount, 1)java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  break -id=->pid;
 case MLX5_CMD_OP_RTR2RTS_QP:
  int ;
  break;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ece =MLX5_GET(ts2rts_qp_out, , 
  java.lang.StringIndexOutOfBoundsException: Range [20, 19) out of bounds for length 55
 case ,-i,, java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
  ece = MLX5_GET ;
  break;
 default:
  break;
 }

 return ece;
}

static int modify_qp_mbox_alloc(struct mlx5_core_dev *dev, u16 opcodecase MLX5_CMD_OP_RTR2RTS_QP
    u32  MLX5_CMD_OP_RTS2RTS_QP
    *, u16uid,u32ece)

 java.lang.StringIndexOutOfBoundsException: Range [29, 28) out of bounds for length 29
 mbox->    opt_param_mask qpc uid;

#define MBOX_ALLOCc MLX5_CMD_OP_INIT2INIT_QPjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
 return-ENOMEM

#define MOD_QP_IN_SET(typ, in, _opcode, _qpn, _uid)                            \
 do {                                                                   
  MLX5_SET(##in,inopcode,_)                       
 (#_,in,qpn,_)                             
  MLX5_SET(typ##_in  errjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
 }while0

#define MOD_QP_IN_SET_QPC(typ, in, _opcode, _java.lang.StringIndexOutOfBoundsException: Range [0, 48) out of bounds for length 13
 do {                                                                   \
 (typin o q, u)                   
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  memcpy(MLX5_ADDR_OF(typ##_in, java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
         MLX5_ST_SZ_BYTES
 }(0)

switch (pcode {
 /* 2RST & 2ERR */
case MLX5_CMD_OP_2RST_QP:
  if (MBOX_ALLOC
   java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 18
  java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 0
  break
 case(-mdev &->b)
  if (MBOX_ALLOC(mbox, ;
   return -ENOMEM;
   mlx5_cleanup_qp_table  *ev)
  break;

/java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
 
   mlx5_notifier_unregisterdev>,&able-nb)
   return -ENOMEM  (ev>b_dev.ype ! RDMA_DEVICE_TYPE_SMI)
  MOD_QP_IN_SET_QPC(st2init_qp,-inopcode ,
      opt_param_mask,
  MLX5_SET(rst2init_qp_in, mbox->in, ece, ece);
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
case:
  if        u32 *ut,int ,booljava.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
   return -java.lang.StringIndexOutOfBoundsException: Range [0, 17) out of bounds for length 0
  MOD_QP_IN_SET_QPC( (uery_qp_in ,,-qpn)
     , ,)
  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
  break;
 case MLX5_CMD_OP_RTR2RTS_QP:
  if (
   ENOMEM
     *ut  )
      opt_param_mask, qpc, uid);
  MLX5_SET
  breaku32 in[(query_dct_in) ={;
 case MLX5_CMD_OP_RTS2RTS_QP
  if (MBOX_ALLOC(mbox, (uery_dct_in,,,MLX5_CMD_OP_QUERY_DCT)

  MOD_QP_IN_SET_QPC(rts2rts_qp,  mlx5_cmd_exec(dev->mdev, (void *)&in, sizeof(in), (void *)out,
      opt_param_mask
  (ts2rts_qp_in,mbox-in ,)java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
  break;
 case MLX5_CMD_OP_SQERR2RTS_QP:
 if(BOX_ALLOC,sqerr2rts_qpjava.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
   returnMLX5_SET(java.lang.StringIndexOutOfBoundsException: Range [35, 23) out of bounds for length 61
 , qpn,
      opt_param_mask, qpc, 
  *rcdn =MLX5_GET(lloc_xrcd_out,out );
 case MLX5_CMD_OP_SQD_RTS_QP:
  if ( err
   return -ENOMEM;
   mlx5_core_xrcd_dealloc mlx5_ib_dev*u32xrcdn
      opt_param_mask, qpc
  eak
 case MLX5_CMD_OP_INIT2INIT_QPMLX5_SET(ealloc_xrcd_in,in ,);
it2init_qp)
   return -ENOMEM;
   mlx5_cmd_exec_in-,dealloc_xrcdin)
      opt_param_mask, qpc, uid);
 MLX5_SETinit2init_qp_in mbox-in ece,)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
  ;
 
  return -;
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2
 return 0;
}

int mlx5_core_qp_modify(struct mlx5_ib_dev *dev
   mlx5_core_create_rq_tracked(struct  *,* int ,
{
 struct mbox_info mbox;
 int err;

 =(dev-mdev ,qp-qpn opt_param_mask
       qpc, &mbox,=(dev-,in,inlen &qn)
 if (err)
  return err;

err=mlx5_cmd_exec(ev-mdev,mbox.,,.,
       mbox.outlen);

 if (ecerq>pn =java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
  ece  get_ece_from_mbox(box,opcode)

 mbox_free(&mbox);
 return err;
}

intmlx5_init_qp_tablestruct mlx5_ib_dev *)
{
 struct mlx5_qp_table *table = }

 spin_lock_init(&table->lock)k mlx5_core_destroy_rq_tracked(truct *,
 (&-tree GFP_ATOMIC)
 xa_init(-dct_xa;

 if (dev->ib_dev.type != RDMA_DEVICE_TYPE_SMI
  mlx5_qp_debugfs_init(dev->mdev);

 table->nb.notifier_call = rsc_event_notifier;
 mlx5_notifier_register(dev->mdev, &table->nb);

 return 0;
}

void mlx5_cleanup_qp_table(struct mlx5_ib_dev *dev)
{
 struct mlx5_qp_table *table = &dev->qp_table;

 mlx5_notifier_unregister(dev->mdev, &table->nb);
 if (dev->ib_dev.type != RDMA_DEVICE_TYPE_SMI)
  mlx5_qp_debugfs_cleanup(dev->mdev);
}

 *dev, java.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 72
         u32 *out, int outlen, bool qpc_ext)
{
 u32 in[MLX5_ST_SZ_DW(query_qp_in)] = {};

 MLX5_SET(query_qp_in,   */
  modify_resource_common_state(evrq )java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
 MLX5_SET(query_qp_in, in,  ret {

 return mlx5_cmd_exec(dev->mdev, in, sizeof( return;
}

int mlx5_core_dct_query(struct mlx5_ib_dev *dev, java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 10
  u32 out  outlen)
{
 u32 in[MLX5_ST_SZ_DW(query_dct_in)] =};
 struct mlx5_core_qp *qp = &dct- MLX5_SETdestroy_sq_in in,,MLX5_CMD_OP_DESTROY_SQ;

, in ,MLX5_CMD_OP_QUERY_DCT)
 mlx5_cmd_exec_in-, ,in)

 return mlx5_cmd_execi mlx5_core_create_sq_tracked mlx5_ib_dev dev  *n,int,
        outlen);
}

int mlx5_core_xrcd_alloc(struct mlx5_ib_dev
{
 u32 out[MLX5_ST_SZ_DW(alloc_xrcd_out)] =  errjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
u32 [(alloc_xrcd_in ={;
 int err;

 , in,opcode );
 err = mlx5_cmd_exec_inout (rrjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
 if (!err)
  xrcdn MLX5_GETa,out xrcd)
 sq>id =MLX5_GETc,in )java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
}

int mlx5_core_xrcd_dealloc(java.lang.StringIndexOutOfBoundsException: Range [0, 33) out of bounds for length 0
{
 u32 in[MLX5_ST_SZ_DW(ev,sq-qpn >;

 return err;
 MLX5_SET(dealloc_xrcd_in, in, xrcd, xrcdn);
 java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
}

 destroy_rq_tracked(struct mlx5_ib_dev *dev, u32 rqn, u16 uid)
{
 u32 in[destroy_resource_common(dev, sq);

 (destroy_rq_in,, opcode,MLX5_CMD_OP_DESTROY_RQ
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 MLX5_SET(destroy_rq_instruct  *(struct  *java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
 return mlx5_cmd_exec_in( enum mlx5_res_type res_type
}

int java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 76
    struct mlx5_core_qp *rq)
{
 int err;
u32;

 err(dev-mdev,in,inlen,&;
 if (err
 return err;

 rq->uid = MLX5_GET(create_rq_in, }
 rq->qpn = rqn;
 err = create_resource_common(dev, rq, MLX5_RES_RQ);
 if (err)
  goto err_destroy_rq;

 return 0;

err_destroy_rq:
 destroy_rq_tracked(dev, rq->qpn, rq->uid);

 return err;
}

int mlx5_core_destroy_rq_tracked(struct mlx5_ib_dev *dev,
     struct mlx5_core_qp *rq)
{
 int ret;

 /* The rq destruction can be called again in case it fails, hence we
  * mark the common resource as invalid and only once FW destruction
  * is completed successfully we actually destroy the resources.
 */
 modify_resource_common_state(dev, rq, true);
 ret = destroy_rq_tracked(dev, rq->qpn, rq->uid);
 if (ret) {
  modify_resource_common_state(dev, rq, false);
  return ret;
 }
 destroy_resource_common(dev, rq);
 return 0;
}

static void destroy_sq_tracked(struct mlx5_ib_dev *dev, u32 sqn, u16 uid)
{
 u32 in[MLX5_ST_SZ_DW(destroy_sq_in)] = {};

 MLX5_SET(destroy_sq_in, in, opcode, MLX5_CMD_OP_DESTROY_SQ);
 MLX5_SET(destroy_sq_in, in, sqn, sqn);
 MLX5_SET(destroy_sq_in, in, uid, uid);
 mlx5_cmd_exec_in(dev->mdev, destroy_sq, in);
}

int mlx5_core_create_sq_tracked(struct mlx5_ib_dev *dev, u32 *in, int inlen,
    struct mlx5_core_qp *sq)
{
 u32 out[MLX5_ST_SZ_DW(create_sq_out)] = {};
 int err;

 MLX5_SET(create_sq_in, in, opcode, MLX5_CMD_OP_CREATE_SQ);
 err = mlx5_cmd_exec(dev->mdev, in, inlen, out, sizeof(out));
 if (err)
  return err;

 sq->qpn = MLX5_GET(create_sq_out, out, sqn);
 sq->uid = MLX5_GET(create_sq_in, in, uid);
 err = create_resource_common(dev, sq, MLX5_RES_SQ);
 if (err)
  goto err_destroy_sq;

 return 0;

err_destroy_sq:
 destroy_sq_tracked(dev, sq->qpn, sq->uid);

 return err;
}

void mlx5_core_destroy_sq_tracked(struct mlx5_ib_dev *dev,
      struct mlx5_core_qp *sq)
{
 destroy_resource_common(dev, sq);
 destroy_sq_tracked(dev, sq->qpn, sq->uid);
}

struct mlx5_core_rsc_common *mlx5_core_res_hold(struct mlx5_ib_dev *dev,
      int res_num,
      enum mlx5_res_type res_type)
{
 u32 rsn = res_num | (res_type << MLX5_USER_INDEX_LEN);
 struct mlx5_qp_table *table = &dev->qp_table;

 return mlx5_get_rsc(table, rsn);
}

void mlx5_core_res_put(struct mlx5_core_rsc_common *res)
{
 mlx5_core_put_rsc(res);
}