aboutsummaryrefslogtreecommitdiff
path: root/src/core/stream.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/stream.c')
-rw-r--r--src/core/stream.c25
1 files changed, 12 insertions, 13 deletions
diff --git a/src/core/stream.c b/src/core/stream.c
index 6c7ad5f0..b1cb5d7b 100644
--- a/src/core/stream.c
+++ b/src/core/stream.c
@@ -401,28 +401,27 @@ nng_err
nng_stream_get_addr(nng_stream *s, const char *n, nng_sockaddr *v)
{
const nng_sockaddr *sap;
- int rv = NNG_ENOTSUP;
if (strcmp(n, NNG_OPT_LOCADDR) == 0) {
- rv = nng_stream_self_addr(s, &sap);
+ sap = nng_stream_self_addr(s);
} else if (strcmp(n, NNG_OPT_REMADDR) == 0) {
- rv = nng_stream_peer_addr(s, &sap);
- }
- if (rv == NNG_OK) {
- *v = *sap;
+ sap = nng_stream_peer_addr(s);
+ } else {
+ return (NNG_ENOTSUP);
}
- return (rv);
+ memcpy(v, sap, sizeof(nng_sockaddr));
+ return (NNG_OK);
}
-nng_err
-nng_stream_self_addr(nng_stream *s, const nng_sockaddr **sa)
+const nng_sockaddr *
+nng_stream_self_addr(nng_stream *s)
{
- return (s->s_self_addr(s, &*sa));
+ return (s->s_self_addr(s));
}
-nng_err
-nng_stream_peer_addr(nng_stream *s, const nng_sockaddr **sa)
+const nng_sockaddr *
+nng_stream_peer_addr(nng_stream *s)
{
- return (s->s_peer_addr(s, &*sa));
+ return (s->s_peer_addr(s));
}
nng_err