ipvs: sctp implementation

include/conf/inet.h

@@ -89,6 +89,7 @@ static inline const char *inet_proto_name(uint8_t proto)
     const static char *proto_names[256] = {
         [IPPROTO_TCP]     = "TCP",
         [IPPROTO_UDP]     = "UDP",
+        [IPPROTO_SCTP]    = "SCTP",
         [IPPROTO_ICMP]    = "ICMP",
         [IPPROTO_ICMPV6]  = "ICMPV6",
     };

include/conf/match.h

@@ -93,6 +93,8 @@ static inline int parse_match(const char *pattern, uint8_t *proto,
             *proto = IPPROTO_TCP;
         } else if (strcmp(tok, "udp") == 0) {
             *proto = IPPROTO_UDP;
+        } else if (strcmp(tok, "sctp") == 0) {
+            *proto = IPPROTO_SCTP;
         } else if (strcmp(tok, "icmp") == 0) {
             *proto = IPPROTO_ICMP;
         } else if (strcmp(tok, "icmp6") == 0) {

include/conf/service.h

@@ -52,8 +52,9 @@
 #define DEST_HC_PASSIVE                 0x01
 #define DEST_HC_TCP                     0x02
 #define DEST_HC_UDP                     0x04
-#define DEST_HC_PING                    0x08
-#define DEST_HC_MASK_EXTERNAL           0x0e
+#define DEST_HC_SCTP                    0x08
+#define DEST_HC_PING                    0x10
+#define DEST_HC_MASK_EXTERNAL           0x1e
 
 /* defaults for dest passive health check */
 #define DEST_DOWN_NOTICE_DEFAULT        1

include/ipvs/proto_sctp.h

@@ -0,0 +1,66 @@
+/*
+ * DPVS is a software load balancer (Virtual Server) based on DPDK.
+ *
+ * Copyright (C) 2021 iQIYI (www.iqiyi.com).
+ * All Rights Reserved.
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU General Public License
+ * as published by the Free Software Foundation; either version 2
+ * of the License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ */
+#ifndef __DP_VS_PROTO_SCTP_H__
+#define __DP_VS_PROTO_SCTP_H__
+
+#include <netinet/in.h>
+#include "sctp/sctp.h"
+
+enum dpvs_sctp_event_t {
+	DPVS_SCTP_DATA = 0, /* DATA, SACK, HEARTBEATs */
+	DPVS_SCTP_INIT,
+	DPVS_SCTP_INIT_ACK,
+	DPVS_SCTP_COOKIE_ECHO,
+	DPVS_SCTP_COOKIE_ACK,
+	DPVS_SCTP_SHUTDOWN,
+	DPVS_SCTP_SHUTDOWN_ACK,
+	DPVS_SCTP_SHUTDOWN_COMPLETE,
+	DPVS_SCTP_ERROR,
+	DPVS_SCTP_ABORT,
+	DPVS_SCTP_EVENT_LAST
+};
+
+/* ip_vs_conn handling functions
+ * (from ip_vs_conn.c)
+ */
+enum { DPVS_DIR_INPUT = 0,
+       DPVS_DIR_OUTPUT,
+       DPVS_DIR_INPUT_ONLY,
+       DPVS_DIR_LAST,
+};
+
+/* SCTP State Values */
+enum dpvs_sctp_states {
+	DPVS_SCTP_S_NONE,
+	DPVS_SCTP_S_INIT1,
+	DPVS_SCTP_S_INIT,
+	DPVS_SCTP_S_COOKIE_SENT,
+	DPVS_SCTP_S_COOKIE_REPLIED,
+	DPVS_SCTP_S_COOKIE_WAIT,
+	DPVS_SCTP_S_COOKIE,
+	DPVS_SCTP_S_COOKIE_ECHOED,
+	DPVS_SCTP_S_ESTABLISHED,
+	DPVS_SCTP_S_SHUTDOWN_SENT,
+	DPVS_SCTP_S_SHUTDOWN_RECEIVED,
+	DPVS_SCTP_S_SHUTDOWN_ACK_SENT,
+	DPVS_SCTP_S_REJECTED,
+	DPVS_SCTP_S_CLOSED,
+	DPVS_SCTP_S_LAST
+};
+
+#endif

include/ipvs/stats.h

@@ -53,6 +53,7 @@ enum  dp_vs_estats_type {
     SYNPROXY_CONN_REUSED_CLOSEWAIT,
     SYNPROXY_CONN_REUSED_LASTACK,
     DEFENCE_IP_FRAG_DROP,
+    DEFENCE_SCTP_DROP,
     DEFENCE_TCP_DROP,
     DEFENCE_UDP_DROP,
     FAST_XMIT_REJECT,