net/iavf: add RSS configuration for VF
[dpdk.git] / drivers / net / iavf / iavf_vchnl.c
index a705dbd..2a0cdd9 100644 (file)
 #include <rte_ethdev_driver.h>
 #include <rte_dev.h>
 
-#include "iavf_log.h"
-#include "base/iavf_prototype.h"
-#include "base/iavf_adminq_cmd.h"
-#include "base/iavf_type.h"
-
 #include "iavf.h"
 #include "iavf_rxtx.h"
 
@@ -31,7 +26,7 @@
 #define ASQ_DELAY_MS  10
 
 /* Read data in admin queue to get msg from pf driver */
-static enum iavf_status_code
+static enum iavf_status
 iavf_read_msg_from_pf(struct iavf_adapter *adapter, uint16_t buf_len,
                     uint8_t *buf)
 {
@@ -57,9 +52,11 @@ iavf_read_msg_from_pf(struct iavf_adapter *adapter, uint16_t buf_len,
        PMD_DRV_LOG(DEBUG, "AQ from pf carries opcode %u, retval %d",
                    opcode, vf->cmd_retval);
 
-       if (opcode != vf->pend_cmd)
+       if (opcode != vf->pend_cmd) {
                PMD_DRV_LOG(WARNING, "command mismatch, expect %u, get %u",
                            vf->pend_cmd, opcode);
+               return IAVF_ERR_OPCODE_MISMATCH;
+       }
 
        return IAVF_SUCCESS;
 }
@@ -69,7 +66,7 @@ iavf_execute_vf_cmd(struct iavf_adapter *adapter, struct iavf_cmd_info *args)
 {
        struct iavf_hw *hw = IAVF_DEV_PRIVATE_TO_HW(adapter);
        struct iavf_info *vf = IAVF_DEV_PRIVATE_TO_VF(adapter);
-       enum iavf_status_code ret;
+       enum iavf_status ret;
        int err = 0;
        int i = 0;
 
@@ -91,6 +88,7 @@ iavf_execute_vf_cmd(struct iavf_adapter *adapter, struct iavf_cmd_info *args)
                break;
        case VIRTCHNL_OP_VERSION:
        case VIRTCHNL_OP_GET_VF_RESOURCES:
+       case VIRTCHNL_OP_GET_SUPPORTED_RXDIDS:
                /* for init virtchnl ops, need to poll the response */
                do {
                        ret = iavf_read_msg_from_pf(adapter, args->out_size,
@@ -175,7 +173,7 @@ iavf_handle_virtchnl_msg(struct rte_eth_dev *dev)
        struct iavf_arq_event_info info;
        uint16_t pending, aq_opc;
        enum virtchnl_ops msg_opc;
-       enum iavf_status_code msg_ret;
+       enum iavf_status msg_ret;
        int ret;
 
        info.buf_len = IAVF_AQ_BUF_SZ;
@@ -201,7 +199,7 @@ iavf_handle_virtchnl_msg(struct rte_eth_dev *dev)
                 */
                msg_opc = (enum virtchnl_ops)rte_le_to_cpu_32(
                                                  info.desc.cookie_high);
-               msg_ret = (enum iavf_status_code)rte_le_to_cpu_32(
+               msg_ret = (enum iavf_status)rte_le_to_cpu_32(
                                                  info.desc.cookie_low);
                switch (aq_opc) {
                case iavf_aqc_opc_send_msg_to_vf:
@@ -210,12 +208,9 @@ iavf_handle_virtchnl_msg(struct rte_eth_dev *dev)
                                                        info.msg_len);
                        } else {
                                /* read message and it's expected one */
-                               if (msg_opc == vf->pend_cmd) {
-                                       vf->cmd_retval = msg_ret;
-                                       /* prevent compiler reordering */
-                                       rte_compiler_barrier();
-                                       _clear_cmd(vf);
-                               } else
+                               if (msg_opc == vf->pend_cmd)
+                                       _notify_cmd(vf, msg_ret);
+                               else
                                        PMD_DRV_LOG(ERR, "command mismatch,"
                                                    "expect %u, get %u",
                                                    vf->pend_cmd, msg_opc);
@@ -340,11 +335,10 @@ iavf_get_vf_resource(struct iavf_adapter *adapter)
        args.out_buffer = vf->aq_resp;
        args.out_size = IAVF_AQ_BUF_SZ;
 
-       /* TODO: basic offload capabilities, need to
-        * add advanced/optional offload capabilities
-        */
-
-       caps = IAVF_BASIC_OFFLOAD_CAPS | VIRTCHNL_VF_CAP_ADV_LINK_SPEED;
+       caps = IAVF_BASIC_OFFLOAD_CAPS | VIRTCHNL_VF_CAP_ADV_LINK_SPEED |
+               VIRTCHNL_VF_OFFLOAD_RX_FLEX_DESC |
+               VIRTCHNL_VF_OFFLOAD_FDIR_PF |
+               VIRTCHNL_VF_OFFLOAD_ADV_RSS_PF;
 
        args.in_args = (uint8_t *)&caps;
        args.in_args_size = sizeof(caps);
@@ -363,7 +357,7 @@ iavf_get_vf_resource(struct iavf_adapter *adapter)
        rte_memcpy(vf->vf_res, args.out_buffer,
                   RTE_MIN(args.out_size, len));
        /* parse  VF config message back from PF*/
-       iavf_parse_hw_config(hw, vf->vf_res);
+       iavf_vf_parse_hw_config(hw, vf->vf_res);
        for (i = 0; i < vf->vf_res->num_vsis; i++) {
                if (vf->vf_res->vsi_res[i].vsi_type == VIRTCHNL_VSI_SRIOV)
                        vf->vsi_res = &vf->vf_res->vsi_res[i];
@@ -381,6 +375,32 @@ iavf_get_vf_resource(struct iavf_adapter *adapter)
        return 0;
 }
 
+int
+iavf_get_supported_rxdid(struct iavf_adapter *adapter)
+{
+       struct iavf_info *vf = IAVF_DEV_PRIVATE_TO_VF(adapter);
+       struct iavf_cmd_info args;
+       int ret;
+
+       args.ops = VIRTCHNL_OP_GET_SUPPORTED_RXDIDS;
+       args.in_args = NULL;
+       args.in_args_size = 0;
+       args.out_buffer = vf->aq_resp;
+       args.out_size = IAVF_AQ_BUF_SZ;
+
+       ret = iavf_execute_vf_cmd(adapter, &args);
+       if (ret) {
+               PMD_DRV_LOG(ERR,
+                           "Failed to execute command of OP_GET_SUPPORTED_RXDIDS");
+               return ret;
+       }
+
+       vf->supported_rxdid =
+               ((struct virtchnl_supported_rxdids *)args.out_buffer)->supported_rxdids;
+
+       return 0;
+}
+
 int
 iavf_enable_queues(struct iavf_adapter *adapter)
 {
@@ -573,6 +593,31 @@ iavf_configure_queues(struct iavf_adapter *adapter)
                        vc_qp->rxq.ring_len = rxq[i]->nb_rx_desc;
                        vc_qp->rxq.dma_ring_addr = rxq[i]->rx_ring_phys_addr;
                        vc_qp->rxq.databuffer_size = rxq[i]->rx_buf_len;
+
+#ifndef RTE_LIBRTE_IAVF_16BYTE_RX_DESC
+                       if (vf->vf_res->vf_cap_flags &
+                           VIRTCHNL_VF_OFFLOAD_RX_FLEX_DESC &&
+                           vf->supported_rxdid & BIT(IAVF_RXDID_COMMS_OVS_1)) {
+                               vc_qp->rxq.rxdid = IAVF_RXDID_COMMS_OVS_1;
+                               PMD_DRV_LOG(NOTICE, "request RXDID == %d in "
+                                           "Queue[%d]", vc_qp->rxq.rxdid, i);
+                       } else {
+                               vc_qp->rxq.rxdid = IAVF_RXDID_LEGACY_1;
+                               PMD_DRV_LOG(NOTICE, "request RXDID == %d in "
+                                           "Queue[%d]", vc_qp->rxq.rxdid, i);
+                       }
+#else
+                       if (vf->vf_res->vf_cap_flags &
+                           VIRTCHNL_VF_OFFLOAD_RX_FLEX_DESC &&
+                           vf->supported_rxdid & BIT(IAVF_RXDID_LEGACY_0)) {
+                               vc_qp->rxq.rxdid = IAVF_RXDID_LEGACY_0;
+                               PMD_DRV_LOG(NOTICE, "request RXDID == %d in "
+                                           "Queue[%d]", vc_qp->rxq.rxdid, i);
+                       } else {
+                               PMD_DRV_LOG(ERR, "RXDID == 0 is not supported");
+                               return -1;
+                       }
+#endif
                }
        }
 
@@ -647,7 +692,7 @@ iavf_add_del_all_mac_addr(struct iavf_adapter *adapter, bool add)
                len = sizeof(struct virtchnl_ether_addr_list);
                for (i = begin; i < IAVF_NUM_MACADDR_MAX; i++, next_begin++) {
                        addr = &adapter->eth_dev->data->mac_addrs[i];
-                       if (is_zero_ether_addr(addr))
+                       if (rte_is_zero_ether_addr(addr))
                                continue;
                        len += sizeof(struct virtchnl_ether_addr);
                        if (len >= IAVF_AQ_BUF_SZ) {
@@ -664,7 +709,7 @@ iavf_add_del_all_mac_addr(struct iavf_adapter *adapter, bool add)
 
                for (i = begin; i < next_begin; i++) {
                        addr = &adapter->eth_dev->data->mac_addrs[i];
-                       if (is_zero_ether_addr(addr))
+                       if (rte_is_zero_ether_addr(addr))
                                continue;
                        rte_memcpy(list->list[j].addr, addr->addr_bytes,
                                   sizeof(addr->addr_bytes));
@@ -808,3 +853,180 @@ iavf_add_del_vlan(struct iavf_adapter *adapter, uint16_t vlanid, bool add)
 
        return err;
 }
+
+int
+iavf_fdir_add(struct iavf_adapter *adapter,
+       struct iavf_fdir_conf *filter)
+{
+       struct iavf_info *vf = IAVF_DEV_PRIVATE_TO_VF(adapter);
+       struct virtchnl_fdir_add *fdir_ret;
+
+       struct iavf_cmd_info args;
+       int err;
+
+       filter->add_fltr.vsi_id = vf->vsi_res->vsi_id;
+       filter->add_fltr.validate_only = 0;
+
+       args.ops = VIRTCHNL_OP_ADD_FDIR_FILTER;
+       args.in_args = (uint8_t *)(&filter->add_fltr);
+       args.in_args_size = sizeof(*(&filter->add_fltr));
+       args.out_buffer = vf->aq_resp;
+       args.out_size = IAVF_AQ_BUF_SZ;
+
+       err = iavf_execute_vf_cmd(adapter, &args);
+       if (err) {
+               PMD_DRV_LOG(ERR, "fail to execute command OP_ADD_FDIR_FILTER");
+               return err;
+       }
+
+       fdir_ret = (struct virtchnl_fdir_add *)args.out_buffer;
+       filter->flow_id = fdir_ret->flow_id;
+
+       if (fdir_ret->status == VIRTCHNL_FDIR_SUCCESS) {
+               PMD_DRV_LOG(INFO,
+                       "Succeed in adding rule request by PF");
+       } else if (fdir_ret->status == VIRTCHNL_FDIR_FAILURE_RULE_NORESOURCE) {
+               PMD_DRV_LOG(ERR,
+                       "Failed to add rule request due to no hw resource");
+               return -1;
+       } else if (fdir_ret->status == VIRTCHNL_FDIR_FAILURE_RULE_EXIST) {
+               PMD_DRV_LOG(ERR,
+                       "Failed to add rule request due to the rule is already existed");
+               return -1;
+       } else if (fdir_ret->status == VIRTCHNL_FDIR_FAILURE_RULE_CONFLICT) {
+               PMD_DRV_LOG(ERR,
+                       "Failed to add rule request due to the rule is conflict with existing rule");
+               return -1;
+       } else if (fdir_ret->status == VIRTCHNL_FDIR_FAILURE_RULE_INVALID) {
+               PMD_DRV_LOG(ERR,
+                       "Failed to add rule request due to the hw doesn't support");
+               return -1;
+       } else if (fdir_ret->status == VIRTCHNL_FDIR_FAILURE_RULE_TIMEOUT) {
+               PMD_DRV_LOG(ERR,
+                       "Failed to add rule request due to time out for programming");
+               return -1;
+       } else {
+               PMD_DRV_LOG(ERR,
+                       "Failed to add rule request due to other reasons");
+               return -1;
+       }
+
+       return 0;
+};
+
+int
+iavf_fdir_del(struct iavf_adapter *adapter,
+       struct iavf_fdir_conf *filter)
+{
+       struct iavf_info *vf = IAVF_DEV_PRIVATE_TO_VF(adapter);
+       struct virtchnl_fdir_del *fdir_ret;
+
+       struct iavf_cmd_info args;
+       int err;
+
+       filter->del_fltr.vsi_id = vf->vsi_res->vsi_id;
+       filter->del_fltr.flow_id = filter->flow_id;
+
+       args.ops = VIRTCHNL_OP_DEL_FDIR_FILTER;
+       args.in_args = (uint8_t *)(&filter->del_fltr);
+       args.in_args_size = sizeof(filter->del_fltr);
+       args.out_buffer = vf->aq_resp;
+       args.out_size = IAVF_AQ_BUF_SZ;
+
+       err = iavf_execute_vf_cmd(adapter, &args);
+       if (err) {
+               PMD_DRV_LOG(ERR, "fail to execute command OP_DEL_FDIR_FILTER");
+               return err;
+       }
+
+       fdir_ret = (struct virtchnl_fdir_del *)args.out_buffer;
+
+       if (fdir_ret->status == VIRTCHNL_FDIR_SUCCESS) {
+               PMD_DRV_LOG(INFO,
+                       "Succeed in deleting rule request by PF");
+       } else if (fdir_ret->status == VIRTCHNL_FDIR_FAILURE_RULE_NONEXIST) {
+               PMD_DRV_LOG(ERR,
+                       "Failed to delete rule request due to this rule doesn't exist");
+               return -1;
+       } else if (fdir_ret->status == VIRTCHNL_FDIR_FAILURE_RULE_TIMEOUT) {
+               PMD_DRV_LOG(ERR,
+                       "Failed to delete rule request due to time out for programming");
+               return -1;
+       } else {
+               PMD_DRV_LOG(ERR,
+                       "Failed to delete rule request due to other reasons");
+               return -1;
+       }
+
+       return 0;
+};
+
+int
+iavf_fdir_check(struct iavf_adapter *adapter,
+               struct iavf_fdir_conf *filter)
+{
+       struct iavf_info *vf = IAVF_DEV_PRIVATE_TO_VF(adapter);
+       struct virtchnl_fdir_add *fdir_ret;
+
+       struct iavf_cmd_info args;
+       int err;
+
+       filter->add_fltr.vsi_id = vf->vsi_res->vsi_id;
+       filter->add_fltr.validate_only = 1;
+
+       args.ops = VIRTCHNL_OP_ADD_FDIR_FILTER;
+       args.in_args = (uint8_t *)(&filter->add_fltr);
+       args.in_args_size = sizeof(*(&filter->add_fltr));
+       args.out_buffer = vf->aq_resp;
+       args.out_size = IAVF_AQ_BUF_SZ;
+
+       err = iavf_execute_vf_cmd(adapter, &args);
+       if (err) {
+               PMD_DRV_LOG(ERR, "fail to check flow direcotor rule");
+               return err;
+       }
+
+       fdir_ret = (struct virtchnl_fdir_add *)args.out_buffer;
+
+       if (fdir_ret->status == VIRTCHNL_FDIR_SUCCESS) {
+               PMD_DRV_LOG(INFO,
+                       "Succeed in checking rule request by PF");
+       } else if (fdir_ret->status == VIRTCHNL_FDIR_FAILURE_RULE_INVALID) {
+               PMD_DRV_LOG(ERR,
+                       "Failed to check rule request due to parameters validation"
+                       " or HW doesn't support");
+               return -1;
+       } else {
+               PMD_DRV_LOG(ERR,
+                       "Failed to check rule request due to other reasons");
+               return -1;
+       }
+
+       return 0;
+}
+
+int
+iavf_add_del_rss_cfg(struct iavf_adapter *adapter,
+                    struct virtchnl_rss_cfg *rss_cfg, bool add)
+{
+       struct iavf_info *vf = IAVF_DEV_PRIVATE_TO_VF(adapter);
+       struct iavf_cmd_info args;
+       int err;
+
+       memset(&args, 0, sizeof(args));
+       args.ops = add ? VIRTCHNL_OP_ADD_RSS_CFG :
+               VIRTCHNL_OP_DEL_RSS_CFG;
+       args.in_args = (u8 *)rss_cfg;
+       args.in_args_size = sizeof(*rss_cfg);
+       args.out_buffer = vf->aq_resp;
+       args.out_size = IAVF_AQ_BUF_SZ;
+
+       err = iavf_execute_vf_cmd(adapter, &args);
+       if (err)
+               PMD_DRV_LOG(ERR,
+                           "Failed to execute command of %s",
+                           add ? "OP_ADD_RSS_CFG" :
+                           "OP_DEL_RSS_INPUT_CFG");
+
+       return err;
+}