aboutsummaryrefslogtreecommitdiff
path: root/src/platform/posix
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2025-10-25 23:02:17 -0700
committerGarrett D'Amore <garrett@damore.org>2025-10-25 23:02:17 -0700
commitf9ff44ce0f0c73f05c182bb07c76bf6b51470560 (patch)
treebc37e151ab8527ca6df85ccb079c2b03673ba319 /src/platform/posix
parentc2aa8c12e705ba77f3d2d28c5ba0a9ec7efb7632 (diff)
downloadnng-f9ff44ce0f0c73f05c182bb07c76bf6b51470560.tar.gz
nng-f9ff44ce0f0c73f05c182bb07c76bf6b51470560.tar.bz2
nng-f9ff44ce0f0c73f05c182bb07c76bf6b51470560.zip
Plumb sockaddrs all the way through pipes, make them failsafe.
These functions can no longer fail.
Diffstat (limited to 'src/platform/posix')
-rw-r--r--src/platform/posix/posix_ipcconn.c7
-rw-r--r--src/platform/posix/posix_sockfd.c7
-rw-r--r--src/platform/posix/posix_tcpconn.c14
3 files changed, 12 insertions, 16 deletions
diff --git a/src/platform/posix/posix_ipcconn.c b/src/platform/posix/posix_ipcconn.c
index 11bd03d8..29550b7f 100644
--- a/src/platform/posix/posix_ipcconn.c
+++ b/src/platform/posix/posix_ipcconn.c
@@ -299,12 +299,11 @@ ipc_recv(void *arg, nni_aio *aio)
nni_mtx_unlock(&c->mtx);
}
-static nng_err
-ipc_sock_addr(void *arg, const nng_sockaddr **sap)
+static const nng_sockaddr *
+ipc_sock_addr(void *arg)
{
ipc_conn *c = arg;
- *sap = &c->sa;
- return (NNG_OK);
+ return (&c->sa);
}
static nng_err
diff --git a/src/platform/posix/posix_sockfd.c b/src/platform/posix/posix_sockfd.c
index 43225e7e..6a08f5c6 100644
--- a/src/platform/posix/posix_sockfd.c
+++ b/src/platform/posix/posix_sockfd.c
@@ -431,13 +431,12 @@ sfd_set(void *arg, const char *name, const void *buf, size_t sz, nni_type t)
return (nni_setopt(sfd_options, name, c, buf, sz, t));
}
-static nng_err
-sfd_addr(void *arg, const nng_sockaddr **sap)
+static const nng_sockaddr *
+sfd_addr(void *arg)
{
static nng_sockaddr sa = { .s_family = NNG_AF_UNSPEC };
NNI_ARG_UNUSED(arg);
- *sap = &sa;
- return (NNG_OK);
+ return &sa;
}
nng_err
diff --git a/src/platform/posix/posix_tcpconn.c b/src/platform/posix/posix_tcpconn.c
index 43dfb4e4..c04c27c1 100644
--- a/src/platform/posix/posix_tcpconn.c
+++ b/src/platform/posix/posix_tcpconn.c
@@ -332,20 +332,18 @@ tcp_recv(void *arg, nni_aio *aio)
nni_mtx_unlock(&c->mtx);
}
-static nng_err
-tcp_get_peer_addr(void *arg, const nng_sockaddr **addr)
+static const nng_sockaddr *
+tcp_get_peer_addr(void *arg)
{
nni_tcp_conn *c = arg;
- *addr = &c->peer;
- return (NNG_OK);
+ return (&c->peer);
}
-static nng_err
-tcp_get_self_addr(void *arg, const nng_sockaddr **addr)
+static const nng_sockaddr *
+tcp_get_self_addr(void *arg)
{
nni_tcp_conn *c = arg;
- *addr = &c->self;
- return (NNG_OK);
+ return (&c->self);
}
static nng_err