VF is able to subscribe a flow from PF by VIRTCHNL_FLOW_SUBSCRIBE.

PF is expected to offload a rule to hardware which will redirect
the packet that matching the required pattern to this VF.

Only a flow with dst mac address as PF's mac address can be subscribed.

VIRTCHNL_VF_OFFLOAD_FSUB_PF is used for Flow subscription capability
negotiation and only a trusted VF can be granted with this capability.

A flow can be unsubscribed by VIRTCHNL_FLOW_UNSUBSCRIBE.

Signed-off-by: Jie Wang <jie1x.w...@intel.com>
Signed-off-by: Qi Zhang <qi.z.zh...@intel.com>
---
 drivers/common/iavf/virtchnl.h | 104 +++++++++++++++++++++++++++++++--
 1 file changed, 100 insertions(+), 4 deletions(-)

diff --git a/drivers/common/iavf/virtchnl.h b/drivers/common/iavf/virtchnl.h
index f123daec8e..e02eec4935 100644
--- a/drivers/common/iavf/virtchnl.h
+++ b/drivers/common/iavf/virtchnl.h
@@ -168,6 +168,8 @@ enum virtchnl_ops {
        VIRTCHNL_OP_MAP_QUEUE_VECTOR = 111,
        VIRTCHNL_OP_CONFIG_QUEUE_BW = 112,
        VIRTCHNL_OP_CONFIG_QUANTA = 113,
+       VIRTCHNL_OP_FLOW_SUBSCRIBE = 114,
+       VIRTCHNL_OP_FLOW_UNSUBSCRIBE = 115,
        VIRTCHNL_OP_MAX,
 };
 
@@ -282,6 +284,10 @@ static inline const char *virtchnl_op_str(enum 
virtchnl_ops v_opcode)
                return "VIRTCHNL_OP_1588_PTP_GET_CAPS";
        case VIRTCHNL_OP_1588_PTP_GET_TIME:
                return "VIRTCHNL_OP_1588_PTP_GET_TIME";
+       case VIRTCHNL_OP_FLOW_SUBSCRIBE:
+               return "VIRTCHNL_OP_FLOW_SUBSCRIBE";
+       case VIRTCHNL_OP_FLOW_UNSUBSCRIBE:
+               return "VIRTCHNL_OP_FLOW_UNSUBSCRIBE";
        case VIRTCHNL_OP_MAX:
                return "VIRTCHNL_OP_MAX";
        default:
@@ -401,6 +407,7 @@ VIRTCHNL_CHECK_STRUCT_LEN(16, virtchnl_vsi_resource);
 #define VIRTCHNL_VF_OFFLOAD_INLINE_IPSEC_CRYPTO        BIT(8)
 #define VIRTCHNL_VF_LARGE_NUM_QPAIRS           BIT(9)
 #define VIRTCHNL_VF_OFFLOAD_CRC                        BIT(10)
+#define VIRTCHNL_VF_OFFLOAD_FSUB_PF            BIT(14)
 #define VIRTCHNL_VF_OFFLOAD_VLAN_V2            BIT(15)
 #define VIRTCHNL_VF_OFFLOAD_VLAN               BIT(16)
 #define VIRTCHNL_VF_OFFLOAD_RX_POLLING         BIT(17)
@@ -1503,6 +1510,7 @@ enum virtchnl_vfr_states {
 };
 
 #define VIRTCHNL_MAX_NUM_PROTO_HDRS    32
+#define VIRTCHNL_MAX_NUM_PROTO_HDRS_W_MSK      16
 #define VIRTCHNL_MAX_SIZE_RAW_PACKET   1024
 #define PROTO_HDR_SHIFT                        5
 #define PROTO_HDR_FIELD_START(proto_hdr_type) \
@@ -1695,6 +1703,22 @@ struct virtchnl_proto_hdr {
 
 VIRTCHNL_CHECK_STRUCT_LEN(72, virtchnl_proto_hdr);
 
+struct virtchnl_proto_hdr_w_msk {
+       /* see enum virtchnl_proto_hdr_type */
+       s32 type;
+       u32 pad;
+       /**
+        * binary buffer in network order for specific header type.
+        * For example, if type = VIRTCHNL_PROTO_HDR_IPV4, a IPv4
+        * header is expected to be copied into the buffer.
+        */
+       u8 buffer_spec[64];
+       /* binary buffer for bit-mask applied to specific header type */
+       u8 buffer_mask[64];
+};
+
+VIRTCHNL_CHECK_STRUCT_LEN(136, virtchnl_proto_hdr_w_msk);
+
 struct virtchnl_proto_hdrs {
        u8 tunnel_level;
        /**
@@ -1706,11 +1730,18 @@ struct virtchnl_proto_hdrs {
         */
        int count;
        /**
-        * number of proto layers, must < VIRTCHNL_MAX_NUM_PROTO_HDRS
-        * must be 0 for a raw packet request.
+        * count must <=
+        * VIRTCHNL_MAX_NUM_PROTO_HDRS + VIRTCHNL_MAX_NUM_PROTO_HDRS_W_MSK
+        * count = 0 :                                  select raw
+        * 1 < count <= VIRTCHNL_MAX_NUM_PROTO_HDRS :   select proto_hdr
+        * count > VIRTCHNL_MAX_NUM_PROTO_HDRS :        select proto_hdr_w_msk
+        * last valid index = count - VIRTCHNL_MAX_NUM_PROTO_HDRS
         */
        union {
-               struct virtchnl_proto_hdr 
proto_hdr[VIRTCHNL_MAX_NUM_PROTO_HDRS];
+               struct virtchnl_proto_hdr
+                       proto_hdr[VIRTCHNL_MAX_NUM_PROTO_HDRS];
+               struct virtchnl_proto_hdr_w_msk
+                       proto_hdr_w_msk[VIRTCHNL_MAX_NUM_PROTO_HDRS_W_MSK];
                struct {
                        u16 pkt_len;
                        u8 spec[VIRTCHNL_MAX_SIZE_RAW_PACKET];
@@ -1731,7 +1762,7 @@ struct virtchnl_rss_cfg {
 
 VIRTCHNL_CHECK_STRUCT_LEN(2444, virtchnl_rss_cfg);
 
-/* action configuration for FDIR */
+/* action configuration for FDIR and FSUB */
 struct virtchnl_filter_action {
        /* see enum virtchnl_action type */
        s32 type;
@@ -1849,6 +1880,65 @@ struct virtchnl_fdir_del {
 
 VIRTCHNL_CHECK_STRUCT_LEN(12, virtchnl_fdir_del);
 
+/* Status returned to VF after VF requests FSUB commands
+ * VIRTCHNL_FSUB_SUCCESS
+ * VF FLOW related request is successfully done by PF
+ * The request can be OP_FLOW_SUBSCRIBE/UNSUBSCRIBE.
+ *
+ * VIRTCHNL_FSUB_FAILURE_RULE_NORESOURCE
+ * OP_FLOW_SUBSCRIBE request is failed due to no Hardware resource.
+ *
+ * VIRTCHNL_FSUB_FAILURE_RULE_EXIST
+ * OP_FLOW_SUBSCRIBE request is failed due to the rule is already existed.
+ *
+ * VIRTCHNL_FSUB_FAILURE_RULE_NONEXIST
+ * OP_FLOW_UNSUBSCRIBE request is failed due to this rule doesn't exist.
+ *
+ * VIRTCHNL_FSUB_FAILURE_RULE_INVALID
+ * OP_FLOW_SUBSCRIBE request is failed due to parameters validation
+ * or HW doesn't support.
+ */
+enum virtchnl_fsub_prgm_status {
+       VIRTCHNL_FSUB_SUCCESS = 0,
+       VIRTCHNL_FSUB_FAILURE_RULE_NORESOURCE,
+       VIRTCHNL_FSUB_FAILURE_RULE_EXIST,
+       VIRTCHNL_FSUB_FAILURE_RULE_NONEXIST,
+       VIRTCHNL_FSUB_FAILURE_RULE_INVALID,
+};
+
+/* VIRTCHNL_OP_FLOW_SUBSCRIBE
+ * VF sends this request to PF by filling out vsi_id,
+ * validate_only, priority, proto_hdrs and actions.
+ * PF will return flow_id
+ * if the request is successfully done and return status to VF.
+ */
+struct virtchnl_flow_sub {
+       u16 vsi_id; /* INPUT */
+       u8 validate_only; /* INPUT */
+       u8 priority; /* INPUT */
+       u32 flow_id; /* OUTPUT */
+       struct virtchnl_proto_hdrs proto_hdrs; /* INPUT */
+       struct virtchnl_filter_action_set actions; /* INPUT */
+       /* see enum virtchnl_fsub_prgm_status; OUTPUT */
+       s32 status;
+};
+
+VIRTCHNL_CHECK_STRUCT_LEN(2616, virtchnl_flow_sub);
+
+/* VIRTCHNL_OP_FLOW_UNSUBSCRIBE
+ * VF sends this request to PF by filling out vsi_id
+ * and flow_id. PF will return status to VF.
+ */
+struct virtchnl_flow_unsub {
+       u16 vsi_id; /* INPUT */
+       u16 pad;
+       u32 flow_id; /* INPUT */
+       /* see enum virtchnl_fsub_prgm_status; OUTPUT */
+       s32 status;
+};
+
+VIRTCHNL_CHECK_STRUCT_LEN(12, virtchnl_flow_unsub);
+
 /* VIRTCHNL_OP_GET_QOS_CAPS
  * VF sends this message to get its QoS Caps, such as
  * TC number, Arbiter and Bandwidth.
@@ -2318,6 +2408,12 @@ virtchnl_vc_validate_vf_msg(struct virtchnl_version_info 
*ver, u32 v_opcode,
        case VIRTCHNL_OP_DEL_FDIR_FILTER:
                valid_len = sizeof(struct virtchnl_fdir_del);
                break;
+       case VIRTCHNL_OP_FLOW_SUBSCRIBE:
+               valid_len = sizeof(struct virtchnl_flow_sub);
+               break;
+       case VIRTCHNL_OP_FLOW_UNSUBSCRIBE:
+               valid_len = sizeof(struct virtchnl_flow_unsub);
+               break;
        case VIRTCHNL_OP_GET_QOS_CAPS:
                break;
        case VIRTCHNL_OP_CONFIG_QUEUE_TC_MAP:
-- 
2.25.1

Reply via email to