/*
 * Copyright (c) 2016-2017 Hisilicon Limited.
 *
 * This software is available to you under a choice of one of two
 * licenses.  You may choose to be licensed under the terms of the GNU
 * General Public License (GPL) Version 2, available from the file
 * COPYING in the main directory of this source tree, or the
 * OpenIB.org BSD license below:
 *
 *     Redistribution and use in source and binary forms, with or
 *     without modification, are permitted provided that the following
 *     conditions are met:
 *
 *      - Redistributions of source code must retain the above
 *        copyright notice, this list of conditions and the following
 *        disclaimer.
 *
 *      - Redistributions in binary form must reproduce the above
 *        copyright notice, this list of conditions and the following
 *        disclaimer in the documentation and/or other materials
 *        provided with the distribution.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */

#include <linux/acpi.h>
#include <linux/etherdevice.h>
#include <linux/interrupt.h>
#include <linux/kernel.h>
#include <linux/types.h>
#include <net/addrconf.h>
#include <rdma/ib_addr.h>
#include <rdma/ib_cache.h>
#include <rdma/ib_umem.h>
#include <rdma/uverbs_ioctl.h>

#include "hnae3.h"
#include "hns_roce_common.h"
#include "hns_roce_device.h"
#include "hns_roce_cmd.h"
#include "hns_roce_hem.h"
#include "hns_roce_hw_v2.h"

enum {
        CMD_RST_PRC_OTHERS,
        CMD_RST_PRC_SUCCESS,
        CMD_RST_PRC_EBUSY,
};

static inline void set_data_seg_v2(struct hns_roce_v2_wqe_data_seg *dseg,
                                   struct ib_sge *sg)
{
        dseg->lkey = cpu_to_le32(sg->lkey);
        dseg->addr = cpu_to_le64(sg->addr);
        dseg->len  = cpu_to_le32(sg->length);
}

/*
 * mapped-value = 1 + real-value
 * The hns wr opcode real value is start from 0, In order to distinguish between
 * initialized and uninitialized map values, we plus 1 to the actual value when
 * defining the mapping, so that the validity can be identified by checking the
 * mapped value is greater than 0.
 */
#define HR_OPC_MAP(ib_key, hr_key) \
                [IB_WR_ ## ib_key] = 1 + HNS_ROCE_V2_WQE_OP_ ## hr_key

static const u32 hns_roce_op_code[] = {
        HR_OPC_MAP(RDMA_WRITE,                  RDMA_WRITE),
        HR_OPC_MAP(RDMA_WRITE_WITH_IMM,         RDMA_WRITE_WITH_IMM),
        HR_OPC_MAP(SEND,                        SEND),
        HR_OPC_MAP(SEND_WITH_IMM,               SEND_WITH_IMM),
        HR_OPC_MAP(RDMA_READ,                   RDMA_READ),
        HR_OPC_MAP(ATOMIC_CMP_AND_SWP,          ATOM_CMP_AND_SWAP),
        HR_OPC_MAP(ATOMIC_FETCH_AND_ADD,        ATOM_FETCH_AND_ADD),
        HR_OPC_MAP(SEND_WITH_INV,               SEND_WITH_INV),
        HR_OPC_MAP(LOCAL_INV,                   LOCAL_INV),
        HR_OPC_MAP(MASKED_ATOMIC_CMP_AND_SWP,   ATOM_MSK_CMP_AND_SWAP),
        HR_OPC_MAP(MASKED_ATOMIC_FETCH_AND_ADD, ATOM_MSK_FETCH_AND_ADD),
        HR_OPC_MAP(REG_MR,                      FAST_REG_PMR),
};

static u32 to_hr_opcode(u32 ib_opcode)
{
        if (ib_opcode >= ARRAY_SIZE(hns_roce_op_code))
                return HNS_ROCE_V2_WQE_OP_MASK;

        return hns_roce_op_code[ib_opcode] ? hns_roce_op_code[ib_opcode] - 1 :
                                             HNS_ROCE_V2_WQE_OP_MASK;
}

static void set_frmr_seg(struct hns_roce_v2_rc_send_wqe *rc_sq_wqe,
                         const struct ib_reg_wr *wr)
{
        struct hns_roce_wqe_frmr_seg *fseg =
                (void *)rc_sq_wqe + sizeof(struct hns_roce_v2_rc_send_wqe);
        struct hns_roce_mr *mr = to_hr_mr(wr->mr);
        u64 pbl_ba;

        /* use ib_access_flags */
        hr_reg_write_bool(fseg, FRMR_BIND_EN, wr->access & IB_ACCESS_MW_BIND);
        hr_reg_write_bool(fseg, FRMR_ATOMIC,
                          wr->access & IB_ACCESS_REMOTE_ATOMIC);
        hr_reg_write_bool(fseg, FRMR_RR, wr->access & IB_ACCESS_REMOTE_READ);
        hr_reg_write_bool(fseg, FRMR_RW, wr->access & IB_ACCESS_REMOTE_WRITE);
        hr_reg_write_bool(fseg, FRMR_LW, wr->access & IB_ACCESS_LOCAL_WRITE);

        /* Data structure reuse may lead to confusion */
        pbl_ba = mr->pbl_mtr.hem_cfg.root_ba;
        rc_sq_wqe->msg_len = cpu_to_le32(lower_32_bits(pbl_ba));
        rc_sq_wqe->inv_key = cpu_to_le32(upper_32_bits(pbl_ba));

        rc_sq_wqe->byte_16 = cpu_to_le32(wr->mr->length & 0xffffffff);
        rc_sq_wqe->byte_20 = cpu_to_le32(wr->mr->length >> 32);
        rc_sq_wqe->rkey = cpu_to_le32(wr->key);
        rc_sq_wqe->va = cpu_to_le64(wr->mr->iova);

        hr_reg_write(fseg, FRMR_PBL_SIZE, mr->npages);
        hr_reg_write(fseg, FRMR_PBL_BUF_PG_SZ,
                     to_hr_hw_page_shift(mr->pbl_mtr.hem_cfg.buf_pg_shift));
        hr_reg_clear(fseg, FRMR_BLK_MODE);
}

static void set_atomic_seg(const struct ib_send_wr *wr,
                           struct hns_roce_v2_rc_send_wqe *rc_sq_wqe,
                           unsigned int valid_num_sge)
{
        struct hns_roce_v2_wqe_data_seg *dseg =
                (void *)rc_sq_wqe + sizeof(struct hns_roce_v2_rc_send_wqe);
        struct hns_roce_wqe_atomic_seg *aseg =
                (void *)dseg + sizeof(struct hns_roce_v2_wqe_data_seg);

        set_data_seg_v2(dseg, wr->sg_list);

        if (wr->opcode == IB_WR_ATOMIC_CMP_AND_SWP) {
                aseg->fetchadd_swap_data = cpu_to_le64(atomic_wr(wr)->swap);
                aseg->cmp_data = cpu_to_le64(atomic_wr(wr)->compare_add);
        } else {
                aseg->fetchadd_swap_data =
                        cpu_to_le64(atomic_wr(wr)->compare_add);
                aseg->cmp_data = 0;
        }

        roce_set_field(rc_sq_wqe->byte_16, V2_RC_SEND_WQE_BYTE_16_SGE_NUM_M,
                       V2_RC_SEND_WQE_BYTE_16_SGE_NUM_S, valid_num_sge);
}

static int fill_ext_sge_inl_data(struct hns_roce_qp *qp,
                                 const struct ib_send_wr *wr,
                                 unsigned int *sge_idx, u32 msg_len)
{
        struct ib_device *ibdev = &(to_hr_dev(qp->ibqp.device))->ib_dev;
        unsigned int dseg_len = sizeof(struct hns_roce_v2_wqe_data_seg);
        unsigned int ext_sge_sz = qp->sq.max_gs * dseg_len;
        unsigned int left_len_in_pg;
        unsigned int idx = *sge_idx;
        unsigned int i = 0;
        unsigned int len;
        void *addr;
        void *dseg;

        if (msg_len > ext_sge_sz) {
                ibdev_err(ibdev,
                          "no enough extended sge space for inline data.\n");
                return -EINVAL;
        }

        dseg = hns_roce_get_extend_sge(qp, idx & (qp->sge.sge_cnt - 1));
        left_len_in_pg = hr_hw_page_align((uintptr_t)dseg) - (uintptr_t)dseg;
        len = wr->sg_list[0].length;
        addr = (void *)(unsigned long)(wr->sg_list[0].addr);

        /* When copying data to extended sge space, the left length in page may
         * not long enough for current user's sge. So the data should be
         * splited into several parts, one in the first page, and the others in
         * the subsequent pages.
         */
        while (1) {
                if (len <= left_len_in_pg) {
                        memcpy(dseg, addr, len);

                        idx += len / dseg_len;

                        i++;
                        if (i >= wr->num_sge)
                                break;

                        left_len_in_pg -= len;
                        len = wr->sg_list[i].length;
                        addr = (void *)(unsigned long)(wr->sg_list[i].addr);
                        dseg += len;
                } else {
                        memcpy(dseg, addr, left_len_in_pg);

                        len -= left_len_in_pg;
                        addr += left_len_in_pg;
                        idx += left_len_in_pg / dseg_len;
                        dseg = hns_roce_get_extend_sge(qp,
                                                idx & (qp->sge.sge_cnt - 1));
                        left_len_in_pg = 1 << HNS_HW_PAGE_SHIFT;
                }
        }

        *sge_idx = idx;

        return 0;
}

static void set_extend_sge(struct hns_roce_qp *qp, struct ib_sge *sge,
                           unsigned int *sge_ind, unsigned int cnt)
{
        struct hns_roce_v2_wqe_data_seg *dseg;
        unsigned int idx = *sge_ind;

        while (cnt > 0) {
                dseg = hns_roce_get_extend_sge(qp, idx & (qp->sge.sge_cnt - 1));
                if (likely(sge->length)) {
                        set_data_seg_v2(dseg, sge);
                        idx++;
                        cnt--;
                }
                sge++;
        }

        *sge_ind = idx;
}

static bool check_inl_data_len(struct hns_roce_qp *qp, unsigned int len)
{
        struct hns_roce_dev *hr_dev = to_hr_dev(qp->ibqp.device);
        int mtu = ib_mtu_enum_to_int(qp->path_mtu);

        if (len > qp->max_inline_data || len > mtu) {
                ibdev_err(&hr_dev->ib_dev,
                          "invalid length of data, data len = %u, max inline len = %u, path mtu = %d.\n",
                          len, qp->max_inline_data, mtu);
                return false;
        }

        return true;
}

static int set_rc_inl(struct hns_roce_qp *qp, const struct ib_send_wr *wr,
                      struct hns_roce_v2_rc_send_wqe *rc_sq_wqe,
                      unsigned int *sge_idx)
{
        struct hns_roce_dev *hr_dev = to_hr_dev(qp->ibqp.device);
        u32 msg_len = le32_to_cpu(rc_sq_wqe->msg_len);
        struct ib_device *ibdev = &hr_dev->ib_dev;
        unsigned int curr_idx = *sge_idx;
        void *dseg = rc_sq_wqe;
        unsigned int i;
        int ret;

        if (unlikely(wr->opcode == IB_WR_RDMA_READ)) {
                ibdev_err(ibdev, "invalid inline parameters!\n");
                return -EINVAL;
        }

        if (!check_inl_data_len(qp, msg_len))
                return -EINVAL;

        dseg += sizeof(struct hns_roce_v2_rc_send_wqe);

        if (msg_len <= HNS_ROCE_V2_MAX_RC_INL_INN_SZ) {
                roce_set_bit(rc_sq_wqe->byte_20,
                             V2_RC_SEND_WQE_BYTE_20_INL_TYPE_S, 0);

                for (i = 0; i < wr->num_sge; i++) {
                        memcpy(dseg, ((void *)wr->sg_list[i].addr),
                               wr->sg_list[i].length);
                        dseg += wr->sg_list[i].length;
                }
        } else {
                roce_set_bit(rc_sq_wqe->byte_20,
                             V2_RC_SEND_WQE_BYTE_20_INL_TYPE_S, 1);

                ret = fill_ext_sge_inl_data(qp, wr, &curr_idx, msg_len);
                if (ret)
                        return ret;

                roce_set_field(rc_sq_wqe->byte_16,
                               V2_RC_SEND_WQE_BYTE_16_SGE_NUM_M,
                               V2_RC_SEND_WQE_BYTE_16_SGE_NUM_S,
                               curr_idx - *sge_idx);
        }

        *sge_idx = curr_idx;

        return 0;
}

static int set_rwqe_data_seg(struct ib_qp *ibqp, const struct ib_send_wr *wr,
                             struct hns_roce_v2_rc_send_wqe *rc_sq_wqe,
                             unsigned int *sge_ind,
                             unsigned int valid_num_sge)
{
        struct hns_roce_v2_wqe_data_seg *dseg =
                (void *)rc_sq_wqe + sizeof(struct hns_roce_v2_rc_send_wqe);
        struct hns_roce_qp *qp = to_hr_qp(ibqp);
        int j = 0;
        int i;

        roce_set_field(rc_sq_wqe->byte_20,
                       V2_RC_SEND_WQE_BYTE_20_MSG_START_SGE_IDX_M,
                       V2_RC_SEND_WQE_BYTE_20_MSG_START_SGE_IDX_S,
                       (*sge_ind) & (qp->sge.sge_cnt - 1));

        roce_set_bit(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_INLINE_S,
                     !!(wr->send_flags & IB_SEND_INLINE));
        if (wr->send_flags & IB_SEND_INLINE)
                return set_rc_inl(qp, wr, rc_sq_wqe, sge_ind);

        if (valid_num_sge <= HNS_ROCE_SGE_IN_WQE) {
                for (i = 0; i < wr->num_sge; i++) {
                        if (likely(wr->sg_list[i].length)) {
                                set_data_seg_v2(dseg, wr->sg_list + i);
                                dseg++;
                        }
                }
        } else {
                for (i = 0; i < wr->num_sge && j < HNS_ROCE_SGE_IN_WQE; i++) {
                        if (likely(wr->sg_list[i].length)) {
                                set_data_seg_v2(dseg, wr->sg_list + i);
                                dseg++;
                                j++;
                        }
                }

                set_extend_sge(qp, wr->sg_list + i, sge_ind,
                               valid_num_sge - HNS_ROCE_SGE_IN_WQE);
        }

        roce_set_field(rc_sq_wqe->byte_16,
                       V2_RC_SEND_WQE_BYTE_16_SGE_NUM_M,
                       V2_RC_SEND_WQE_BYTE_16_SGE_NUM_S, valid_num_sge);

        return 0;
}

static int check_send_valid(struct hns_roce_dev *hr_dev,
                            struct hns_roce_qp *hr_qp)
{
        struct ib_device *ibdev = &hr_dev->ib_dev;
        struct ib_qp *ibqp = &hr_qp->ibqp;

        if (unlikely(ibqp->qp_type != IB_QPT_RC &&
                     ibqp->qp_type != IB_QPT_GSI &&
                     ibqp->qp_type != IB_QPT_UD)) {
                ibdev_err(ibdev, "Not supported QP(0x%x)type!\n",
                          ibqp->qp_type);
                return -EOPNOTSUPP;
        } else if (unlikely(hr_qp->state == IB_QPS_RESET ||
                   hr_qp->state == IB_QPS_INIT ||
                   hr_qp->state == IB_QPS_RTR)) {
                ibdev_err(ibdev, "failed to post WQE, QP state %u!\n",
                          hr_qp->state);
                return -EINVAL;
        } else if (unlikely(hr_dev->state >= HNS_ROCE_DEVICE_STATE_RST_DOWN)) {
                ibdev_err(ibdev, "failed to post WQE, dev state %d!\n",
                          hr_dev->state);
                return -EIO;
        }

        return 0;
}

static unsigned int calc_wr_sge_num(const struct ib_send_wr *wr,
                                    unsigned int *sge_len)
{
        unsigned int valid_num = 0;
        unsigned int len = 0;
        int i;

        for (i = 0; i < wr->num_sge; i++) {
                if (likely(wr->sg_list[i].length)) {
                        len += wr->sg_list[i].length;
                        valid_num++;
                }
        }

        *sge_len = len;
        return valid_num;
}

static __le32 get_immtdata(const struct ib_send_wr *wr)
{
        switch (wr->opcode) {
        case IB_WR_SEND_WITH_IMM:
        case IB_WR_RDMA_WRITE_WITH_IMM:
                return cpu_to_le32(be32_to_cpu(wr->ex.imm_data));
        default:
                return 0;
        }
}

static int set_ud_opcode(struct hns_roce_v2_ud_send_wqe *ud_sq_wqe,
                         const struct ib_send_wr *wr)
{
        u32 ib_op = wr->opcode;

        if (ib_op != IB_WR_SEND && ib_op != IB_WR_SEND_WITH_IMM)
                return -EINVAL;

        ud_sq_wqe->immtdata = get_immtdata(wr);

        roce_set_field(ud_sq_wqe->byte_4, V2_UD_SEND_WQE_BYTE_4_OPCODE_M,
                       V2_UD_SEND_WQE_BYTE_4_OPCODE_S, to_hr_opcode(ib_op));

        return 0;
}

static int fill_ud_av(struct hns_roce_v2_ud_send_wqe *ud_sq_wqe,
                      struct hns_roce_ah *ah)
{
        struct ib_device *ib_dev = ah->ibah.device;
        struct hns_roce_dev *hr_dev = to_hr_dev(ib_dev);

        roce_set_field(ud_sq_wqe->byte_24, V2_UD_SEND_WQE_BYTE_24_UDPSPN_M,
                       V2_UD_SEND_WQE_BYTE_24_UDPSPN_S, ah->av.udp_sport);

        roce_set_field(ud_sq_wqe->byte_36, V2_UD_SEND_WQE_BYTE_36_HOPLIMIT_M,
                       V2_UD_SEND_WQE_BYTE_36_HOPLIMIT_S, ah->av.hop_limit);
        roce_set_field(ud_sq_wqe->byte_36, V2_UD_SEND_WQE_BYTE_36_TCLASS_M,
                       V2_UD_SEND_WQE_BYTE_36_TCLASS_S, ah->av.tclass);
        roce_set_field(ud_sq_wqe->byte_40, V2_UD_SEND_WQE_BYTE_40_FLOW_LABEL_M,
                       V2_UD_SEND_WQE_BYTE_40_FLOW_LABEL_S, ah->av.flowlabel);

        if (WARN_ON(ah->av.sl > MAX_SERVICE_LEVEL))
                return -EINVAL;

        roce_set_field(ud_sq_wqe->byte_40, V2_UD_SEND_WQE_BYTE_40_SL_M,
                       V2_UD_SEND_WQE_BYTE_40_SL_S, ah->av.sl);

        ud_sq_wqe->sgid_index = ah->av.gid_index;

        memcpy(ud_sq_wqe->dmac, ah->av.mac, ETH_ALEN);
        memcpy(ud_sq_wqe->dgid, ah->av.dgid, GID_LEN_V2);

        if (hr_dev->pci_dev->revision >= PCI_REVISION_ID_HIP09)
                return 0;

        roce_set_bit(ud_sq_wqe->byte_40, V2_UD_SEND_WQE_BYTE_40_UD_VLAN_EN_S,
                     ah->av.vlan_en);
        roce_set_field(ud_sq_wqe->byte_36, V2_UD_SEND_WQE_BYTE_36_VLAN_M,
                       V2_UD_SEND_WQE_BYTE_36_VLAN_S, ah->av.vlan_id);

        return 0;
}

static inline int set_ud_wqe(struct hns_roce_qp *qp,
                             const struct ib_send_wr *wr,
                             void *wqe, unsigned int *sge_idx,
                             unsigned int owner_bit)
{
        struct hns_roce_ah *ah = to_hr_ah(ud_wr(wr)->ah);
        struct hns_roce_v2_ud_send_wqe *ud_sq_wqe = wqe;
        unsigned int curr_idx = *sge_idx;
        unsigned int valid_num_sge;
        u32 msg_len = 0;
        int ret;

        valid_num_sge = calc_wr_sge_num(wr, &msg_len);

        ret = set_ud_opcode(ud_sq_wqe, wr);
        if (WARN_ON(ret))
                return ret;

        ud_sq_wqe->msg_len = cpu_to_le32(msg_len);

        roce_set_bit(ud_sq_wqe->byte_4, V2_UD_SEND_WQE_BYTE_4_CQE_S,
                     !!(wr->send_flags & IB_SEND_SIGNALED));

        roce_set_bit(ud_sq_wqe->byte_4, V2_UD_SEND_WQE_BYTE_4_SE_S,
                     !!(wr->send_flags & IB_SEND_SOLICITED));

        roce_set_field(ud_sq_wqe->byte_16, V2_UD_SEND_WQE_BYTE_16_PD_M,
                       V2_UD_SEND_WQE_BYTE_16_PD_S, to_hr_pd(qp->ibqp.pd)->pdn);

        roce_set_field(ud_sq_wqe->byte_16, V2_UD_SEND_WQE_BYTE_16_SGE_NUM_M,
                       V2_UD_SEND_WQE_BYTE_16_SGE_NUM_S, valid_num_sge);

        roce_set_field(ud_sq_wqe->byte_20,
                       V2_UD_SEND_WQE_BYTE_20_MSG_START_SGE_IDX_M,
                       V2_UD_SEND_WQE_BYTE_20_MSG_START_SGE_IDX_S,
                       curr_idx & (qp->sge.sge_cnt - 1));

        ud_sq_wqe->qkey = cpu_to_le32(ud_wr(wr)->remote_qkey & 0x80000000 ?
                          qp->qkey : ud_wr(wr)->remote_qkey);
        roce_set_field(ud_sq_wqe->byte_32, V2_UD_SEND_WQE_BYTE_32_DQPN_M,
                       V2_UD_SEND_WQE_BYTE_32_DQPN_S, ud_wr(wr)->remote_qpn);

        ret = fill_ud_av(ud_sq_wqe, ah);
        if (ret)
                return ret;

        qp->sl = to_hr_ah(ud_wr(wr)->ah)->av.sl;

        set_extend_sge(qp, wr->sg_list, &curr_idx, valid_num_sge);

        /*
         * The pipeline can sequentially post all valid WQEs into WQ buffer,
         * including new WQEs waiting for the doorbell to update the PI again.
         * Therefore, the owner bit of WQE MUST be updated after all fields
         * and extSGEs have been written into DDR instead of cache.
         */
        if (qp->en_flags & HNS_ROCE_QP_CAP_OWNER_DB)
                dma_wmb();

        *sge_idx = curr_idx;
        roce_set_bit(ud_sq_wqe->byte_4, V2_UD_SEND_WQE_BYTE_4_OWNER_S,
                     owner_bit);

        return 0;
}

static int set_rc_opcode(struct hns_roce_dev *hr_dev,
                         struct hns_roce_v2_rc_send_wqe *rc_sq_wqe,
                         const struct ib_send_wr *wr)
{
        u32 ib_op = wr->opcode;
        int ret = 0;

        rc_sq_wqe->immtdata = get_immtdata(wr);

        switch (ib_op) {
        case IB_WR_RDMA_READ:
        case IB_WR_RDMA_WRITE:
        case IB_WR_RDMA_WRITE_WITH_IMM:
                rc_sq_wqe->rkey = cpu_to_le32(rdma_wr(wr)->rkey);
                rc_sq_wqe->va = cpu_to_le64(rdma_wr(wr)->remote_addr);
                break;
        case IB_WR_SEND:
        case IB_WR_SEND_WITH_IMM:
                break;
        case IB_WR_ATOMIC_CMP_AND_SWP:
        case IB_WR_ATOMIC_FETCH_AND_ADD:
                rc_sq_wqe->rkey = cpu_to_le32(atomic_wr(wr)->rkey);
                rc_sq_wqe->va = cpu_to_le64(atomic_wr(wr)->remote_addr);
                break;
        case IB_WR_REG_MR:
                if (hr_dev->pci_dev->revision >= PCI_REVISION_ID_HIP09)
                        set_frmr_seg(rc_sq_wqe, reg_wr(wr));
                else
                        ret = -EOPNOTSUPP;
                break;
        case IB_WR_LOCAL_INV:
                roce_set_bit(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_SO_S, 1);
                fallthrough;
        case IB_WR_SEND_WITH_INV:
                rc_sq_wqe->inv_key = cpu_to_le32(wr->ex.invalidate_rkey);
                break;
        default:
                ret = -EINVAL;
        }

        if (unlikely(ret))
                return ret;

        roce_set_field(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_OPCODE_M,
                       V2_RC_SEND_WQE_BYTE_4_OPCODE_S, to_hr_opcode(ib_op));

        return ret;
}
static inline int set_rc_wqe(struct hns_roce_qp *qp,
                             const struct ib_send_wr *wr,
                             void *wqe, unsigned int *sge_idx,
                             unsigned int owner_bit)
{
        struct hns_roce_dev *hr_dev = to_hr_dev(qp->ibqp.device);
        struct hns_roce_v2_rc_send_wqe *rc_sq_wqe = wqe;
        unsigned int curr_idx = *sge_idx;
        unsigned int valid_num_sge;
        u32 msg_len = 0;
        int ret;

        valid_num_sge = calc_wr_sge_num(wr, &msg_len);

        rc_sq_wqe->msg_len = cpu_to_le32(msg_len);

        ret = set_rc_opcode(hr_dev, rc_sq_wqe, wr);
        if (WARN_ON(ret))
                return ret;

        roce_set_bit(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_FENCE_S,
                     (wr->send_flags & IB_SEND_FENCE) ? 1 : 0);

        roce_set_bit(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_SE_S,
                     (wr->send_flags & IB_SEND_SOLICITED) ? 1 : 0);

        roce_set_bit(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_CQE_S,
                     (wr->send_flags & IB_SEND_SIGNALED) ? 1 : 0);

        if (wr->opcode == IB_WR_ATOMIC_CMP_AND_SWP ||
            wr->opcode == IB_WR_ATOMIC_FETCH_AND_ADD)
                set_atomic_seg(wr, rc_sq_wqe, valid_num_sge);
        else if (wr->opcode != IB_WR_REG_MR)
                ret = set_rwqe_data_seg(&qp->ibqp, wr, rc_sq_wqe,
                                        &curr_idx, valid_num_sge);

        /*
         * The pipeline can sequentially post all valid WQEs into WQ buffer,
         * including new WQEs waiting for the doorbell to update the PI again.
         * Therefore, the owner bit of WQE MUST be updated after all fields
         * and extSGEs have been written into DDR instead of cache.
         */
        if (qp->en_flags & HNS_ROCE_QP_CAP_OWNER_DB)
                dma_wmb();

        *sge_idx = curr_idx;
        roce_set_bit(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_OWNER_S,
                     owner_bit);

        return ret;
}

static inline void update_sq_db(struct hns_roce_dev *hr_dev,
                                struct hns_roce_qp *qp)
{
        if (unlikely(qp->state == IB_QPS_ERR)) {
                flush_cqe(hr_dev, qp);
        } else {
                struct hns_roce_v2_db sq_db = {};

                hr_reg_write(&sq_db, DB_TAG, qp->doorbell_qpn);
                hr_reg_write(&sq_db, DB_CMD, HNS_ROCE_V2_SQ_DB);
                hr_reg_write(&sq_db, DB_PI, qp->sq.head);
                hr_reg_write(&sq_db, DB_SL, qp->sl);

                hns_roce_write64(hr_dev, (__le32 *)&sq_db, qp->sq.db_reg);
        }
}

static inline void update_rq_db(struct hns_roce_dev *hr_dev,
                                struct hns_roce_qp *qp)
{
        if (unlikely(qp->state == IB_QPS_ERR)) {
                flush_cqe(hr_dev, qp);
        } else {
                if (likely(qp->en_flags & HNS_ROCE_QP_CAP_RQ_RECORD_DB)) {
                        *qp->rdb.db_record =
                                        qp->rq.head & V2_DB_PRODUCER_IDX_M;
                } else {
                        struct hns_roce_v2_db rq_db = {};

                        hr_reg_write(&rq_db, DB_TAG, qp->qpn);
                        hr_reg_write(&rq_db, DB_CMD, HNS_ROCE_V2_RQ_DB);
                        hr_reg_write(&rq_db, DB_PI, qp->rq.head);

                        hns_roce_write64(hr_dev, (__le32 *)&rq_db,
                                         qp->rq.db_reg);
                }
        }
}

static void hns_roce_write512(struct hns_roce_dev *hr_dev, u64 *val,
                              u64 __iomem *dest)
{
#define HNS_ROCE_WRITE_TIMES 8
        struct hns_roce_v2_priv *priv = (struct hns_roce_v2_priv *)hr_dev->priv;
        struct hnae3_handle *handle = priv->handle;
        const struct hnae3_ae_ops *ops = handle->ae_algo->ops;
        int i;

        if (!hr_dev->dis_db && !ops->get_hw_reset_stat(handle))
                for (i = 0; i < HNS_ROCE_WRITE_TIMES; i++)
                        writeq_relaxed(*(val + i), dest + i);
}

static void write_dwqe(struct hns_roce_dev *hr_dev, struct hns_roce_qp *qp,
                       void *wqe)
{
        struct hns_roce_v2_rc_send_wqe *rc_sq_wqe = wqe;

        /* All kinds of DirectWQE have the same header field layout */
        roce_set_bit(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_FLAG_S, 1);
        roce_set_field(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_DB_SL_L_M,
                       V2_RC_SEND_WQE_BYTE_4_DB_SL_L_S, qp->sl);
        roce_set_field(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_DB_SL_H_M,
                       V2_RC_SEND_WQE_BYTE_4_DB_SL_H_S, qp->sl >> 2);
        roce_set_field(rc_sq_wqe->byte_4, V2_RC_SEND_WQE_BYTE_4_WQE_INDEX_M,
                       V2_RC_SEND_WQE_BYTE_4_WQE_INDEX_S, qp->sq.head);

        hns_roce_write512(hr_dev, wqe, qp->sq.db_reg);
}

static int hns_roce_v2_post_send(struct ib_qp *ibqp,
                                 const struct ib_send_wr *wr,
                                 const struct ib_send_wr **bad_wr)
{
        struct hns_roce_dev *hr_dev = to_hr_dev(ibqp->device);
        struct ib_device *ibdev = &hr_dev->ib_dev;
        struct hns_roce_qp *qp = to_hr_qp(ibqp);
        unsigned long flags = 0;
        unsigned int owner_bit;
        unsigned int sge_idx;
        unsigned int wqe_idx;
        void *wqe = NULL;
        u32 nreq;
        int ret;

        spin_lock_irqsave(&qp->sq.lock, flags);

        ret = check_send_valid(hr_dev, qp);
        if (unlikely(ret)) {
                *bad_wr = wr;
                nreq = 0;
                goto out;
        }

        sge_idx = qp->next_sge;

        for (nreq = 0; wr; ++nreq, wr = wr->next) {
                if (hns_roce_wq_overflow(&qp->sq, nreq, qp->ibqp.send_cq)) {
                        ret = -ENOMEM;
                        *bad_wr = wr;
                        goto out;
                }

                wqe_idx = (qp->sq.head + nreq) & (qp->sq.wqe_cnt - 1);

                if (unlikely(wr->num_sge > qp->sq.max_gs)) {
                        ibdev_err(ibdev, "num_sge = %d > qp->sq.max_gs = %u.\n",
                                  wr->num_sge, qp->sq.max_gs);
                        ret = -EINVAL;
                        *bad_wr = wr;
                        goto out;
                }

                wqe = hns_roce_get_send_wqe(qp, wqe_idx);
                qp->sq.wrid[wqe_idx] = wr->wr_id;
                owner_bit =
                       ~(((qp->sq.head + nreq) >> ilog2(qp->sq.wqe_cnt)) & 0x1);

                /* Corresponding to the QP type, wqe process separately */
                if (ibqp->qp_type == IB_QPT_RC)
                        ret = set_rc_wqe(qp, wr, wqe, &sge_idx, owner_bit);
                else
                        ret = set_ud_wqe(qp, wr, wqe, &sge_idx, owner_bit);

                if (unlikely(ret)) {
                        *bad_wr = wr;
                        goto out;
                }
        }

out:
        if (likely(nreq)) {
                qp->sq.head += nreq;
                qp->next_sge = sge_idx;

                if (nreq == 1 && (qp->en_flags & HNS_ROCE_QP_CAP_DIRECT_WQE))
                        write_dwqe(hr_dev, qp, wqe);
                else
                        update_sq_db(hr_dev, qp);
        }

        spin_unlock_irqrestore(&qp->sq.lock, flags);

        return ret;
}

static int check_recv_valid(struct hns_roce_dev *hr_dev,
                            struct hns_roce_qp *hr_qp)
{
        struct ib_device *ibdev = &hr_dev->ib_dev;
        struct ib_qp *ibqp = &hr_qp->ibqp;

        if (unlikely(ibqp->qp_type != IB_QPT_RC &&
                     ibqp->qp_type != IB_QPT_GSI &&
                     ibqp->qp_type != IB_QPT_UD)) {
                ibdev_err(ibdev, "unsupported qp type, qp_type = %d.\n",
                          ibqp->qp_type);
                return -EOPNOTSUPP;
        }

        if (unlikely(hr_dev->state >= HNS_ROCE_DEVICE_STATE_RST_DOWN))
                return -EIO;

        if (hr_qp->state == IB_QPS_RESET)
                return -EINVAL;

        return 0;
}

static void fill_recv_sge_to_wqe(const struct ib_recv_wr *wr, void *wqe,
                                 u32 max_sge, bool rsv)
{
        struct hns_roce_v2_wqe_data_seg *dseg = wqe;
        u32 i, cnt;

        for (i = 0, cnt = 0; i < wr->num_sge; i++) {
                /* Skip zero-length sge */
                if (!wr->sg_list[i].length)
                        continue;
                set_data_seg_v2(dseg + cnt, wr->sg_list + i);
                cnt++;
        }

        /* Fill a reserved sge to make hw stop reading remaining segments */
        if (rsv) {
                dseg[cnt].lkey = cpu_to_le32(HNS_ROCE_INVALID_LKEY);
                dseg[cnt].addr = 0;
                dseg[cnt].len = cpu_to_le32(HNS_ROCE_INVALID_SGE_LENGTH);
        } else {
                /* Clear remaining segments to make ROCEE ignore sges */
                if (cnt < max_sge)
                        memset(dseg + cnt, 0,
                               (max_sge - cnt) * HNS_ROCE_SGE_SIZE);
        }
}

static void fill_rq_wqe(struct hns_roce_qp *hr_qp, const struct ib_recv_wr *wr,
                        u32 wqe_idx, u32 max_sge)
{
        struct hns_roce_rinl_sge *sge_list;
        void *wqe = NULL;
        u32 i;

        wqe = hns_roce_get_recv_wqe(hr_qp, wqe_idx);
        fill_recv_sge_to_wqe(wr, wqe, max_sge, hr_qp->rq.rsv_sge);

        /* rq support inline data */
        if (hr_qp->rq_inl_buf.wqe_cnt) {
                sge_list = hr_qp->rq_inl_buf.wqe_list[wqe_idx].sg_list;
                hr_qp->rq_inl_buf.wqe_list[wqe_idx].sge_cnt = (u32)wr->num_sge;
                for (i = 0; i < wr->num_sge; i++) {
                        sge_list[i].addr = (void *)(u64)wr->sg_list[i].addr;
                        sge_list[i].len = wr->sg_list[i].length;
                }
        }
}

static int hns_roce_v2_post_recv(struct ib_qp *ibqp,
                                 const struct ib_recv_wr *wr,
                                 const struct ib_recv_wr **bad_wr)
{
        struct hns_roce_dev *hr_dev = to_hr_dev(ibqp->device);
        struct hns_roce_qp *hr_qp = to_hr_qp(ibqp);
        struct ib_device *ibdev = &hr_dev->ib_dev;
        u32 wqe_idx, nreq, max_sge;
        unsigned long flags;
        int ret;

        spin_lock_irqsave(&hr_qp->rq.lock, flags);

        ret = check_recv_valid(hr_dev, hr_qp);
        if (unlikely(ret)) {
                *bad_wr = wr;
                nreq = 0;
                goto out;
        }

        max_sge = hr_qp->rq.max_gs - hr_qp->rq.rsv_sge;
        for (nreq = 0; wr; ++nreq, wr = wr->next) {
                if (unlikely(hns_roce_wq_overflow(&hr_qp->rq, nreq,
                                                  hr_qp->ibqp.recv_cq))) {
                        ret = -ENOMEM;
                        *bad_wr = wr;
                        goto out;
                }

                if (unlikely(wr->num_sge > max_sge)) {
                        ibdev_err(ibdev, "num_sge = %d >= max_sge = %u.\n",
                                  wr->num_sge, max_sge);
                        ret = -EINVAL;
                        *bad_wr = wr;
                        goto out;
                }

                wqe_idx = (hr_qp->rq.head + nreq) & (hr_qp->rq.wqe_cnt - 1);
                fill_rq_wqe(hr_qp, wr, wqe_idx, max_sge);
                hr_qp->rq.wrid[wqe_idx] = wr->wr_id;
        }

out:
        if (likely(nreq)) {
                hr_qp->rq.head += nreq;

                update_rq_db(hr_dev, hr_qp);
        }
        spin_unlock_irqrestore(&hr_qp->rq.lock, flags);

        return ret;
}

static void *get_srq_wqe_buf(struct hns_roce_srq *srq, u32 n)
{
        return hns_roce_buf_offset(srq->buf_mtr.kmem, n << srq->wqe_shift);
}

static void *get_idx_buf(struct hns_roce_idx_que *idx_que, u32 n)
{
        return hns_roce_buf_offset(idx_que->mtr.kmem,
                                   n << idx_que->entry_shift);
}

static void hns_roce_free_srq_wqe(struct hns_roce_srq *srq, u32 wqe_index)
{
        /* always called with interrupts disabled. */
        spin_lock(&srq->lock);

        bitmap_clear(srq->idx_que.bitmap, wqe_index, 1);
        srq->idx_que.tail++;

        spin_unlock(&srq->lock);
}

static int hns_roce_srqwq_overflow(struct hns_roce_srq *srq)
{
        struct hns_roce_idx_que *idx_que = &srq->idx_que;

        return idx_que->head - idx_que->tail >= srq->wqe_cnt;
}

static int check_post_srq_valid(struct hns_roce_srq *srq, u32 max_sge,
                                const struct ib_recv_wr *wr)
{
        struct ib_device *ib_dev = srq->ibsrq.device;

        if (unlikely(wr->num_sge > max_sge)) {
                ibdev_err(ib_dev,
                          "failed to check sge, wr->num_sge = %d, max_sge = %u.\n",
                          wr->num_sge, max_sge);
                return -EINVAL;
        }

        if (unlikely(hns_roce_srqwq_overflow(srq))) {
                ibdev_err(ib_dev,
                          "failed to check srqwq status, srqwq is full.\n");
                return -ENOMEM;
        }

        return 0;
}

static int get_srq_wqe_idx(struct hns_roce_srq *srq, u32 *wqe_idx)
{
        struct hns_roce_idx_que *idx_que = &srq->idx_que;
        u32 pos;

        pos = find_first_zero_bit(idx_que->bitmap, srq->wqe_cnt);
        if (unlikely(pos == srq->wqe_cnt))
                return -ENOSPC;

        bitmap_set(idx_que->bitmap, pos, 1);
        *wqe_idx = pos;
        return 0;
}

static void fill_wqe_idx(struct hns_roce_srq *srq, unsigned int wqe_idx)
{
        struct hns_roce_idx_que *idx_que = &srq->idx_que;
        unsigned int head;
        __le32 *buf;

        head = idx_que->head & (srq->wqe_cnt - 1);

        buf = get_idx_buf(idx_que, head);
        *buf = cpu_to_le32(wqe_idx);

        idx_que->head++;
}

static void update_srq_db(struct hns_roce_v2_db *db, struct hns_roce_srq *srq)
{
        hr_reg_write(db, DB_TAG, srq->srqn);
        hr_reg_write(db, DB_CMD, HNS_ROCE_V2_SRQ_DB);
        hr_reg_write(db, DB_PI, srq->idx_que.head);
}

static int hns_roce_v2_post_srq_recv(struct ib_srq *ibsrq,
                                     const struct ib_recv_wr *wr,
                                     const struct ib_recv_wr **bad_wr)
{
        struct hns_roce_dev *hr_dev = to_hr_dev(ibsrq->device);
        struct hns_roce_srq *srq = to_hr_srq(ibsrq);
        struct hns_roce_v2_db srq_db;
        unsigned long flags;
        int ret = 0;
        u32 max_sge;
        u32 wqe_idx;
        void *wqe;
        u32 nreq;

        spin_lock_irqsave(&srq->lock, flags);

        max_sge = srq->max_gs - srq->rsv_sge;
        for (nreq = 0; wr; ++nreq, wr = wr->next) {
                ret = check_post_srq_valid(srq, max_sge, wr);
                if (ret) {
                        *bad_wr = wr;
                        break;

                }

                ret = get_srq_wqe_idx(srq, &wqe_idx);
                if (unlikely(ret)) {
                        *bad_wr = wr;
                        break;
                }

                wqe = get_srq_wqe_buf(srq, wqe_idx);
                fill_recv_sge_to_wqe(wr, wqe, max_sge, srq->rsv_sge);
                fill_wqe_idx(srq, wqe_idx);
                srq->wrid[wqe_idx] = wr->wr_id;
        }

        if (likely(nreq)) {
                update_srq_db(&srq_db, srq);

                hns_roce_write64(hr_dev, (__le32 *)&srq_db, srq->db_reg);
        }

        spin_unlock_irqrestore(&srq->lock, flags);

        return ret;
}

static u32 hns_roce_v2_cmd_hw_reseted(struct hns_roce_dev *hr_dev,
                                      unsigned long instance_stage,
                                      unsigned long reset_stage)
{
        /* When hardware reset has been completed once or more, we should stop
         * sending mailbox&cmq&doorbell to hardware. If now in .init_instance()
         * function, we should exit with error. If now at HNAE3_INIT_CLIENT
         * stage of soft reset process, we should exit with error, and then
         * HNAE3_INIT_CLIENT related process can rollback the operation like
         * notifing hardware to free resources, HNAE3_INIT_CLIENT related
         * process will exit with error to notify NIC driver to reschedule soft
         * reset process once again.
         */
        hr_dev->is_reset = true;
        hr_dev->dis_db = true;

        if (reset_stage == HNS_ROCE_STATE_RST_INIT ||
            instance_stage == HNS_ROCE_STATE_INIT)
                return CMD_RST_PRC_EBUSY;

        return CMD_RST_PRC_SUCCESS;
}

static u32 hns_roce_v2_cmd_hw_resetting(struct hns_roce_dev *hr_dev,
                                        unsigned long instance_stage,
                                        unsigned long reset_stage)
{
        struct hns_roce_v2_priv *priv = hr_dev->priv;
        struct hnae3_handle *handle = priv->handle;
        const struct hnae3_ae_ops *ops = handle->ae_algo->ops;

        /* When hardware reset is detected, we should stop sending mailbox&cmq&
         * doorbell to hardware. If now in .init_instance() function, we should
         * exit with error. If now at HNAE3_INIT_CLIENT stage of soft reset
         * process, we should exit with error, and then HNAE3_INIT_CLIENT
         * related process can rollback the operation like notifing hardware to
         * free resources, HNAE3_INIT_CLIENT related process will exit with
         * error to notify NIC driver to reschedule soft reset process once
         * again.
         */
        hr_dev->dis_db = true;
        if (!ops->get_hw_reset_stat(handle))
                hr_dev->is_reset = true;

        if (!hr_dev->is_reset || reset_stage == HNS_ROCE_STATE_RST_INIT ||
            instance_stage == HNS_ROCE_STATE_INIT)
                return CMD_RST_PRC_EBUSY;

        return CMD_RST_PRC_SUCCESS;
}

static u32 hns_roce_v2_cmd_sw_resetting(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_v2_priv *priv = hr_dev->priv;
        struct hnae3_handle *handle = priv->handle;
        const struct hnae3_ae_ops *ops = handle->ae_algo->ops;

        /* When software reset is detected at .init_instance() function, we
         * should stop sending mailbox&cmq&doorbell to hardware, and exit
         * with error.
         */
        hr_dev->dis_db = true;
        if (ops->ae_dev_reset_cnt(handle) != hr_dev->reset_cnt)
                hr_dev->is_reset = true;

        return CMD_RST_PRC_EBUSY;
}

static u32 check_aedev_reset_status(struct hns_roce_dev *hr_dev,
                                    struct hnae3_handle *handle)
{
        const struct hnae3_ae_ops *ops = handle->ae_algo->ops;
        unsigned long instance_stage; /* the current instance stage */
        unsigned long reset_stage; /* the current reset stage */
        unsigned long reset_cnt;
        bool sw_resetting;
        bool hw_resetting;

        /* Get information about reset from NIC driver or RoCE driver itself,
         * the meaning of the following variables from NIC driver are described
         * as below:
         * reset_cnt -- The count value of completed hardware reset.
         * hw_resetting -- Whether hardware device is resetting now.
         * sw_resetting -- Whether NIC's software reset process is running now.
         */
        instance_stage = handle->rinfo.instance_state;
        reset_stage = handle->rinfo.reset_state;
        reset_cnt = ops->ae_dev_reset_cnt(handle);
        if (reset_cnt != hr_dev->reset_cnt)
                return hns_roce_v2_cmd_hw_reseted(hr_dev, instance_stage,
                                                  reset_stage);

        hw_resetting = ops->get_cmdq_stat(handle);
        if (hw_resetting)
                return hns_roce_v2_cmd_hw_resetting(hr_dev, instance_stage,
                                                    reset_stage);

        sw_resetting = ops->ae_dev_resetting(handle);
        if (sw_resetting && instance_stage == HNS_ROCE_STATE_INIT)
                return hns_roce_v2_cmd_sw_resetting(hr_dev);

        return CMD_RST_PRC_OTHERS;
}

static bool check_device_is_in_reset(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_v2_priv *priv = hr_dev->priv;
        struct hnae3_handle *handle = priv->handle;
        const struct hnae3_ae_ops *ops = handle->ae_algo->ops;

        if (hr_dev->reset_cnt != ops->ae_dev_reset_cnt(handle))
                return true;

        if (ops->get_hw_reset_stat(handle))
                return true;

        if (ops->ae_dev_resetting(handle))
                return true;

        return false;
}

static bool v2_chk_mbox_is_avail(struct hns_roce_dev *hr_dev, bool *busy)
{
        struct hns_roce_v2_priv *priv = hr_dev->priv;
        u32 status;

        if (hr_dev->is_reset)
                status = CMD_RST_PRC_SUCCESS;
        else
                status = check_aedev_reset_status(hr_dev, priv->handle);

        *busy = (status == CMD_RST_PRC_EBUSY);

        return status == CMD_RST_PRC_OTHERS;
}

static int hns_roce_alloc_cmq_desc(struct hns_roce_dev *hr_dev,
                                   struct hns_roce_v2_cmq_ring *ring)
{
        int size = ring->desc_num * sizeof(struct hns_roce_cmq_desc);

        ring->desc = kzalloc(size, GFP_KERNEL);
        if (!ring->desc)
                return -ENOMEM;

        ring->desc_dma_addr = dma_map_single(hr_dev->dev, ring->desc, size,
                                             DMA_BIDIRECTIONAL);
        if (dma_mapping_error(hr_dev->dev, ring->desc_dma_addr)) {
                ring->desc_dma_addr = 0;
                kfree(ring->desc);
                ring->desc = NULL;

                return -ENOMEM;
        }

        return 0;
}

static void hns_roce_free_cmq_desc(struct hns_roce_dev *hr_dev,
                                   struct hns_roce_v2_cmq_ring *ring)
{
        dma_unmap_single(hr_dev->dev, ring->desc_dma_addr,
                         ring->desc_num * sizeof(struct hns_roce_cmq_desc),
                         DMA_BIDIRECTIONAL);

        ring->desc_dma_addr = 0;
        kfree(ring->desc);
}

static int init_csq(struct hns_roce_dev *hr_dev,
                    struct hns_roce_v2_cmq_ring *csq)
{
        dma_addr_t dma;
        int ret;

        csq->desc_num = CMD_CSQ_DESC_NUM;
        spin_lock_init(&csq->lock);
        csq->flag = TYPE_CSQ;
        csq->head = 0;

        ret = hns_roce_alloc_cmq_desc(hr_dev, csq);
        if (ret)
                return ret;

        dma = csq->desc_dma_addr;
        roce_write(hr_dev, ROCEE_TX_CMQ_BASEADDR_L_REG, lower_32_bits(dma));
        roce_write(hr_dev, ROCEE_TX_CMQ_BASEADDR_H_REG, upper_32_bits(dma));
        roce_write(hr_dev, ROCEE_TX_CMQ_DEPTH_REG,
                   (u32)csq->desc_num >> HNS_ROCE_CMQ_DESC_NUM_S);

        /* Make sure to write CI first and then PI */
        roce_write(hr_dev, ROCEE_TX_CMQ_CI_REG, 0);
        roce_write(hr_dev, ROCEE_TX_CMQ_PI_REG, 0);

        return 0;
}

static int hns_roce_v2_cmq_init(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_v2_priv *priv = hr_dev->priv;
        int ret;

        priv->cmq.tx_timeout = HNS_ROCE_CMQ_TX_TIMEOUT;

        ret = init_csq(hr_dev, &priv->cmq.csq);
        if (ret)
                dev_err(hr_dev->dev, "failed to init CSQ, ret = %d.\n", ret);

        return ret;
}

static void hns_roce_v2_cmq_exit(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_v2_priv *priv = hr_dev->priv;

        hns_roce_free_cmq_desc(hr_dev, &priv->cmq.csq);
}

static void hns_roce_cmq_setup_basic_desc(struct hns_roce_cmq_desc *desc,
                                          enum hns_roce_opcode_type opcode,
                                          bool is_read)
{
        memset((void *)desc, 0, sizeof(struct hns_roce_cmq_desc));
        desc->opcode = cpu_to_le16(opcode);
        desc->flag =
                cpu_to_le16(HNS_ROCE_CMD_FLAG_NO_INTR | HNS_ROCE_CMD_FLAG_IN);
        if (is_read)
                desc->flag |= cpu_to_le16(HNS_ROCE_CMD_FLAG_WR);
        else
                desc->flag &= cpu_to_le16(~HNS_ROCE_CMD_FLAG_WR);
}

static int hns_roce_cmq_csq_done(struct hns_roce_dev *hr_dev)
{
        u32 tail = roce_read(hr_dev, ROCEE_TX_CMQ_CI_REG);
        struct hns_roce_v2_priv *priv = hr_dev->priv;

        return tail == priv->cmq.csq.head;
}

static int __hns_roce_cmq_send(struct hns_roce_dev *hr_dev,
                               struct hns_roce_cmq_desc *desc, int num)
{
        struct hns_roce_v2_priv *priv = hr_dev->priv;
        struct hns_roce_v2_cmq_ring *csq = &priv->cmq.csq;
        u32 timeout = 0;
        u16 desc_ret;
        u32 tail;
        int ret;
        int i;

        spin_lock_bh(&csq->lock);

        tail = csq->head;

        for (i = 0; i < num; i++) {
                csq->desc[csq->head++] = desc[i];
                if (csq->head == csq->desc_num)
                        csq->head = 0;
        }

        /* Write to hardware */
        roce_write(hr_dev, ROCEE_TX_CMQ_PI_REG, csq->head);

        /* If the command is sync, wait for the firmware to write back,
         * if multi descriptors to be sent, use the first one to check
         */
        if (le16_to_cpu(desc->flag) & HNS_ROCE_CMD_FLAG_NO_INTR) {
                do {
                        if (hns_roce_cmq_csq_done(hr_dev))
                                break;
                        udelay(1);
                } while (++timeout < priv->cmq.tx_timeout);
        }

        if (hns_roce_cmq_csq_done(hr_dev)) {
                for (ret = 0, i = 0; i < num; i++) {
                        /* check the result of hardware write back */
                        desc[i] = csq->desc[tail++];
                        if (tail == csq->desc_num)
                                tail = 0;

                        desc_ret = le16_to_cpu(desc[i].retval);
                        if (likely(desc_ret == CMD_EXEC_SUCCESS))
                                continue;

                        dev_err_ratelimited(hr_dev->dev,
                                            "Cmdq IO error, opcode = %x, return = %x\n",
                                            desc->opcode, desc_ret);
                        ret = -EIO;
                }
        } else {
                /* FW/HW reset or incorrect number of desc */
                tail = roce_read(hr_dev, ROCEE_TX_CMQ_CI_REG);
                dev_warn(hr_dev->dev, "CMDQ move tail from %d to %d\n",
                         csq->head, tail);
                csq->head = tail;

                ret = -EAGAIN;
        }

        spin_unlock_bh(&csq->lock);

        return ret;
}

static int hns_roce_cmq_send(struct hns_roce_dev *hr_dev,
                             struct hns_roce_cmq_desc *desc, int num)
{
        bool busy;
        int ret;

        if (!v2_chk_mbox_is_avail(hr_dev, &busy))
                return busy ? -EBUSY : 0;

        ret = __hns_roce_cmq_send(hr_dev, desc, num);
        if (ret) {
                if (!v2_chk_mbox_is_avail(hr_dev, &busy))
                        return busy ? -EBUSY : 0;
        }

        return ret;
}

static int config_hem_ba_to_hw(struct hns_roce_dev *hr_dev, unsigned long obj,
                               dma_addr_t base_addr, u16 op)
{
        struct hns_roce_cmd_mailbox *mbox = hns_roce_alloc_cmd_mailbox(hr_dev);
        int ret;

        if (IS_ERR(mbox))
                return PTR_ERR(mbox);

        ret = hns_roce_cmd_mbox(hr_dev, base_addr, mbox->dma, obj, 0, op,
                                HNS_ROCE_CMD_TIMEOUT_MSECS);
        hns_roce_free_cmd_mailbox(hr_dev, mbox);
        return ret;
}

static int hns_roce_cmq_query_hw_info(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_query_version *resp;
        struct hns_roce_cmq_desc desc;
        int ret;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_QUERY_HW_VER, true);
        ret = hns_roce_cmq_send(hr_dev, &desc, 1);
        if (ret)
                return ret;

        resp = (struct hns_roce_query_version *)desc.data;
        hr_dev->hw_rev = le16_to_cpu(resp->rocee_hw_version);
        hr_dev->vendor_id = hr_dev->pci_dev->vendor;

        return 0;
}

static void func_clr_hw_resetting_state(struct hns_roce_dev *hr_dev,
                                        struct hnae3_handle *handle)
{
        const struct hnae3_ae_ops *ops = handle->ae_algo->ops;
        unsigned long end;

        hr_dev->dis_db = true;

        dev_warn(hr_dev->dev,
                 "Func clear is pending, device in resetting state.\n");
        end = HNS_ROCE_V2_HW_RST_TIMEOUT;
        while (end) {
                if (!ops->get_hw_reset_stat(handle)) {
                        hr_dev->is_reset = true;
                        dev_info(hr_dev->dev,
                                 "Func clear success after reset.\n");
                        return;
                }
                msleep(HNS_ROCE_V2_HW_RST_COMPLETION_WAIT);
                end -= HNS_ROCE_V2_HW_RST_COMPLETION_WAIT;
        }

        dev_warn(hr_dev->dev, "Func clear failed.\n");
}

static void func_clr_sw_resetting_state(struct hns_roce_dev *hr_dev,
                                        struct hnae3_handle *handle)
{
        const struct hnae3_ae_ops *ops = handle->ae_algo->ops;
        unsigned long end;

        hr_dev->dis_db = true;

        dev_warn(hr_dev->dev,
                 "Func clear is pending, device in resetting state.\n");
        end = HNS_ROCE_V2_HW_RST_TIMEOUT;
        while (end) {
                if (ops->ae_dev_reset_cnt(handle) !=
                    hr_dev->reset_cnt) {
                        hr_dev->is_reset = true;
                        dev_info(hr_dev->dev,
                                 "Func clear success after sw reset\n");
                        return;
                }
                msleep(HNS_ROCE_V2_HW_RST_COMPLETION_WAIT);
                end -= HNS_ROCE_V2_HW_RST_COMPLETION_WAIT;
        }

        dev_warn(hr_dev->dev, "Func clear failed because of unfinished sw reset\n");
}

static void hns_roce_func_clr_rst_proc(struct hns_roce_dev *hr_dev, int retval,
                                       int flag)
{
        struct hns_roce_v2_priv *priv = hr_dev->priv;
        struct hnae3_handle *handle = priv->handle;
        const struct hnae3_ae_ops *ops = handle->ae_algo->ops;

        if (ops->ae_dev_reset_cnt(handle) != hr_dev->reset_cnt) {
                hr_dev->dis_db = true;
                hr_dev->is_reset = true;
                dev_info(hr_dev->dev, "Func clear success after reset.\n");
                return;
        }

        if (ops->get_hw_reset_stat(handle)) {
                func_clr_hw_resetting_state(hr_dev, handle);
                return;
        }

        if (ops->ae_dev_resetting(handle) &&
            handle->rinfo.instance_state == HNS_ROCE_STATE_INIT) {
                func_clr_sw_resetting_state(hr_dev, handle);
                return;
        }

        if (retval && !flag)
                dev_warn(hr_dev->dev,
                         "Func clear read failed, ret = %d.\n", retval);

        dev_warn(hr_dev->dev, "Func clear failed.\n");
}

static void __hns_roce_function_clear(struct hns_roce_dev *hr_dev, int vf_id)
{
        bool fclr_write_fail_flag = false;
        struct hns_roce_func_clear *resp;
        struct hns_roce_cmq_desc desc;
        unsigned long end;
        int ret = 0;

        if (check_device_is_in_reset(hr_dev))
                goto out;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_FUNC_CLEAR, false);
        resp = (struct hns_roce_func_clear *)desc.data;
        resp->rst_funcid_en = cpu_to_le32(vf_id);

        ret = hns_roce_cmq_send(hr_dev, &desc, 1);
        if (ret) {
                fclr_write_fail_flag = true;
                dev_err(hr_dev->dev, "Func clear write failed, ret = %d.\n",
                         ret);
                goto out;
        }

        msleep(HNS_ROCE_V2_READ_FUNC_CLEAR_FLAG_INTERVAL);
        end = HNS_ROCE_V2_FUNC_CLEAR_TIMEOUT_MSECS;
        while (end) {
                if (check_device_is_in_reset(hr_dev))
                        goto out;
                msleep(HNS_ROCE_V2_READ_FUNC_CLEAR_FLAG_FAIL_WAIT);
                end -= HNS_ROCE_V2_READ_FUNC_CLEAR_FLAG_FAIL_WAIT;

                hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_FUNC_CLEAR,
                                              true);

                resp->rst_funcid_en = cpu_to_le32(vf_id);
                ret = hns_roce_cmq_send(hr_dev, &desc, 1);
                if (ret)
                        continue;

                if (roce_get_bit(resp->func_done, FUNC_CLEAR_RST_FUN_DONE_S)) {
                        if (vf_id == 0)
                                hr_dev->is_reset = true;
                        return;
                }
        }

out:
        hns_roce_func_clr_rst_proc(hr_dev, ret, fclr_write_fail_flag);
}

static void hns_roce_free_vf_resource(struct hns_roce_dev *hr_dev, int vf_id)
{
        enum hns_roce_opcode_type opcode = HNS_ROCE_OPC_ALLOC_VF_RES;
        struct hns_roce_cmq_desc desc[2];
        struct hns_roce_cmq_req *req_a;

        req_a = (struct hns_roce_cmq_req *)desc[0].data;
        hns_roce_cmq_setup_basic_desc(&desc[0], opcode, false);
        desc[0].flag |= cpu_to_le16(HNS_ROCE_CMD_FLAG_NEXT);
        hns_roce_cmq_setup_basic_desc(&desc[1], opcode, false);
        hr_reg_write(req_a, FUNC_RES_A_VF_ID, vf_id);
        hns_roce_cmq_send(hr_dev, desc, 2);
}

static void hns_roce_function_clear(struct hns_roce_dev *hr_dev)
{
        int i;

        for (i = hr_dev->func_num - 1; i >= 0; i--) {
                __hns_roce_function_clear(hr_dev, i);
                if (i != 0)
                        hns_roce_free_vf_resource(hr_dev, i);
        }
}

static int hns_roce_clear_extdb_list_info(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_cmq_desc desc;
        int ret;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_CLEAR_EXTDB_LIST_INFO,
                                      false);
        ret = hns_roce_cmq_send(hr_dev, &desc, 1);
        if (ret)
                ibdev_err(&hr_dev->ib_dev,
                          "failed to clear extended doorbell info, ret = %d.\n",
                          ret);

        return ret;
}

static int hns_roce_query_fw_ver(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_query_fw_info *resp;
        struct hns_roce_cmq_desc desc;
        int ret;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_QUERY_FW_VER, true);
        ret = hns_roce_cmq_send(hr_dev, &desc, 1);
        if (ret)
                return ret;

        resp = (struct hns_roce_query_fw_info *)desc.data;
        hr_dev->caps.fw_ver = (u64)(le32_to_cpu(resp->fw_ver));

        return 0;
}

static int hns_roce_query_func_info(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_cmq_desc desc;
        int ret;

        if (hr_dev->pci_dev->revision < PCI_REVISION_ID_HIP09) {
                hr_dev->func_num = 1;
                return 0;
        }

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_QUERY_FUNC_INFO,
                                      true);
        ret = hns_roce_cmq_send(hr_dev, &desc, 1);
        if (ret) {
                hr_dev->func_num = 1;
                return ret;
        }

        hr_dev->func_num = le32_to_cpu(desc.func_info.own_func_num);
        hr_dev->cong_algo_tmpl_id = le32_to_cpu(desc.func_info.own_mac_id);

        return 0;
}

static int hns_roce_config_global_param(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_cmq_desc desc;
        struct hns_roce_cmq_req *req = (struct hns_roce_cmq_req *)desc.data;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_CFG_GLOBAL_PARAM,
                                      false);

        hr_reg_write(req, CFG_GLOBAL_PARAM_1US_CYCLES, 0x3e8);
        hr_reg_write(req, CFG_GLOBAL_PARAM_UDP_PORT, ROCE_V2_UDP_DPORT);

        return hns_roce_cmq_send(hr_dev, &desc, 1);
}

static int load_func_res_caps(struct hns_roce_dev *hr_dev, bool is_vf)
{
        struct hns_roce_cmq_desc desc[2];
        struct hns_roce_cmq_req *r_a = (struct hns_roce_cmq_req *)desc[0].data;
        struct hns_roce_cmq_req *r_b = (struct hns_roce_cmq_req *)desc[1].data;
        struct hns_roce_caps *caps = &hr_dev->caps;
        enum hns_roce_opcode_type opcode;
        u32 func_num;
        int ret;

        if (is_vf) {
                opcode = HNS_ROCE_OPC_QUERY_VF_RES;
                func_num = 1;
        } else {
                opcode = HNS_ROCE_OPC_QUERY_PF_RES;
                func_num = hr_dev->func_num;
        }

        hns_roce_cmq_setup_basic_desc(&desc[0], opcode, true);
        desc[0].flag |= cpu_to_le16(HNS_ROCE_CMD_FLAG_NEXT);
        hns_roce_cmq_setup_basic_desc(&desc[1], opcode, true);

        ret = hns_roce_cmq_send(hr_dev, desc, 2);
        if (ret)
                return ret;

        caps->qpc_bt_num = hr_reg_read(r_a, FUNC_RES_A_QPC_BT_NUM) / func_num;
        caps->srqc_bt_num = hr_reg_read(r_a, FUNC_RES_A_SRQC_BT_NUM) / func_num;
        caps->cqc_bt_num = hr_reg_read(r_a, FUNC_RES_A_CQC_BT_NUM) / func_num;
        caps->mpt_bt_num = hr_reg_read(r_a, FUNC_RES_A_MPT_BT_NUM) / func_num;
        caps->eqc_bt_num = hr_reg_read(r_a, FUNC_RES_A_EQC_BT_NUM) / func_num;
        caps->smac_bt_num = hr_reg_read(r_b, FUNC_RES_B_SMAC_NUM) / func_num;
        caps->sgid_bt_num = hr_reg_read(r_b, FUNC_RES_B_SGID_NUM) / func_num;
        caps->sccc_bt_num = hr_reg_read(r_b, FUNC_RES_B_SCCC_BT_NUM) / func_num;

        if (is_vf) {
                caps->sl_num = hr_reg_read(r_b, FUNC_RES_V_QID_NUM) / func_num;
                caps->gmv_bt_num = hr_reg_read(r_b, FUNC_RES_V_GMV_BT_NUM) /
                                               func_num;
        } else {
                caps->sl_num = hr_reg_read(r_b, FUNC_RES_B_QID_NUM) / func_num;
                caps->gmv_bt_num = hr_reg_read(r_b, FUNC_RES_B_GMV_BT_NUM) /
                                               func_num;
        }

        return 0;
}

static int load_ext_cfg_caps(struct hns_roce_dev *hr_dev, bool is_vf)
{
        struct hns_roce_cmq_desc desc;
        struct hns_roce_cmq_req *req = (struct hns_roce_cmq_req *)desc.data;
        struct hns_roce_caps *caps = &hr_dev->caps;
        u32 func_num, qp_num;
        int ret;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_EXT_CFG, true);
        ret = hns_roce_cmq_send(hr_dev, &desc, 1);
        if (ret)
                return ret;

        func_num = is_vf ? 1 : max_t(u32, 1, hr_dev->func_num);
        qp_num = hr_reg_read(req, EXT_CFG_QP_PI_NUM) / func_num;
        caps->num_pi_qps = round_down(qp_num, HNS_ROCE_QP_BANK_NUM);

        qp_num = hr_reg_read(req, EXT_CFG_QP_NUM) / func_num;
        caps->num_qps = round_down(qp_num, HNS_ROCE_QP_BANK_NUM);

        return 0;
}

static int load_pf_timer_res_caps(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_cmq_desc desc;
        struct hns_roce_cmq_req *req = (struct hns_roce_cmq_req *)desc.data;
        struct hns_roce_caps *caps = &hr_dev->caps;
        int ret;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_QUERY_PF_TIMER_RES,
                                      true);

        ret = hns_roce_cmq_send(hr_dev, &desc, 1);
        if (ret)
                return ret;

        caps->qpc_timer_bt_num = hr_reg_read(req, PF_TIMER_RES_QPC_ITEM_NUM);
        caps->cqc_timer_bt_num = hr_reg_read(req, PF_TIMER_RES_CQC_ITEM_NUM);

        return 0;
}

static int query_func_resource_caps(struct hns_roce_dev *hr_dev, bool is_vf)
{
        struct device *dev = hr_dev->dev;
        int ret;

        ret = load_func_res_caps(hr_dev, is_vf);
        if (ret) {
                dev_err(dev, "failed to load res caps, ret = %d (%s).\n", ret,
                        is_vf ? "vf" : "pf");
                return ret;
        }

        if (hr_dev->pci_dev->revision >= PCI_REVISION_ID_HIP09) {
                ret = load_ext_cfg_caps(hr_dev, is_vf);
                if (ret)
                        dev_err(dev, "failed to load ext cfg, ret = %d (%s).\n",
                                ret, is_vf ? "vf" : "pf");
        }

        return ret;
}

static int hns_roce_query_pf_resource(struct hns_roce_dev *hr_dev)
{
        struct device *dev = hr_dev->dev;
        int ret;

        ret = query_func_resource_caps(hr_dev, false);
        if (ret)
                return ret;

        ret = load_pf_timer_res_caps(hr_dev);
        if (ret)
                dev_err(dev, "failed to load pf timer resource, ret = %d.\n",
                        ret);

        return ret;
}

static int hns_roce_query_vf_resource(struct hns_roce_dev *hr_dev)
{
        return query_func_resource_caps(hr_dev, true);
}

static int __hns_roce_set_vf_switch_param(struct hns_roce_dev *hr_dev,
                                          u32 vf_id)
{
        struct hns_roce_vf_switch *swt;
        struct hns_roce_cmq_desc desc;
        int ret;

        swt = (struct hns_roce_vf_switch *)desc.data;
        hns_roce_cmq_setup_basic_desc(&desc, HNS_SWITCH_PARAMETER_CFG, true);
        swt->rocee_sel |= cpu_to_le32(HNS_ICL_SWITCH_CMD_ROCEE_SEL);
        roce_set_field(swt->fun_id, VF_SWITCH_DATA_FUN_ID_VF_ID_M,
                       VF_SWITCH_DATA_FUN_ID_VF_ID_S, vf_id);
        ret = hns_roce_cmq_send(hr_dev, &desc, 1);
        if (ret)
                return ret;

        desc.flag =
                cpu_to_le16(HNS_ROCE_CMD_FLAG_NO_INTR | HNS_ROCE_CMD_FLAG_IN);
        desc.flag &= cpu_to_le16(~HNS_ROCE_CMD_FLAG_WR);
        roce_set_bit(swt->cfg, VF_SWITCH_DATA_CFG_ALW_LPBK_S, 1);
        roce_set_bit(swt->cfg, VF_SWITCH_DATA_CFG_ALW_LCL_LPBK_S, 0);
        roce_set_bit(swt->cfg, VF_SWITCH_DATA_CFG_ALW_DST_OVRD_S, 1);

        return hns_roce_cmq_send(hr_dev, &desc, 1);
}

static int hns_roce_set_vf_switch_param(struct hns_roce_dev *hr_dev)
{
        u32 vf_id;
        int ret;

        for (vf_id = 0; vf_id < hr_dev->func_num; vf_id++) {
                ret = __hns_roce_set_vf_switch_param(hr_dev, vf_id);
                if (ret)
                        return ret;
        }
        return 0;
}

static int config_vf_hem_resource(struct hns_roce_dev *hr_dev, int vf_id)
{
        struct hns_roce_cmq_desc desc[2];
        struct hns_roce_cmq_req *r_a = (struct hns_roce_cmq_req *)desc[0].data;
        struct hns_roce_cmq_req *r_b = (struct hns_roce_cmq_req *)desc[1].data;
        enum hns_roce_opcode_type opcode = HNS_ROCE_OPC_ALLOC_VF_RES;
        struct hns_roce_caps *caps = &hr_dev->caps;

        hns_roce_cmq_setup_basic_desc(&desc[0], opcode, false);
        desc[0].flag |= cpu_to_le16(HNS_ROCE_CMD_FLAG_NEXT);
        hns_roce_cmq_setup_basic_desc(&desc[1], opcode, false);

        hr_reg_write(r_a, FUNC_RES_A_VF_ID, vf_id);

        hr_reg_write(r_a, FUNC_RES_A_QPC_BT_NUM, caps->qpc_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_QPC_BT_IDX, vf_id * caps->qpc_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_SRQC_BT_NUM, caps->srqc_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_SRQC_BT_IDX, vf_id * caps->srqc_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_CQC_BT_NUM, caps->cqc_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_CQC_BT_IDX, vf_id * caps->cqc_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_MPT_BT_NUM, caps->mpt_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_MPT_BT_IDX, vf_id * caps->mpt_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_EQC_BT_NUM, caps->eqc_bt_num);
        hr_reg_write(r_a, FUNC_RES_A_EQC_BT_IDX, vf_id * caps->eqc_bt_num);
        hr_reg_write(r_b, FUNC_RES_V_QID_NUM, caps->sl_num);
        hr_reg_write(r_b, FUNC_RES_B_QID_IDX, vf_id * caps->sl_num);
        hr_reg_write(r_b, FUNC_RES_B_SCCC_BT_NUM, caps->sccc_bt_num);
        hr_reg_write(r_b, FUNC_RES_B_SCCC_BT_IDX, vf_id * caps->sccc_bt_num);

        if (hr_dev->pci_dev->revision >= PCI_REVISION_ID_HIP09) {
                hr_reg_write(r_b, FUNC_RES_V_GMV_BT_NUM, caps->gmv_bt_num);
                hr_reg_write(r_b, FUNC_RES_B_GMV_BT_IDX,
                             vf_id * caps->gmv_bt_num);
        } else {
                hr_reg_write(r_b, FUNC_RES_B_SGID_NUM, caps->sgid_bt_num);
                hr_reg_write(r_b, FUNC_RES_B_SGID_IDX,
                             vf_id * caps->sgid_bt_num);
                hr_reg_write(r_b, FUNC_RES_B_SMAC_NUM, caps->smac_bt_num);
                hr_reg_write(r_b, FUNC_RES_B_SMAC_IDX,
                             vf_id * caps->smac_bt_num);
        }

        return hns_roce_cmq_send(hr_dev, desc, 2);
}

static int config_vf_ext_resource(struct hns_roce_dev *hr_dev, u32 vf_id)
{
        struct hns_roce_cmq_desc desc;
        struct hns_roce_cmq_req *req = (struct hns_roce_cmq_req *)desc.data;
        struct hns_roce_caps *caps = &hr_dev->caps;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_EXT_CFG, false);

        hr_reg_write(req, EXT_CFG_VF_ID, vf_id);

        hr_reg_write(req, EXT_CFG_QP_PI_NUM, caps->num_pi_qps);
        hr_reg_write(req, EXT_CFG_QP_PI_IDX, vf_id * caps->num_pi_qps);
        hr_reg_write(req, EXT_CFG_QP_NUM, caps->num_qps);
        hr_reg_write(req, EXT_CFG_QP_IDX, vf_id * caps->num_qps);

        return hns_roce_cmq_send(hr_dev, &desc, 1);
}

static int hns_roce_alloc_vf_resource(struct hns_roce_dev *hr_dev)
{
        u32 func_num = max_t(u32, 1, hr_dev->func_num);
        u32 vf_id;
        int ret;

        for (vf_id = 0; vf_id < func_num; vf_id++) {
                ret = config_vf_hem_resource(hr_dev, vf_id);
                if (ret) {
                        dev_err(hr_dev->dev,
                                "failed to config vf-%u hem res, ret = %d.\n",
                                vf_id, ret);
                        return ret;
                }

                if (hr_dev->pci_dev->revision >= PCI_REVISION_ID_HIP09) {
                        ret = config_vf_ext_resource(hr_dev, vf_id);
                        if (ret) {
                                dev_err(hr_dev->dev,
                                        "failed to config vf-%u ext res, ret = %d.\n",
                                        vf_id, ret);
                                return ret;
                        }
                }
        }

        return 0;
}

static int hns_roce_v2_set_bt(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_cmq_desc desc;
        struct hns_roce_cmq_req *req = (struct hns_roce_cmq_req *)desc.data;
        struct hns_roce_caps *caps = &hr_dev->caps;

        hns_roce_cmq_setup_basic_desc(&desc, HNS_ROCE_OPC_CFG_BT_ATTR, false);

        hr_reg_write(req, CFG_BT_ATTR_QPC_BA_PGSZ,
                     caps->qpc_ba_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_QPC_BUF_PGSZ,
                     caps->qpc_buf_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_QPC_HOPNUM,
                     to_hr_hem_hopnum(caps->qpc_hop_num, caps->num_qps));

        hr_reg_write(req, CFG_BT_ATTR_SRQC_BA_PGSZ,
                     caps->srqc_ba_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_SRQC_BUF_PGSZ,
                     caps->srqc_buf_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_SRQC_HOPNUM,
                     to_hr_hem_hopnum(caps->srqc_hop_num, caps->num_srqs));

        hr_reg_write(req, CFG_BT_ATTR_CQC_BA_PGSZ,
                     caps->cqc_ba_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_CQC_BUF_PGSZ,
                     caps->cqc_buf_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_CQC_HOPNUM,
                     to_hr_hem_hopnum(caps->cqc_hop_num, caps->num_cqs));

        hr_reg_write(req, CFG_BT_ATTR_MPT_BA_PGSZ,
                     caps->mpt_ba_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_MPT_BUF_PGSZ,
                     caps->mpt_buf_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_MPT_HOPNUM,
                     to_hr_hem_hopnum(caps->mpt_hop_num, caps->num_mtpts));

        hr_reg_write(req, CFG_BT_ATTR_SCCC_BA_PGSZ,
                     caps->sccc_ba_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_SCCC_BUF_PGSZ,
                     caps->sccc_buf_pg_sz + PG_SHIFT_OFFSET);
        hr_reg_write(req, CFG_BT_ATTR_SCCC_HOPNUM,
                     to_hr_hem_hopnum(caps->sccc_hop_num, caps->num_qps));

        return hns_roce_cmq_send(hr_dev, &desc, 1);
}

/* Use default caps when hns_roce_query_pf_caps() failed or init VF profile */
static void set_default_caps(struct hns_roce_dev *hr_dev)
{
        struct hns_roce_caps *caps = &hr_dev->caps;

        caps->num_qps           = HNS_ROCE_V2_MAX_QP_NUM;
        caps->max_wqes          = HNS_ROCE_V2_MAX_WQE_NUM;
        caps->num_cqs           = HNS_ROCE_V2_MAX_CQ_NUM;
        caps->num_srqs          = HNS_ROCE_V2_MAX_SRQ_NUM;
        caps->min_cqes          = HNS_ROCE_MIN_CQE_NUM;
        caps->max_cqes          = HNS_ROCE_V2_MAX_CQE_NUM;
        caps->max_sq_sg         = HNS_ROCE_V2_MAX_SQ_SGE_NUM;
        caps->max_extend_sg     = HNS_ROCE_V2_MAX_EXTEND_SGE_NUM;
        caps->max_rq_sg         = HNS_ROCE_V2_MAX_RQ_SGE_NUM;

        caps->num_uars          = HNS_ROCE_V2_UAR_NUM;
        caps->phy_num_uars      = HNS_ROCE_V2_PHY_UAR_NUM;
        caps->num_aeq_vectors   = HNS_ROCE_V2_AEQE_VEC_NUM;
        caps->num_other_vectors = HNS_ROCE_V2_ABNORMAL_VEC_NUM;
        caps->num_comp_vectors  = 0;

        caps->num_mtpts         = HNS_ROCE_V2_MAX_MTPT_NUM;
        caps->num_pds           = HNS_ROCE_V2_MAX_PD_NUM;
        caps->num_qpc_timer     = HNS_ROCE_V2_MAX_QPC_TIMER_NUM;
        caps->num_cqc_timer     = HNS_ROCE_V2_MAX_CQC_TIMER_NUM;

        caps->max_qp_init_rdma  = HNS_ROCE_V2_MAX_QP_INIT_RDMA;
        caps->max_qp_dest_rdma  = HNS_ROCE_V2_MAX_QP_DEST_RDMA;
        caps->max_sq_desc_sz    = HNS_ROCE_V2_MAX_SQ_DESC_SZ;
        caps->max_rq_desc_sz    = HNS_ROCE_V2_MAX_RQ_DESC_SZ;
        caps->max_srq_desc_sz   = HNS_ROCE_V2_MAX_SRQ_DESC_SZ;
        caps->irrl_entry_sz     = HNS_ROCE_V2_IRRL_ENTRY_SZ;
        caps->trrl_entry_sz     = HNS_ROCE_V2_EXT_ATOMIC_TRRL_ENTRY_SZ;
        caps->cqc_entry_sz      = HNS_ROCE_V2_CQC_ENTRY_SZ;
        caps->srqc_entry_sz     = HNS_ROCE_V2_SRQC_ENTRY_SZ;
        caps->mtpt_entry_sz     = HNS_ROCE_V2_MTPT_ENTRY_SZ;
        caps->idx_entry_sz      = HNS_ROCE_V2_IDX_ENTRY_SZ;
        caps->page_size_cap     = HNS_ROCE_V2_PAGE_SIZE_SUPPORTED;
        caps->reserved_lkey     = 0;
        caps->reserved_pds      = 0;
        caps->reserved_mrws     = 1;
        caps->reserved_uars     = 0;
        caps->reserved_cqs      = 0;
        caps->reserved_srqs     = 0;
        caps->reserved_qps      = HNS_ROCE_V2_RSV_QPS;

        caps->qpc_hop_num       = HNS_ROCE_CONTEXT_HOP_NUM;
        caps->srqc_hop_num      = HNS_ROCE_CONTEXT_HOP_NUM;
        caps->cqc_hop_num       = HNS_ROCE_CONTEXT_HOP_NUM;
        caps->mpt_hop_num       = HNS_ROCE_CONTEXT_HOP_NUM;
        caps->sccc_hop_num      = HNS_ROCE_SCCC_HOP_NUM;

        caps->mtt_hop_num       = HNS_ROCE_MTT_HOP_NUM;
        caps->wqe_sq_hop_num    = HNS_ROCE_SQWQE_HOP_NUM;
        caps->wqe_sge_hop_num   = HNS_ROCE_EXT_SGE_HOP_NUM;
        caps->wqe_rq_hop_num    = HNS_ROCE_RQWQE_HOP_NUM;
        caps->cqe_hop_num       = HNS_ROCE_CQE_HOP_NUM;
        caps->srqwqe_hop_num    = HNS_ROCE_SRQWQE_HOP_NUM;
        caps->idx_hop_num       = HNS_ROCE_IDX_HOP_NUM;
        caps->chunk_sz          = HNS_ROCE_V2_TABLE_CHUNK_SIZE;

        caps->flags             = HNS_ROCE_CAP_FLAG_REREG_MR |
                                  HNS_ROCE_CAP_FLAG_ROCE_V1_V2 |
                                  HNS_ROCE_CAP_FLAG_CQ_RECORD_DB |
                                  HNS_ROCE_CAP_FLAG_QP_RECORD_DB;

        caps->pkey_table_len[0] = 1;
        caps->ceqe_depth        = HNS_ROCE_V2_COMP_EQE_NUM;
        caps->aeqe_depth        = HNS_ROCE_V2_ASYNC_EQE_NUM;
        caps->local_ca_ack_delay = 0;
        caps->max_mtu = IB_MTU_4096;

        caps->max_srq_wrs       = HNS_ROCE_V2_MAX_SRQ_WR;
        caps->max_srq_sges      = HNS_ROCE_V2_MAX_SRQ_SGE;

        caps->flags |= HNS_ROCE_CAP_FLAG_ATOMIC | HNS_ROCE_CAP_FLAG_MW |