vrr/open5gs
2
0
Fork 0
mirror of https://github.com/open5gs/open5gs.git synced 2026-05-05 07:08:11 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

udp connect function is added for bind & connect behavior

Browse source
This commit is contained in:
Sukchan Lee 2017-11-19 08:27:20 +09:00
parent 1238f31178
commit 376f7c1304
8 changed files with 135 additions and 41 deletions
Download patch file Download diff file Expand all files Collapse all files

113
lib/core/test/testsock.c
View file

@ -8,20 +8,9 @@
#define DATASTR "This is a test"
#define STRLEN 8092
#define PORT 7777
#define PORT2 7778
static void sock_test1(abts_case *tc, void *data)
{
c_sockaddr_t *sa;
status_t rv;
rv = core_getaddrinfo(&sa, AF_UNSPEC, NULL, PORT, 0);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
rv = core_freeaddrinfo(sa);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
}
static void sock_test2(abts_case *tc, void *data)
{
sock_id udp;
status_t rv;
@ -45,8 +34,8 @@ static void sock_test2(abts_case *tc, void *data)
ABTS_INT_EQUAL(tc, CORE_OK, rv);
}
static thread_id test3_thread;
static void *THREAD_FUNC test3_main(thread_id id, void *data)
static thread_id test2_thread;
static void *THREAD_FUNC test2_main(thread_id id, void *data)
{
abts_case *tc = data;
status_t rv;
@ -67,7 +56,7 @@ static void *THREAD_FUNC test3_main(thread_id id, void *data)
return NULL;
}
static void sock_test3(abts_case *tc, void *data)
static void sock_test2(abts_case *tc, void *data)
{
status_t rv;
sock_id tcp, tcp2;
@ -77,7 +66,7 @@ static void sock_test3(abts_case *tc, void *data)
rv = tcp_server(&tcp, AF_INET6, NULL, PORT);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
rv = thread_create(&test3_thread, NULL, test3_main, tc);
rv = thread_create(&test2_thread, NULL, test2_main, tc);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
rv = sock_accept(&tcp2, &sa, tcp);
@ -86,7 +75,7 @@ static void sock_test3(abts_case *tc, void *data)
size = core_send(tcp2, DATASTR, strlen(DATASTR), 0);
ABTS_INT_EQUAL(tc, strlen(DATASTR), size);
thread_join(&rv, test3_thread);
thread_join(&rv, test2_thread);
ABTS_INT_EQUAL(tc, strlen(DATASTR), rv);
rv = sock_delete(tcp2);
@ -96,8 +85,8 @@ static void sock_test3(abts_case *tc, void *data)
ABTS_INT_EQUAL(tc, CORE_OK, rv);
}
static thread_id test4_thread;
static void *THREAD_FUNC test4_main(thread_id id, void *data)
static thread_id test3_thread;
static void *THREAD_FUNC test3_main(thread_id id, void *data)
{
abts_case *tc = data;
status_t rv;
@ -126,6 +115,59 @@ static void *THREAD_FUNC test4_main(thread_id id, void *data)
return NULL;
}
static void sock_test3(abts_case *tc, void *data)
{
sock_id udp;
status_t rv;
ssize_t size;
c_sockaddr_t sa;
socklen_t addrlen;
char str[STRLEN];
char buf[CORE_ADDRSTRLEN];
rv = udp_server(&udp, AF_INET, NULL, PORT);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
rv = thread_create(&test3_thread, NULL, test3_main, tc);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
size = core_recvfrom(udp, str, STRLEN, 0, &sa);
ABTS_INT_EQUAL(tc, strlen(DATASTR), size);
ABTS_INT_EQUAL(tc, sizeof(struct sockaddr_in), sa.sa_len);
ABTS_STR_EQUAL(tc, "127.0.0.1", CORE_NTOP(&sa, buf));
thread_join(&rv, test3_thread);
ABTS_INT_EQUAL(tc, strlen(DATASTR), rv);
rv = sock_delete(udp);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
}
static thread_id test4_thread;
static void *THREAD_FUNC test4_main(thread_id id, void *data)
{
abts_case *tc = data;
status_t rv;
sock_id udp;
char str[STRLEN];
ssize_t size;
rv = udp_client(&udp, AF_INET, "127.0.0.1", PORT);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
size = core_send(udp, DATASTR, strlen(DATASTR), 0);
ABTS_INT_EQUAL(tc, strlen(DATASTR), size);
size = core_recv(udp, str, STRLEN, 0);
ABTS_INT_EQUAL(tc, strlen(DATASTR), size);
rv = sock_delete(udp);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
thread_exit(id, size);
return NULL;
}
static void sock_test4(abts_case *tc, void *data)
{
sock_id udp;
@ -147,6 +189,9 @@ static void sock_test4(abts_case *tc, void *data)
ABTS_INT_EQUAL(tc, sizeof(struct sockaddr_in), sa.sa_len);
ABTS_STR_EQUAL(tc, "127.0.0.1", CORE_NTOP(&sa, buf));
size = core_sendto(udp, DATASTR, strlen(DATASTR), 0, &sa);
ABTS_INT_EQUAL(tc, strlen(DATASTR), size);
thread_join(&rv, test4_thread);
ABTS_INT_EQUAL(tc, strlen(DATASTR), rv);
@ -163,7 +208,10 @@ static void *THREAD_FUNC test5_main(thread_id id, void *data)
char str[STRLEN];
ssize_t size;
rv = udp_client(&udp, AF_INET, "127.0.0.1", PORT);
rv = udp_server(&udp, AF_INET6, NULL, PORT2);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
rv = udp_connect(udp, "::1", PORT);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
size = core_send(udp, DATASTR, strlen(DATASTR), 0);
@ -189,7 +237,10 @@ static void sock_test5(abts_case *tc, void *data)
char str[STRLEN];
char buf[CORE_ADDRSTRLEN];
rv = udp_server(&udp, AF_INET, NULL, PORT);
rv = udp_server(&udp, AF_INET6, NULL, PORT);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
rv = udp_connect(udp, "::1", PORT2);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
rv = thread_create(&test5_thread, NULL, test5_main, tc);
@ -197,10 +248,10 @@ static void sock_test5(abts_case *tc, void *data)
size = core_recvfrom(udp, str, STRLEN, 0, &sa);
ABTS_INT_EQUAL(tc, strlen(DATASTR), size);
ABTS_INT_EQUAL(tc, sizeof(struct sockaddr_in), sa.sa_len);
ABTS_STR_EQUAL(tc, "127.0.0.1", CORE_NTOP(&sa, buf));
ABTS_INT_EQUAL(tc, sizeof(struct sockaddr_in6), sa.sa_len);
ABTS_STR_EQUAL(tc, "::1", CORE_NTOP(&sa, buf));
size = core_sendto(udp, DATASTR, strlen(DATASTR), 0, &sa);
size = core_send(udp, DATASTR, strlen(DATASTR), 0);
ABTS_INT_EQUAL(tc, strlen(DATASTR), size);
thread_join(&rv, test5_thread);
@ -210,6 +261,19 @@ static void sock_test5(abts_case *tc, void *data)
ABTS_INT_EQUAL(tc, CORE_OK, rv);
}
static void sock_test6(abts_case *tc, void *data)
{
c_sockaddr_t *sa;
status_t rv;
rv = core_getaddrinfo(&sa, AF_UNSPEC, NULL, PORT, 0);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
rv = core_freeaddrinfo(sa);
ABTS_INT_EQUAL(tc, CORE_OK, rv);
}
abts_suite *testsock(abts_suite *suite)
{
suite = ADD_SUITE(suite)
@ -219,6 +283,7 @@ abts_suite *testsock(abts_suite *suite)
abts_run_test(suite, sock_test3, NULL);
abts_run_test(suite, sock_test4, NULL);
abts_run_test(suite, sock_test5, NULL);
abts_run_test(suite, sock_test6, NULL);
return suite;
}