blob: b25d574fc27788784e4fb0d58efadf2e8b02e729 [file] [log] [blame]
Benny Prijono5dcb38d2005-11-21 01:55:47 +00001/* $Id$ */
2/*
Benny Prijono844653c2008-12-23 17:27:53 +00003 * Copyright (C) 2008-2009 Teluu Inc. (http://www.teluu.com)
4 * Copyright (C) 2003-2008 Benny Prijono <benny@prijono.org>
Benny Prijono5dcb38d2005-11-21 01:55:47 +00005 *
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19 */
20#include <pjlib.h>
21#include "test.h"
22
23
24/**
25 * \page page_pjlib_sock_test Test: Socket
26 *
27 * This file provides implementation of \b sock_test(). It tests the
28 * various aspects of the socket API.
29 *
30 * \section sock_test_scope_sec Scope of the Test
31 *
32 * The scope of the test:
33 * - verify the validity of the address structs.
34 * - verify that address manipulation API works.
35 * - simple socket creation and destruction.
36 * - simple socket send/recv and sendto/recvfrom.
37 * - UDP connect()
38 * - send/recv big data.
39 * - all for both UDP and TCP.
40 *
41 * The APIs tested in this test:
42 * - pj_inet_aton()
43 * - pj_inet_ntoa()
Benny Prijonoc16c6e32007-11-18 14:53:47 +000044 * - pj_inet_pton() (only if IPv6 is enabled)
45 * - pj_inet_ntop() (only if IPv6 is enabled)
Benny Prijono5dcb38d2005-11-21 01:55:47 +000046 * - pj_gethostname()
47 * - pj_sock_socket()
48 * - pj_sock_close()
49 * - pj_sock_send()
50 * - pj_sock_sendto()
51 * - pj_sock_recv()
52 * - pj_sock_recvfrom()
53 * - pj_sock_bind()
54 * - pj_sock_connect()
55 * - pj_sock_listen()
56 * - pj_sock_accept()
Benny Prijono60cac482007-03-01 18:56:02 +000057 * - pj_gethostbyname()
Benny Prijono5dcb38d2005-11-21 01:55:47 +000058 *
59 *
60 * This file is <b>pjlib-test/sock.c</b>
61 *
62 * \include pjlib-test/sock.c
63 */
64
65#if INCLUDE_SOCK_TEST
66
67#define UDP_PORT 51234
68#define TCP_PORT (UDP_PORT+10)
Benny Prijonof260e462007-04-30 21:03:32 +000069#define BIG_DATA_LEN 8192
Benny Prijono42c5b9e2006-05-10 19:24:40 +000070#define ADDRESS "127.0.0.1"
Benny Prijono5dcb38d2005-11-21 01:55:47 +000071
72static char bigdata[BIG_DATA_LEN];
73static char bigbuffer[BIG_DATA_LEN];
74
75static int format_test(void)
76{
Benny Prijono42c5b9e2006-05-10 19:24:40 +000077 pj_str_t s = pj_str(ADDRESS);
78 unsigned char *p;
Benny Prijono5dcb38d2005-11-21 01:55:47 +000079 pj_in_addr addr;
Benny Prijono0e25e7c2006-06-28 11:10:02 +000080 char zero[64];
81 pj_sockaddr_in addr2;
Benny Prijono5dcb38d2005-11-21 01:55:47 +000082 const pj_str_t *hostname;
Benny Prijono8ab968f2007-07-20 08:08:30 +000083 const unsigned char A[] = {127, 0, 0, 1};
Benny Prijono5dcb38d2005-11-21 01:55:47 +000084
85 PJ_LOG(3,("test", "...format_test()"));
86
87 /* pj_inet_aton() */
88 if (pj_inet_aton(&s, &addr) != 1)
89 return -10;
90
91 /* Check the result. */
Benny Prijono42c5b9e2006-05-10 19:24:40 +000092 p = (unsigned char*)&addr;
Benny Prijonof260e462007-04-30 21:03:32 +000093 if (p[0]!=A[0] || p[1]!=A[1] || p[2]!=A[2] || p[3]!=A[3]) {
Benny Prijono42c5b9e2006-05-10 19:24:40 +000094 PJ_LOG(3,("test", " error: mismatched address. p0=%d, p1=%d, "
95 "p2=%d, p3=%d", p[0] & 0xFF, p[1] & 0xFF,
96 p[2] & 0xFF, p[3] & 0xFF));
Benny Prijono5dcb38d2005-11-21 01:55:47 +000097 return -15;
Benny Prijono42c5b9e2006-05-10 19:24:40 +000098 }
Benny Prijono5dcb38d2005-11-21 01:55:47 +000099
100 /* pj_inet_ntoa() */
Benny Prijonod8410532006-06-15 11:04:33 +0000101 p = (unsigned char*) pj_inet_ntoa(addr);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000102 if (!p)
103 return -20;
104
Benny Prijonod8410532006-06-15 11:04:33 +0000105 if (pj_strcmp2(&s, (char*)p) != 0)
Benny Prijonoc16c6e32007-11-18 14:53:47 +0000106 return -22;
107
108#if defined(PJ_HAS_IPV6) && PJ_HAS_IPV6!=0
109 /* pj_inet_pton() */
110 /* pj_inet_ntop() */
111 {
112 const pj_str_t s_ipv4 = pj_str("127.0.0.1");
113 const pj_str_t s_ipv6 = pj_str("fe80::2ff:83ff:fe7c:8b42");
114 char buf_ipv4[PJ_INET_ADDRSTRLEN];
115 char buf_ipv6[PJ_INET6_ADDRSTRLEN];
116 pj_in_addr ipv4;
117 pj_in6_addr ipv6;
118
119 if (pj_inet_pton(pj_AF_INET(), &s_ipv4, &ipv4) != PJ_SUCCESS)
120 return -24;
121
122 p = (unsigned char*)&ipv4;
123 if (p[0]!=A[0] || p[1]!=A[1] || p[2]!=A[2] || p[3]!=A[3]) {
124 return -25;
125 }
126
127 if (pj_inet_pton(pj_AF_INET6(), &s_ipv6, &ipv6) != PJ_SUCCESS)
128 return -26;
129
130 p = (unsigned char*)&ipv6;
131 if (p[0] != 0xfe || p[1] != 0x80 || p[2] != 0 || p[3] != 0 ||
132 p[4] != 0 || p[5] != 0 || p[6] != 0 || p[7] != 0 ||
133 p[8] != 0x02 || p[9] != 0xff || p[10] != 0x83 || p[11] != 0xff ||
134 p[12]!=0xfe || p[13]!=0x7c || p[14] != 0x8b || p[15]!=0x42)
135 {
136 return -27;
137 }
138
139 if (pj_inet_ntop(pj_AF_INET(), &ipv4, buf_ipv4, sizeof(buf_ipv4)) != PJ_SUCCESS)
140 return -28;
141 if (pj_stricmp2(&s_ipv4, buf_ipv4) != 0)
142 return -29;
143
144 if (pj_inet_ntop(pj_AF_INET6(), &ipv6, buf_ipv6, sizeof(buf_ipv6)) != PJ_SUCCESS)
145 return -30;
146 if (pj_stricmp2(&s_ipv6, buf_ipv6) != 0)
147 return -31;
148 }
149
150#endif /* PJ_HAS_IPV6 */
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000151
Benny Prijono0e25e7c2006-06-28 11:10:02 +0000152 /* Test that pj_sockaddr_in_init() initialize the whole structure,
153 * including sin_zero.
154 */
155 pj_sockaddr_in_init(&addr2, 0, 1000);
Benny Prijonoac623b32006-07-03 15:19:31 +0000156 pj_bzero(zero, sizeof(zero));
Benny Prijono0e25e7c2006-06-28 11:10:02 +0000157 if (pj_memcmp(addr2.sin_zero, zero, sizeof(addr2.sin_zero)) != 0)
158 return -35;
159
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000160 /* pj_gethostname() */
161 hostname = pj_gethostname();
162 if (!hostname || !hostname->ptr || !hostname->slen)
163 return -40;
164
Benny Prijono42c5b9e2006-05-10 19:24:40 +0000165 PJ_LOG(3,("test", "....hostname is %.*s",
166 (int)hostname->slen, hostname->ptr));
167
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000168 /* pj_gethostaddr() */
169
Benny Prijono0e25e7c2006-06-28 11:10:02 +0000170
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000171 return 0;
172}
173
Benny Prijono0f4b9db2009-06-04 15:11:25 +0000174static int parse_test(void)
175{
176#define IPv4 1
177#define IPv6 2
178
179 struct test_t {
180 const char *input;
181 int result_af;
182 const char *result_ip;
183 pj_uint16_t result_port;
184 };
185 struct test_t valid_tests[] =
186 {
187 /* IPv4 */
188 { "10.0.0.1:80", IPv4, "10.0.0.1", 80},
189 { "10.0.0.1", IPv4, "10.0.0.1", 0},
190 { "10.0.0.1:", IPv4, "10.0.0.1", 0},
191 { "10.0.0.1:0", IPv4, "10.0.0.1", 0},
192 { ":80", IPv4, "0.0.0.0", 80},
193 { ":", IPv4, "0.0.0.0", 0},
Benny Prijonod4b0b1d2009-06-17 12:38:58 +0000194#if !PJ_SYMBIAN
Benny Prijono0f4b9db2009-06-04 15:11:25 +0000195 { "localhost", IPv4, "127.0.0.1", 0},
196 { "localhost:", IPv4, "127.0.0.1", 0},
197 { "localhost:80", IPv4, "127.0.0.1", 80},
Benny Prijonod4b0b1d2009-06-17 12:38:58 +0000198#endif
Benny Prijono0f4b9db2009-06-04 15:11:25 +0000199
200#if defined(PJ_HAS_IPV6) && PJ_HAS_IPV6
201 { "fe::01:80", IPv6, "fe::01:80", 0},
202 { "[fe::01]:80", IPv6, "fe::01", 80},
203 { "fe::01", IPv6, "fe::01", 0},
204 { "[fe::01]", IPv6, "fe::01", 0},
205 { "fe::01:", IPv6, "fe::01", 0},
206 { "[fe::01]:", IPv6, "fe::01", 0},
207 { "::", IPv6, "::0", 0},
208 { "[::]", IPv6, "::", 0},
209 { ":::", IPv6, "::", 0},
210 { "[::]:", IPv6, "::", 0},
211 { ":::80", IPv6, "::", 80},
212 { "[::]:80", IPv6, "::", 80},
213#endif
214 };
215 struct test_t invalid_tests[] =
216 {
217 /* IPv4 */
218 { "10.0.0.1:abcd", IPv4}, /* port not numeric */
219 { "10.0.0.1:-1", IPv4}, /* port contains illegal character */
220 { "10.0.0.1:123456", IPv4}, /* port too big */
221 { "1.2.3.4.5:80", IPv4}, /* invalid IP */
222
223#if defined(PJ_HAS_IPV6) && PJ_HAS_IPV6
224 { "[fe::01]:abcd", IPv6}, /* port not numeric */
225 { "[fe::01]:-1", IPv6}, /* port contains illegal character */
226 { "[fe::01]:123456", IPv6}, /* port too big */
227 { "fe::01:02::03:04:80", IPv6}, /* invalid IP */
228 { "[fe::01:02::03:04]:80", IPv6}, /* invalid IP */
229 { "[fe:01", IPv6}, /* Unterminated bracket */
230#endif
231 };
232
233 unsigned i;
234
235 PJ_LOG(3,("test", "...IP address parsing"));
236
237 for (i=0; i<PJ_ARRAY_SIZE(valid_tests); ++i) {
238 pj_status_t status;
239 pj_str_t input;
240 pj_sockaddr addr, result;
241
242 switch (valid_tests[i].result_af) {
243 case IPv4:
244 valid_tests[i].result_af = PJ_AF_INET;
245 break;
246 case IPv6:
247 valid_tests[i].result_af = PJ_AF_INET6;
248 break;
249 default:
250 pj_assert(!"Invalid AF!");
251 continue;
252 }
253
254 /* Try parsing with PJ_AF_UNSPEC */
255 status = pj_sockaddr_parse(PJ_AF_UNSPEC, 0,
256 pj_cstr(&input, valid_tests[i].input),
257 &addr);
258 if (status != PJ_SUCCESS) {
Benny Prijonod4b0b1d2009-06-17 12:38:58 +0000259 PJ_LOG(1,("test", ".... failed when parsing %s (i=%d)",
260 valid_tests[i].input, i));
Benny Prijono0f4b9db2009-06-04 15:11:25 +0000261 return -10;
262 }
263
264 /* Build the correct result */
265 status = pj_sockaddr_init(valid_tests[i].result_af,
266 &result,
267 pj_cstr(&input, valid_tests[i].result_ip),
268 valid_tests[i].result_port);
269 if (status != PJ_SUCCESS) {
270 PJ_LOG(1,("test", ".... error building IP address %s",
271 valid_tests[i].input));
272 return -30;
273 }
274
275 /* Compare the result */
276 if (pj_sockaddr_cmp(&addr, &result) != 0) {
277 PJ_LOG(1,("test", ".... parsed result mismatched for %s",
278 valid_tests[i].input));
279 return -40;
280 }
281
282 /* Parse again with the specified af */
283 status = pj_sockaddr_parse(valid_tests[i].result_af, 0,
284 pj_cstr(&input, valid_tests[i].input),
285 &addr);
286 if (status != PJ_SUCCESS) {
287 PJ_LOG(1,("test", ".... failed when parsing %s",
288 valid_tests[i].input));
289 return -50;
290 }
291
292 /* Compare the result again */
293 if (pj_sockaddr_cmp(&addr, &result) != 0) {
294 PJ_LOG(1,("test", ".... parsed result mismatched for %s",
295 valid_tests[i].input));
296 return -60;
297 }
298 }
299
300 for (i=0; i<PJ_ARRAY_SIZE(invalid_tests); ++i) {
301 pj_status_t status;
302 pj_str_t input;
303 pj_sockaddr addr;
304
305 switch (invalid_tests[i].result_af) {
306 case IPv4:
307 invalid_tests[i].result_af = PJ_AF_INET;
308 break;
309 case IPv6:
310 invalid_tests[i].result_af = PJ_AF_INET6;
311 break;
312 default:
313 pj_assert(!"Invalid AF!");
314 continue;
315 }
316
317 /* Try parsing with PJ_AF_UNSPEC */
318 status = pj_sockaddr_parse(PJ_AF_UNSPEC, 0,
319 pj_cstr(&input, invalid_tests[i].input),
320 &addr);
321 if (status == PJ_SUCCESS) {
322 PJ_LOG(1,("test", ".... expecting failure when parsing %s",
323 invalid_tests[i].input));
324 return -100;
325 }
326 }
327
328 return 0;
329}
330
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000331static int simple_sock_test(void)
332{
333 int types[2];
334 pj_sock_t sock;
335 int i;
336 pj_status_t rc = PJ_SUCCESS;
337
Benny Prijono8ab968f2007-07-20 08:08:30 +0000338 types[0] = pj_SOCK_STREAM();
339 types[1] = pj_SOCK_DGRAM();
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000340
341 PJ_LOG(3,("test", "...simple_sock_test()"));
342
Benny Prijonoa1e69682007-05-11 15:14:34 +0000343 for (i=0; i<(int)(sizeof(types)/sizeof(types[0])); ++i) {
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000344
Benny Prijono8ab968f2007-07-20 08:08:30 +0000345 rc = pj_sock_socket(pj_AF_INET(), types[i], 0, &sock);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000346 if (rc != PJ_SUCCESS) {
Benny Prijono8ab968f2007-07-20 08:08:30 +0000347 app_perror("...error: unable to create socket", rc);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000348 break;
349 } else {
350 rc = pj_sock_close(sock);
351 if (rc != 0) {
352 app_perror("...error: close socket", rc);
353 break;
354 }
355 }
356 }
357 return rc;
358}
359
360
361static int send_recv_test(int sock_type,
362 pj_sock_t ss, pj_sock_t cs,
363 pj_sockaddr_in *dstaddr, pj_sockaddr_in *srcaddr,
364 int addrlen)
365{
366 enum { DATA_LEN = 16 };
367 char senddata[DATA_LEN+4], recvdata[DATA_LEN+4];
368 pj_ssize_t sent, received, total_received;
369 pj_status_t rc;
370
371 TRACE_(("test", "....create_random_string()"));
372 pj_create_random_string(senddata, DATA_LEN);
373 senddata[DATA_LEN-1] = '\0';
374
375 /*
376 * Test send/recv small data.
377 */
378 TRACE_(("test", "....sendto()"));
379 if (dstaddr) {
380 sent = DATA_LEN;
381 rc = pj_sock_sendto(cs, senddata, &sent, 0, dstaddr, addrlen);
382 if (rc != PJ_SUCCESS || sent != DATA_LEN) {
383 app_perror("...sendto error", rc);
384 rc = -140; goto on_error;
385 }
386 } else {
387 sent = DATA_LEN;
388 rc = pj_sock_send(cs, senddata, &sent, 0);
389 if (rc != PJ_SUCCESS || sent != DATA_LEN) {
390 app_perror("...send error", rc);
391 rc = -145; goto on_error;
392 }
393 }
394
395 TRACE_(("test", "....recv()"));
396 if (srcaddr) {
397 pj_sockaddr_in addr;
398 int srclen = sizeof(addr);
399
Benny Prijonoac623b32006-07-03 15:19:31 +0000400 pj_bzero(&addr, sizeof(addr));
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000401
402 received = DATA_LEN;
403 rc = pj_sock_recvfrom(ss, recvdata, &received, 0, &addr, &srclen);
404 if (rc != PJ_SUCCESS || received != DATA_LEN) {
405 app_perror("...recvfrom error", rc);
406 rc = -150; goto on_error;
407 }
408 if (srclen != addrlen)
409 return -151;
410 if (pj_memcmp(&addr, srcaddr, srclen) != 0) {
411 char srcaddr_str[32], addr_str[32];
412 strcpy(srcaddr_str, pj_inet_ntoa(srcaddr->sin_addr));
413 strcpy(addr_str, pj_inet_ntoa(addr.sin_addr));
414 PJ_LOG(3,("test", "...error: src address mismatch (original=%s, "
415 "recvfrom addr=%s)",
416 srcaddr_str, addr_str));
417 return -152;
418 }
419
420 } else {
421 /* Repeat recv() until all data is received.
422 * This applies only for non-UDP of course, since for UDP
423 * we would expect all data to be received in one packet.
424 */
425 total_received = 0;
426 do {
427 received = DATA_LEN-total_received;
428 rc = pj_sock_recv(ss, recvdata+total_received, &received, 0);
429 if (rc != PJ_SUCCESS) {
430 app_perror("...recv error", rc);
431 rc = -155; goto on_error;
432 }
433 if (received <= 0) {
434 PJ_LOG(3,("", "...error: socket has closed! (received=%d)",
435 received));
436 rc = -156; goto on_error;
437 }
438 if (received != DATA_LEN-total_received) {
Benny Prijono8ab968f2007-07-20 08:08:30 +0000439 if (sock_type != pj_SOCK_STREAM()) {
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000440 PJ_LOG(3,("", "...error: expecting %u bytes, got %u bytes",
441 DATA_LEN-total_received, received));
442 rc = -157; goto on_error;
443 }
444 }
445 total_received += received;
446 } while (total_received < DATA_LEN);
447 }
448
449 TRACE_(("test", "....memcmp()"));
450 if (pj_memcmp(senddata, recvdata, DATA_LEN) != 0) {
451 PJ_LOG(3,("","...error: received data mismatch "
452 "(got:'%s' expecting:'%s'",
453 recvdata, senddata));
454 rc = -160; goto on_error;
455 }
456
457 /*
458 * Test send/recv big data.
459 */
460 TRACE_(("test", "....sendto()"));
461 if (dstaddr) {
462 sent = BIG_DATA_LEN;
463 rc = pj_sock_sendto(cs, bigdata, &sent, 0, dstaddr, addrlen);
464 if (rc != PJ_SUCCESS || sent != BIG_DATA_LEN) {
465 app_perror("...sendto error", rc);
466 rc = -161; goto on_error;
467 }
468 } else {
469 sent = BIG_DATA_LEN;
470 rc = pj_sock_send(cs, bigdata, &sent, 0);
471 if (rc != PJ_SUCCESS || sent != BIG_DATA_LEN) {
472 app_perror("...send error", rc);
473 rc = -165; goto on_error;
474 }
475 }
476
477 TRACE_(("test", "....recv()"));
478
479 /* Repeat recv() until all data is received.
480 * This applies only for non-UDP of course, since for UDP
481 * we would expect all data to be received in one packet.
482 */
483 total_received = 0;
484 do {
485 received = BIG_DATA_LEN-total_received;
486 rc = pj_sock_recv(ss, bigbuffer+total_received, &received, 0);
487 if (rc != PJ_SUCCESS) {
488 app_perror("...recv error", rc);
489 rc = -170; goto on_error;
490 }
491 if (received <= 0) {
492 PJ_LOG(3,("", "...error: socket has closed! (received=%d)",
493 received));
494 rc = -173; goto on_error;
495 }
496 if (received != BIG_DATA_LEN-total_received) {
Benny Prijono8ab968f2007-07-20 08:08:30 +0000497 if (sock_type != pj_SOCK_STREAM()) {
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000498 PJ_LOG(3,("", "...error: expecting %u bytes, got %u bytes",
499 BIG_DATA_LEN-total_received, received));
500 rc = -176; goto on_error;
501 }
502 }
503 total_received += received;
504 } while (total_received < BIG_DATA_LEN);
505
506 TRACE_(("test", "....memcmp()"));
507 if (pj_memcmp(bigdata, bigbuffer, BIG_DATA_LEN) != 0) {
508 PJ_LOG(3,("", "...error: received data has been altered!"));
509 rc = -180; goto on_error;
510 }
511
512 rc = 0;
513
514on_error:
515 return rc;
516}
517
518static int udp_test(void)
519{
520 pj_sock_t cs = PJ_INVALID_SOCKET, ss = PJ_INVALID_SOCKET;
521 pj_sockaddr_in dstaddr, srcaddr;
522 pj_str_t s;
523 pj_status_t rc = 0, retval;
524
525 PJ_LOG(3,("test", "...udp_test()"));
526
Benny Prijono8ab968f2007-07-20 08:08:30 +0000527 rc = pj_sock_socket(pj_AF_INET(), pj_SOCK_DGRAM(), 0, &ss);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000528 if (rc != 0) {
529 app_perror("...error: unable to create socket", rc);
530 return -100;
531 }
532
Benny Prijono8ab968f2007-07-20 08:08:30 +0000533 rc = pj_sock_socket(pj_AF_INET(), pj_SOCK_DGRAM(), 0, &cs);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000534 if (rc != 0)
535 return -110;
536
537 /* Bind server socket. */
Benny Prijonoac623b32006-07-03 15:19:31 +0000538 pj_bzero(&dstaddr, sizeof(dstaddr));
Benny Prijono8ab968f2007-07-20 08:08:30 +0000539 dstaddr.sin_family = pj_AF_INET();
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000540 dstaddr.sin_port = pj_htons(UDP_PORT);
Benny Prijono42c5b9e2006-05-10 19:24:40 +0000541 dstaddr.sin_addr = pj_inet_addr(pj_cstr(&s, ADDRESS));
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000542
543 if ((rc=pj_sock_bind(ss, &dstaddr, sizeof(dstaddr))) != 0) {
Benny Prijono42c5b9e2006-05-10 19:24:40 +0000544 app_perror("...bind error udp:"ADDRESS, rc);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000545 rc = -120; goto on_error;
546 }
547
548 /* Bind client socket. */
Benny Prijonoac623b32006-07-03 15:19:31 +0000549 pj_bzero(&srcaddr, sizeof(srcaddr));
Benny Prijono8ab968f2007-07-20 08:08:30 +0000550 srcaddr.sin_family = pj_AF_INET();
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000551 srcaddr.sin_port = pj_htons(UDP_PORT-1);
Benny Prijono42c5b9e2006-05-10 19:24:40 +0000552 srcaddr.sin_addr = pj_inet_addr(pj_cstr(&s, ADDRESS));
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000553
554 if ((rc=pj_sock_bind(cs, &srcaddr, sizeof(srcaddr))) != 0) {
555 app_perror("...bind error", rc);
556 rc = -121; goto on_error;
557 }
558
559 /* Test send/recv, with sendto */
Benny Prijono8ab968f2007-07-20 08:08:30 +0000560 rc = send_recv_test(pj_SOCK_DGRAM(), ss, cs, &dstaddr, NULL,
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000561 sizeof(dstaddr));
562 if (rc != 0)
563 goto on_error;
564
565 /* Test send/recv, with sendto and recvfrom */
Benny Prijono8ab968f2007-07-20 08:08:30 +0000566 rc = send_recv_test(pj_SOCK_DGRAM(), ss, cs, &dstaddr,
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000567 &srcaddr, sizeof(dstaddr));
568 if (rc != 0)
569 goto on_error;
570
Benny Prijonoaeeb1d12007-05-01 10:42:22 +0000571 /* Disable this test on Symbian since UDP connect()/send() failed
572 * with S60 3rd edition (including MR2).
573 * See http://www.pjsip.org/trac/ticket/264
574 */
575#if !defined(PJ_SYMBIAN) || PJ_SYMBIAN==0
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000576 /* connect() the sockets. */
577 rc = pj_sock_connect(cs, &dstaddr, sizeof(dstaddr));
578 if (rc != 0) {
579 app_perror("...connect() error", rc);
580 rc = -122; goto on_error;
581 }
582
583 /* Test send/recv with send() */
Benny Prijono8ab968f2007-07-20 08:08:30 +0000584 rc = send_recv_test(pj_SOCK_DGRAM(), ss, cs, NULL, NULL, 0);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000585 if (rc != 0)
586 goto on_error;
587
588 /* Test send/recv with send() and recvfrom */
Benny Prijono8ab968f2007-07-20 08:08:30 +0000589 rc = send_recv_test(pj_SOCK_DGRAM(), ss, cs, NULL, &srcaddr,
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000590 sizeof(srcaddr));
591 if (rc != 0)
592 goto on_error;
Benny Prijonof260e462007-04-30 21:03:32 +0000593#endif
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000594
595on_error:
596 retval = rc;
597 if (cs != PJ_INVALID_SOCKET) {
598 rc = pj_sock_close(cs);
599 if (rc != PJ_SUCCESS) {
600 app_perror("...error in closing socket", rc);
601 return -1000;
602 }
603 }
604 if (ss != PJ_INVALID_SOCKET) {
605 rc = pj_sock_close(ss);
606 if (rc != PJ_SUCCESS) {
607 app_perror("...error in closing socket", rc);
608 return -1010;
609 }
610 }
611
612 return retval;
613}
614
615static int tcp_test(void)
616{
617 pj_sock_t cs, ss;
618 pj_status_t rc = 0, retval;
619
620 PJ_LOG(3,("test", "...tcp_test()"));
621
Benny Prijono8ab968f2007-07-20 08:08:30 +0000622 rc = app_socketpair(pj_AF_INET(), pj_SOCK_STREAM(), 0, &ss, &cs);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000623 if (rc != PJ_SUCCESS) {
624 app_perror("...error: app_socketpair():", rc);
625 return -2000;
626 }
627
628 /* Test send/recv with send() and recv() */
Benny Prijono8ab968f2007-07-20 08:08:30 +0000629 retval = send_recv_test(pj_SOCK_STREAM(), ss, cs, NULL, NULL, 0);
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000630
631 rc = pj_sock_close(cs);
632 if (rc != PJ_SUCCESS) {
633 app_perror("...error in closing socket", rc);
634 return -2000;
635 }
636
637 rc = pj_sock_close(ss);
638 if (rc != PJ_SUCCESS) {
639 app_perror("...error in closing socket", rc);
640 return -2010;
641 }
642
643 return retval;
644}
645
646static int ioctl_test(void)
647{
648 return 0;
649}
650
Benny Prijono60cac482007-03-01 18:56:02 +0000651static int gethostbyname_test(void)
652{
653 pj_str_t host;
654 pj_hostent he;
655 pj_status_t status;
656
657 /* Testing pj_gethostbyname() with invalid host */
658 host = pj_str("an-invalid-host-name");
659 status = pj_gethostbyname(&host, &he);
660
661 /* Must return failure! */
662 if (status == PJ_SUCCESS)
663 return -20100;
664 else
665 return 0;
666}
667
Benny Prijonof260e462007-04-30 21:03:32 +0000668#if 0
669#include "../pj/os_symbian.h"
670static int connect_test()
671{
672 RSocketServ rSockServ;
673 RSocket rSock;
674 TInetAddr inetAddr;
675 TRequestStatus reqStatus;
676 char buffer[16];
677 TPtrC8 data((const TUint8*)buffer, (TInt)sizeof(buffer));
678 int rc;
679
680 rc = rSockServ.Connect();
681 if (rc != KErrNone)
682 return rc;
683
684 rc = rSock.Open(rSockServ, KAfInet, KSockDatagram, KProtocolInetUdp);
685 if (rc != KErrNone)
686 {
687 rSockServ.Close();
688 return rc;
689 }
690
691 inetAddr.Init(KAfInet);
692 inetAddr.Input(_L("127.0.0.1"));
693 inetAddr.SetPort(80);
694
695 rSock.Connect(inetAddr, reqStatus);
696 User::WaitForRequest(reqStatus);
697
698 if (reqStatus != KErrNone) {
699 rSock.Close();
700 rSockServ.Close();
701 return rc;
702 }
703
704 rSock.Send(data, 0, reqStatus);
705 User::WaitForRequest(reqStatus);
706
707 if (reqStatus!=KErrNone) {
708 rSock.Close();
709 rSockServ.Close();
710 return rc;
711 }
712
713 rSock.Close();
714 rSockServ.Close();
715 return KErrNone;
716}
717#endif
718
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000719int sock_test()
720{
721 int rc;
722
723 pj_create_random_string(bigdata, BIG_DATA_LEN);
724
Benny Prijonof260e462007-04-30 21:03:32 +0000725// Enable this to demonstrate the error witn S60 3rd Edition MR2
726#if 0
727 rc = connect_test();
728 if (rc != 0)
729 return rc;
730#endif
731
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000732 rc = format_test();
733 if (rc != 0)
734 return rc;
735
Benny Prijono0f4b9db2009-06-04 15:11:25 +0000736 rc = parse_test();
737 if (rc != 0)
738 return rc;
739
Benny Prijono60cac482007-03-01 18:56:02 +0000740 rc = gethostbyname_test();
741 if (rc != 0)
742 return rc;
743
Benny Prijono5dcb38d2005-11-21 01:55:47 +0000744 rc = simple_sock_test();
745 if (rc != 0)
746 return rc;
747
748 rc = ioctl_test();
749 if (rc != 0)
750 return rc;
751
752 rc = udp_test();
753 if (rc != 0)
754 return rc;
755
756 rc = tcp_test();
757 if (rc != 0)
758 return rc;
759
760 return 0;
761}
762
763
764#else
765/* To prevent warning about "translation unit is empty"
766 * when this test is disabled.
767 */
768int dummy_sock_test;
769#endif /* INCLUDE_SOCK_TEST */
770