diff options
| author | Garrett D'Amore <garrett@damore.org> | 2022-04-16 14:36:27 -0700 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2022-04-16 14:36:27 -0700 |
| commit | 60bf092d3e6e68d0af55c78b679310b1687016e8 (patch) | |
| tree | 9644e6ff61b4f23e4c77b01965fdfb928082b6a2 /tests | |
| parent | ef929a35833fed8eac4aaaf7739d4df1ed72ae00 (diff) | |
| download | nng-60bf092d3e6e68d0af55c78b679310b1687016e8.tar.gz nng-60bf092d3e6e68d0af55c78b679310b1687016e8.tar.bz2 nng-60bf092d3e6e68d0af55c78b679310b1687016e8.zip | |
fixes #1577 nng_stat_find_socket always returns the same stats node
Also this fixes problems with uninitialized socket names, and the
socket name stat not being adjusted correctly when set via API.
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/CMakeLists.txt | 1 | ||||
| -rw-r--r-- | tests/stats.c | 74 |
2 files changed, 0 insertions, 75 deletions
diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt index bc212c0f..063692cb 100644 --- a/tests/CMakeLists.txt +++ b/tests/CMakeLists.txt @@ -137,7 +137,6 @@ add_nng_test(options 5) add_nng_test(pipe 5) add_nng_test(pollfd 5) add_nng_test(scalability 20 ON) -add_nng_test1(stats 5 NNG_ENABLE_STATS) add_nng_test(synch 5) add_nng_test(tls 60) add_nng_test(tcpsupp 10) diff --git a/tests/stats.c b/tests/stats.c deleted file mode 100644 index c42c129c..00000000 --- a/tests/stats.c +++ /dev/null @@ -1,74 +0,0 @@ -// -// Copyright 2021 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 <string.h> - -#include <nng/nng.h> -#include <nng/protocol/pair1/pair.h> -#include <nng/protocol/pubsub0/sub.h> -#include <nng/supplemental/util/platform.h> - -#include "convey.h" -#include "stubs.h" -#include "trantest.h" - -#define SECONDS(x) ((x) *1000) - -TestMain("Stats Test", { - - Convey("We are able to open a PAIR socket", { - nng_socket s1; - - So(nng_pair_open(&s1) == 0); - - Reset({ nng_close(s1); }); - - Convey("We can send and receive messages", { - nng_socket s2; - int len; - size_t sz; - nng_duration to = SECONDS(3); - char * buf; - char * a = "inproc://stats"; - nng_stat * stats; - - So(nng_pair_open(&s2) == 0); - Reset({ nng_close(s2); }); - - So(nng_socket_set_int(s1, NNG_OPT_RECVBUF, 1) == 0); - So(nng_socket_get_int(s1, NNG_OPT_RECVBUF, &len) == 0); - So(len == 1); - - So(nng_socket_set_int(s1, NNG_OPT_SENDBUF, 1) == 0); - So(nng_socket_set_int(s2, NNG_OPT_SENDBUF, 1) == 0); - - So(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, to) == 0); - So(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, to) == 0); - So(nng_socket_set_ms(s2, NNG_OPT_SENDTIMEO, to) == 0); - So(nng_socket_set_ms(s2, NNG_OPT_RECVTIMEO, to) == 0); - - So(nng_listen(s1, a, NULL, 0) == 0); - So(nng_dial(s2, a, NULL, 0) == 0); - - So(nng_send(s1, "abc", 4, 0) == 0); - So(nng_recv(s2, &buf, &sz, NNG_FLAG_ALLOC) == 0); - So(buf != NULL); - So(sz == 4); - So(memcmp(buf, "abc", 4) == 0); - nng_free(buf, sz); - - Convey("We can collect stats", { - So(nng_stats_get(&stats) == 0); - nng_stats_dump(stats); - nng_stats_free(stats); - }); - }); - }); -}) |
