From 8f036f1e0b231f5ec7c146ba31a6f73d3595d47a Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Sat, 30 Nov 2024 22:46:27 -0500 Subject: tests: convert nonblock test to NUTS --- src/sp/nonblock_test.c | 128 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 128 insertions(+) create mode 100644 src/sp/nonblock_test.c (limited to 'src/sp/nonblock_test.c') diff --git a/src/sp/nonblock_test.c b/src/sp/nonblock_test.c new file mode 100644 index 00000000..0f9be034 --- /dev/null +++ b/src/sp/nonblock_test.c @@ -0,0 +1,128 @@ +// +// Copyright 2024 Staysail Systems, Inc. +// Copyright 2018 Capitar IT Group BV +// +// 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 +#include + +#ifndef _WIN32 +#include +#include +#define PLATFD int +#else +#include +// order counts +#include +#define PLATFD SOCKET +#endif + +#include +#include +#include + +#include + +const char *addr = "inproc://bug346"; + +void +repthr(void *arg) +{ + nng_socket rep = *(nng_socket *) arg; + nng_listener l; + int ifd; + PLATFD fd; + + nng_listen(rep, addr, &l, NNG_FLAG_NONBLOCK); + + nng_socket_get_recv_poll_fd(rep, &ifd); + fd = ifd; + + for (;;) { + fd_set fset; + struct timeval tmo; + char *msgbuf; + size_t msglen; + + FD_ZERO(&fset); + FD_SET(fd, &fset); + + tmo.tv_sec = 0; + tmo.tv_usec = 20 * 1000; // 20 msec + + select(1, &fset, NULL, NULL, &tmo); + + for (;;) { + int rv; + rv = nng_recv(rep, &msgbuf, &msglen, + NNG_FLAG_NONBLOCK | NNG_FLAG_ALLOC); + if (rv != 0) { + return; + } + nng_free(msgbuf, msglen); + int ok = 0; + rv = nng_send(rep, &ok, 4, NNG_FLAG_NONBLOCK); + if (rv == NNG_ECLOSED) { + return; + } + } + } +} + +void +reqthr(void *arg) +{ + nng_socket req = *(nng_socket *) arg; + + nng_dial(req, addr, NULL, NNG_FLAG_NONBLOCK); + + int query = 0; + // We just keep pounding out requests, no wait for response. + for (;;) { + int rv; + rv = nng_send(req, &query, sizeof(query), 0); + if (rv == NNG_ECLOSED) { + return; + } + nng_msleep(50); + } +} + +#define NCLIENTS 10 +nng_socket reqs[NCLIENTS]; +nng_socket rep; + +static void +test_nonblocking(void) +{ + nng_thread *server; + nng_thread *clients[NCLIENTS]; + + NUTS_PASS(nng_rep0_open(&rep)); + for (int i = 0; i < NCLIENTS; i++) { + NUTS_PASS(nng_req0_open(&reqs[i])); + } + + NUTS_PASS(nng_thread_create(&server, repthr, &rep)); + for (int i = 0; i < NCLIENTS; i++) { + NUTS_PASS(nng_thread_create(&clients[i], reqthr, &reqs[i])); + } + + nng_msleep(15000); + nng_close(rep); + nng_thread_destroy(server); + for (int i = 0; i < NCLIENTS; i++) { + nng_close(reqs[i]); + nng_thread_destroy(clients[i]); + } +} + +NUTS_TESTS = { + { "nonblocking", test_nonblocking }, + { NULL, NULL }, +}; -- cgit v1.2.3-70-g09d2