diff --git a/src/tests/kits/net/Jamfile b/src/tests/kits/net/Jamfile index 5beb3a8641..1c4697578e 100644 --- a/src/tests/kits/net/Jamfile +++ b/src/tests/kits/net/Jamfile @@ -34,3 +34,4 @@ SubInclude HAIKU_TOP src tests kits net sock ; SubInclude HAIKU_TOP src tests kits net tcp_shell ; SubInclude HAIKU_TOP src tests kits net tcptester ; SubInclude HAIKU_TOP src tests kits net icmp ; +SubInclude HAIKU_TOP src tests kits net ipv6 ; diff --git a/src/tests/kits/net/ipv6/Jamfile b/src/tests/kits/net/ipv6/Jamfile new file mode 100644 index 0000000000..3cc6dc4848 --- /dev/null +++ b/src/tests/kits/net/ipv6/Jamfile @@ -0,0 +1,12 @@ +SubDir HAIKU_TOP src tests kits net ipv6 ; + +SimpleTest ipv6_raw_server : raw_server.cpp : $(TARGET_NETWORK_LIBS) ; +SimpleTest ipv6_raw_client : raw_client.cpp : $(TARGET_NETWORK_LIBS) ; + +SimpleTest ipv6_udp_server : udp_server.cpp : $(TARGET_NETWORK_LIBS) ; +SimpleTest ipv6_udp_client : udp_client.cpp : $(TARGET_NETWORK_LIBS) ; + +SimpleTest ipv6_tcp_udp_server : tcp_udp_server.cpp : $(TARGET_NETWORK_LIBS) ; +SimpleTest ipv6_tcp_udp_client : tcp_udp_client.cpp : $(TARGET_NETWORK_LIBS) ; + +SimpleTest ipv6_multicast_sender : multicast_sender.cpp : $(TARGET_NETWORK_LIBS) ; diff --git a/src/tests/kits/net/ipv6/multicast_sender.cpp b/src/tests/kits/net/ipv6/multicast_sender.cpp new file mode 100644 index 0000000000..5e9c7f008a --- /dev/null +++ b/src/tests/kits/net/ipv6/multicast_sender.cpp @@ -0,0 +1,94 @@ +/* + * Copyright 2010, Atis Elsts, the.kfx@gmail.com + * Distributed under the terms of the MIT license. + */ + + +#include +#include +#include +#include +#include +#include +#include + + +const unsigned short TEST_PORT = 40000; + + +int +main(int argc, char *argv[]) +{ + int socketFamily = AF_INET; + + int i = 1; + if (argc > i) { + if (!strcmp(argv[i], "-4")) { + i++; + socketFamily = AF_INET; + } else if (!strcmp(argv[i], "-6")) { + i++; + socketFamily = AF_INET6; + } + } + in_addr multicastSource; + multicastSource.s_addr = 0; + if (argc > i) { + if (!strcmp(argv[i], "-s")) { + ++i; + if (inet_aton(argv[i], &multicastSource) == 0) { + fprintf(stderr, "IPv4 source address expected"); + return -1; + } + ++i; + } + } + + int fd = socket(socketFamily, SOCK_DGRAM, 0); + if (fd < 0) { + perror("socket"); + return -1; + } + + sockaddr_storage saddr; + memset(&saddr, 0, sizeof(saddr)); + if (socketFamily == AF_INET) { + sockaddr_in *sa = (sockaddr_in *) &saddr; + sa->sin_family = AF_INET; + sa->sin_port = htons(TEST_PORT); + sa->sin_addr.s_addr = htonl(INADDR_ALLHOSTS_GROUP); + } else { + sockaddr_in6 *sa = (sockaddr_in6 *) &saddr; + sa->sin6_family = AF_INET6; + sa->sin6_port = htons(TEST_PORT); + // ff01::1 (all nodes multicast) + sa->sin6_addr.s6_addr[0] = 0xff; + sa->sin6_addr.s6_addr[1] = 0x01; + sa->sin6_addr.s6_addr[15] = 0x01; + } + + if (multicastSource.s_addr) { + if (setsockopt(fd, IPPROTO_IP, IP_MULTICAST_IF, + &multicastSource, sizeof(multicastSource)) < 0) { + perror("setsockopt IP_MULTICAST_IF"); + return -1; + } + } + + const char *buffer = "hello world"; + unsigned length = strlen(buffer); + int status = sendto(fd, buffer, length, 0, (sockaddr *) &saddr, + socketFamily == AF_INET ? sizeof(sockaddr_in) : sizeof(sockaddr_in6)); + if (status < length) { + if (status < 0) + perror("sendto"); + else if (status == 0) + printf("no data sent!\n"); + else + printf("not all data sent!\n"); + } else + printf("send(): success\n"); + + close(fd); + return 0; +} diff --git a/src/tests/kits/net/ipv6/raw_client.cpp b/src/tests/kits/net/ipv6/raw_client.cpp new file mode 100644 index 0000000000..db3a26b52b --- /dev/null +++ b/src/tests/kits/net/ipv6/raw_client.cpp @@ -0,0 +1,65 @@ +/* + * Copyright 2010, Atis Elsts, the.kfx@gmail.com + * Distributed under the terms of the MIT license. + */ + + +#include +#include +#include +#include +#include +#include +#include + + +const unsigned short TEST_PROTOCOL = 89; + + +int +main(int argc, char *argv[]) +{ + int socketFamily = AF_INET; + + if (argc > 1) { + if (!strcmp(argv[1], "-4")) + socketFamily = AF_INET; + else if (!strcmp(argv[1], "-6")) + socketFamily = AF_INET6; + } + + int fd = socket(socketFamily, SOCK_RAW, TEST_PROTOCOL); + if (fd < 0) { + perror("socket"); + return -1; + } + + sockaddr_storage saddr; + memset(&saddr, 0, sizeof(saddr)); + if (socketFamily == AF_INET) { + sockaddr_in *sa = (sockaddr_in *) &saddr; + sa->sin_family = AF_INET; + sa->sin_addr.s_addr = htonl(INADDR_LOOPBACK); + } else { + sockaddr_in6 *sa = (sockaddr_in6 *) &saddr; + sa->sin6_family = AF_INET6; + sa->sin6_addr.s6_addr[15] = 0x01; // loopback + } + + const char *buffer = "hello world"; + unsigned length = strlen(buffer); + int status = sendto(fd, buffer, length, 0, (sockaddr *) &saddr, + socketFamily == AF_INET ? sizeof(sockaddr_in) : sizeof(sockaddr_in6)); + if (status < length) { + if (status < 0) + perror("sendto"); + else if (status == 0) + printf("no data sent!\n"); + else + printf("not all data sent!\n"); + } else + printf("send(): success\n"); + + close(fd); + return 0; +} diff --git a/src/tests/kits/net/ipv6/raw_server.cpp b/src/tests/kits/net/ipv6/raw_server.cpp new file mode 100644 index 0000000000..62a81b086b --- /dev/null +++ b/src/tests/kits/net/ipv6/raw_server.cpp @@ -0,0 +1,86 @@ +/* + * Copyright 2010, Atis Elsts, the.kfx@gmail.com + * Distributed under the terms of the MIT license. + */ + + +#include +#include +#include +#include +#include +#include +#include +#include + + +const unsigned short TEST_PROTOCOL = 89; + + +void +recvLoop(int fd) +{ + for (;;) { + char buffer[1000]; + sockaddr_storage address; + socklen_t socklen = sizeof(address); + memset(&address, 0, socklen); + + int status = recvfrom(fd, buffer, sizeof(buffer) - 1, 0, + (sockaddr *) &address, &socklen); + if (status < 0) { + perror("recvfrom"); + exit(-1); + } + if (status == 0) { + printf("received EOF!\n"); + break; + } else { + char *p = buffer; + if (address.ss_family == AF_INET && status >= sizeof(struct ip)) + p += sizeof(struct ip); + buffer[status] = 0; + printf("received %d bytes: \"%s\"\n", status, p); + } + } +} + + +int +main(int argc, char *argv[]) +{ + int socketFamily = AF_INET; + + if (argc > 1) { + if (!strcmp(argv[1], "-4")) + socketFamily = AF_INET; + else if (!strcmp(argv[1], "-6")) + socketFamily = AF_INET6; + } + + int fd = socket(socketFamily, SOCK_RAW, TEST_PROTOCOL); + if (fd < 0) { + perror("socket"); + return -1; + } + + sockaddr_storage localAddress; + memset(&localAddress, 0, sizeof(localAddress)); + if (socketFamily == AF_INET) { + sockaddr_in *sa = (sockaddr_in *) &localAddress; + sa->sin_family = AF_INET; + } else { + sockaddr_in6 *sa = (sockaddr_in6 *) &localAddress; + sa->sin6_family = AF_INET6; + } + + // TODO: is this even necessary? + if (bind(fd, (sockaddr *)&localAddress, socketFamily == AF_INET ? + sizeof(sockaddr_in) : sizeof(sockaddr_in6)) < 0) { + perror("bind"); + return -1; + } + + for (;;) + recvLoop(fd); +} diff --git a/src/tests/kits/net/ipv6/tcp_udp_client.cpp b/src/tests/kits/net/ipv6/tcp_udp_client.cpp new file mode 100644 index 0000000000..77dd5f5b28 --- /dev/null +++ b/src/tests/kits/net/ipv6/tcp_udp_client.cpp @@ -0,0 +1,98 @@ +/* + * Copyright 2010, Atis Elsts, the.kfx@gmail.com + * Distributed under the terms of the MIT license. + */ + + +#include +#include +#include +#include +#include +#include +#include + + +const unsigned short TEST_PORT = 40000; + + +void +usage() +{ + printf("client [tcp|udp] [4|6] [4|6]\n"); + exit(1); +} + + +int +main(int argc, char *argv[]) +{ + int socketType = SOCK_DGRAM; + int socketFamily1 = AF_INET; + int socketFamily2 = AF_INET; + + if (argc > 1) { + if (!strcmp(argv[1], "tcp")) + socketType = SOCK_STREAM; + else if (!strcmp(argv[1], "udp")) + socketType = SOCK_DGRAM; + else + usage(); + } + if (argc > 2) { + switch (atoi(argv[2])) { + case 4: + socketFamily1 = AF_INET; + break; + case 6: + socketFamily1 = AF_INET6; + break; + default: + usage(); + } + } + if (argc > 3) { + switch (atoi(argv[3])) { + case 4: + socketFamily2 = AF_INET; + break; + case 6: + socketFamily2 = AF_INET6; + break; + default: + usage(); + } + } + + int fd = socket(socketFamily1, socketType, 0); + if (fd < 0) { + perror("socket"); + return -1; + } + + sockaddr_storage saddr; + memset(&saddr, 0, sizeof(saddr)); + saddr.ss_family = socketFamily2; + ((sockaddr_in *) &saddr)->sin_port = htons(TEST_PORT); + if (connect(fd, (sockaddr *) &saddr, socketFamily2 == AF_INET ? + sizeof(sockaddr_in) : sizeof(sockaddr_in6)) < 0) { + perror("connect"); + close(fd); + return -1; + } + + const char *buffer = "hello world"; + unsigned length = strlen(buffer); + int status = send(fd, buffer, length, 0); + if (status < length) { + if (status < 0) + perror("send"); + else if (status == 0) + printf("no data sent!\n"); + else + printf("not all data sent!\n"); + } else + printf("send(): success\n"); + close(fd); + return 0; +} diff --git a/src/tests/kits/net/ipv6/tcp_udp_server.cpp b/src/tests/kits/net/ipv6/tcp_udp_server.cpp new file mode 100644 index 0000000000..c6200a6d44 --- /dev/null +++ b/src/tests/kits/net/ipv6/tcp_udp_server.cpp @@ -0,0 +1,140 @@ +/* + * Copyright 2010, Atis Elsts, the.kfx@gmail.com + * Distributed under the terms of the MIT license. + */ + + +#include +#include +#include +#include +#include +#include +#include + + +const unsigned short TEST_PORT = 40000; + + +void +usage() +{ + printf("server [tcp|udp] [4|6] [local-address]\n"); + exit(1); +} + + +void +recvLoop(int fd) +{ + for (;;) { + char buffer[1000]; + int status = recv(fd, buffer, sizeof(buffer) - 1, 0); + if (status < 0) { + perror("recv"); + exit(-1); + } + if (status == 0) { + printf("received EOF!\n"); + break; + } else { + buffer[status] = 0; + printf("received %d bytes: \"%s\"\n", status, buffer); + } + } +} + + +int +main(int argc, char *argv[]) +{ + int socketType = SOCK_DGRAM; + int socketFamily = AF_INET; + if (argc > 1) { + if (!strcmp(argv[1], "tcp")) + socketType = SOCK_STREAM; + else if (!strcmp(argv[1], "udp")) + socketType = SOCK_DGRAM; + else + usage(); + } + if (argc > 2) { + switch (atoi(argv[2])) { + case 4: + socketFamily = AF_INET; + break; + case 6: + socketFamily = AF_INET6; + break; + default: + usage(); + } + } + + sockaddr_storage localAddress; + memset(&localAddress, 0, sizeof(localAddress)); + localAddress.ss_family = socketFamily; + ((sockaddr_in *) &localAddress)->sin_port = htons(TEST_PORT); + + if (argc > 3) { + do { + void *dstBuffer = &((sockaddr_in *) &localAddress)->sin_addr; + if (inet_pton(AF_INET, argv[3], dstBuffer) == 1) { + printf("using IPv4 local address\n"); + localAddress.ss_family = AF_INET; + break; + } + + dstBuffer = &((sockaddr_in6 *) &localAddress)->sin6_addr; + if (inet_pton(AF_INET6, argv[3], dstBuffer) == 1) { + printf("using IPv6 local address\n"); + localAddress.ss_family = AF_INET6; + break; + } + + usage(); + } while (false); + } + + int fd = socket(socketFamily, socketType, 0); + if (fd < 0) { + perror("socket"); + return -1; + } + + if (bind(fd, (sockaddr *)&localAddress, localAddress.ss_family == AF_INET ? + sizeof(sockaddr_in) : sizeof(sockaddr_in6)) < 0) { + perror("bind"); + return -1; + } + + switch (socketType) { + case SOCK_DGRAM: + for (;;) + recvLoop(fd); + break; + case SOCK_STREAM: + if (listen(fd, 5) < 0) { + perror("listen"); + return 1; + } + for (;;) { + int clientfd = accept(fd, NULL, 0); + if (clientfd < 0) { + perror("accept"); + return 1; + } + printf("TCP server: got some client!\n"); + if (fork() != 0) { + // parent code + close(clientfd); + continue; + } + // child code + close(fd); + recvLoop(clientfd); + exit(0); + } + break; + } +} diff --git a/src/tests/kits/net/ipv6/udp_client.cpp b/src/tests/kits/net/ipv6/udp_client.cpp new file mode 100644 index 0000000000..263684121b --- /dev/null +++ b/src/tests/kits/net/ipv6/udp_client.cpp @@ -0,0 +1,72 @@ +/* + * Copyright 2010, Atis Elsts, the.kfx@gmail.com + * Distributed under the terms of the MIT license. + */ + + +#include +#include +#include +#include +#include +#include +#include + + +const unsigned short TEST_PORT = 40000; + + +int +main(int argc, char *argv[]) +{ + int socketFamily = AF_INET; + + if (argc > 1) { + if (!strcmp(argv[1], "-4")) + socketFamily = AF_INET; + else if (!strcmp(argv[1], "-6")) + socketFamily = AF_INET6; + } + + int fd = socket(socketFamily, SOCK_DGRAM, 0); + if (fd < 0) { + perror("socket"); + return -1; + } + + sockaddr_storage saddr; + memset(&saddr, 0, sizeof(saddr)); + if (socketFamily == AF_INET) { + sockaddr_in *sa = (sockaddr_in *) &saddr; + sa->sin_family = AF_INET; + sa->sin_port = htons(TEST_PORT); + sa->sin_addr.s_addr = htonl(INADDR_LOOPBACK); + } else { + sockaddr_in6 *sa = (sockaddr_in6 *) &saddr; + sa->sin6_family = AF_INET6; + sa->sin6_port = htons(TEST_PORT); + sa->sin6_addr.s6_addr[15] = 0x01; // loopback + + // 2001::1 + // sa->sin6_addr.s6_addr[0] = 0x20; + // sa->sin6_addr.s6_addr[1] = 0x01; + // sa->sin6_addr.s6_addr[15] = 0x01; + } + + const char *buffer = "hello world"; + unsigned length = strlen(buffer); + int status = sendto(fd, buffer, length, 0, (sockaddr *) &saddr, + socketFamily == AF_INET ? sizeof(sockaddr_in) : sizeof(sockaddr_in6)); + if (status < length) { + if (status < 0) + perror("sendto"); + else if (status == 0) + printf("no data sent!\n"); + else + printf("not all data sent!\n"); + } else + printf("send(): success\n"); + + close(fd); + return 0; +} diff --git a/src/tests/kits/net/ipv6/udp_server.cpp b/src/tests/kits/net/ipv6/udp_server.cpp new file mode 100644 index 0000000000..69ef98dd52 --- /dev/null +++ b/src/tests/kits/net/ipv6/udp_server.cpp @@ -0,0 +1,86 @@ +/* + * Copyright 2010, Atis Elsts, the.kfx@gmail.com + * Distributed under the terms of the MIT license. + */ + + +#include +#include +#include +#include +#include +#include +#include +#include + + +const unsigned short TEST_PORT = 40000; + + +void +recvLoop(int fd) +{ + for (;;) { + char buffer[1000]; + sockaddr_storage address; + socklen_t socklen = sizeof(address); + memset(&address, 0, socklen); + + int status = recvfrom(fd, buffer, sizeof(buffer) - 1, 0, + (sockaddr *) &address, &socklen); + if (status < 0) { + perror("recvfrom"); + exit(-1); + } + if (status == 0) { + printf("received EOF!\n"); + break; + } else { + buffer[status] = 0; + printf("received %d bytes: \"%s\"\n", status, buffer); + } + } +} + + +int +main(int argc, char *argv[]) +{ + int socketFamily = AF_INET; + + if (argc > 1) { + if (!strcmp(argv[1], "-4")) + socketFamily = AF_INET; + else if (!strcmp(argv[1], "-6")) + socketFamily = AF_INET6; + } + + int fd = socket(socketFamily, SOCK_DGRAM, 0); + if (fd < 0) { + perror("socket"); + return -1; + } + + sockaddr_storage localAddress; + memset(&localAddress, 0, sizeof(localAddress)); + if (socketFamily == AF_INET) { + sockaddr_in *sa = (sockaddr_in *) &localAddress; + sa->sin_family = AF_INET; + sa->sin_port = htons(TEST_PORT); + } else { + sockaddr_in6 *sa = (sockaddr_in6 *) &localAddress; + sa->sin6_family = AF_INET6; + sa->sin6_port = htons(TEST_PORT); + // loopback + sa->sin6_addr.s6_addr[15] = 0x01; + } + + if (bind(fd, (sockaddr *)&localAddress, socketFamily == AF_INET ? + sizeof(sockaddr_in) : sizeof(sockaddr_in6)) < 0) { + perror("bind"); + return -1; + } + + for (;;) + recvLoop(fd); +}