| /external/ltp/utils/sctp/func_tests/ |
| test_recvmsg.c | 64 int svr_sk, clt_sk; local
94 clt_sk = test_socket(AF_INET, SOCK_SEQPACKET, IPPROTO_SCTP);
95 test_bind(clt_sk, (struct sockaddr *)&clt_loop, sizeof(clt_loop));
99 test_enable_assoc_change(clt_sk);
110 test_sendmsg(clt_sk, &outmessage, 0, 30000);
121 /* Receive COMM_UP on clt_sk. */
123 error = test_recvmsg(clt_sk, &inmessage, 0);
156 close(clt_sk);
|
| test_tcp_style.c | 63 int clt_sk[MAX_CLIENTS], accept_sk[MAX_CLIENTS]; local
127 clt_sk[i] = test_socket(pf_class, SOCK_STREAM, IPPROTO_SCTP);
128 test_bind(clt_sk[i], &clt_loop[i].sa, sizeof(clt_loop[i]));
135 error = accept(clt_sk[0], &accept_loop.sa, &addrlen);
151 /* Do a blocking connect from clt_sk's to listen_sk */
153 test_connect(clt_sk[i], &svr_loop.sa, sizeof(svr_loop));
199 error = accept(clt_sk[0], &accept_loop.sa, &addrlen);
210 test_send(clt_sk[i], message, strlen(message), 0);
221 test_recv(clt_sk[i], msgbuf, 100, 0);
247 test_enable_assoc_change(clt_sk[0])
[all...] |
| test_1_to_1_events.c | 55 int svr_sk, clt_sk,acpt_sk; local
93 clt_sk = test_socket(AF_INET, SOCK_STREAM, IPPROTO_SCTP);
100 test_setsockopt(clt_sk, SCTP_EVENTS, &event, len);
103 test_connect(clt_sk, (struct sockaddr *) &clt_loop, len);
134 test_sendmsg(clt_sk, &outmessage, 0, strlen(message)+1);
151 error = test_recvmsg(clt_sk, &inmessage, MSG_WAITALL);
177 close(clt_sk);
|
| test_peeloff.c | 64 int svr_sk, clt_sk[MAX_CLIENTS], peeloff_sk[MAX_CLIENTS]; local
113 clt_sk[i] = test_socket(pf_class, SOCK_SEQPACKET, IPPROTO_SCTP);
123 test_bind(clt_sk[i], &clt_loop[i].sa, sizeof(clt_loop[i]));
125 test_enable_assoc_change(clt_sk[i]);
152 test_sendmsg(clt_sk[i], &outmessage, 0,
167 error = test_recvmsg(clt_sk[i], &inmessage, MSG_WAITALL);
226 test_sendmsg(clt_sk[i], &outmessage, 0, strlen(message)+1);
252 error = test_recvmsg(clt_sk[i], &inmessage, MSG_WAITALL);
271 error = test_recvmsg(clt_sk[0], &inmessage, MSG_WAITALL);
288 error = test_recvmsg(clt_sk[i], &inmessage, MSG_WAITALL)
[all...] |
| test_assoc_abort.c | 66 int svr_sk, clt_sk[MAX_CLIENTS]; local
107 clt_sk[i] = test_socket(AF_INET, SOCK_SEQPACKET, IPPROTO_SCTP);
112 test_bind(clt_sk[i], &clt_loop[i].sa, sizeof(clt_loop[i]));
114 test_enable_assoc_change(clt_sk[i]);
143 test_sendmsg(clt_sk[i], &outmessage, 0, strlen(message) + 1);
157 error = test_recvmsg(clt_sk[i], &inmessage, MSG_WAITALL);
232 error = test_recvmsg(clt_sk[i], &inmessage, MSG_WAITALL);
237 close(clt_sk[i]);
|
| test_assoc_shutdown.c | 65 int svr_sk, clt_sk[MAX_CLIENTS]; local
107 clt_sk[i] = test_socket(AF_INET, SOCK_SEQPACKET, IPPROTO_SCTP);
112 test_bind(clt_sk[i], &clt_loop[i].sa, sizeof(clt_loop[i]));
114 test_enable_assoc_change(clt_sk[i]);
143 test_sendmsg(clt_sk[i], &outmessage, 0, strlen(message)+1);
157 error = test_recvmsg(clt_sk[i], &inmessage, MSG_WAITALL);
233 error = test_recvmsg(clt_sk[i], &inmessage, MSG_WAITALL);
239 close(clt_sk[i]);
|
| test_getname.c | 62 int clt_sk, svr_sk, accept_sk; local
117 clt_sk = test_socket(pf_class, SOCK_STREAM, IPPROTO_SCTP);
119 /* Do a blocking connect from clt_sk to svr_sk */
125 test_connect(clt_sk, &svr_loop.sa, sizeof(svr_loop));
130 error = getsockname(clt_sk, (struct sockaddr *)&clt_local_addr, &len);
140 error = getpeername(clt_sk, (struct sockaddr *)&clt_peer_addr, &len);
230 error = getsockname(clt_sk, (struct sockaddr *)-1, &len);
265 error = getpeername(clt_sk, (struct sockaddr *)-1, &len);
272 close(clt_sk);
|
