[PATCH lksctp-tools 0/2] func_tests: Add test cases for interleaving and stream RE_CONFIG

[PATCH lksctp-tools 0/2] func_tests: Add test cases for interleaving and stream RE_CONFIG

[Yuxuan Luo]

Add two test cases for verifying the support
for interleaving and re_config recently implemented in kernel.

Signed-off-by: Yuxuan Luo <luoyuxuan.carl@gmail.com>

Yuxuan Luo (2):
  Add a test case for interleaving
  Add a test cacse for RE_CONFIG

 configure.ac                     |   3 +
 src/func_tests/.gitignore        |   4 +
 src/func_tests/Makefile.am       |  20 +++
 src/func_tests/test_interleave.c | 254 +++++++++++++++++++++++++++++++
 src/func_tests/test_re_conf.c    | 251 ++++++++++++++++++++++++++++++
 5 files changed, 532 insertions(+)
 create mode 100644 src/func_tests/test_interleave.c
 create mode 100644 src/func_tests/test_re_conf.c

-- 
2.37.1

[PATCH lksctp-tools 1/2] Add a test case for interleaving

[Yuxuan Luo]

Add a test case for verifying the support for user message interleave
implemented in RFC8260.

This test case will not be built if the SCTP_FRAGMENT_INTERLEAVE
declaration is not present and will skip if net.sctp.intl_enable
is not set to 1.
---
 configure.ac                     |   3 +
 src/func_tests/.gitignore        |   2 +
 src/func_tests/Makefile.am       |  10 ++
 src/func_tests/test_interleave.c | 254 +++++++++++++++++++++++++++++++
 4 files changed, 269 insertions(+)
 create mode 100644 src/func_tests/test_interleave.c

diff --git a/configure.ac b/configure.ac
index 28132bf..bd0144c 100644
--- a/configure.ac
+++ b/configure.ac
@@ -107,6 +107,9 @@ LKSCTP_CHECK_MEMBER([struct sctp_paddrparams.spp_ipv6_flowlabel],
 LKSCTP_CHECK_MEMBER([struct sctp_paddrparams.spp_dscp],
 		    [HAVE_SCTP_SPP_DSCP])
 
+# RFC 8260 (Message Interleaving)
+LKSCTP_CHECK_DECL([SCTP_FRAGMENT_INTERLEAVE], [HAVE_SCTP_FRAGMENT_INTERLEAVE])
+
 AC_CONFIG_HEADERS([src/include/netinet/sctp.h])
 AC_CONFIG_FILES([lksctp-tools.spec
 		Makefile
diff --git a/src/func_tests/.gitignore b/src/func_tests/.gitignore
index 720db65..4e51a74 100644
--- a/src/func_tests/.gitignore
+++ b/src/func_tests/.gitignore
@@ -28,6 +28,8 @@ test_getname
 test_getname_v6
 test_inaddr_any
 test_inaddr_any_v6
+test_interleave
+test_interleave_v6
 test_peeloff
 test_peeloff_v6
 test_recvmsg
diff --git a/src/func_tests/Makefile.am b/src/func_tests/Makefile.am
index e5bf454..07d9fa4 100644
--- a/src/func_tests/Makefile.am
+++ b/src/func_tests/Makefile.am
@@ -68,6 +68,13 @@ PASSING_V6_KERN_TESTS += \
 	test_sctp_sendvrecvv_v6
 endif
 
+if HAVE_SCTP_FRAGMENT_INTERLEAVE
+PASSING_KERN_TESTS += \
+	test_interleave
+PASSING_V6_KERN_TESTS += \
+	test_interleave_v6
+endif
+
 noinst_PROGRAMS = ${PASSING_KERN_TESTS} ${PASSING_V6_KERN_TESTS}
 
 $(top_builddir)/src/lib/libsctp.la:
@@ -177,3 +184,6 @@ test_getname_v6_CFLAGS = ${V6FLAGS}
 
 test_tcp_style_v6_SOURCES = test_tcp_style.c
 test_tcp_style_v6_CFLAGS = ${V6FLAGS}
+
+test_interleave_v6_SOURCES = test_interleave.c
+test_interleave_v6_CFLAGS = ${V6FLAGS}
diff --git a/src/func_tests/test_interleave.c b/src/func_tests/test_interleave.c
new file mode 100644
index 0000000..d92e2b0
--- /dev/null
+++ b/src/func_tests/test_interleave.c
@@ -0,0 +1,254 @@
+/* This purpose of this test is to examine the
+ * support of the interleaving
+ * The following tests are done in sequence:
+ * - Verify SCTP_FRAGMENT_INTERLEAVE and SCTP_INTERLEAVING_SUPPORTED
+ *   socket option by doing a setsockopt() followed by a getsockopt()
+ * - Verify the integrity of the data sent by client using a sendmsg()
+ */
+
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/uio.h>
+#include <netinet/in.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <netinet/sctp.h>
+#include <sctputil.h>
+
+#define MSG_SIZE 1000
+
+char *TCID = __FILE__;
+int TST_TOTAL = 2;
+int TST_CNT = 0;
+
+int
+main(int argc, char *argv[])
+{
+	int sk1, sk2;
+	int pf_class;
+	int error;
+	int fd;
+	int msg_len, bytes_sent;
+	int frag_interleave, get_result;
+	sockaddr_storage_t loop1;
+	sockaddr_storage_t loop2;
+	struct iovec iov;
+	struct iovec out_iov;
+	struct msghdr inmessage;
+	struct msghdr outmessage;
+	struct cmsghdr *cmsg;
+	struct sctp_sndrcvinfo *sinfo;
+	struct sctp_assoc_value assoc, get_assoc;
+	uint32_t ppid;
+	uint32_t stream;
+	char *buffer;
+	char setting[4];
+	char incmsg[CMSG_SPACE(sizeof(sctp_cmsg_data_t))];
+	char outcmsg[CMSG_SPACE(sizeof(struct sctp_sndrcvinfo))];
+	void *msg_buffer;
+	socklen_t optlen;
+
+	/* Rather than fflush() throughout the code, set stdout to
+	 * be unbuffered.
+	 */
+	setvbuf(stdout, NULL, _IONBF, 0);
+
+	/* Set some basic values which depend on the address family. */
+#if TEST_V6
+	pf_class = PF_INET6;
+
+	loop1.v6.sin6_family = AF_INET6;
+	loop1.v6.sin6_addr = in6addr_loopback;
+	loop1.v6.sin6_port = htons(SCTP_TESTPORT_1);
+
+	loop2.v6.sin6_family = AF_INET6;
+	loop2.v6.sin6_addr = in6addr_loopback;
+	loop2.v6.sin6_port = htons(SCTP_TESTPORT_2);
+#else
+	pf_class = PF_INET;
+
+	loop1.v4.sin_family = AF_INET;
+	loop1.v4.sin_addr.s_addr = SCTP_IP_LOOPBACK;
+	loop1.v4.sin_port = htons(SCTP_TESTPORT_1);
+
+	loop2.v4.sin_family = AF_INET;
+	loop2.v4.sin_addr.s_addr = SCTP_IP_LOOPBACK;
+	loop2.v4.sin_port = htons(SCTP_TESTPORT_2);
+#endif /* TEST_V6 */
+
+	/* Create the two endpoints which will talk to each other */
+	sk1 = test_socket(pf_class, SOCK_SEQPACKET, IPPROTO_SCTP);
+	sk2 = test_socket(pf_class, SOCK_SEQPACKET, IPPROTO_SCTP);
+
+	/* Enable ASSOC_CHANGE and SNDRCVINFO notifications */
+	test_enable_assoc_change(sk1);
+	test_enable_assoc_change(sk2);
+
+	/* Bind these sockets to the test ports */
+	test_bind(sk1, &loop1.sa, sizeof(loop1));
+	test_bind(sk2, &loop2.sa, sizeof(loop2));
+
+	/* Let sk2 listen to new associations */
+	test_listen(sk2, 1);
+
+	/* TEST #1: verify SCTP_FRAGMENT_INTERLEAVE option
+	 *          followed by a getsockopt()
+	 */
+	frag_interleave = 1;
+	test_setsockopt(sk1, SCTP_FRAGMENT_INTERLEAVE,
+			&frag_interleave, sizeof(frag_interleave));
+	test_setsockopt(sk2, SCTP_FRAGMENT_INTERLEAVE,
+			&frag_interleave, sizeof(frag_interleave));
+
+	tst_resm(TPASS, "setsockopt(SCTP_FRAGMENT_INTERLEAVE)");
+
+	get_result = 0;
+	optlen = sizeof(get_result);
+	error = test_getsockopt(sk1, SCTP_FRAGMENT_INTERLEAVE,
+				&get_result, &optlen);
+	if (get_result != frag_interleave)
+		tst_brkm(TBROK, tst_exit, "getsockopt(SCTP_FRAGMENT_INTERLEAVE) "
+			 "error: %d errno: %d get_result: %d",
+			 error, errno, get_result);
+	get_result = 0;
+	error = test_getsockopt(sk2, SCTP_FRAGMENT_INTERLEAVE,
+				&get_result, &optlen);
+	if (get_result != frag_interleave)
+		tst_brkm(TBROK, tst_exit, "getsockopt(SCTP_FRAGMENT_INTERLEAVE) "
+			 "error: %d errno: %d get_result: %d",
+			 error, errno, get_result);
+
+	tst_resm(TPASS, "getsockopt(SCTP_FRAGMENT_INTERLEAVE)");
+
+	/* Check if net.sctp.intl_enable=1, exit if not */
+	fd = open("/proc/sys/net/sctp/intl_enable", O_RDONLY);
+	if (fd < 0 ||
+	    read(fd, &setting, 4) < 0 ||
+	    strncmp("1", setting, 1) != 0) {
+		tst_resm(TINFO, "intl_enable is not set to 1, skip test\n");
+		return 0;
+	}
+	close(fd);
+
+	assoc.assoc_id = 0;
+	assoc.assoc_value = 1;
+	test_setsockopt(sk1, SCTP_INTERLEAVING_SUPPORTED,
+			&assoc, sizeof(assoc));
+	test_setsockopt(sk2, SCTP_INTERLEAVING_SUPPORTED,
+			&assoc, sizeof(assoc));
+
+	tst_resm(TPASS, "setsockopt(SCTP_INTERLEAVING_SUPPORTED)");
+
+
+	memset(&get_assoc, 0x00, sizeof(struct sctp_assoc_value));
+	optlen = sizeof(get_assoc);
+	error = test_getsockopt(sk1, SCTP_INTERLEAVING_SUPPORTED,
+				&get_assoc, &optlen);
+	if (get_assoc.assoc_value != 1)
+		tst_brkm(TBROK, tst_exit,
+			 "getsockopt(SCTP_INTERLEAVING_SUPPORTED) "
+			 "error: %d errno: %d get_result: %d",
+			 error, errno, get_assoc.assoc_value);
+	error = test_getsockopt(sk2, SCTP_INTERLEAVING_SUPPORTED,
+				&get_assoc, &optlen);
+	if (get_assoc.assoc_value != 1)
+		tst_brkm(TBROK, tst_exit,
+			 "getsockopt(SCTP_INTERLEAVING_SUPPORTED) "
+			 "error: %d errno: %d get_result: %d",
+			 error, errno, get_assoc.assoc_value);
+
+	tst_resm(TPASS, "getsockopt(SCTP_INTERLEAVING_SUPPORTED)");
+	/* End of TEST #1 */
+
+	/* Send the first message to create an association */
+	outmessage.msg_name = &loop2;
+	outmessage.msg_namelen = sizeof(loop2);
+	outmessage.msg_iov = &out_iov;
+	outmessage.msg_iovlen = 1;
+	outmessage.msg_control = outcmsg;
+	outmessage.msg_controllen = sizeof(outcmsg);
+	outmessage.msg_flags = 0;
+	cmsg = CMSG_FIRSTHDR(&outmessage);
+	cmsg->cmsg_level = IPPROTO_SCTP;
+	cmsg->cmsg_type = SCTP_SNDRCV;
+	cmsg->cmsg_len = CMSG_LEN(sizeof(struct sctp_sndrcvinfo));
+	sinfo = (struct sctp_sndrcvinfo *)CMSG_DATA(cmsg);
+	memset(sinfo, 0x00, sizeof(struct sctp_sndrcvinfo));
+	ppid = rand(); /* Choose an arbitrary value */
+	stream = 1;
+	sinfo->sinfo_ppid = ppid;
+	sinfo->sinfo_stream = stream;
+	msg_len = 10;
+	msg_buffer = test_build_msg(10);
+	outmessage.msg_iov->iov_base = msg_buffer;
+	outmessage.msg_iov->iov_len = msg_len;
+	test_sendmsg(sk1, &outmessage, 0, msg_len);
+
+	/* Initialize inmessage for all receives */
+	buffer = test_malloc(REALLY_BIG);
+	memset(&inmessage, 0x00, sizeof(inmessage));
+	iov.iov_base = buffer;
+	iov.iov_len = REALLY_BIG;
+	inmessage.msg_iov = &iov;
+	inmessage.msg_iovlen = 1;
+	inmessage.msg_control = incmsg;
+
+	/* Get the communication up message on sk2 */
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(sk2, &inmessage, MSG_WAITALL);
+	test_check_msg_notification(&inmessage, error,
+				    sizeof(struct sctp_assoc_change),
+				    SCTP_ASSOC_CHANGE, SCTP_COMM_UP);
+
+	/* Get the communication up message on sk1 */
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(sk1, &inmessage, MSG_WAITALL);
+	test_check_msg_notification(&inmessage, error,
+				    sizeof(struct sctp_assoc_change),
+				    SCTP_ASSOC_CHANGE, SCTP_COMM_UP);
+
+	/* Get the first message which was sent.  */
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(sk2, &inmessage, MSG_WAITALL);
+	test_check_msg_data(&inmessage, error, msg_len, MSG_EOR, stream, ppid);
+
+	/* TEST #2: Verify data integrity */
+	msg_len = MSG_SIZE;
+	msg_buffer = test_build_msg(msg_len);
+	outmessage.msg_iov->iov_base = msg_buffer;
+	outmessage.msg_iov->iov_len = msg_len;
+	bytes_sent = test_sendmsg(sk1, &outmessage, 0, msg_len);
+
+	tst_resm(TINFO, "Sent %d byte message", bytes_sent);
+
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(sk2, &inmessage, MSG_WAITALL);
+
+	tst_resm(TINFO, "Received %d byte message", error);
+
+	test_check_msg_data(&inmessage, error, bytes_sent,
+			    MSG_EOR, stream, ppid);
+
+	tst_resm(TPASS, "Received same byte of message");
+	/* End of TEST #2 */
+
+	/* Shut down the link */
+	close(sk1);
+
+	/* Get the shutdown complete notification */
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(sk2, &inmessage, MSG_WAITALL);
+	test_check_msg_notification(&inmessage, error,
+				    sizeof(struct sctp_assoc_change),
+				    SCTP_ASSOC_CHANGE, SCTP_SHUTDOWN_COMP);
+	close(sk2);
+
+	free(buffer);
+
+	/* Indicate successful completion */
+	return 0;
+}
-- 
2.37.1

[PATCH lksctp-tools 2/2] Add a test cacse for RE_CONFIG

[Yuxuan Luo]

Add a test case for verifying the support for stream re_config
implemented in RFC6525.

This test case will not be built if the SCTP_RECONFIG_SUPPORTED
declaration is not present and will abort if net.sctp.reconf_enable
is not set to 1.
---
 src/func_tests/.gitignore     |   2 +
 src/func_tests/Makefile.am    |  10 ++
 src/func_tests/test_re_conf.c | 251 ++++++++++++++++++++++++++++++++++
 3 files changed, 263 insertions(+)
 create mode 100644 src/func_tests/test_re_conf.c

diff --git a/src/func_tests/.gitignore b/src/func_tests/.gitignore
index 4e51a74..175e71b 100644
--- a/src/func_tests/.gitignore
+++ b/src/func_tests/.gitignore
@@ -32,6 +32,8 @@ test_interleave
 test_interleave_v6
 test_peeloff
 test_peeloff_v6
+test_re_conf
+test_re_conf_v6
 test_recvmsg
 test_sctp_sendrecvmsg
 test_sctp_sendrecvmsg_v6
diff --git a/src/func_tests/Makefile.am b/src/func_tests/Makefile.am
index 07d9fa4..54e1627 100644
--- a/src/func_tests/Makefile.am
+++ b/src/func_tests/Makefile.am
@@ -75,6 +75,13 @@ PASSING_V6_KERN_TESTS += \
 	test_interleave_v6
 endif
 
+if HAVE_SCTP_STREAM_RECONFIG
+PASSING_KERN_TESTS += \
+	test_re_conf
+PASSING_V6_KERN_TESTS += \
+	test_re_conf_v6
+endif
+
 noinst_PROGRAMS = ${PASSING_KERN_TESTS} ${PASSING_V6_KERN_TESTS}
 
 $(top_builddir)/src/lib/libsctp.la:
@@ -187,3 +194,6 @@ test_tcp_style_v6_CFLAGS = ${V6FLAGS}
 
 test_interleave_v6_SOURCES = test_interleave.c
 test_interleave_v6_CFLAGS = ${V6FLAGS}
+
+test_re_conf_v6_SOURCES = test_re_conf.c
+test_re_conf_v6_CFLAGS = ${V6FLAGS}
diff --git a/src/func_tests/test_re_conf.c b/src/func_tests/test_re_conf.c
new file mode 100644
index 0000000..ea330a9
--- /dev/null
+++ b/src/func_tests/test_re_conf.c
@@ -0,0 +1,251 @@
+/* The purpose of this test is to examine the support for RE-CONFIG chunk
+ * The following tests are done in sequence:
+ * - Verify the SCTP_ENABLE_STREAM_RESET option by doing a setsockopt()
+ *   followed by a getsockopt()
+ * - Verify the reset I/O stream functionality by setting SCTP_RESET_STREAMS
+ * - Verify the reset assoc functionality by setting SCTP_RESET_ASSOC
+ * - Verify the add streams functionality by setting SCTP_ADD_STREAMS
+ */
+
+#include <stdio.h>
+#include <unistd.h>
+#include <stdlib.h>
+#include <string.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/uio.h>
+#include <netinet/in.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <netinet/sctp.h>
+#include <sctputil.h>
+
+#define STREAM_NUM 3
+#define ADD_STREAM 2
+
+char *TCID = __FILE__;
+int TST_TOTAL = 4;
+int TST_CNT = 0;
+
+int
+main(int argc, char *argv[])
+{
+	int error;
+	int sk1, sk2, acpt_sk;
+	int pf_class;
+	int fd;
+	int msg_len;
+	void *msg_buffer;
+	sockaddr_storage_t loop1;
+	sockaddr_storage_t loop2;
+	sockaddr_storage_t acpt_addr;
+	sctp_assoc_t assoc_id;
+	socklen_t optlen, sock_len;
+	uint32_t ppid;
+	uint32_t stream;
+	struct msghdr inmessage;
+	struct msghdr outmessage;
+	struct iovec iov;
+	struct iovec out_iov;
+	struct cmsghdr *cmsg;
+	struct sctp_assoc_value assoc;
+	struct sctp_assoc_value get_assoc;
+	struct sctp_reset_streams *srs;
+	struct sctp_add_streams *sas;
+	struct sctp_sndrcvinfo *sinfo;
+	char setting[4];
+	char * buffer;
+	char incmsg[CMSG_SPACE(sizeof(sctp_cmsg_data_t))];
+	char outcmsg[CMSG_SPACE(sizeof(struct sctp_sndrcvinfo))];
+
+	/* Rather than fflush() throughout the code, set stdout to
+	 * be unbuffered.
+	 */
+	setvbuf(stdout, NULL, _IONBF, 0);
+
+#if TEST_V6
+	pf_class = PF_INET6;
+	sock_len = sizeof(struct sockaddr_in6);
+
+	loop1.v6.sin6_family = AF_INET6;
+	loop1.v6.sin6_addr = in6addr_loopback;
+	loop1.v6.sin6_port = htons(SCTP_TESTPORT_1);
+
+	loop2.v6.sin6_family = AF_INET6;
+	loop2.v6.sin6_addr = in6addr_loopback;
+	loop2.v6.sin6_port = htons(SCTP_TESTPORT_2);
+#else
+	pf_class = PF_INET;
+	sock_len = sizeof(struct sockaddr_in);
+
+	loop1.v4.sin_family = AF_INET;
+	loop1.v4.sin_addr.s_addr = SCTP_IP_LOOPBACK;
+	loop1.v4.sin_port = htons(SCTP_TESTPORT_1);
+
+	loop2.v4.sin_family = AF_INET;
+	loop2.v4.sin_addr.s_addr = SCTP_IP_LOOPBACK;
+	loop2.v4.sin_port = htons(SCTP_TESTPORT_2);
+#endif /* TEST_V6 */
+
+	/* Create the two endpoints which will talk to each other */
+	sk1 = test_socket(pf_class, SOCK_STREAM, IPPROTO_SCTP);
+	sk2 = test_socket(pf_class, SOCK_STREAM, IPPROTO_SCTP);
+
+	/* Enable ASSOC_CHANGE and SNDRCVINFO notifications */
+	test_enable_assoc_change(sk1);
+	test_enable_assoc_change(sk2);
+
+	/* Bind these sockets to the test ports */
+	test_bind(sk1, &loop1.sa, sizeof(loop2));
+	test_bind(sk2, &loop2.sa, sizeof(loop2));
+
+	/* Let sk2 listen to new associations */
+	test_listen(sk2, 1);
+
+	/* Set up connection */
+	test_connectx(sk1, &loop2.sa, 1);
+	acpt_sk = test_accept(sk2, &acpt_addr.sa, &sock_len);
+	test_enable_assoc_change(acpt_sk);
+
+	/* Initialize inmessage for all receives */
+	buffer = test_malloc(REALLY_BIG);
+	memset(&inmessage, 0x00, sizeof(inmessage));
+	iov.iov_base = buffer;
+	iov.iov_len = REALLY_BIG;
+	inmessage.msg_iov = &iov;
+	inmessage.msg_iovlen = 1;
+	inmessage.msg_control = incmsg;
+
+	/* Send the first message to create an association */
+	memset(&outmessage, 0x00, sizeof(outmessage));
+	outmessage.msg_name = &loop2;
+	outmessage.msg_namelen = sizeof(loop2);
+	outmessage.msg_iov = &out_iov;
+	outmessage.msg_iovlen = 1;
+	outmessage.msg_control = outcmsg;
+	outmessage.msg_controllen = sizeof(outcmsg);
+	outmessage.msg_flags = 0;
+	cmsg = CMSG_FIRSTHDR(&outmessage);
+	cmsg->cmsg_level = IPPROTO_SCTP;
+	cmsg->cmsg_type = SCTP_SNDRCV;
+	cmsg->cmsg_len = CMSG_LEN(sizeof(struct sctp_sndrcvinfo));
+	sinfo = (struct sctp_sndrcvinfo *)CMSG_DATA(cmsg);
+	memset(sinfo, 0x00, sizeof(struct sctp_sndrcvinfo));
+	ppid = rand(); /* Choose an arbitrary value */
+	stream = 1;
+	sinfo->sinfo_ppid = ppid;
+	sinfo->sinfo_stream = stream;
+	msg_len = 10;
+	msg_buffer = test_build_msg(10);
+	outmessage.msg_iov->iov_base = msg_buffer;
+	outmessage.msg_iov->iov_len = msg_len;
+	test_sendmsg(sk1, &outmessage, 0, msg_len);
+
+	/* Get the communication up message on sk1 */
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(sk1, &inmessage, MSG_WAITALL);
+	test_check_msg_notification(&inmessage, error,
+					sizeof(struct sctp_assoc_change),
+					SCTP_ASSOC_CHANGE, SCTP_COMM_UP);
+
+	/* Get the communication up message on acpt_sk */
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(acpt_sk, &inmessage, MSG_WAITALL);
+	test_check_msg_notification(&inmessage, error,
+					sizeof(struct sctp_assoc_change),
+					SCTP_ASSOC_CHANGE, SCTP_COMM_UP);
+
+	/* Get the first data message which was sent. */
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(acpt_sk, &inmessage, MSG_WAITALL);
+	test_check_msg_data(&inmessage, error, 10, MSG_EOR, stream, ppid);
+
+	/* TEST #1: verify SCTP_ENABLE_STREAM_RESET option */
+	memset(&assoc, 0, sizeof(struct sctp_assoc_value));
+	assoc.assoc_id = 0;
+	assoc.assoc_value = (SCTP_ENABLE_RESET_STREAM_REQ
+			   | SCTP_ENABLE_RESET_ASSOC_REQ
+			   | SCTP_ENABLE_CHANGE_ASSOC_REQ);
+	test_setsockopt(sk1, SCTP_ENABLE_STREAM_RESET, &assoc, sizeof(assoc));
+	test_setsockopt(sk2, SCTP_ENABLE_STREAM_RESET, &assoc, sizeof(assoc));
+
+	tst_resm(TPASS, "setsockopt(SCTP_ENABLE_STREAM_RESET)");
+
+	optlen = sizeof(struct sctp_assoc_value);
+	memset(&get_assoc, 0x00, optlen);
+	assoc.assoc_id = 0;
+	error = test_getsockopt(sk1, SCTP_ENABLE_STREAM_RESET,
+				&get_assoc, &optlen);
+	if (get_assoc.assoc_value != 7)
+		tst_brkm(TBROK, tst_exit,
+			 "getsockopt(SCTP_INTERLEAVING_SUPPORTED) "
+			 "error: %d errno: %d get_result: %d",
+			 error, errno, get_assoc.assoc_value);
+	error = test_getsockopt(sk2, SCTP_ENABLE_STREAM_RESET,
+				&get_assoc, &optlen);
+	if (get_assoc.assoc_value != 7)
+		tst_brkm(TBROK, tst_exit,
+			 "getsockopt(SCTP_INTERLEAVING_SUPPORTED) "
+			 "error: %d errno: %d get_result: %d",
+			 error, errno, get_assoc.assoc_value);
+
+	tst_resm(TPASS, "getsockopt(SCTP_ENABLE_STREAM_RESET)");
+
+	/* TEST #2: Reset I/O streams */
+	/* Check if net.sctp.reconf_enable=1, exit if not */
+	fd = open("/proc/sys/net/sctp/reconf_enable", O_RDONLY);
+	if (0 > fd ||
+	    0 >= read(fd, &setting, 4) ||
+	    strncmp("1", setting, 1) != 0) {
+		fprintf(stderr, "reconf_enable is not set to 1, skip test\n");
+		exit(0);
+	}
+	close(fd);
+
+	optlen = sizeof(struct sctp_reset_streams)
+		 + STREAM_NUM * sizeof(uint16_t);
+	srs = (struct sctp_reset_streams*) test_malloc(optlen);
+	srs->srs_assoc_id = 0;
+	srs->srs_number_streams = STREAM_NUM;
+	for (int i = 0; i < srs->srs_number_streams; ++i)
+		srs->srs_stream_list[i] = i;
+	srs->srs_flags = (SCTP_STREAM_RESET_INCOMING | SCTP_STREAM_RESET_OUTGOING);
+
+	test_setsockopt(sk1, SCTP_RESET_STREAMS, srs, optlen);
+
+	tst_resm(TPASS, "setsockopt(SCTP_RESET_STREAMS)");
+
+	/* TEST #3: Reset assoc */
+	assoc_id = 0;
+	test_setsockopt(sk1, SCTP_RESET_ASSOC, &assoc_id, sizeof(socklen_t));
+
+	tst_resm(TPASS, "setsockopt(SCTP_RESET_ASSOC)");
+
+	/* TEST #4: Add stream */
+	sas = (struct sctp_add_streams *) test_malloc(sizeof(struct sctp_add_streams));
+	sas->sas_assoc_id = 0;
+	sas->sas_instrms = ADD_STREAM;
+	sas->sas_outstrms= ADD_STREAM;
+	test_setsockopt(sk1, SCTP_ADD_STREAMS, sas, (socklen_t)sizeof(struct sctp_add_streams));
+
+	tst_resm(TPASS, "setsockopt(SCTP_ADD_STREAMS)");
+
+	/* Shut down the link */
+	close(sk1);
+
+	/* Get the shutdown complete notification */
+	inmessage.msg_controllen = sizeof(incmsg);
+	error = test_recvmsg(acpt_sk, &inmessage, MSG_WAITALL);
+	test_check_msg_notification(&inmessage, error,
+					sizeof(struct sctp_assoc_change),
+					SCTP_ASSOC_CHANGE, SCTP_SHUTDOWN_COMP);
+	close(acpt_sk);
+	close(sk2);
+
+	free(buffer);
+	free(srs);
+	free(sas);
+
+	/*Indicate successful completion*/
+	exit(EXIT_SUCCESS);
+}
-- 
2.37.1

Re: [PATCH lksctp-tools 0/2] func_tests: Add test cases for interleaving and stream RE_CONFIG

[Xin Long]

On Fri, Aug 5, 2022 at 11:44 AM Yuxuan Luo <luoyuxuan.carl@gmail.com> wrote:
>
> Add two test cases for verifying the support
> for interleaving and re_config recently implemented in kernel.
>
> Signed-off-by: Yuxuan Luo <luoyuxuan.carl@gmail.com>
>
> Yuxuan Luo (2):
>   Add a test case for interleaving
>   Add a test cacse for RE_CONFIG
>
>  configure.ac                     |   3 +
>  src/func_tests/.gitignore        |   4 +
>  src/func_tests/Makefile.am       |  20 +++
>  src/func_tests/test_interleave.c | 254 +++++++++++++++++++++++++++++++
>  src/func_tests/test_re_conf.c    | 251 ++++++++++++++++++++++++++++++
>  5 files changed, 532 insertions(+)
>  create mode 100644 src/func_tests/test_interleave.c
>  create mode 100644 src/func_tests/test_re_conf.c
>
> --
> 2.37.1
>
Reviewed-by: Xin Long <lucien.xin@gmail.com>

Re: [PATCH lksctp-tools 0/2] func_tests: Add test cases for interleaving and stream RE_CONFIG

[Marcelo Ricardo Leitner]

On Fri, Aug 05, 2022 at 11:43:50AM -0400, Yuxuan Luo wrote:
> Add two test cases for verifying the support
> for interleaving and re_config recently implemented in kernel.
> 
> Signed-off-by: Yuxuan Luo <luoyuxuan.carl@gmail.com>
> 

Applied. Thanks folks.

  Marcelo