diff options
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/CMakeLists.txt | 27 | ||||
| -rw-r--r-- | tests/compat_block.c | 69 | ||||
| -rw-r--r-- | tests/compat_bug777.c | 48 | ||||
| -rw-r--r-- | tests/compat_bus.c | 88 | ||||
| -rw-r--r-- | tests/compat_cmsg.c | 117 | ||||
| -rw-r--r-- | tests/compat_device.c | 189 | ||||
| -rw-r--r-- | tests/compat_iovec.c | 74 | ||||
| -rw-r--r-- | tests/compat_msg.c | 131 | ||||
| -rw-r--r-- | tests/compat_options.c | 57 | ||||
| -rw-r--r-- | tests/compat_pair.c | 50 | ||||
| -rw-r--r-- | tests/compat_pipeline.c | 85 | ||||
| -rw-r--r-- | tests/compat_poll.c | 203 | ||||
| -rw-r--r-- | tests/compat_reqrep.c | 203 | ||||
| -rw-r--r-- | tests/compat_reqttl.c | 153 | ||||
| -rw-r--r-- | tests/compat_shutdown.c | 48 | ||||
| -rw-r--r-- | tests/compat_survey.c | 106 | ||||
| -rw-r--r-- | tests/compat_surveyttl.c | 146 | ||||
| -rw-r--r-- | tests/compat_testutil.c | 240 | ||||
| -rw-r--r-- | tests/compat_testutil.h | 86 |
19 files changed, 0 insertions, 2120 deletions
diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt index 35a3b44f..2fcc331e 100644 --- a/tests/CMakeLists.txt +++ b/tests/CMakeLists.txt @@ -148,32 +148,5 @@ add_nng_test1(zt 60 NNG_TRANSPORT_ZEROTIER) add_nng_test(reqctx 5) add_nng_test(reqstress 60) -# compatibility tests -# We only support these if ALL the legacy protocols are supported. This -# is because we don't want to make modifications to partially enable some -# of these tests. Folks minimizing the library probably don't care too -# much about these anyway. -if (NNG_ENABLE_COMPAT) - add_nng_compat_test(compat_block 10) - add_nng_compat_test(compat_bug777 10) - add_nng_compat_test(compat_bus 10) - add_nng_compat_test(compat_cmsg 10) - add_nng_compat_test(compat_msg 10) - add_nng_compat_test(compat_iovec 10) - add_nng_compat_test(compat_device 10) - add_nng_compat_test(compat_pair 10) - add_nng_compat_test(compat_pipeline 10) - add_nng_compat_test(compat_poll 10) - add_nng_compat_test(compat_reqrep 10) - add_nng_compat_test(compat_survey 10) - add_nng_compat_test(compat_reqttl 10) - add_nng_compat_test(compat_shutdown 10) - add_nng_compat_test(compat_surveyttl 10) - - # These are special tests for compat mode, not inherited from the - # legacy libnanomsg suite. - add_nng_test(compat_options 5) -endif() - # c++ tests add_nng_cpp_test(cplusplus_pair 5) diff --git a/tests/compat_block.c b/tests/compat_block.c deleted file mode 100644 index a0a1fd1a..00000000 --- a/tests/compat_block.c +++ /dev/null @@ -1,69 +0,0 @@ -/* - Copyright (c) 2012 Martin Sustrik All rights reserved. - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/pair.h> -#include "compat_testutil.h" - -/* This test checks whether blocking on send/recv works as expected. */ - -#define SOCKET_ADDRESS "inproc://a" - -int sc; -int sb; - -void worker (NN_UNUSED void *arg) -{ - /* Wait 0.1 sec for the main thread to block. */ - nn_sleep (100); - - test_send (sc, "ABC"); - - /* Wait 0.1 sec for the main thread to process the previous message - and block once again. */ - nn_sleep (100); - - test_send (sc, "ABC"); -} - -int main () -{ - struct nn_thread thread; - - sb = test_socket (AF_SP, NN_PAIR); - test_bind (sb, SOCKET_ADDRESS); - sc = test_socket (AF_SP, NN_PAIR); - test_connect (sc, SOCKET_ADDRESS); - - nn_thread_init (&thread, worker, NULL); - - test_recv (sb, "ABC"); - test_recv (sb, "ABC"); - - nn_thread_term (&thread); - - test_close (sc); - test_close (sb); - - return 0; -} - diff --git a/tests/compat_bug777.c b/tests/compat_bug777.c deleted file mode 100644 index 638c41b2..00000000 --- a/tests/compat_bug777.c +++ /dev/null @@ -1,48 +0,0 @@ -/* - Copyright 2018 Staysail Systems, Inc. <info@staysail.tech> - Copyright 2018 Capitar IT Group BV <info@capitar.com> - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/pair.h> -#include "compat_testutil.h" - -int main (NN_UNUSED int argc, NN_UNUSED const char *argv[]) -{ - int sb; - int sc1; - int sc2; - - sb = test_socket (AF_SP, NN_PAIR); - test_bind (sb, "inproc://pair"); - sc1 = test_socket (AF_SP, NN_PAIR); - test_connect (sc1, "inproc://pair"); - nn_sleep (100); - sc2 = test_socket (AF_SP, NN_PAIR); - test_connect (sc2, "inproc://pair"); - - test_send (sb, "HELLO"); - test_recv (sc1, "HELLO"); - - test_send (sc1, "THERE"); - test_recv (sb, "THERE"); - return 0; -} diff --git a/tests/compat_bus.c b/tests/compat_bus.c deleted file mode 100644 index 70506047..00000000 --- a/tests/compat_bus.c +++ /dev/null @@ -1,88 +0,0 @@ -/* - Copyright (c) 2012 Martin Sustrik All rights reserved. - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/bus.h> -#include "compat_testutil.h" - -#define SOCKET_ADDRESS_A "inproc://a" -#define SOCKET_ADDRESS_B "inproc://b" - -int main () -{ - int rc; - int bus1; - int bus2; - int bus3; - char buf [3]; - - /* Create a simple bus topology consisting of 3 nodes. */ - bus1 = test_socket (AF_SP, NN_BUS); - test_bind (bus1, SOCKET_ADDRESS_A); - bus2 = test_socket (AF_SP, NN_BUS); - test_bind (bus2, SOCKET_ADDRESS_B); - - nn_sleep(100); - - test_connect (bus2, SOCKET_ADDRESS_A); - bus3 = test_socket (AF_SP, NN_BUS); - test_connect (bus3, SOCKET_ADDRESS_A); - test_connect (bus3, SOCKET_ADDRESS_B); - - /* Wait for connections to establish asynchronously. */ - nn_sleep(100); - - /* Send a message from each node. */ - test_send (bus1, "A"); - test_send (bus2, "AB"); - test_send (bus3, "ABC"); - - /* Check that two messages arrived at each node. */ - rc = nn_recv (bus1, buf, 3, 0); - errno_assert (rc >= 0); - nn_assert (rc == 2 || rc == 3); - rc = nn_recv (bus1, buf, 3, 0); - errno_assert (rc >= 0); - nn_assert (rc == 2 || rc == 3); - rc = nn_recv (bus2, buf, 3, 0); - errno_assert (rc >= 0); - nn_assert (rc == 1 || rc == 3); - rc = nn_recv (bus2, buf, 3, 0); - errno_assert (rc >= 0); - nn_assert (rc == 1 || rc == 3); - rc = nn_recv (bus3, buf, 3, 0); - errno_assert (rc >= 0); - nn_assert (rc == 1 || rc == 2); - rc = nn_recv (bus3, buf, 3, 0); - errno_assert (rc >= 0); - nn_assert (rc == 1 || rc == 2); - - /* Wait till both connections are established. */ - nn_sleep (10); - - test_close (bus3); - test_close (bus2); - test_close (bus1); - - return 0; -} - diff --git a/tests/compat_cmsg.c b/tests/compat_cmsg.c deleted file mode 100644 index 06d67467..00000000 --- a/tests/compat_cmsg.c +++ /dev/null @@ -1,117 +0,0 @@ -/* - Copyright (c) 2014 Martin Sustrik All rights reserved. - Copyright 2018 Garrett D'Amore <garrett@damore.org> - Copyright 2016 Franklin "Snaipe" Mathieu <franklinmathieu@gmail.com> - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/tcp.h> -#include <nng/compat/nanomsg/reqrep.h> - -#include "compat_testutil.h" - -int main (int argc, const char *argv[]) -{ - int rc; - int rep; - int req; - struct nn_msghdr hdr; - struct nn_iovec iovec; - unsigned char body [3]; - unsigned char ctrl [256]; - struct nn_cmsghdr *cmsg; - unsigned char *data; - void *buf; - char socket_address[128]; - - test_addr_from(socket_address, "tcp", "127.0.0.1", - get_test_port(argc, argv)); - strcpy(socket_address, "inproc://testaddr"); - - rep = test_socket (AF_SP_RAW, NN_REP); - test_bind (rep, socket_address); - req = test_socket (AF_SP, NN_REQ); - test_connect (req, socket_address); - - /* Test ancillary data in static buffer. */ - - test_send (req, "ABC"); - - iovec.iov_base = body; - iovec.iov_len = sizeof (body); - hdr.msg_iov = &iovec; - hdr.msg_iovlen = 1; - hdr.msg_control = ctrl; - hdr.msg_controllen = sizeof (ctrl); - rc = nn_recvmsg (rep, &hdr, 0); - errno_assert (rc == 3); - - cmsg = NN_CMSG_FIRSTHDR (&hdr); - while (1) { - nn_assert (cmsg); - if (cmsg->cmsg_level == PROTO_SP && cmsg->cmsg_type == SP_HDR) - break; - cmsg = NN_CMSG_NXTHDR (&hdr, cmsg); - } - nn_assert (cmsg->cmsg_len == NN_CMSG_SPACE (8+sizeof (size_t))); - data = NN_CMSG_DATA (cmsg); - nn_assert (!(data[0+sizeof (size_t)] & 0x80)); - nn_assert (data[4+sizeof (size_t)] & 0x80); - - rc = nn_sendmsg (rep, &hdr, 0); - nn_assert (rc == 3); - test_recv (req, "ABC"); - - /* Test ancillary data in dynamically allocated buffer (NN_MSG). */ - - test_send (req, "ABC"); - - iovec.iov_base = body; - iovec.iov_len = sizeof (body); - hdr.msg_iov = &iovec; - hdr.msg_iovlen = 1; - hdr.msg_control = &buf; - hdr.msg_controllen = NN_MSG; - rc = nn_recvmsg (rep, &hdr, 0); - errno_assert (rc == 3); - - cmsg = NN_CMSG_FIRSTHDR (&hdr); - while (1) { - nn_assert (cmsg); - if (cmsg->cmsg_level == PROTO_SP && cmsg->cmsg_type == SP_HDR) - break; - cmsg = NN_CMSG_NXTHDR (&hdr, cmsg); - } - nn_assert (cmsg->cmsg_len == NN_CMSG_SPACE (8+sizeof (size_t))); - data = NN_CMSG_DATA (cmsg); - nn_assert (!(data[0+sizeof (size_t)] & 0x80)); - nn_assert (data[4+sizeof (size_t)] & 0x80); - - rc = nn_sendmsg (rep, &hdr, 0); - nn_assert (rc == 3); - test_recv (req, "ABC"); - - test_close (req); - test_close (rep); - - return 0; -} - diff --git a/tests/compat_device.c b/tests/compat_device.c deleted file mode 100644 index 3c96e5b9..00000000 --- a/tests/compat_device.c +++ /dev/null @@ -1,189 +0,0 @@ -/* - * Copyright (c) 2012 Martin Sustrik All rights reserved. - * Copyright (c) 2013 GoPivotal, Inc. All rights reserved. - * - * Permission is hereby granted, free of charge, to any person obtaining a copy - * of this software and associated documentation files (the "Software"), - * to deal in the Software without restriction, including without limitation - * the rights to use, copy, modify, merge, publish, distribute, sublicense, - * and/or sell copies of the Software, and to permit persons to whom - * the Software is furnished to do so, subject to the following conditions: - * - * The above copyright notice and this permission notice shall be included - * in all copies or substantial portions of the Software. - * - * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - * IN THE SOFTWARE. - */ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/bus.h> -#include <nng/compat/nanomsg/pair.h> -#include <nng/compat/nanomsg/pipeline.h> -#include <nng/compat/nanomsg/inproc.h> -#include "compat_testutil.h" - -#define SOCKET_ADDRESS_A "inproc://a" -#define SOCKET_ADDRESS_B "inproc://b" -#define SOCKET_ADDRESS_C "inproc://c" -#define SOCKET_ADDRESS_D "inproc://d" -#define SOCKET_ADDRESS_E "inproc://e" - -int deva = -1; -int devb = -1; -int devc = -1; -int devd = -1; -int deve = -1; - -void device1(NN_UNUSED void *arg) -{ - int rc; - - /* Intialise the device sockets. */ - deva = test_socket(AF_SP_RAW, NN_PAIR); - test_bind(deva, SOCKET_ADDRESS_A); - devb = test_socket(AF_SP_RAW, NN_PAIR); - test_bind(devb, SOCKET_ADDRESS_B); - - /* Run the device. */ - rc = nn_device(deva, devb); - nn_assert(rc < 0 && (nn_errno() == EBADF)); -} - - -void device2(NN_UNUSED void *arg) -{ - int rc; - - /* Intialise the device sockets. */ - devc = test_socket(AF_SP_RAW, NN_PULL); - test_bind(devc, SOCKET_ADDRESS_C); - devd = test_socket(AF_SP_RAW, NN_PUSH); - test_bind(devd, SOCKET_ADDRESS_D); - - /* Run the device. */ - rc = nn_device(devc, devd); - nn_assert(rc < 0 && nn_errno() == EBADF); -} - - -void device3(NN_UNUSED void *arg) -{ - int rc; - - /* Intialise the device socket. */ - deve = test_socket(AF_SP_RAW, NN_BUS); - test_bind(deve, SOCKET_ADDRESS_E); - - /* Run the device. */ - rc = nn_device(deve, -1); - nn_assert(rc < 0 && nn_errno() == EBADF); -} - - -int main() -{ - int enda; - int endb; - int endc; - int endd; - int ende1; - int ende2; - struct nn_thread thread1; - struct nn_thread thread2; - struct nn_thread thread3; - int timeo; - - /* Test the bi-directional device. */ - - /* Start the device. */ - nn_thread_init(&thread1, device1, NULL); - - /* Create two sockets to connect to the device. */ - enda = test_socket(AF_SP, NN_PAIR); - test_connect(enda, SOCKET_ADDRESS_A); - endb = test_socket(AF_SP, NN_PAIR); - test_connect(endb, SOCKET_ADDRESS_B); - - nn_sleep(100); - - /* Pass a pair of messages between endpoints. */ - test_send(enda, "ABC"); - test_recv(endb, "ABC"); - test_send(endb, "ABC"); - test_recv(enda, "ABC"); - - /* Clean up. */ - test_close(endb); - test_close(enda); - test_close(deva); - test_close(devb); - - /* Test the uni-directional device. */ - - /* Start the device. */ - nn_thread_init(&thread2, device2, NULL); - - nn_sleep(100); - - /* Create two sockets to connect to the device. */ - endc = test_socket(AF_SP, NN_PUSH); - test_connect(endc, SOCKET_ADDRESS_C); - endd = test_socket(AF_SP, NN_PULL); - test_connect(endd, SOCKET_ADDRESS_D); - - - /* Pass a message between endpoints. */ - test_send(endc, "XYZ"); - test_recv(endd, "XYZ"); - - /* Clean up. */ - test_close(endd); - test_close(endc); - test_close(devc); - test_close(devd); - - /* Test the loopback device. */ - - /* Start the device. */ - nn_thread_init(&thread3, device3, NULL); - nn_sleep(100); - - /* Create two sockets to connect to the device. */ - ende1 = test_socket(AF_SP, NN_BUS); - test_connect(ende1, SOCKET_ADDRESS_E); - ende2 = test_socket(AF_SP, NN_BUS); - test_connect(ende2, SOCKET_ADDRESS_E); - - /* BUS is unreliable so wait a bit for connections to be established. */ - nn_sleep(200); - - /* Pass a message to the bus. */ - test_send(ende1, "KLM"); - test_recv(ende2, "KLM"); - - /* Make sure that the message doesn't arrive at the socket it was - * originally sent to. */ - timeo = 100; - test_setsockopt(ende1, NN_SOL_SOCKET, NN_RCVTIMEO, - &timeo, sizeof (timeo)); - test_drop(ende1, ETIMEDOUT); - - /* Clean up. */ - test_close(ende2); - test_close(ende1); - test_close(deve); - - /* Shut down the devices. */ - nn_term(); - nn_thread_term(&thread1); - nn_thread_term(&thread2); - nn_thread_term(&thread3); - - return (0); -} diff --git a/tests/compat_iovec.c b/tests/compat_iovec.c deleted file mode 100644 index 54f078aa..00000000 --- a/tests/compat_iovec.c +++ /dev/null @@ -1,74 +0,0 @@ -/* - Copyright (c) 2013 Martin Sustrik All rights reserved. - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/pair.h> - -#include "compat_testutil.h" - -#include <string.h> - -#define SOCKET_ADDRESS "inproc://a" - -int main () -{ - int rc; - int sb; - int sc; - struct nn_iovec iov [2]; - struct nn_msghdr hdr; - char buf [6]; - - sb = test_socket (AF_SP, NN_PAIR); - test_bind (sb, SOCKET_ADDRESS); - sc = test_socket (AF_SP, NN_PAIR); - test_connect (sc, SOCKET_ADDRESS); - - iov [0].iov_base = "AB"; - iov [0].iov_len = 2; - iov [1].iov_base = "CDEF"; - iov [1].iov_len = 4; - memset (&hdr, 0, sizeof (hdr)); - hdr.msg_iov = iov; - hdr.msg_iovlen = 2; - rc = nn_sendmsg (sc, &hdr, 0); - errno_assert (rc >= 0); - nn_assert (rc == 6); - - iov [0].iov_base = buf; - iov [0].iov_len = 4; - iov [1].iov_base = buf + 4; - iov [1].iov_len = 2; - memset (&hdr, 0, sizeof (hdr)); - hdr.msg_iov = iov; - hdr.msg_iovlen = 2; - rc = nn_recvmsg (sb, &hdr, 0); - errno_assert (rc >= 0); - nn_assert (rc == 6); - nn_assert (memcmp (buf, "ABCDEF", 6) == 0); - - test_close (sc); - test_close (sb); - - return 0; -} - diff --git a/tests/compat_msg.c b/tests/compat_msg.c deleted file mode 100644 index c2efb2cc..00000000 --- a/tests/compat_msg.c +++ /dev/null @@ -1,131 +0,0 @@ -/* - Copyright (c) 2013 Martin Sustrik All rights reserved. - Copyright 2016 Franklin "Snaipe" Mathieu <franklinmathieu@gmail.com> - Copyright 2017 Garrett D'Amore <garrett@damore.org> - Copyright 2017 Capitar IT Group BV <info@capitar.com> - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/pair.h> - -#include "compat_testutil.h" - -#include <string.h> - -#define SOCKET_ADDRESS "inproc://a" - -char longdata[1 << 20]; - -int main (int argc, const char *argv[]) -{ - int rc; - int sb; - int sc; - unsigned char *buf1, *buf2; - int i; - struct nn_iovec iov; - struct nn_msghdr hdr; - char socket_address_tcp[128]; - - test_addr_from(socket_address_tcp, "tcp", "127.0.0.1", - get_test_port(argc, argv)); - - sb = test_socket (AF_SP, NN_PAIR); - test_bind (sb, SOCKET_ADDRESS); - sc = test_socket (AF_SP, NN_PAIR); - test_connect (sc, SOCKET_ADDRESS); - - buf1 = nn_allocmsg (256, 0); - alloc_assert (buf1); - for (i = 0; i != 256; ++i) - buf1 [i] = (unsigned char) i; - rc = nn_send (sc, &buf1, NN_MSG, 0); - errno_assert (rc >= 0); - nn_assert (rc == 256); - - buf2 = NULL; - rc = nn_recv (sb, &buf2, NN_MSG, 0); - errno_assert (rc >= 0); - nn_assert (rc == 256); - nn_assert (buf2); - for (i = 0; i != 256; ++i) - nn_assert (buf2 [i] == (unsigned char) i); - rc = nn_freemsg (buf2); - errno_assert (rc == 0); - - buf1 = nn_allocmsg (256, 0); - alloc_assert (buf1); - for (i = 0; i != 256; ++i) - buf1 [i] = (unsigned char) i; - iov.iov_base = &buf1; - iov.iov_len = NN_MSG; - memset (&hdr, 0, sizeof (hdr)); - hdr.msg_iov = &iov; - hdr.msg_iovlen = 1; - rc = nn_sendmsg (sc, &hdr, 0); - errno_assert (rc >= 0); - nn_assert (rc == 256); - - buf2 = NULL; - iov.iov_base = &buf2; - iov.iov_len = NN_MSG; - memset (&hdr, 0, sizeof (hdr)); - hdr.msg_iov = &iov; - hdr.msg_iovlen = 1; - rc = nn_recvmsg (sb, &hdr, 0); - errno_assert (rc >= 0); - nn_assert (rc == 256); - nn_assert (buf2); - for (i = 0; i != 256; ++i) - nn_assert (buf2 [i] == (unsigned char) i); - rc = nn_freemsg (buf2); - errno_assert (rc == 0); - - test_close (sc); - test_close (sb); - - /* Test receiving of large message */ - - sb = test_socket (AF_SP, NN_PAIR); - test_bind (sb, socket_address_tcp); - sc = test_socket (AF_SP, NN_PAIR); - test_connect (sc, socket_address_tcp); - - for (i = 0; i < (int) sizeof (longdata); ++i) - longdata[i] = '0' + (i % 10); - longdata [sizeof (longdata) - 1] = 0; - test_send (sb, longdata); - - rc = nn_recv (sc, &buf2, NN_MSG, 0); - errno_assert (rc >= 0); - nn_assert (rc == sizeof (longdata) - 1); - nn_assert (buf2); - for (i = 0; i < (int) sizeof (longdata) - 1; ++i) - nn_assert (buf2 [i] == longdata [i]); - rc = nn_freemsg (buf2); - errno_assert (rc == 0); - - test_close (sc); - test_close (sb); - - return 0; -} - diff --git a/tests/compat_options.c b/tests/compat_options.c deleted file mode 100644 index 305ae128..00000000 --- a/tests/compat_options.c +++ /dev/null @@ -1,57 +0,0 @@ -// -// Copyright 2018 Staysail Systems, Inc. <info@staysail.tech> -// Copyright 2018 Capitar IT Group BV <info@capitar.com> -// -// This software is supplied under the terms of the MIT License, a -// copy of which should be located in the distribution where this -// file was obtained (LICENSE.txt). A copy of the license may also be -// found online at https://opensource.org/licenses/MIT. -// - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/reqrep.h> - -#include "convey.h" -#include "compat_testutil.h" - -#include <string.h> - -#define SECONDS(x) ((x) *1000) - -TestMain("Compatible Options", { - - atexit(nn_term); - - Convey("Given a compat NN_REP socket", { - int repsock; - - So((repsock = nn_socket(AF_SP, NN_REP)) != -1); - Reset({ nn_close(repsock); }); - - Convey("NN_DOMAIN works", { - int dom = 4321; - size_t sz; - sz = sizeof(dom); - So(nn_getsockopt(repsock, NN_SOL_SOCKET, NN_DOMAIN, - &dom, &sz) == 0); - So(sz == sizeof(dom)); - So(dom == AF_SP); - - So(nn_setsockopt(repsock, NN_SOL_SOCKET, NN_DOMAIN, - &dom, sz) == -1); - So(nn_errno() == ENOPROTOOPT); - }); - Convey("NN_LINGER has no effect", { - int l = 4321; - size_t sz; - sz = sizeof(l); - So(nn_setsockopt(repsock, NN_SOL_SOCKET, NN_LINGER, &l, - sz) == 0); - - So(nn_getsockopt(repsock, NN_SOL_SOCKET, NN_LINGER, &l, - &sz) == 0); - So(sz == sizeof(l)); - So(l == 0); - }); - }); -}) diff --git a/tests/compat_pair.c b/tests/compat_pair.c deleted file mode 100644 index 000944c1..00000000 --- a/tests/compat_pair.c +++ /dev/null @@ -1,50 +0,0 @@ -/* - Copyright (c) 2012 Martin Sustrik All rights reserved. - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/pair.h> - -#include "compat_testutil.h" - -#define SOCKET_ADDRESS "inproc://a" - -int main () -{ - int sb; - int sc; - - sb = test_socket (AF_SP, NN_PAIR); - test_bind (sb, SOCKET_ADDRESS); - sc = test_socket (AF_SP, NN_PAIR); - test_connect (sc, SOCKET_ADDRESS); - - test_send (sc, "ABC"); - test_recv (sb, "ABC"); - test_send (sb, "DEF"); - test_recv (sc, "DEF"); - - test_close (sc); - test_close (sb); - - return 0; -} - diff --git a/tests/compat_pipeline.c b/tests/compat_pipeline.c deleted file mode 100644 index 679f08f7..00000000 --- a/tests/compat_pipeline.c +++ /dev/null @@ -1,85 +0,0 @@ -/* - Copyright (c) 2012 Martin Sustrik All rights reserved. - Copyright (c) 2013 GoPivotal, Inc. All rights reserved. - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/pipeline.h> -#include "compat_testutil.h" - -#define SOCKET_ADDRESS "inproc://a" - -int main () -{ - int push1; - int push2; - int pull1; - int pull2; - - /* Test fan-out. */ - - push1 = test_socket (AF_SP, NN_PUSH); - test_bind (push1, SOCKET_ADDRESS); - pull1 = test_socket (AF_SP, NN_PULL); - test_connect (pull1, SOCKET_ADDRESS); - nn_sleep (20); - pull2 = test_socket (AF_SP, NN_PULL); - test_connect (pull2, SOCKET_ADDRESS); - - /* Wait till both connections are established to get messages spread - evenly between the two pull sockets. */ - nn_sleep (20); - - test_send (push1, "ABC"); - test_send (push1, "DEF"); - - test_recv (pull1, "ABC"); - test_recv (pull2, "DEF"); - - test_close (push1); - test_close (pull1); - test_close (pull2); - - /* Test fan-in. */ - - pull1 = test_socket (AF_SP, NN_PULL); - test_bind (pull1, SOCKET_ADDRESS); - push1 = test_socket (AF_SP, NN_PUSH); - test_connect (push1, SOCKET_ADDRESS); - push2 = test_socket (AF_SP, NN_PUSH); - test_connect (push2, SOCKET_ADDRESS); - - nn_sleep (10); - test_send (push1, "ABC"); - - nn_sleep (10); - test_send (push2, "DEF"); - - test_recv (pull1, "ABC"); - test_recv (pull1, "DEF"); - - test_close (pull1); - test_close (push1); - test_close (push2); - - return 0; -} - diff --git a/tests/compat_poll.c b/tests/compat_poll.c deleted file mode 100644 index 3431f5f2..00000000 --- a/tests/compat_poll.c +++ /dev/null @@ -1,203 +0,0 @@ -/* - Copyright (c) 2013 Martin Sustrik All rights reserved. - - Permission is hereby granted, free of charge, to any person obtaining a - copy of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER - DEALINGS IN THE SOFTWARE. -*/ - - -#if defined _WIN32 -#define poll WSAPoll -#ifndef WIN32_LEAN_AND_MEAN -#define WIN32_LEAN_AND_MEAN -#endif -#include <windows.h> -#include <winsock2.h> -#include <mswsock.h> -#else -#include <sys/select.h> -#endif -#include "compat_testutil.h" -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/pair.h> -#include <nng/compat/nanomsg/inproc.h> - -/* Test of polling via NN_SNDFD/NN_RCVFD mechanism. */ - -#define SOCKET_ADDRESS "inproc://a" - -int sc; - -void -routine1(NN_UNUSED void *arg) -{ - nn_sleep(10); - test_send(sc, "ABC"); -} - -void -routine2(NN_UNUSED void *arg) -{ - nn_sleep(10); - nn_term(); -} - -#define NN_IN 1 -#define NN_OUT 2 - -int -getevents(int s, int events, int timeout) -{ - int rc; - fd_set pollset; -#if defined _WIN32 - SOCKET rcvfd; - SOCKET sndfd; -#else - int rcvfd; - int sndfd; - int maxfd; -#endif - size_t fdsz; - struct timeval tv; - int revents; - -#if !defined _WIN32 - maxfd = 0; -#endif - FD_ZERO(&pollset); - - if (events & NN_IN) { - fdsz = sizeof(rcvfd); - rc = nn_getsockopt( - s, NN_SOL_SOCKET, NN_RCVFD, (char *) &rcvfd, &fdsz); - errno_assert(rc == 0); - nn_assert(fdsz == sizeof(rcvfd)); - FD_SET(rcvfd, &pollset); -#if !defined _WIN32 - if (rcvfd + 1 > maxfd) - maxfd = rcvfd + 1; -#endif - } - - if (events & NN_OUT) { - fdsz = sizeof(sndfd); - rc = nn_getsockopt( - s, NN_SOL_SOCKET, NN_SNDFD, (char *) &sndfd, &fdsz); - errno_assert(rc == 0); - nn_assert(fdsz == sizeof(sndfd)); - FD_SET(sndfd, &pollset); -#if !defined _WIN32 - if (sndfd + 1 > maxfd) - maxfd = sndfd + 1; -#endif - } - - if (timeout >= 0) { - tv.tv_sec = timeout / 1000; - tv.tv_usec = (timeout % 1000) * 1000; - } -#if defined _WIN32 - rc = select(0, &pollset, NULL, NULL, timeout < 0 ? NULL : &tv); - wsa_assert(rc != SOCKET_ERROR); -#else - rc = select(maxfd, &pollset, NULL, NULL, timeout < 0 ? NULL : &tv); - errno_assert(rc >= 0); -#endif - revents = 0; - if ((events & NN_IN) && FD_ISSET(rcvfd, &pollset)) - revents |= NN_IN; - if ((events & NN_OUT) && FD_ISSET(sndfd, &pollset)) - revents |= NN_OUT; - return revents; -} - -int -main() -{ - int rc; - int sb; - char buf[3]; - struct nn_thread thread; - struct nn_pollfd pfd[2]; - - /* Test nn_poll() function. */ - sb = test_socket(AF_SP, NN_PAIR); - test_bind(sb, SOCKET_ADDRESS); - sc = test_socket(AF_SP, NN_PAIR); - test_connect(sc, SOCKET_ADDRESS); - nn_sleep(200); - test_send(sc, "ABC"); - nn_sleep(100); - pfd[0].fd = sb; - pfd[0].events = NN_POLLIN | NN_POLLOUT; - pfd[1].fd = sc; - pfd[1].events = NN_POLLIN | NN_POLLOUT; - rc = nn_poll(pfd, 2, -1); - errno_assert(rc >= 0); - nn_assert(rc == 2); - nn_assert(pfd[0].revents == (NN_POLLIN | NN_POLLOUT)); - nn_assert(pfd[1].revents == NN_POLLOUT); - test_close(sc); - test_close(sb); - - /* Create a simple topology. */ - sb = test_socket(AF_SP, NN_PAIR); - test_bind(sb, SOCKET_ADDRESS); - sc = test_socket(AF_SP, NN_PAIR); - test_connect(sc, SOCKET_ADDRESS); - - /* Check the initial state of the socket. */ - rc = getevents(sb, NN_IN | NN_OUT, 1000); - nn_assert(rc == NN_OUT); - - /* Poll for IN when there's no message available. The call should - time out. */ - rc = getevents(sb, NN_IN, 10); - nn_assert(rc == 0); - - /* Send a message and start polling. This time IN event should be - signaled. */ - test_send(sc, "ABC"); - rc = getevents(sb, NN_IN, 1000); - nn_assert(rc == NN_IN); - - /* Receive the message and make sure that IN is no longer signaled. */ - test_recv(sb, "ABC"); - rc = getevents(sb, NN_IN, 10); - nn_assert(rc == 0); - - /* Check signalling from a different thread. */ - nn_thread_init(&thread, routine1, NULL); - rc = getevents(sb, NN_IN, 1000); - nn_assert(rc == NN_IN); - test_recv(sb, "ABC"); - nn_thread_term(&thread); - - /* Check terminating the library from a different thread. */ - nn_thread_init(&thread, routine2, NULL); - rc = nn_recv(sb, buf, sizeof(buf), 0); - nn_assert(rc < 0 && nn_errno() == EBADF); - nn_thread_term(&thread); - - /* Clean up. */ - test_close(sc); - test_close(sb); - - return 0; -} diff --git a/tests/compat_reqrep.c b/tests/compat_reqrep.c deleted file mode 100644 index 7bd7bf7b..00000000 --- a/tests/compat_reqrep.c +++ /dev/null @@ -1,203 +0,0 @@ -/* - Copyright (c) 2012 Martin Sustrik All rights reserved. - Copyright 2018 Staysail Systems, Inc. <info@staysail.tech> - Copyright 2018 Capitar IT Group BV <info@capitar.com> - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/reqrep.h> - -#include "compat_testutil.h" - -#define SOCKET_ADDRESS "inproc://test" - -int main () -{ - int rc; - int rep1; - int rep2; - int req1; - int req2; - int resend_ivl; - char buf [7]; - int timeo; - - /* Test req/rep with full socket types. */ - rep1 = test_socket (AF_SP, NN_REP); - test_bind (rep1, SOCKET_ADDRESS); - req1 = test_socket (AF_SP, NN_REQ); - test_connect (req1, SOCKET_ADDRESS); - req2 = test_socket (AF_SP, NN_REQ); - test_connect (req2, SOCKET_ADDRESS); - - /* Check invalid sequence of sends and recvs. */ - rc = nn_send (rep1, "ABC", 3, 0); - nn_assert (rc == -1 && nn_errno () == EFSM); - rc = nn_recv (req1, buf, sizeof (buf), 0); - nn_assert (rc == -1 && nn_errno () == EFSM); - - /* Check fair queueing the requests. */ - test_send (req2, "ABC"); - test_recv (rep1, "ABC"); - test_send (rep1, "ABC"); - test_recv (req2, "ABC"); - - test_send (req1, "ABC"); - test_recv (rep1, "ABC"); - test_send (rep1, "ABC"); - test_recv (req1, "ABC"); - - test_close (rep1); - test_close (req1); - test_close (req2); - - /* Check load-balancing of requests. */ - req1 = test_socket (AF_SP, NN_REQ); - test_bind (req1, SOCKET_ADDRESS); - - rep1 = test_socket (AF_SP, NN_REP); - test_connect (rep1, SOCKET_ADDRESS); - - nn_sleep(10); // ensure rep1 binds before rep2 - - rep2 = test_socket (AF_SP, NN_REP); - test_connect (rep2, SOCKET_ADDRESS); - - timeo = 500; - test_setsockopt (req1, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - test_setsockopt (rep1, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - test_setsockopt (rep2, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - - // Give time for connections to settle -- required for LB stuff. - nn_sleep(100); - - test_send (req1, "ABC"); - test_recv (rep1, "ABC"); - test_send (rep1, "ABC"); - test_recv (req1, "ABC"); - - test_send (req1, "ABC"); - test_recv (rep2, "ABC"); - test_send (rep2, "ABC"); - test_recv (req1, "ABC"); - - test_close (rep2); - test_close (rep1); - test_close (req1); - - /* Test re-sending of the request. */ - rep1 = test_socket (AF_SP, NN_REP); - test_bind (rep1, SOCKET_ADDRESS); - req1 = test_socket (AF_SP, NN_REQ); - test_connect (req1, SOCKET_ADDRESS); - resend_ivl = 100; - rc = nn_setsockopt (req1, NN_REQ, NN_REQ_RESEND_IVL, - &resend_ivl, sizeof (resend_ivl)); - errno_assert (rc == 0); - - test_send (req1, "ABC"); - test_recv (rep1, "ABC"); - /* The following waits for request to be resent */ - test_recv (rep1, "ABC"); - - test_close (req1); - test_close (rep1); - - - /* Check sending a request when the peer is not available. (It should - be sent immediately when the peer comes online rather than relying - on the resend algorithm.) */ - req1 = test_socket (AF_SP, NN_REQ); - timeo = 10; - test_setsockopt (req1, NN_SOL_SOCKET, NN_RECONNECT_IVL, &timeo, sizeof (timeo)); - test_connect (req1, SOCKET_ADDRESS); - - rep1 = test_socket (AF_SP, NN_REP); - test_bind (rep1, SOCKET_ADDRESS); - - timeo = 500; - test_setsockopt (rep1, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - errno_assert (rc == 0); - test_send (req1, "ABC"); - - /* Now close the peer, and reopen it. This should still work. */ - test_close(rep1); - rep1 = test_socket (AF_SP, NN_REP); - test_bind (rep1, SOCKET_ADDRESS); - - test_recv (rep1, "ABC"); - - test_close (req1); - test_close (rep1); - - /* Check removing socket request sent to (It should - be sent immediatelly to other peer rather than relying - on the resend algorithm). */ - req1 = test_socket (AF_SP, NN_REQ); - test_bind (req1, SOCKET_ADDRESS); - rep1 = test_socket (AF_SP, NN_REP); - test_connect (rep1, SOCKET_ADDRESS); - rep2 = test_socket (AF_SP, NN_REP); - nn_sleep (10); // give time for rep1 to connect - test_connect (rep2, SOCKET_ADDRESS); - - timeo = 500; // Was 200, but Windows occasionally fails at that rate. - test_setsockopt (rep1, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - test_setsockopt (rep2, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - - test_send (req1, "ABC"); - /* We got request through rep1 */ - test_recv (rep1, "ABC"); - /* But instead replying we simulate crash */ - test_close (rep1); - /* The rep2 should get request immediately */ - test_recv (rep2, "ABC"); - /* Let's check it's delivered well */ - test_send (rep2, "REPLY"); - test_recv (req1, "REPLY"); - - test_close (req1); - test_close (rep2); - - /* Test cancelling delayed request */ - - req1 = test_socket (AF_SP, NN_REQ); - test_connect (req1, SOCKET_ADDRESS); - - rep1 = test_socket (AF_SP, NN_REP); - test_bind (rep1, SOCKET_ADDRESS); - - test_send (req1, "ABC"); - test_send (req1, "DEF"); - test_close (rep1); - - rep1 = test_socket (AF_SP, NN_REP); - test_bind (rep1, SOCKET_ADDRESS); - - timeo = 100; - test_recv (rep1, "DEF"); - - test_close (req1); - test_close (rep1); - - return 0; -} - diff --git a/tests/compat_reqttl.c b/tests/compat_reqttl.c deleted file mode 100644 index 939ca567..00000000 --- a/tests/compat_reqttl.c +++ /dev/null @@ -1,153 +0,0 @@ -/* - Copyright (c) 2012 Martin Sustrik All rights reserved. - Copyright (c) 2013 GoPivotal, Inc. All rights reserved. - Copyright 2016 Franklin "Snaipe" Mathieu <franklinmathieu@gmail.com> - Copyright 2018 Garrett D'Amore <garrett@damore.org> - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/reqrep.h> -#include <nng/compat/nanomsg/tcp.h> - -#include "compat_testutil.h" - -static char socket_address_a[128]; -static char socket_address_b[128]; -int dev0; -int dev1; - -void device (NN_UNUSED void *arg) -{ - int rc; - - /* Run the device. */ - rc = nn_device (dev0, dev1); - nn_assert (rc < 0 && nn_errno () == EBADF); - - /* Clean up. */ - nn_close (dev0); - nn_close (dev1); -} - -int main (int argc, const char *argv[]) -{ - int end0; - int end1; - struct nn_thread thread1; - int timeo; - int maxttl; - size_t sz; - int rc; - - int port = get_test_port(argc, argv); - - test_addr_from(socket_address_a, "tcp", "127.0.0.1", port); - test_addr_from(socket_address_b, "tcp", "127.0.0.1", port + 1); - - /* Intialise the device sockets. */ - dev0 = test_socket (AF_SP_RAW, NN_REP); - dev1 = test_socket (AF_SP_RAW, NN_REQ); - - test_bind (dev0, socket_address_a); - test_bind (dev1, socket_address_b); - - /* Start the device. */ - nn_thread_init (&thread1, device, NULL); - - end0 = test_socket (AF_SP, NN_REQ); - end1 = test_socket (AF_SP, NN_REP); - - /* Test the bi-directional device TTL */ - test_connect (end0, socket_address_a); - test_connect (end1, socket_address_b); - - /* Wait for TCP to establish. */ - nn_sleep (100); - - /* Pass a message between endpoints. */ - /* Set up max receive timeout. */ - timeo = 100; - test_setsockopt (end0, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - timeo = 100; - test_setsockopt (end1, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - - /* Test default TTL is 8. */ - sz = sizeof (maxttl); - maxttl = -1; - rc = nn_getsockopt(end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, &sz); - nn_assert (rc == 0); - nn_assert (sz == sizeof (maxttl)); - nn_assert (maxttl == 8); - - /* Test to make sure option TTL cannot be set below 1. */ - maxttl = -1; - rc = nn_setsockopt(end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - nn_assert (rc < 0 && nn_errno () == EINVAL); - nn_assert (maxttl == -1); - maxttl = 0; - rc = nn_setsockopt(end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - nn_assert (rc < 0 && nn_errno () == EINVAL); - nn_assert (maxttl == 0); - - /* Test to set non-integer size */ - maxttl = 8; - rc = nn_setsockopt(end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, 1); - nn_assert (rc < 0 && nn_errno () == EINVAL); - nn_assert (maxttl == 8); - - test_send (end0, "XYZ"); - - test_recv (end1, "XYZ"); - - /* Now send a reply. */ - test_send (end1, "REPLYXYZ\n"); - test_recv (end0, "REPLYXYZ\n"); - - /* Now set the max TTL. */ - maxttl = 1; - test_setsockopt (end0, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - test_setsockopt (end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - - test_send (end0, "DROPTHIS"); - test_drop (end1, ETIMEDOUT); - - /* Now set the max TTL up. */ - maxttl = 2; - test_setsockopt (end0, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - test_setsockopt (end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - - test_send (end0, "DONTDROP"); - test_recv (end1, "DONTDROP"); - - test_send (end1, "GOTIT"); - test_recv (end0, "GOTIT"); - - /* Clean up. */ - test_close (end0); - test_close (end1); - - /* Shut down the devices. */ - nn_term (); - - nn_thread_term (&thread1); - - return 0; -} diff --git a/tests/compat_shutdown.c b/tests/compat_shutdown.c deleted file mode 100644 index 84d4d244..00000000 --- a/tests/compat_shutdown.c +++ /dev/null @@ -1,48 +0,0 @@ -/* - Copyright (c) 2013 GoPivotal, Inc. All rights reserved. - Copyright 2016 Franklin "Snaipe" Mathieu <franklinmathieu@gmail.com> - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/tcp.h> -#include <nng/compat/nanomsg/reqrep.h> -#include "compat_testutil.h" - -int main (int argc, const char *argv[]) -{ - int s; - int rc; - int eid; - char socket_address[128]; - - test_addr_from(socket_address, "tcp", "127.0.0.1", - get_test_port(argc, argv)); - - /* Run endpoint shutdown and socket shutdown in parallel. */ - s = test_socket (AF_SP, NN_REQ); - eid = test_connect (s, socket_address); - rc = nn_shutdown (s, eid); - errno_assert (rc == 0); - test_close (s); - - return 0; -} - diff --git a/tests/compat_survey.c b/tests/compat_survey.c deleted file mode 100644 index 645021eb..00000000 --- a/tests/compat_survey.c +++ /dev/null @@ -1,106 +0,0 @@ -/* - Copyright (c) 2012 Martin Sustrik All rights reserved. - Copyright 2017 Garrett D'Amore - - Permission is hereby granted, free of charge, to any person obtaining a - copy of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER - DEALINGS IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/survey.h> - -#include "compat_testutil.h" - -#define SOCKET_ADDRESS "inproc://test" - -int -main() -{ - int rc; - int surveyor; - int respondent1; - int respondent2; - int respondent3; - int deadline; - char buf[7]; - - /* Test a simple survey with three respondents. */ - surveyor = test_socket(AF_SP, NN_SURVEYOR); - deadline = 500; - rc = nn_setsockopt(surveyor, NN_SURVEYOR, NN_SURVEYOR_DEADLINE, - &deadline, sizeof(deadline)); - errno_assert(rc == 0); - test_bind(surveyor, SOCKET_ADDRESS); - respondent1 = test_socket(AF_SP, NN_RESPONDENT); - test_connect(respondent1, SOCKET_ADDRESS); - respondent2 = test_socket(AF_SP, NN_RESPONDENT); - test_connect(respondent2, SOCKET_ADDRESS); - respondent3 = test_socket(AF_SP, NN_RESPONDENT); - test_connect(respondent3, SOCKET_ADDRESS); - - /* Sleep a tiny bit. */ - nn_sleep(1000); - - /* Check that attempt to recv with no survey pending is EFSM. */ - rc = nn_recv(surveyor, buf, sizeof(buf), 0); - errno_assert(rc == -1 && nn_errno() == EFSM); - - /* Send the survey. */ - test_send(surveyor, "ABC"); - - /* First respondent answers. */ - test_recv(respondent1, "ABC"); - test_send(respondent1, "DEF"); - - /* Second respondent answers. */ - test_recv(respondent2, "ABC"); - test_send(respondent2, "DEF"); - - /* Surveyor gets the responses. */ - test_recv(surveyor, "DEF"); - test_recv(surveyor, "DEF"); - - /* There are no more responses. Surveyor hits the deadline. */ - rc = nn_recv(surveyor, buf, sizeof(buf), 0); - errno_assert(rc == -1 && nn_errno() == ETIMEDOUT); - - /* Third respondent answers (it have already missed the deadline). */ - test_recv(respondent3, "ABC"); - test_send(respondent3, "GHI"); - - /* Surveyor initiates new survey. */ - test_send(surveyor, "ABC"); - - /* Check that stale response from third respondent is not delivered. - */ - rc = nn_recv(surveyor, buf, sizeof(buf), 0); - errno_assert(rc == -1 && nn_errno() == ETIMEDOUT); - - /* Check that subsequent attempt to recv with no survey pending is - * EFSM. */ - nn_sleep(1000); // nng - sleep a bit as there may be a thread race - rc = nn_recv(surveyor, buf, sizeof(buf), 0); - errno_assert(rc == -1 && nn_errno() == EFSM); - - test_close(surveyor); - test_close(respondent1); - test_close(respondent2); - test_close(respondent3); - - return 0; -} diff --git a/tests/compat_surveyttl.c b/tests/compat_surveyttl.c deleted file mode 100644 index 00915da4..00000000 --- a/tests/compat_surveyttl.c +++ /dev/null @@ -1,146 +0,0 @@ -/* - Copyright (c) 2012 Martin Sustrik All rights reserved. - Copyright (c) 2013 GoPivotal, Inc. All rights reserved. - Copyright 2016 Garrett D'Amore <garrett@damore.org> - Copyright 2016 Franklin "Snaipe" Mathieu <franklinmathieu@gmail.com> - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#include <nng/compat/nanomsg/nn.h> -#include <nng/compat/nanomsg/survey.h> -#include <nng/compat/nanomsg/tcp.h> - -#include "compat_testutil.h" - -static char socket_address_a[128]; -static char socket_address_b[128]; -int dev0; -int dev1; - -void device (NN_UNUSED void *arg) -{ - int rc; - - /* Run the device. */ - rc = nn_device (dev0, dev1); - nn_assert (rc < 0 && nn_errno () == EBADF); - - /* Clean up. */ - test_close (dev0); - test_close (dev1); -} - -int main (int argc, const char *argv[]) -{ - int end0; - int end1; - struct nn_thread thread1; - int timeo; - int maxttl; - size_t sz; - int rc; - - int port = get_test_port(argc, argv); - - test_addr_from(socket_address_a, "tcp", "127.0.0.1", port); - test_addr_from(socket_address_b, "tcp", "127.0.0.1", port + 1); - - /* Intialise the device sockets. */ - dev0 = test_socket (AF_SP_RAW, NN_RESPONDENT); - dev1 = test_socket (AF_SP_RAW, NN_SURVEYOR); - - test_bind (dev0, socket_address_a); - test_bind (dev1, socket_address_b); - - /* Start the device. */ - nn_thread_init (&thread1, device, NULL); - - end0 = test_socket (AF_SP, NN_SURVEYOR); - end1 = test_socket (AF_SP, NN_RESPONDENT); - - /* Test the bi-directional device TTL */ - test_connect (end0, socket_address_a); - test_connect (end1, socket_address_b); - - /* Wait for TCP to establish. */ - nn_sleep (100); - - /* Set up max receive timeout. */ - timeo = 100; - test_setsockopt (end0, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - timeo = 100; - test_setsockopt (end1, NN_SOL_SOCKET, NN_RCVTIMEO, &timeo, sizeof (timeo)); - - /* Test default TTL is 8. */ - sz = sizeof (maxttl); - maxttl = -1; - rc = nn_getsockopt(end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, &sz); - nn_assert (rc == 0); - nn_assert (sz == sizeof (maxttl)); - nn_assert (maxttl == 8); - - /* Test to make sure option TTL cannot be set below 1. */ - maxttl = -1; - rc = nn_setsockopt(end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - nn_assert (rc < 0 && nn_errno () == EINVAL); - nn_assert (maxttl == -1); - maxttl = 0; - rc = nn_setsockopt(end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - nn_assert (rc < 0 && nn_errno () == EINVAL); - nn_assert (maxttl == 0); - - /* Test to set non-integer size */ - maxttl = 8; - rc = nn_setsockopt(end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, 1); - nn_assert (rc < 0 && nn_errno () == EINVAL); - nn_assert (maxttl == 8); - - /* Pass a message between endpoints. */ - test_send (end0, "SURVEY"); - test_recv (end1, "SURVEY"); - - /* Now send a reply. */ - test_send (end1, "REPLYXYZ"); - test_recv (end0, "REPLYXYZ"); - - /* Now set the max TTL. */ - maxttl = 1; - test_setsockopt (end0, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - test_setsockopt (end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - - test_send (end0, "DROPTHIS"); - test_drop (end1, ETIMEDOUT); - - maxttl = 2; - test_setsockopt (end0, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - test_setsockopt (end1, NN_SOL_SOCKET, NN_MAXTTL, &maxttl, sizeof (maxttl)); - test_send (end0, "DONTDROP"); - test_recv (end1, "DONTDROP"); - - /* Clean up. */ - test_close (end0); - test_close (end1); - - /* Shut down the devices. */ - nn_term (); - nn_thread_term (&thread1); - - return 0; -} diff --git a/tests/compat_testutil.c b/tests/compat_testutil.c deleted file mode 100644 index aff8f02d..00000000 --- a/tests/compat_testutil.c +++ /dev/null @@ -1,240 +0,0 @@ -/* - Copyright (c) 2013 Insollo Entertainment, LLC. All rights reserved. - Copyright 2016 Franklin "Snaipe" Mathieu <franklinmathieu@gmail.com> - Copyright 2018 Capitar IT Group BV <info@capitar.com> - Copyright 2024 Staysail Systems, Inc. <info@staysail.tech> - - Permission is hereby granted, free of charge, to any person obtaining a - copy of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER - DEALINGS IN THE SOFTWARE. -*/ - -// Note: This file started life in nanomsg. We have copied it, and adjusted -// it for validating the compatibility features of nanomsg. As much as -// possible we want to run tests from the nanomsg test suite unmodified. - -#include <stdbool.h> -#include <stdio.h> -#include <stdlib.h> -#include <string.h> - -#include "compat_testutil.h" -#include <nng/compat/nanomsg/nn.h> - -int test_socket_impl(char *file, int line, int family, int protocol); -int test_connect_impl(char *file, int line, int sock, char *address); -int test_bind_impl(char *file, int line, int sock, char *address); -void test_close_impl(char *file, int line, int sock); -void test_send_impl(char *file, int line, int sock, char *data); -void test_recv_impl(char *file, int line, int sock, char *data); -void test_drop_impl(char *file, int line, int sock, int err); -int test_setsockopt_impl(char *file, int line, int sock, int level, int option, - const void *optval, size_t optlen); - -int -test_socket_impl(char *file, int line, int family, int protocol) -{ - int sock; - - sock = nn_socket(family, protocol); - if (sock == -1) { - fprintf(stderr, "Failed create socket: %s [%d] (%s:%d)\n", - nn_err_strerror(errno), (int) errno, file, line); - nn_err_abort(); - } - - return (sock); -} - -int -test_connect_impl(char *file, int line, int sock, char *address) -{ - int rc; - - rc = nn_connect(sock, address); - if (rc < 0) { - fprintf(stderr, "Failed connect to \"%s\": %s [%d] (%s:%d)\n", - address, nn_err_strerror(errno), (int) errno, file, line); - nn_err_abort(); - } - return (rc); -} - -int -test_bind_impl(char *file, int line, int sock, char *address) -{ - int rc; - - rc = nn_bind(sock, address); - if (rc < 0) { - fprintf(stderr, "Failed bind to \"%s\": %s [%d] (%s:%d)\n", - address, nn_err_strerror(errno), (int) errno, file, line); - nn_err_abort(); - } - return (rc); -} - -int -test_setsockopt_impl(char *file, int line, int sock, int level, int option, - const void *optval, size_t optlen) -{ - int rc; - - rc = nn_setsockopt(sock, level, option, optval, optlen); - if (rc < 0) { - fprintf(stderr, "Failed set option \"%d\": %s [%d] (%s:%d)\n", - option, nn_err_strerror(errno), (int) errno, file, line); - nn_err_abort(); - } - return rc; -} - -void -test_close_impl(char *file, int line, int sock) -{ - int rc; - - rc = nn_close(sock); - if ((rc != 0) && (errno != EBADF && errno != ETERM)) { - fprintf(stderr, "Failed to close socket: %s [%d] (%s:%d)\n", - nn_err_strerror(errno), (int) errno, file, line); - nn_err_abort(); - } -} - -void -test_send_impl(char *file, int line, int sock, char *data) -{ - size_t data_len; - int rc; - - data_len = strlen(data); - - rc = nn_send(sock, data, data_len, 0); - if (rc < 0) { - fprintf(stderr, "Failed to send: %s [%d] (%s:%d)\n", - nn_err_strerror(errno), (int) errno, file, line); - nn_err_abort(); - } - if (rc != (int) data_len) { - fprintf(stderr, - "Data to send is truncated: %d != %d (%s:%d)\n", rc, - (int) data_len, file, line); - nn_err_abort(); - } -} - -void -test_recv_impl(char *file, int line, int sock, char *data) -{ - size_t data_len; - int rc; - char *buf; - - data_len = strlen(data); - /* We allocate plus one byte so that we are sure that message received - has correct length and not truncated */ - buf = malloc(data_len + 1); - alloc_assert(buf); - - rc = nn_recv(sock, buf, data_len + 1, 0); - if (rc < 0) { - fprintf(stderr, "Failed to recv: %s [%d] (%s:%d)\n", - nn_err_strerror(errno), (int) errno, file, line); - nn_err_abort(); - } - if (rc != (int) data_len) { - fprintf(stderr, - "Received data has wrong length: %d != %d (%s:%d)\n", rc, - (int) data_len, file, line); - nn_err_abort(); - } - if (memcmp(data, buf, data_len) != 0) { - /* We don't print the data as it may have binary garbage */ - fprintf( - stderr, "Received data is wrong (%s:%d)\n", file, line); - nn_err_abort(); - } - - free(buf); -} - -void -test_drop_impl(char *file, int line, int sock, int err) -{ - int rc; - char buf[1024]; - - rc = nn_recv(sock, buf, sizeof(buf), 0); - if (rc < 0 && err != errno) { - fprintf(stderr, - "Got wrong err to recv: %s [%d != %d] (%s:%d)\n", - nn_err_strerror(errno), (int) errno, err, file, line); - nn_err_abort(); - } else if (rc >= 0) { - fprintf(stderr, "Did not drop message: [%d bytes] (%s:%d)\n", - rc, file, line); - nn_err_abort(); - } -} - -int -get_test_port(int argc, const char *argv[]) -{ - return (atoi(argc < 2 ? "5555" : argv[1])); -} - -void -test_addr_from(char *out, const char *proto, const char *ip, int port) -{ - (void) snprintf(out, 128, "%s://%s:%d", proto, ip, port); -} - -extern int nng_thread_create(void **, void (*)(void *), void *); - -int -nn_thread_init(struct nn_thread *thr, void (*func)(void *), void *arg) -{ - return (nng_thread_create(&thr->thr, func, arg)); -} - -extern void nng_thread_destroy(void *); - -void -nn_thread_term(struct nn_thread *thr) -{ - nng_thread_destroy(thr->thr); -} - -extern void nng_msleep(int32_t); - -void -nn_sleep(int ms) -{ - nng_msleep(ms); -} - -void -nn_assert_impl(bool b, const char *expression, const char *file, int line) -{ - if (b) { - return; - } - fprintf( - stderr, "%s:%d: Assertion failed: %s\n", file, line, expression); - abort(); -} diff --git a/tests/compat_testutil.h b/tests/compat_testutil.h deleted file mode 100644 index da9baaa9..00000000 --- a/tests/compat_testutil.h +++ /dev/null @@ -1,86 +0,0 @@ -/* - Copyright (c) 2013 Insollo Entertainment, LLC. All rights reserved. - Copyright 2017 Garrett D'Amore <garrett@damore.org> - Copyright 2016 Franklin "Snaipe" Mathieu <franklinmathieu@gmail.com> - Copyright 2018 Capitar IT Group BV <info@capitar.com> - Copyright 2024 Staysail Systems, Inc. <info@staysail.tech> - - Permission is hereby granted, free of charge, to any person obtaining a - copy of this software and associated documentation files (the "Software"), - to deal in the Software without restriction, including without limitation - the rights to use, copy, modify, merge, publish, distribute, sublicense, - and/or sell copies of the Software, and to permit persons to whom - the Software is furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included - in all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL - THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER - DEALINGS IN THE SOFTWARE. -*/ - -// Note: This file started life in nanomsg. We have copied it, and adjusted -// it for validating the compatibility features of nanomsg. As much as -// possible we want to run tests from the nanomsg test suite unmodified. - -#ifndef COMPAT_TESTUTIL_H_INCLUDED -#define COMPAT_TESTUTIL_H_INCLUDED - -#include <stdbool.h> -#include <stdio.h> -#include <stdlib.h> -#include <string.h> - -#define nn_err_strerror nn_strerror -#define nn_err_abort abort -#define errno_assert nn_assert -#define wsa_assert nn_assert -#define alloc_assert(x) nn_assert((x) != NULL) - -#if defined __GNUC__ || defined __llvm__ || defined __clang__ -#define NN_UNUSED __attribute__((unused)) -#else -#define NN_UNUSED -#endif - -#define nn_assert(x) nn_assert_impl(x, #x, __FILE__, __LINE__) - -extern int test_socket_impl(char *file, int line, int family, int protocol); -extern int test_connect_impl(char *file, int line, int sock, char *address); -extern int test_bind_impl(char *file, int line, int sock, char *address); -extern void test_close_impl(char *file, int line, int sock); -extern void test_send_impl(char *file, int line, int sock, char *data); -extern void test_recv_impl(char *file, int line, int sock, char *data); -extern void test_drop_impl(char *file, int line, int sock, int err); -extern int test_setsockopt_impl(char *file, int line, int sock, int level, - int option, const void *optval, size_t optlen); -extern int get_test_port(int argc, const char *argv[]); -extern void test_addr_from( - char *out, const char *proto, const char *ip, int port); -extern void nn_sleep(int); -extern void nn_assert_impl( - bool b, const char *expression, const char *file, int line); - -#define test_socket(f, p) test_socket_impl(__FILE__, __LINE__, (f), (p)) -#define test_connect(s, a) test_connect_impl(__FILE__, __LINE__, (s), (a)) -#define test_bind(s, a) test_bind_impl(__FILE__, __LINE__, (s), (a)) -#define test_send(s, d) test_send_impl(__FILE__, __LINE__, (s), (d)) -#define test_recv(s, d) test_recv_impl(__FILE__, __LINE__, (s), (d)) -#define test_drop(s, e) test_drop_impl(__FILE__, __LINE__, (s), (e)) -#define test_close(s) test_close_impl(__FILE__, __LINE__, (s)) -#define test_setsockopt(s, l, o, v, z) \ - test_setsockopt_impl(__FILE__, __LINE__, (s), (l), (o), (v), (z)) - -struct nn_thread { - void *thr; -}; - -extern int nn_thread_init(struct nn_thread *, void (*)(void *), void *); -extern void nn_thread_term(struct nn_thread *); - -#endif // COMPAT_TESTUTIL_H_INCLUDED |