From bb2280b5b43617f866afe035c0d02cd77f2a0262 Mon Sep 17 00:00:00 2001
From: gdamore nng_aio when it is created.
int nng_stream_get_bool(nng_stream *s, const char *opt, bool *valp);
-int nng_stream_get_int(nng_stream *s, const char *opt, int *valp);
-int nng_stream_get_ms(nng_stream *s, const char *opt, nng_duration *valp);
-int nng_stream_get_size(nng_stream *s, const char *opt, size_t *valp);
-int nng_stream_get_addr(nng_stream *s, const char *opt, nng_sockaddr *valp);
-int nng_stream_get_string(nng_stream *s, const char *opt, char **valp);
+nng_err nng_stream_get_bool(nng_stream *s, const char *opt, bool *valp);
+nng_err nng_stream_get_int(nng_stream *s, const char *opt, int *valp);
+nng_err nng_stream_get_ms(nng_stream *s, const char *opt, nng_duration *valp);
+nng_err nng_stream_get_size(nng_stream *s, const char *opt, size_t *valp);
+nng_err nng_stream_get_addr(nng_stream *s, const char *opt, nng_sockaddr *valp);
+nng_err nng_stream_get_string(nng_stream *s, const char *opt, char **valp);
@@ -326,10 +326,10 @@ Normally a listener may be used to accept multiple, possibly many, concurrent co
connection requests. While there isn’t a specific BSD socket analogue, this can be thought of as a factory for TCP sockets
created by opening them with socket and then calling connect on them.
Creating a Stream Factory
-int nng_stream_dialer_alloc(nng_stream_dialer **dialerp, const char *url);
-int nng_stream_dialer_alloc_url(nng_stream_dialer **dialerp, const nng_url *url);
-int nng_stream_listener_alloc(nng_stream_listener **lstenerp, const char *url);
-int nng_stream_listener_alloc_url(nng_stream_listener **listenerp, const nng_url *url);
+nng_err nng_stream_dialer_alloc(nng_stream_dialer **dialerp, const char *url);
+nng_err nng_stream_dialer_alloc_url(nng_stream_dialer **dialerp, const nng_url *url);
+nng_err nng_stream_listener_alloc(nng_stream_listener **lstenerp, const char *url);
+nng_err nng_stream_listener_alloc_url(nng_stream_listener **listenerp, const nng_url *url);
The nng_stream_dialer_alloc and nng_stream_dialer_alloc_url functions create a stream dialer, associated the
URL specified by url represented as a string, or as an nng_url object, respectively. The dialer is returned in the location
@@ -401,7 +401,7 @@ if (nng_aio_result(aio) != 0) {
stream = nng_aio_get_output(aio, 0);
Accepting Incoming Connections
-int nng_stream_listener_listen(nng_stream_listener *listener);
+nng_err nng_stream_listener_listen(nng_stream_listener *listener);
void nng_stream_listener_accept(nng_stream_listener *listener, nng_aio *aio);
Accepting incoming connections is performed in two steps. The first step, nng_stream_listener_listen is to setup for
@@ -434,33 +434,33 @@ if (nng_aio_result(aio) != 0) {
stream = nng_aio_get_output(aio, 0);
Stream Factory Options
-int nng_stream_dialer_get_addr(nng_stream_dialer *dialer, const char *opt, nng_sockaddr *valp);
-int nng_stream_dialer_get_bool(nng_stream_dialer *dialer, const char *opt, bool *valp);
-int nng_stream_dialer_get_int(nng_stream_dialer *dialer, const char *opt, int *valp);
-int nng_stream_dialer_get_ms(nng_stream_dialer *dialer, const char *opt, nng_duration *valp);
-int nng_stream_dialer_get_size(nng_stream_dialer *dialer, const char *opt, size_t *valp);
-int nng_stream_dialer_get_string(nng_stream_dialer *dialer, const char *opt, char **valp);
-
-int nng_stream_listener_get_addr(nng_stream_listener *listener, const char *opt, nng_sockaddr *valp);
-int nng_stream_listener_get_bool(nng_stream_listener *listener, const char *opt, bool *valp);
-int nng_stream_listener_get_int(nng_stream_listener *listener, const char *opt, int *valp);
-int nng_stream_listener_get_ms(nng_stream_listener *listener, const char *opt, nng_duration *valp);
-int nng_stream_listener_get_size(nng_stream_listener *listener, const char *opt, size_t *valp);
-int nng_stream_listener_get_string(nng_stream_listener *listener, const char *opt, char **valp);
-
-int nng_stream_dialer_set_addr(nng_stream_dialer *dialer, const char *opt, const nng_sockaddr *val);
-int nng_stream_dialer_set_bool(nng_stream_dialer *dialer, const char *opt, bool val);
-int nng_stream_dialer_set_int(nng_stream_dialer *dialer, const char *opt, int val);
-int nng_stream_dialer_set_ms(nng_stream_dialer *dialer, const char *opt, nng_duration val);
-int nng_stream_dialer_set_size(nng_stream_dialer *dialer, const char *opt, size_t val);
-int nng_stream_dialer_set_string(nng_stream_dialer *dialer, const char *opt, const char *val);
-
-int nng_stream_listener_set_addr(nng_stream_listener *listener, const char *opt, const nng_sockaddr *val);
-int nng_stream_listener_set_bool(nng_stream_listener *listener, const char *opt, bool val);
-int nng_stream_listener_set_int(nng_stream_listener *listener, const char *opt, int val);
-int nng_stream_listener_set_ms(nng_stream_listener *listener, const char *opt, nng_duration val);
-int nng_stream_listener_set_size(nng_stream_listener *listener, const char *opt, size_t val);
-int nng_stream_listener_set_string(nng_stream_listener *listener, const char *opt, const char *val);
+nng_err nng_stream_dialer_get_addr(nng_stream_dialer *dialer, const char *opt, nng_sockaddr *valp);
+nng_err nng_stream_dialer_get_bool(nng_stream_dialer *dialer, const char *opt, bool *valp);
+nng_err nng_stream_dialer_get_int(nng_stream_dialer *dialer, const char *opt, int *valp);
+nng_err nng_stream_dialer_get_ms(nng_stream_dialer *dialer, const char *opt, nng_duration *valp);
+nng_err nng_stream_dialer_get_size(nng_stream_dialer *dialer, const char *opt, size_t *valp);
+nng_err nng_stream_dialer_get_string(nng_stream_dialer *dialer, const char *opt, char **valp);
+
+nng_err nng_stream_listener_get_addr(nng_stream_listener *listener, const char *opt, nng_sockaddr *valp);
+nng_err nng_stream_listener_get_bool(nng_stream_listener *listener, const char *opt, bool *valp);
+nng_err nng_stream_listener_get_int(nng_stream_listener *listener, const char *opt, int *valp);
+nng_err nng_stream_listener_get_ms(nng_stream_listener *listener, const char *opt, nng_duration *valp);
+nng_err nng_stream_listener_get_size(nng_stream_listener *listener, const char *opt, size_t *valp);
+nng_err nng_stream_listener_get_string(nng_stream_listener *listener, const char *opt, char **valp);
+
+nng_err nng_stream_dialer_set_addr(nng_stream_dialer *dialer, const char *opt, const nng_sockaddr *val);
+nng_err nng_stream_dialer_set_bool(nng_stream_dialer *dialer, const char *opt, bool val);
+nng_err nng_stream_dialer_set_int(nng_stream_dialer *dialer, const char *opt, int val);
+nng_err nng_stream_dialer_set_ms(nng_stream_dialer *dialer, const char *opt, nng_duration val);
+nng_err nng_stream_dialer_set_size(nng_stream_dialer *dialer, const char *opt, size_t val);
+nng_err nng_stream_dialer_set_string(nng_stream_dialer *dialer, const char *opt, const char *val);
+
+nng_err nng_stream_listener_set_addr(nng_stream_listener *listener, const char *opt, const nng_sockaddr *val);
+nng_err nng_stream_listener_set_bool(nng_stream_listener *listener, const char *opt, bool val);
+nng_err nng_stream_listener_set_int(nng_stream_listener *listener, const char *opt, int val);
+nng_err nng_stream_listener_set_ms(nng_stream_listener *listener, const char *opt, nng_duration val);
+nng_err nng_stream_listener_set_size(nng_stream_listener *listener, const char *opt, size_t val);
+nng_err nng_stream_listener_set_string(nng_stream_listener *listener, const char *opt, const char *val);
@@ -523,10 +523,10 @@ nng_stream_listener_set_int(listener, NNG_OPT_LISTEN_FD, fd);
// can now start doing nng_stream_listener_accept...
TLS Configuration
-int nng_stream_dialer_get_tls(nng_stream_listener *dialer, nng_tls_config **tlsp);
-int nng_stream_dialer_set_tls(nng_stream_listener *dialer, nng_tls_config *tls);
-int nng_stream_listener_get_tls(nng_stream_listener *listener, nng_tls_config **tlsp);
-int nng_stream_listener_set_tls(nng_stream_listener *listener, nng_tls_config *tls);
+nng_err nng_stream_dialer_get_tls(nng_stream_listener *dialer, nng_tls_config **tlsp);
+nng_err nng_stream_dialer_set_tls(nng_stream_listener *dialer, nng_tls_config *tls);
+nng_err nng_stream_listener_get_tls(nng_stream_listener *listener, nng_tls_config **tlsp);
+nng_err nng_stream_listener_set_tls(nng_stream_listener *listener, nng_tls_config *tls);
Both nng_stream_dialer and nng_stream_listener objects may support configuration of TLS parameters.
The nng_stream_dialer_set_tls and nng_stream_listener_set_tls functions support setting the
--
cgit v1.2.3-70-g09d2