From bb2280b5b43617f866afe035c0d02cd77f2a0262 Mon Sep 17 00:00:00 2001 From: gdamore Date: Mon, 28 Apr 2025 07:18:19 +0000 Subject: deploy: 7d1f3f37d6b6691a60ce649738c323e11517946c --- ref/api/stream.html | 84 ++++++++++++++++++++++++++--------------------------- 1 file changed, 42 insertions(+), 42 deletions(-) (limited to 'ref/api') diff --git a/ref/api/stream.html b/ref/api/stream.html index ae20ae4e..0e9cb4fd 100644 --- a/ref/api/stream.html +++ b/ref/api/stream.html @@ -293,12 +293,12 @@ or be aborted, these functions are unsafe to call from functions that may not bl completion function registered with an nng_aio when it is created.

Getting Stream Options

-
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