From: Danylo Vodopianov <dvo-...@napatech.com>

Add possibility to use RTE_FLOW_ITEM_TYPE_SCTP

Signed-off-by: Danylo Vodopianov <dvo-...@napatech.com>
---
 doc/guides/nics/features/ntnic.ini            |   1 +
 drivers/net/ntnic/include/hw_mod_backend.h    |   2 +
 .../profile_inline/flow_api_profile_inline.c  | 102 ++++++++++++++++++
 3 files changed, 105 insertions(+)

diff --git a/doc/guides/nics/features/ntnic.ini 
b/doc/guides/nics/features/ntnic.ini
index 8b4821d6d0..6691b6dce2 100644
--- a/doc/guides/nics/features/ntnic.ini
+++ b/doc/guides/nics/features/ntnic.ini
@@ -19,6 +19,7 @@ eth                  = Y
 icmp                 = Y
 ipv4                 = Y
 port_id              = Y
+sctp                 = Y
 tcp                  = Y
 udp                  = Y
 vlan                 = Y
diff --git a/drivers/net/ntnic/include/hw_mod_backend.h 
b/drivers/net/ntnic/include/hw_mod_backend.h
index 82ac3d0ff3..f1c57fa9fc 100644
--- a/drivers/net/ntnic/include/hw_mod_backend.h
+++ b/drivers/net/ntnic/include/hw_mod_backend.h
@@ -169,6 +169,7 @@ enum {
 enum {
        PROT_L4_TCP = 1,
        PROT_L4_UDP = 2,
+       PROT_L4_SCTP = 3,
        PROT_L4_ICMP = 4
 };
 
@@ -181,6 +182,7 @@ enum {
        PROT_TUN_L4_OTHER = 0,
        PROT_TUN_L4_TCP = 1,
        PROT_TUN_L4_UDP = 2,
+       PROT_TUN_L4_SCTP = 3,
        PROT_TUN_L4_ICMP = 4
 };
 
diff --git 
a/drivers/net/ntnic/nthw/flow_api/profile_inline/flow_api_profile_inline.c 
b/drivers/net/ntnic/nthw/flow_api/profile_inline/flow_api_profile_inline.c
index 7c1b632dc0..9460325cf6 100644
--- a/drivers/net/ntnic/nthw/flow_api/profile_inline/flow_api_profile_inline.c
+++ b/drivers/net/ntnic/nthw/flow_api/profile_inline/flow_api_profile_inline.c
@@ -1017,6 +1017,100 @@ static int interpret_flow_elements(const struct 
flow_eth_dev *dev,
 
                        break;
 
+               case RTE_FLOW_ITEM_TYPE_SCTP:
+                       NT_LOG(DBG, FILTER, "Adap %i,Port 
%i:RTE_FLOW_ITEM_TYPE_SCTP",
+                               dev->ndev->adapter_no, dev->port);
+                       {
+                               const struct rte_flow_item_sctp *sctp_spec =
+                                       (const struct rte_flow_item_sctp 
*)elem[eidx].spec;
+                               const struct rte_flow_item_sctp *sctp_mask =
+                                       (const struct rte_flow_item_sctp 
*)elem[eidx].mask;
+
+                               if (sctp_spec == NULL || sctp_mask == NULL) {
+                                       if (any_count > 0 || fd->l4_prot != -1) 
{
+                                               fd->tunnel_l4_prot = 
PROT_TUN_L4_SCTP;
+                                               key_def->inner_proto = 1;
+                                       } else {
+                                               fd->l4_prot = PROT_L4_SCTP;
+                                               key_def->outer_proto = 1;
+                                       }
+                                       break;
+                               }
+
+                               if (sctp_mask->hdr.tag != 0 || 
sctp_mask->hdr.cksum != 0) {
+                                       NT_LOG(ERR, FILTER,
+                                               "Requested SCTP field not 
support by running SW version");
+                                       flow_nic_set_error(ERR_FAILED, error);
+                                       return -1;
+                               }
+
+                               if (sctp_mask->hdr.src_port || 
sctp_mask->hdr.dst_port) {
+                                       if (sw_counter < 2) {
+                                               uint32_t *sw_data = 
&packet_data[1 - sw_counter];
+                                               uint32_t *sw_mask = 
&packet_mask[1 - sw_counter];
+
+                                               sw_mask[0] = 
(ntohs(sctp_mask->hdr.src_port)
+                                                       << 16) | 
ntohs(sctp_mask->hdr.dst_port);
+                                               sw_data[0] = 
((ntohs(sctp_spec->hdr.src_port)
+                                                       << 16) | 
ntohs(sctp_spec->hdr.dst_port)) &
+                                                       sw_mask[0];
+
+                                               km_add_match_elem(&fd->km, 
&sw_data[0], &sw_mask[0],
+                                                       1, any_count > 0 ? 
DYN_TUN_L4 : DYN_L4, 0);
+                                               set_key_def_sw(key_def, 
sw_counter, any_count > 0
+                                                       ? DYN_TUN_L4 : DYN_L4, 
0);
+                                               sw_counter += 1;
+
+                                       } else if (qw_counter < 2 && qw_free > 
0) {
+                                               uint32_t *qw_data =
+                                                       &packet_data[2 + 4 - 
qw_counter * 4];
+                                               uint32_t *qw_mask =
+                                                       &packet_mask[2 + 4 - 
qw_counter * 4];
+
+                                               qw_data[0] = 
(ntohs(sctp_spec->hdr.src_port)
+                                                       << 16) | 
ntohs(sctp_spec->hdr.dst_port);
+                                               qw_data[1] = 0;
+                                               qw_data[2] = 0;
+                                               qw_data[3] = 0;
+
+                                               qw_mask[0] = 
(ntohs(sctp_mask->hdr.src_port)
+                                                       << 16) | 
ntohs(sctp_mask->hdr.dst_port);
+                                               qw_mask[1] = 0;
+                                               qw_mask[2] = 0;
+                                               qw_mask[3] = 0;
+
+                                               qw_data[0] &= qw_mask[0];
+                                               qw_data[1] &= qw_mask[1];
+                                               qw_data[2] &= qw_mask[2];
+                                               qw_data[3] &= qw_mask[3];
+
+                                               km_add_match_elem(&fd->km, 
&qw_data[0], &qw_mask[0],
+                                                       4, any_count > 0 ? 
DYN_TUN_L4 : DYN_L4, 0);
+                                               set_key_def_qw(key_def, 
qw_counter, any_count > 0
+                                                       ? DYN_TUN_L4 : DYN_L4, 
0);
+                                               qw_counter += 1;
+                                               qw_free -= 1;
+
+                                       } else {
+                                               NT_LOG(ERR, FILTER,
+                                                       "Key size too big. Out 
of SW-QW resources.");
+                                               flow_nic_set_error(ERR_FAILED, 
error);
+                                               return -1;
+                                       }
+                               }
+
+                               if (any_count > 0 || fd->l4_prot != -1) {
+                                       fd->tunnel_l4_prot = PROT_TUN_L4_SCTP;
+                                       key_def->inner_proto = 1;
+
+                               } else {
+                                       fd->l4_prot = PROT_L4_SCTP;
+                                       key_def->outer_proto = 1;
+                               }
+                       }
+
+                       break;
+
                case RTE_FLOW_ITEM_TYPE_ICMP:
                        NT_LOG(DBG, FILTER, "Adap %i, Port %i: 
RTE_FLOW_ITEM_TYPE_ICMP",
                                dev->ndev->adapter_no, dev->port);
@@ -1258,6 +1352,10 @@ static void copy_fd_to_fh_flm(struct flow_handle *fh, 
const struct nic_flow_def
                fh->flm_prot = 17;
                break;
 
+       case PROT_L4_SCTP:
+               fh->flm_prot = 132;
+               break;
+
        case PROT_L4_ICMP:
                fh->flm_prot = fd->ip_prot;
                break;
@@ -1272,6 +1370,10 @@ static void copy_fd_to_fh_flm(struct flow_handle *fh, 
const struct nic_flow_def
                        fh->flm_prot = 17;
                        break;
 
+               case PROT_TUN_L4_SCTP:
+                       fh->flm_prot = 132;
+                       break;
+
                case PROT_TUN_L4_ICMP:
                        fh->flm_prot = fd->tunnel_ip_prot;
                        break;
-- 
2.45.0

Reply via email to