aboutsummaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2022-04-16 14:36:27 -0700
committerGarrett D'Amore <garrett@damore.org>2022-04-16 14:36:27 -0700
commit60bf092d3e6e68d0af55c78b679310b1687016e8 (patch)
tree9644e6ff61b4f23e4c77b01965fdfb928082b6a2 /tests
parentef929a35833fed8eac4aaaf7739d4df1ed72ae00 (diff)
downloadnng-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.txt1
-rw-r--r--tests/stats.c74
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);
- });
- });
- });
-})