aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/platform/posix/posix_ipcdial.c12
-rw-r--r--src/platform/windows/win_ipcdial.c12
-rw-r--r--src/sp/transport/ipc/ipc_test.c129
3 files changed, 153 insertions, 0 deletions
diff --git a/src/platform/posix/posix_ipcdial.c b/src/platform/posix/posix_ipcdial.c
index 81a8f1dc..1f7728b7 100644
--- a/src/platform/posix/posix_ipcdial.c
+++ b/src/platform/posix/posix_ipcdial.c
@@ -240,8 +240,20 @@ error:
nni_aio_finish_error(aio, rv);
}
+static int
+ipc_dialer_get_remaddr(void *arg, void *buf, size_t *szp, nni_type t)
+{
+ ipc_dialer *d = arg;
+
+ return (nni_copyout_sockaddr(&d->sa, buf, szp, t));
+}
+
static const nni_option ipc_dialer_options[] = {
{
+ .o_name = NNG_OPT_REMADDR,
+ .o_get = ipc_dialer_get_remaddr,
+ },
+ {
.o_name = NULL,
},
};
diff --git a/src/platform/windows/win_ipcdial.c b/src/platform/windows/win_ipcdial.c
index d84b959d..a09d120c 100644
--- a/src/platform/windows/win_ipcdial.c
+++ b/src/platform/windows/win_ipcdial.c
@@ -202,8 +202,20 @@ ipc_dialer_free(void *arg)
NNI_FREE_STRUCT(d);
}
+static int
+ipc_dialer_get_remaddr(void *arg, void *buf, size_t *szp, nni_type t)
+{
+ ipc_dialer *d = arg;
+
+ return (nni_copyout_sockaddr(&d->sa, buf, szp, t));
+}
+
static const nni_option ipc_dialer_options[] = {
{
+ .o_name = NNG_OPT_REMADDR,
+ .o_get = ipc_dialer_get_remaddr,
+ },
+ {
.o_name = NULL,
},
};
diff --git a/src/sp/transport/ipc/ipc_test.c b/src/sp/transport/ipc/ipc_test.c
index 083326bb..6a4021a0 100644
--- a/src/sp/transport/ipc/ipc_test.c
+++ b/src/sp/transport/ipc/ipc_test.c
@@ -69,6 +69,8 @@ test_ipc_dialer_properties(void)
NUTS_FAIL(nng_dialer_get_addr(d, NNG_OPT_LOCADDR, &sa), NNG_ENOTSUP);
NUTS_FAIL(nng_dialer_set_addr(d, NNG_OPT_LOCADDR, &sa), NNG_ENOTSUP);
+ NUTS_PASS(nng_dialer_get_addr(d, NNG_OPT_REMADDR, &sa));
+ NUTS_TRUE(sa.s_family == NNG_AF_IPC);
z = 8192;
NUTS_PASS(nng_dialer_set_size(d, NNG_OPT_RECVMAXSZ, z));
@@ -144,6 +146,95 @@ test_ipc_listener_properties(void)
}
void
+test_ipc_ping_pong(void)
+{
+ nng_socket s0;
+ nng_socket s1;
+ char *addr;
+
+ NUTS_ENABLE_LOG(NNG_LOG_INFO);
+ NUTS_ADDR(addr, "ipc");
+ NUTS_OPEN(s0);
+ NUTS_OPEN(s1);
+ NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_RECVTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_SENDTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, 100));
+
+ NUTS_MARRY_EX(s0, s1, addr, NULL, NULL);
+
+ NUTS_SEND(s0, "ping");
+ NUTS_RECV(s1, "ping");
+ NUTS_SEND(s1, "pong");
+ NUTS_RECV(s0, "pong");
+ NUTS_CLOSE(s0);
+ NUTS_CLOSE(s1);
+}
+
+void
+test_ipc_ping_pong_many(void)
+{
+ nng_socket s0;
+ nng_socket s1;
+ char *addr;
+
+ NUTS_ADDR(addr, "ipc");
+ NUTS_OPEN(s0);
+ NUTS_OPEN(s1);
+ NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_RECVTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_SENDTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, 100));
+
+ NUTS_MARRY_EX(s0, s1, addr, NULL, NULL);
+
+ for (int i = 0; i < 100; i++) {
+ NUTS_SEND(s0, "ping");
+ NUTS_RECV(s1, "ping");
+ NUTS_SEND(s1, "pong");
+ NUTS_RECV(s0, "pong");
+ }
+ NUTS_CLOSE(s0);
+ NUTS_CLOSE(s1);
+}
+
+void
+test_ipc_huge_msg(void)
+{
+ nng_socket s0;
+ nng_socket s1;
+ char *addr;
+ nng_msg *m;
+
+ NUTS_ADDR(addr, "ipc");
+ NUTS_PASS(nng_msg_alloc(&m, 1 << 20));
+ memset(nng_msg_body(m), 'a', 1 << 20);
+ NUTS_OPEN(s0);
+ NUTS_OPEN(s1);
+ NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_RECVTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_SENDTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_RECVTIMEO, 100));
+ NUTS_PASS(nng_socket_set_ms(s1, NNG_OPT_SENDTIMEO, 100));
+
+ NUTS_MARRY_EX(s0, s1, addr, NULL, NULL);
+
+ NUTS_PASS(nng_sendmsg(s0, m, 0));
+ NUTS_PASS(nng_recvmsg(s1, &m, 0));
+
+ NUTS_TRUE(nng_msg_len(m) == 1 << 20);
+ char *body = nng_msg_body(m);
+ for (int i = 0; i < 1 << 20; i++) {
+ if (body[i] != 'a') {
+ NUTS_TRUE(body[i] == 'a');
+ break;
+ }
+ }
+ nng_msg_free(m);
+ NUTS_CLOSE(s0);
+ NUTS_CLOSE(s1);
+}
+
+void
test_ipc_recv_max(void)
{
char msg[256];
@@ -178,6 +269,23 @@ test_ipc_recv_max(void)
}
void
+test_ipc_connect_refused(void)
+{
+ nng_socket s0;
+ nng_dialer d;
+ char *addr;
+
+ NUTS_ENABLE_LOG(NNG_LOG_INFO);
+ NUTS_ADDR(addr, "ipc");
+ NUTS_OPEN(s0);
+ NUTS_PASS(nng_socket_set_ms(s0, NNG_OPT_RECVTIMEO, 100));
+ NUTS_PASS(nng_socket_set_size(s0, NNG_OPT_RECVMAXSZ, 200));
+ NUTS_PASS(nng_dialer_create(&d, s0, addr));
+ NUTS_FAIL(nng_dialer_start(d, 0), NNG_ECONNREFUSED);
+ NUTS_CLOSE(s0);
+}
+
+void
test_ipc_connect_blocking(void)
{
nng_socket s0;
@@ -251,6 +359,22 @@ test_ipc_listen_accept_cancel(void)
}
void
+test_ipc_listen_duplicate(void)
+{
+ nng_socket s0;
+ char *addr;
+
+ NUTS_ENABLE_LOG(NNG_LOG_INFO);
+ NUTS_ADDR(addr, "ipc");
+ NUTS_OPEN(s0);
+
+ // start a listening stream listener but do not call accept
+ NUTS_PASS(nng_listen(s0, addr, NULL, 0));
+ NUTS_FAIL(nng_listen(s0, addr, NULL, 0), NNG_EADDRINUSE);
+ NUTS_CLOSE(s0);
+}
+
+void
test_ipc_listener_clean_stale(void)
{
#ifdef NNG_PLATFORM_POSIX
@@ -556,10 +680,15 @@ TEST_LIST = {
{ "ipc dialer props", test_ipc_dialer_properties },
{ "ipc listener perms", test_ipc_listener_perms },
{ "ipc listener props", test_ipc_listener_properties },
+ { "ipc ping pong", test_ipc_ping_pong },
+ { "ipc ping pong many", test_ipc_ping_pong_many },
+ { "ipc huge msg", test_ipc_huge_msg },
{ "ipc recv max", test_ipc_recv_max },
+ { "ipc connect refused", test_ipc_connect_refused },
{ "ipc connect blocking", test_ipc_connect_blocking },
{ "ipc connect blocking accept", test_ipc_connect_blocking_accept },
{ "ipc listen cleanup stale", test_ipc_listener_clean_stale },
+ { "ipc listen duplicate", test_ipc_listen_duplicate },
{ "ipc listen accept cancel", test_ipc_listen_accept_cancel },
{ "ipc abstract sockets", test_abstract_sockets },
{ "ipc abstract auto bind", test_abstract_auto_bind },
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-01-18 12:46:19 +0000