Home
last modified time | relevance | path

Searched refs:on_read (Results 1 – 25 of 55) sorted by relevance

123

/third_party/libuv/docs/code/uvcat/
Dmain.c6 void on_read(uv_fs_t *req);
21 uv_fs_read(uv_default_loop(), &read_req, open_req.result, &iov, 1, -1, on_read); in on_write()
25 void on_read(uv_fs_t *req) { in on_read() function
47 &iov, 1, -1, on_read); in on_open()
/third_party/libuv/docs/code/dns/
Dmain.c13 void on_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) { in on_read() function
39 uv_read_start((uv_stream_t*) req->handle, alloc_buffer, on_read); in on_connect()
/third_party/nghttp2/src/
Dshrpx_quic_listener.cc35 l->on_read(); in readcb()
51 void QUICListener::on_read() { in on_read() function in shrpx::QUICListener
Dshrpx_client_handler.cc121 if (rb_.rleft() && on_read() != 0) { in read_clear()
204 if (on_read() != 0) { in proxy_protocol_peek_clear()
251 if (rb_.rleft() && on_read() != 0) { in read_tls()
329 return upstream->on_read(faddr, remote_addr, local_addr, pi, data, datalen); in read_quic()
339 if (upstream_->on_read() != 0) { in upstream_read()
378 if (on_read() != 0) { in upstream_http2_connhd_read()
401 if (on_read() != 0) { in upstream_http1_connhd_read()
423 if (on_read() != 0) { in upstream_http1_connhd_read()
664 if (on_read() != 0) { in validate_next_proto()
678 if (on_read() != 0) { in validate_next_proto()
[all …]
Dshrpx_quic_listener.h41 void on_read();
Dh2load_session.h47 virtual int on_read(const uint8_t *data, size_t len) = 0;
Dh2load_http2_session.h42 virtual int on_read(const uint8_t *data, size_t len);
Dh2load_http1_session.h44 virtual int on_read(const uint8_t *data, size_t len);
Dshrpx_http3_upstream.h49 virtual int on_read();
94 int on_read(const UpstreamAddr *faddr, const Address &remote_addr,
Dshrpx_health_monitor_downstream_connection.h49 virtual int on_read();
Dshrpx_null_downstream_connection.h50 virtual int on_read();
Dshrpx_null_downstream_connection.cc73 int NullDownstreamConnection::on_read() { return 0; } in on_read() function in shrpx::NullDownstreamConnection
Dshrpx_downstream_connection.h57 virtual int on_read() = 0;
Dshrpx_dns_resolver.h87 int on_read(int fd);
Dshrpx_live_check.h78 int on_read(const uint8_t *data, size_t len);
Dshrpx_http2_downstream_connection.h57 virtual int on_read();
Dshrpx_api_downstream_connection.h81 virtual int on_read();
Dshrpx_health_monitor_downstream_connection.cc97 int HealthMonitorDownstreamConnection::on_read() { return 0; } in on_read() function in shrpx::HealthMonitorDownstreamConnection
Dshrpx_http_downstream_connection.h62 virtual int on_read();
Dh2load_http3_session.h42 virtual int on_read(const uint8_t *data, size_t len);
/third_party/libuv/test/
Dbenchmark-spawn.c91 static void on_read(uv_stream_t* pipe, ssize_t nread, const uv_buf_t* buf) { in on_read() function
132 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in spawn()
Dtest-spawn.c129 static void on_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in on_read() function
141 on_read(tcp, nread, buf); in on_read_once()
297 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
608 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
642 r = uv_read_start((uv_stream_t*) &pipe, on_alloc, on_read); in TEST_IMPL()
806 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
888 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
891 r = uv_read_start((uv_stream_t*) &err, on_alloc, on_read); in TEST_IMPL()
942 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
989 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
[all …]
Dtest-stdio-over-pipes.c97 static void on_read(uv_stream_t* pipe, ssize_t nread, const uv_buf_t* rdbuf) { in on_read() function
145 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in test_stdio_over_pipes()
/third_party/libuv/docs/code/udp-dhcp/
Dmain.c17 void on_read(uv_udp_t *req, ssize_t nread, const uv_buf_t *buf, const struct sockaddr *addr, unsign… in on_read() function
112 uv_udp_recv_start(&recv_socket, alloc_buffer, on_read); in main()
/third_party/libuv/docs/src/
Dmigration_010_100.rst154 void on_read(uv_stream_t* handle,
172 void on_read(uv_stream_t* handle,
196 void on_read(uv_pipe_t* pipe,
209 void on_read(uv_stream_t* handle,

123