diff options
Diffstat (limited to 'src/core/pipe.c')
| -rw-r--r-- | src/core/pipe.c | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/src/core/pipe.c b/src/core/pipe.c index 10a1f35a..2fa8d017 100644 --- a/src/core/pipe.c +++ b/src/core/pipe.c @@ -1,5 +1,5 @@ // -// Copyright 2023 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2024 Staysail Systems, Inc. <info@staysail.tech> // Copyright 2018 Capitar IT Group BV <info@capitar.com> // Copyright 2018 Devolutions <info@devolutions.net> // @@ -10,6 +10,7 @@ // #include "core/nng_impl.h" +#include "nng/nng.h" #include "sockimpl.h" #include <stdio.h> @@ -409,3 +410,14 @@ nni_pipe_bump_error(nni_pipe *p, int err) nni_listener_bump_error(p->p_listener, err); } } + +char * +nni_pipe_peer_addr(nni_pipe *p, char buf[NNG_MAXADDRSTRLEN]) +{ + nng_sockaddr sa; + size_t sz = sizeof(sa); + sa.s_family = AF_UNSPEC; + nni_pipe_getopt(p, NNG_OPT_REMADDR, &sa, &sz, NNI_TYPE_SOCKADDR); + nng_str_sockaddr(&sa, buf, NNG_MAXADDRSTRLEN); + return (buf); +} |