1 files changed, 51 insertions, 51 deletions

diff --git a/src/core/stream.c b/src/core/stream.c
index d8111c7a..e0da3582 100644
--- a/src/core/stream.c
+++ b/src/core/stream.c
@@ -150,7 +150,7 @@ nng_stream_recv(nng_stream *s, nng_aio *aio)
 	s->s_recv(s, aio);
 }
 
-int
+nng_err
 nni_stream_get(
     nng_stream *s, const char *nm, void *data, size_t *szp, nni_type t)
 {
@@ -187,7 +187,7 @@ nng_stream_dialer_dial(nng_stream_dialer *d, nng_aio *aio)
 	d->sd_dial(d, aio);
 }
 
-int
+nng_err
 nng_stream_dialer_alloc_url(nng_stream_dialer **dp, const nng_url *url)
 {
 	for (int i = 0; stream_drivers[i].scheme != NULL; i++) {
@@ -198,7 +198,7 @@ nng_stream_dialer_alloc_url(nng_stream_dialer **dp, const nng_url *url)
 	return (NNG_ENOTSUP);
 }
 
-int
+nng_err
 nng_stream_dialer_alloc(nng_stream_dialer **dp, const char *uri)
 {
 	nng_url *url;
@@ -212,21 +212,21 @@ nng_stream_dialer_alloc(nng_stream_dialer **dp, const char *uri)
 	return (rv);
 }
 
-int
+nng_err
 nni_stream_dialer_get(
     nng_stream_dialer *d, const char *nm, void *data, size_t *szp, nni_type t)
 {
 	return (d->sd_get(d, nm, data, szp, t));
 }
 
-int
+nng_err
 nni_stream_dialer_set(nng_stream_dialer *d, const char *nm, const void *data,
     size_t sz, nni_type t)
 {
 	return (d->sd_set(d, nm, data, sz, t));
 }
 
-int
+nng_err
 nni_stream_dialer_get_tls(nng_stream_dialer *d, nng_tls_config **cfgp)
 {
 	if (d->sd_get_tls == NULL) {
@@ -235,7 +235,7 @@ nni_stream_dialer_get_tls(nng_stream_dialer *d, nng_tls_config **cfgp)
 	return (d->sd_get_tls(d, cfgp));
 }
 
-int
+nng_err
 nni_stream_dialer_set_tls(nng_stream_dialer *d, nng_tls_config *cfg)
 {
 	if (d->sd_set_tls == NULL) {
@@ -267,7 +267,7 @@ nng_stream_listener_free(nng_stream_listener *l)
 		l->sl_free(l);
 	}
 }
-int
+nng_err
 nng_stream_listener_listen(nng_stream_listener *l)
 {
 	return (l->sl_listen(l));
@@ -279,21 +279,21 @@ nng_stream_listener_accept(nng_stream_listener *l, nng_aio *aio)
 	l->sl_accept(l, aio);
 }
 
-int
+nng_err
 nni_stream_listener_get(nng_stream_listener *l, const char *nm, void *data,
     size_t *szp, nni_type t)
 {
 	return (l->sl_get(l, nm, data, szp, t));
 }
 
-int
+nng_err
 nni_stream_listener_set(nng_stream_listener *l, const char *nm,
     const void *data, size_t sz, nni_type t)
 {
 	return (l->sl_set(l, nm, data, sz, t));
 }
 
-int
+nng_err
 nni_stream_listener_get_tls(nng_stream_listener *l, nng_tls_config **cfgp)
 {
 	if (l->sl_get_tls == NULL) {
@@ -302,7 +302,7 @@ nni_stream_listener_get_tls(nng_stream_listener *l, nng_tls_config **cfgp)
 	return (l->sl_get_tls(l, cfgp));
 }
 
-int
+nng_err
 nni_stream_listener_set_tls(nng_stream_listener *l, nng_tls_config *cfg)
 {
 	if (l->sl_set_tls == NULL) {
@@ -311,7 +311,7 @@ nni_stream_listener_set_tls(nng_stream_listener *l, nng_tls_config *cfg)
 	return (l->sl_set_tls(l, cfg));
 }
 
-int
+nng_err
 nng_stream_listener_set_security_descriptor(
     nng_stream_listener *l, void *pdesc)
 {
@@ -321,7 +321,7 @@ nng_stream_listener_set_security_descriptor(
 	return (l->sl_set_security_descriptor(l, pdesc));
 }
 
-int
+nng_err
 nng_stream_listener_alloc_url(nng_stream_listener **lp, const nng_url *url)
 {
 	for (int i = 0; stream_drivers[i].scheme != NULL; i++) {
@@ -332,13 +332,13 @@ nng_stream_listener_alloc_url(nng_stream_listener **lp, const nng_url *url)
 	return (NNG_ENOTSUP);
 }
 
-int
+nng_err
 nng_stream_listener_alloc(nng_stream_listener **lp, const char *uri)
 {
 	nng_url *url;
-	int      rv;
+	nng_err  rv;
 
-	if ((rv = nng_url_parse(&url, uri)) != 0) {
+	if ((rv = nng_url_parse(&url, uri)) != NNG_OK) {
 		return (rv);
 	}
 	rv = nng_stream_listener_alloc_url(lp, url);
@@ -348,154 +348,154 @@ nng_stream_listener_alloc(nng_stream_listener **lp, const char *uri)
 
 // Public stream options.
 
-int
+nng_err
 nng_stream_get_int(nng_stream *s, const char *n, int *v)
 {
 	return (nni_stream_get(s, n, v, NULL, NNI_TYPE_INT32));
 }
 
-int
+nng_err
 nng_stream_get_bool(nng_stream *s, const char *n, bool *v)
 {
 	return (nni_stream_get(s, n, v, NULL, NNI_TYPE_BOOL));
 }
 
-int
+nng_err
 nng_stream_get_size(nng_stream *s, const char *n, size_t *v)
 {
 	return (nni_stream_get(s, n, v, NULL, NNI_TYPE_SIZE));
 }
 
-int
+nng_err
 nng_stream_get_string(nng_stream *s, const char *n, char **v)
 {
 	return (nni_stream_get(s, n, v, NULL, NNI_TYPE_STRING));
 }
 
-int
+nng_err
 nng_stream_get_ms(nng_stream *s, const char *n, nng_duration *v)
 {
 	return (nni_stream_get(s, n, v, NULL, NNI_TYPE_DURATION));
 }
 
-int
+nng_err
 nng_stream_get_addr(nng_stream *s, const char *n, nng_sockaddr *v)
 {
 	return (nni_stream_get(s, n, v, NULL, NNI_TYPE_SOCKADDR));
 }
 
-int
+nng_err
 nng_stream_dialer_get_int(nng_stream_dialer *d, const char *n, int *v)
 {
 	return (nni_stream_dialer_get(d, n, v, NULL, NNI_TYPE_INT32));
 }
 
-int
+nng_err
 nng_stream_dialer_get_bool(nng_stream_dialer *d, const char *n, bool *v)
 {
 	return (nni_stream_dialer_get(d, n, v, NULL, NNI_TYPE_BOOL));
 }
 
-int
+nng_err
 nng_stream_dialer_get_size(nng_stream_dialer *d, const char *n, size_t *v)
 {
 	return (nni_stream_dialer_get(d, n, v, NULL, NNI_TYPE_SIZE));
 }
 
-int
+nng_err
 nng_stream_dialer_get_string(nng_stream_dialer *d, const char *n, char **v)
 {
 	return (nni_stream_dialer_get(d, n, v, NULL, NNI_TYPE_STRING));
 }
 
-int
+nng_err
 nng_stream_dialer_get_ms(nng_stream_dialer *d, const char *n, nng_duration *v)
 {
 	return (nni_stream_dialer_get(d, n, v, NULL, NNI_TYPE_DURATION));
 }
 
-int
+nng_err
 nng_stream_dialer_get_addr(
     nng_stream_dialer *d, const char *n, nng_sockaddr *v)
 {
 	return (nni_stream_dialer_get(d, n, v, NULL, NNI_TYPE_SOCKADDR));
 }
 
-int
+nng_err
 nng_stream_dialer_get_tls(nng_stream_dialer *d, nng_tls_config **cfgp)
 {
 	return (nni_stream_dialer_get_tls(d, cfgp));
 }
 
-int
+nng_err
 nng_stream_listener_get_int(nng_stream_listener *l, const char *n, int *v)
 {
 	return (nni_stream_listener_get(l, n, v, NULL, NNI_TYPE_INT32));
 }
 
-int
+nng_err
 nng_stream_listener_get_bool(nng_stream_listener *l, const char *n, bool *v)
 {
 	return (nni_stream_listener_get(l, n, v, NULL, NNI_TYPE_BOOL));
 }
 
-int
+nng_err
 nng_stream_listener_get_size(nng_stream_listener *l, const char *n, size_t *v)
 {
 	return (nni_stream_listener_get(l, n, v, NULL, NNI_TYPE_SIZE));
 }
 
-int
+nng_err
 nng_stream_listener_get_string(nng_stream_listener *l, const char *n, char **v)
 {
 	return (nni_stream_listener_get(l, n, v, NULL, NNI_TYPE_STRING));
 }
 
-int
+nng_err
 nng_stream_listener_get_ms(
     nng_stream_listener *l, const char *n, nng_duration *v)
 {
 	return (nni_stream_listener_get(l, n, v, NULL, NNI_TYPE_DURATION));
 }
 
-int
+nng_err
 nng_stream_listener_get_addr(
     nng_stream_listener *l, const char *n, nng_sockaddr *v)
 {
 	return (nni_stream_listener_get(l, n, v, NULL, NNI_TYPE_SOCKADDR));
 }
 
-int
+nng_err
 nng_stream_listener_get_tls(nng_stream_listener *l, nng_tls_config **cfgp)
 {
 	return (nni_stream_listener_get_tls(l, cfgp));
 }
 
-int
+nng_err
 nng_stream_dialer_set_int(nng_stream_dialer *d, const char *n, int v)
 {
 	return (nni_stream_dialer_set(d, n, &v, sizeof(v), NNI_TYPE_INT32));
 }
 
-int
+nng_err
 nng_stream_dialer_set_bool(nng_stream_dialer *d, const char *n, bool v)
 {
 	return (nni_stream_dialer_set(d, n, &v, sizeof(v), NNI_TYPE_BOOL));
 }
 
-int
+nng_err
 nng_stream_dialer_set_size(nng_stream_dialer *d, const char *n, size_t v)
 {
 	return (nni_stream_dialer_set(d, n, &v, sizeof(v), NNI_TYPE_SIZE));
 }
 
-int
+nng_err
 nng_stream_dialer_set_ms(nng_stream_dialer *d, const char *n, nng_duration v)
 {
 	return (nni_stream_dialer_set(d, n, &v, sizeof(v), NNI_TYPE_DURATION));
 }
 
-int
+nng_err
 nng_stream_dialer_set_string(
     nng_stream_dialer *d, const char *n, const char *v)
 {
@@ -503,38 +503,38 @@ nng_stream_dialer_set_string(
 	    d, n, v, v == NULL ? 0 : strlen(v) + 1, NNI_TYPE_STRING));
 }
 
-int
+nng_err
 nng_stream_dialer_set_addr(
     nng_stream_dialer *d, const char *n, const nng_sockaddr *v)
 {
 	return (nni_stream_dialer_set(d, n, v, sizeof(*v), NNI_TYPE_SOCKADDR));
 }
 
-int
+nng_err
 nng_stream_dialer_set_tls(nng_stream_dialer *d, nng_tls_config *cfg)
 {
 	return (nni_stream_dialer_set_tls(d, cfg));
 }
 
-int
+nng_err
 nng_stream_listener_set_int(nng_stream_listener *l, const char *n, int v)
 {
 	return (nni_stream_listener_set(l, n, &v, sizeof(v), NNI_TYPE_INT32));
 }
 
-int
+nng_err
 nng_stream_listener_set_bool(nng_stream_listener *l, const char *n, bool v)
 {
 	return (nni_stream_listener_set(l, n, &v, sizeof(v), NNI_TYPE_BOOL));
 }
 
-int
+nng_err
 nng_stream_listener_set_size(nng_stream_listener *l, const char *n, size_t v)
 {
 	return (nni_stream_listener_set(l, n, &v, sizeof(v), NNI_TYPE_SIZE));
 }
 
-int
+nng_err
 nng_stream_listener_set_ms(
     nng_stream_listener *l, const char *n, nng_duration v)
 {
@@ -542,7 +542,7 @@ nng_stream_listener_set_ms(
 	    nni_stream_listener_set(l, n, &v, sizeof(v), NNI_TYPE_DURATION));
 }
 
-int
+nng_err
 nng_stream_listener_set_string(
     nng_stream_listener *l, const char *n, const char *v)
 {
@@ -550,7 +550,7 @@ nng_stream_listener_set_string(
 	    l, n, v, v == NULL ? 0 : strlen(v) + 1, NNI_TYPE_STRING));
 }
 
-int
+nng_err
 nng_stream_listener_set_addr(
     nng_stream_listener *l, const char *n, const nng_sockaddr *v)
 {
@@ -558,7 +558,7 @@ nng_stream_listener_set_addr(
 	    nni_stream_listener_set(l, n, v, sizeof(*v), NNI_TYPE_SOCKADDR));
 }
 
-int
+nng_err
 nng_stream_listener_set_tls(nng_stream_listener *l, nng_tls_config *cfg)
 {
 	return (nni_stream_listener_set_tls(l, cfg));