blob: e65fac0e923ea895e2664ebb22df4b23d3ef5563 [file] [log] [blame]
Austin Schuh8d0a2852019-12-28 22:54:28 -08001/* SCTP kernel Implementation
2 * (C) Copyright IBM Corp. 2001, 2003
3 * Copyright (c) 1999-2000 Cisco, Inc.
4 * Copyright (c) 1999-2001 Motorola, Inc.
5 * Copyright (c) 2001 Intel Corp.
6 * Copyright (c) 2001 Nokia, Inc.
7 *
8 * The SCTP implementation is free software;
9 * you can redistribute it and/or modify it under the terms of
10 * the GNU General Public License as published by
11 * the Free Software Foundation; either version 2, or (at your option)
12 * any later version.
13 *
14 * The SCTP implementation is distributed in the hope that it
15 * will be useful, but WITHOUT ANY WARRANTY; without even the implied
16 * ************************
17 * warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
18 * See the GNU General Public License for more details.
19 *
20 * You should have received a copy of the GNU General Public License
21 * along with GNU CC; see the file COPYING. If not, write to
22 * the Free Software Foundation, 59 Temple Place - Suite 330,
23 * Boston, MA 02111-1307, USA.
24 *
25 * Please send any bug reports or fixes you make to the
26 * email address(es):
27 * lksctp developers <lksctp-developers@lists.sourceforge.net>
28 *
29 * Or submit a bug report through the following website:
30 * http://www.sf.net/projects/lksctp
31 *
32 * Any bugs reported to us we will try to fix... any fixes shared will
33 * be incorporated into the next SCTP release.
34 *
35 * Written or modified by:
36 * Sridhar Samudrala <sri@us.ibm.com>
37 */
38
39/* This is a Functional Test to verify autoclose functionality and the
40 * socket option SCTP_AUTOCLOSE that can be used to specify the duration in
41 * which an idle association is automatically closed.
42 */
43
44#include <stdio.h>
45#include <unistd.h>
46#include <stdlib.h>
47#include <string.h>
48#include <sys/types.h>
49#include <sys/socket.h>
50#include <sys/uio.h>
51#include <netinet/in.h>
52#include <errno.h>
53#include <netinet/sctp.h>
54#include <sctputil.h>
55
56char *TCID = __FILE__;
57int TST_TOTAL = 1;
58int TST_CNT = 0;
59
60int
61main(int argc, char *argv[])
62{
63 int sk1, sk2;
64 sockaddr_storage_t loop1, loop2;
65 struct msghdr inmessage, outmessage;
66 struct iovec iov, out_iov;
67 int error;
68 char *big_buffer;
69 char *message = "hello, world!\n";
70 uint32_t autoclose;
71
72 /* Rather than fflush() throughout the code, set stdout to
73 * be unbuffered.
74 */
75 setvbuf(stdout, NULL, _IONBF, 0);
76
77 loop1.v4.sin_family = AF_INET;
78 loop1.v4.sin_addr.s_addr = SCTP_IP_LOOPBACK;
79 loop1.v4.sin_port = htons(SCTP_TESTPORT_1);
80
81 loop2.v4.sin_family = AF_INET;
82 loop2.v4.sin_addr.s_addr = SCTP_IP_LOOPBACK;
83 loop2.v4.sin_port = htons(SCTP_TESTPORT_2);
84
85 /* Create the two endpoints which will talk to each other. */
86 sk1 = test_socket(AF_INET, SOCK_SEQPACKET, IPPROTO_SCTP);
87 sk2 = test_socket(AF_INET, SOCK_SEQPACKET, IPPROTO_SCTP);
88
89 /* Enable ASSOC_CHANGE and SNDRCVINFO notifications. */
90 test_enable_assoc_change(sk1);
91 test_enable_assoc_change(sk2);
92
93 /* Bind these sockets to the test ports. */
94 test_bind(sk1, &loop1.sa, sizeof(loop1));
95 test_bind(sk2, &loop2.sa, sizeof(loop2));
96
97 /* Mark sk2 as being able to accept new associations. */
98 test_listen(sk2, 1);
99
100 /* Set the autoclose duration for the associations created on sk1
101 * and sk2 to be 5 seconds.
102 */
103 autoclose = 5;
104 test_setsockopt(sk1, SCTP_AUTOCLOSE, &autoclose, sizeof(autoclose));
105 test_setsockopt(sk2, SCTP_AUTOCLOSE, &autoclose, sizeof(autoclose));
106
107 /* Send the first message. This will create the association. */
108 memset(&outmessage, 0, sizeof(outmessage));
109 outmessage.msg_name = &loop2;
110 outmessage.msg_namelen = sizeof(loop2);
111 outmessage.msg_iov = &out_iov;
112 outmessage.msg_iovlen = 1;
113 outmessage.msg_iov->iov_base = message;
114 outmessage.msg_iov->iov_len = strlen(message) + 1;
115
116 test_sendmsg(sk1, &outmessage, 0, strlen(message)+1);
117
118 /* Initialize inmessage for all receives. */
119 big_buffer = test_malloc(REALLY_BIG);
120 memset(&inmessage, 0, sizeof(inmessage));
121 iov.iov_base = big_buffer;
122 iov.iov_len = REALLY_BIG;
123 inmessage.msg_iov = &iov;
124 inmessage.msg_iovlen = 1;
125 inmessage.msg_control = NULL;
126
127 /* Get the communication up message on sk2. */
128 error = test_recvmsg(sk2, &inmessage, MSG_WAITALL);
129 test_check_msg_notification(&inmessage, error,
130 sizeof(struct sctp_assoc_change),
131 SCTP_ASSOC_CHANGE, SCTP_COMM_UP);
132
133 /* Get the communication up message on sk1. */
134 error = test_recvmsg(sk1, &inmessage, MSG_WAITALL);
135 test_check_msg_notification(&inmessage, error,
136 sizeof(struct sctp_assoc_change),
137 SCTP_ASSOC_CHANGE, SCTP_COMM_UP);
138
139 /* Get the first message which was sent. */
140 error = test_recvmsg(sk2, &inmessage, MSG_WAITALL);
141 test_check_msg_data(&inmessage, error, strlen(message) + 1,
142 MSG_EOR|MSG_CTRUNC, 0, 0);
143
144 tst_resm(TINFO, "Waiting for the associations to close automatically "
145 "in 5 secs");
146
147 /* Get the shutdown complete notification from sk1. */
148 error = test_recvmsg(sk1, &inmessage, MSG_WAITALL);
149 test_check_msg_notification(&inmessage, error,
150 sizeof(struct sctp_assoc_change),
151 SCTP_ASSOC_CHANGE, SCTP_SHUTDOWN_COMP);
152
153 /* Get the shutdown complete notification from sk2. */
154 error = test_recvmsg(sk2, &inmessage, MSG_WAITALL);
155 test_check_msg_notification(&inmessage, error,
156 sizeof(struct sctp_assoc_change),
157 SCTP_ASSOC_CHANGE, SCTP_SHUTDOWN_COMP);
158
159 tst_resm(TPASS, "Autoclose of associations");
160
161 /* Shut down the link. */
162 close(sk1);
163 close(sk2);
164
165 /* Indicate successful completion. */
166 return 0;
167}