Home
last modified time | relevance | path

Searched refs:nng_aio (Results 1 – 25 of 91) sorted by relevance

1234

/dports/net/nng/nng-1.5.2/include/nng/supplemental/http/
H A Dhttp.h242 NNG_DECL void nng_http_conn_read(nng_http_conn *, nng_aio *);
246 NNG_DECL void nng_http_conn_read_all(nng_http_conn *, nng_aio *);
251 NNG_DECL void nng_http_conn_write(nng_http_conn *, nng_aio *);
255 NNG_DECL void nng_http_conn_write_all(nng_http_conn *, nng_aio *);
260 nng_http_conn *, nng_http_req *, nng_aio *);
265 nng_http_conn *, nng_http_res *, nng_aio *);
271 nng_http_conn *, nng_http_req *, nng_aio *);
277 nng_http_conn *, nng_http_res *, nng_aio *);
313 nng_http_handler **, const char *, void (*)(nng_aio *));
527 nng_http_conn *, nng_http_req *, nng_http_res *, nng_aio *);
[all …]
/dports/net/nng/nng-1.5.2/include/nng/
H A Dnng.h99 typedef struct nng_aio nng_aio; typedef
489 NNG_DECL void nng_aio_free(nng_aio *);
496 NNG_DECL void nng_aio_reap(nng_aio *);
502 NNG_DECL void nng_aio_stop(nng_aio *);
507 NNG_DECL int nng_aio_result(nng_aio *);
512 NNG_DECL size_t nng_aio_count(nng_aio *);
517 NNG_DECL void nng_aio_cancel(nng_aio *);
521 NNG_DECL void nng_aio_abort(nng_aio *, int);
527 NNG_DECL void nng_aio_wait(nng_aio *);
535 NNG_DECL nng_msg *nng_aio_get_msg(nng_aio *);
[all …]
/dports/net/nng/nng-1.5.2/src/core/
H A Daio_test.c39 nng_aio *aio; in test_sleep()
59 nng_aio *aio; in test_sleep_timeout()
78 nng_aio *aio; in test_insane_nio()
89 nng_aio *aio; in test_provider_cancel()
104 nng_aio * a; in test_consumer_cancel()
127 nng_aio * tx_aio; in test_traffic()
128 nng_aio * rx_aio; in test_traffic()
179 nng_aio * a; in test_explicit_timeout()
197 nng_aio * a; in test_inherited_timeout()
215 nng_aio * a; in test_zero_timeout()
[all …]
H A Dstream.h40 void (*s_recv)(void *, nng_aio *);
41 void (*s_send)(void *, nng_aio *);
50 void (*sd_dial)(void *, nng_aio *);
61 void (*sl_accept)(void *, nng_aio *);
/dports/net/nng/nng-1.5.2/src/platform/
H A Dresolver_test.c20 nng_aio * aio; in test_google_dns()
37 nng_aio * aio; in test_numeric_addr()
53 nng_aio * aio; in test_numeric_v6()
76 nng_aio * aio; in test_service_names()
91 nng_aio * aio; in test_localhost_v4()
107 nng_aio * aio; in test_localhost_unspecified()
132 nng_aio * aio; in test_null_passive()
148 nng_aio * aio; in test_null_not_passive()
169 nng_aio * aio; in test_bad_port_number()
/dports/net/nng/nng-1.5.2/docs/man/
H A Dnng_aio.5.adoc1 = nng_aio(5)
14 nng_aio - asynchronous I/O handle
22 typedef struct nng_aio nng_aio;
27 An `nng_aio`(((aio))) is an opaque structure used in conjunction with
69 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_aio_set_msg.3.adoc22 void nng_aio_set_msg(nng_aio *aio, nng_msg *msg);
30 IMPORTANT: The xref:nng_aio.5.adoc[`nng_aio`] must not have an operation in progress.
45 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_aio_get_msg.3.adoc22 nng_msg *nng_aio_get_msg(nng_aio *aio);
32 IMPORTANT: The xref:nng_aio.5.adoc[`nng_aio`] must not have an operation in progress.
47 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_aio_free.3.adoc22 void nng_aio_free(nng_aio *aio);
23 void nng_aio_reap(nng_aio *aio);
53 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_iov.5.adoc38 an xref:nng_aio.5.adoc[`nng_aio`] structure using the
54 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_aio_wait.3.adoc22 void nng_aio_wait(nng_aio *aio);
48 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_aio_alloc.3.adoc22 int nng_aio_alloc(nng_aio **aiop, void (*callb)(void *), void *arg);
43 Asynchronous I/O operations all take an xref:nng_aio.5.adoc[`nng_aio`]
87 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_sleep_aio.3.adoc22 void nng_sleep_aio(nng_duration msec, nng_aio *aio);
51 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_aio_abort.3.adoc22 void nng_aio_abort(nng_aio *aio, int err);
54 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_aio_get_input.3.adoc22 void *nng_aio_get_input(nng_aio *aio, unsigned int index);
52 xref:nng_aio.5.adoc[nng_aio(5)],
H A Dnng_aio_defer.3.adoc22 typedef void (*nng_aio_cancelfn)(nng_aio *aio, void *arg, int err);
24 void nng_aio_defer(nng_aio *aio, nng_aio_cancelfn fn, void *arg);
77 xref:nng_aio.5.adoc[nng_aio(5)],
/dports/net/nng/nng-1.5.2/tests/
H A Dudp.c60 nng_aio * aio1;
61 nng_aio * aio2;
104 nng_aio *aio1;
129 nng_aio * aio1;
130 nng_aio * aio2;
131 nng_aio * aio3;
132 nng_aio * aio4;
194 nng_aio *aio1;
210 nng_aio * aio1;
236 nng_aio * aio1;
H A Dipcsupp.c41 nng_aio * daio = NULL;
42 nng_aio * laio = NULL;
43 nng_aio * maio = NULL;
80 nng_aio * aio1;
81 nng_aio * aio2;
H A Dtcpsupp.c49 nng_aio * daio = NULL;
50 nng_aio * laio = NULL;
51 nng_aio * maio = NULL;
96 nng_aio * aio1;
97 nng_aio * aio2;
/dports/net/nng/nng-1.5.2/src/supplemental/websocket/
H A Dwebsocket_test.c25 nng_aio * daio = NULL; in test_websocket_wildcard()
26 nng_aio * laio = NULL; in test_websocket_wildcard()
27 nng_aio * aio1 = NULL; in test_websocket_wildcard()
28 nng_aio * aio2 = NULL; in test_websocket_wildcard()
133 nng_aio * daio = NULL; in test_websocket_conn_props()
134 nng_aio * laio = NULL; in test_websocket_conn_props()
224 nng_aio * daio = NULL; in test_websocket_text_mode()
225 nng_aio * laio = NULL; in test_websocket_text_mode()
226 nng_aio * aio1 = NULL; in test_websocket_text_mode()
227 nng_aio * aio2 = NULL; in test_websocket_text_mode()
[all …]
/dports/net/nng/nng-1.5.2/src/supplemental/http/
H A Dhttp_public.c403 nng_http_conn_read(nng_http_conn *conn, nng_aio *aio) in nng_http_conn_read()
416 nng_http_conn_read_all(nng_http_conn *conn, nng_aio *aio) in nng_http_conn_read_all()
429 nng_http_conn_write(nng_http_conn *conn, nng_aio *aio) in nng_http_conn_write()
442 nng_http_conn_write_all(nng_http_conn *conn, nng_aio *aio) in nng_http_conn_write_all()
453 nng_http_conn_write_req(nng_http_conn *conn, nng_http_req *req, nng_aio *aio) in nng_http_conn_write_req()
467 nng_http_conn_write_res(nng_http_conn *conn, nng_http_res *res, nng_aio *aio) in nng_http_conn_write_res()
481 nng_http_conn_read_req(nng_http_conn *conn, nng_http_req *req, nng_aio *aio) in nng_http_conn_read_req()
495 nng_http_conn_read_res(nng_http_conn *conn, nng_http_res *res, nng_aio *aio) in nng_http_conn_read_res()
510 nng_http_handler **hp, const char *uri, void (*cb)(nng_aio *)) in nng_http_handler_alloc() argument
883 nng_http_client_connect(nng_http_client *cli, nng_aio *aio) in nng_http_client_connect()
[all …]
/dports/net/nng/nng-1.5.2/src/
H A Dnng.c124 nng_aio *ap; in nng_recvmsg()
175 nng_aio *ap; in nng_sendmsg()
1732 nng_aio *aio; in nng_aio_alloc()
1746 nng_aio_free(nng_aio *aio) in nng_aio_free()
1752 nng_aio_reap(nng_aio *aio) in nng_aio_reap()
1764 nng_aio_result(nng_aio *aio) in nng_aio_result()
1770 nng_aio_count(nng_aio *aio) in nng_aio_count()
1776 nng_aio_stop(nng_aio *aio) in nng_aio_stop()
1782 nng_aio_wait(nng_aio *aio) in nng_aio_wait()
1794 nng_aio_cancel(nng_aio *aio) in nng_aio_cancel()
[all …]
/dports/net/nng/nng-1.5.2/src/testing/
H A Dstreams.c20 nng_aio * upper_aio;
21 nng_aio * lower_aio;
23 void (*submit)(nng_stream *, nng_aio *);
78 stream_xfr_alloc(nng_stream *s, void (*submit)(nng_stream *, nng_aio *), in stream_xfr_alloc() argument
/dports/net/nng/nng-1.5.2/src/sp/protocol/reqrep0/
H A Drep_test.c170 nng_aio * aio1; in test_rep_double_recv()
171 nng_aio * aio2; in test_rep_double_recv()
194 nng_aio * aio1; in test_rep_close_pipe_before_send()
266 nng_aio * aio; in test_rep_ctx_recv_aio_stopped()
289 nng_aio * aio[100]; in test_rep_close_pipe_context_send()
348 nng_aio * aio[100]; in test_rep_close_context_send()
402 nng_aio * aio; in test_rep_close_recv()
421 nng_aio *aio;
482 nng_aio * aio; in test_rep_ctx_recv_nonblock()
503 nng_aio * aio; in test_rep_ctx_send_nonblock()
[all …]
/dports/net/nng/nng-1.5.2/demo/rest/
H A Dserver.c76 nng_aio * http_aio; // aio from HTTP we must reply to
80 nng_aio * aio; // request flow
142 nng_aio * aio = job->http_aio; in rest_http_fatal()
159 nng_aio * aio = job->aio; in rest_job_cb()
205 rest_handle(nng_aio *aio) in rest_handle()

1234