| /third_party/libuv/docs/code/uvcat/ |
| H A D | main.c | 6 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() local
25 void on_read(uv_fs_t *req) { in on_read() function
47 &iov, 1, -1, on_read); in on_open() local
|
| /third_party/libuv/docs/code/dns/ |
| H A D | main.c | 13 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/ |
| H A D | shrpx_client_handler.cc | 121 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()
376 // Run on_read to process data left in buffer since they are not in upstream_http2_connhd_read()
378 if (on_read() != 0) { in upstream_http2_connhd_read()
401 if (on_read() != 0) { in upstream_http1_connhd_read()
421 // Run on_read to process data left in buffer since they are not in upstream_http1_connhd_read()
423 if (on_read() ! in upstream_http1_connhd_read()
693 int ClientHandler::on_read() { on_read() function in shrpx::ClientHandler
[all...] |
| H A D | shrpx_quic_listener.cc | 35 l->on_read(); in readcb()
51 void QUICListener::on_read() { in on_read() function in shrpx::QUICListener
|
| H A D | shrpx_quic_listener.h | 41 void on_read();
|
| H A D | h2load_session.h | 47 virtual int on_read(const uint8_t *data, size_t len) = 0;
|
| H A D | h2load_http2_session.h | 42 virtual int on_read(const uint8_t *data, size_t len);
|
| H A D | shrpx_health_monitor_downstream_connection.h | 49 virtual int on_read();
|
| H A D | h2load_http1_session.h | 44 virtual int on_read(const uint8_t *data, size_t len);
|
| H A D | shrpx_http3_upstream.h | 49 virtual int on_read();
95 int on_read(const UpstreamAddr *faddr, const Address &remote_addr,
|
| H A D | shrpx_downstream_connection.h | 57 virtual int on_read() = 0;
|
| H A D | shrpx_null_downstream_connection.cc | 73 int NullDownstreamConnection::on_read() { return 0; } in on_read() function in shrpx::NullDownstreamConnection
|
| H A D | shrpx_null_downstream_connection.h | 50 virtual int on_read();
|
| H A D | shrpx_http2_downstream_connection.h | 57 virtual int on_read();
|
| H A D | shrpx_api_downstream_connection.h | 81 virtual int on_read();
|
| H A D | shrpx_health_monitor_downstream_connection.cc | 97 int HealthMonitorDownstreamConnection::on_read() { return 0; } in on_read() function in shrpx::HealthMonitorDownstreamConnection
|
| H A D | shrpx_live_check.h | 78 int on_read(const uint8_t *data, size_t len);
|
| H A D | shrpx_dns_resolver.h | 87 int on_read(int fd);
|
| H A D | shrpx_live_check.cc | 466 if (on_read(buf.data(), nread) != 0) { in read_tls()
537 if (on_read(buf.data(), nread) != 0) { in read_clear()
589 int LiveCheck::on_read(const uint8_t *data, size_t len) { in on_read() function in shrpx::LiveCheck
|
| H A D | shrpx_upstream.h | 43 virtual int on_read() = 0;
|
| H A D | shrpx_http_downstream_connection.h | 62 virtual int on_read();
|
| /third_party/libuv/docs/code/udp-dhcp/ |
| H A D | main.c | 17 void on_read(uv_udp_t *req, ssize_t nread, const uv_buf_t *buf, const struct sockaddr *addr, unsigned flags) { in on_read() function
112 uv_udp_recv_start(&recv_socket, alloc_buffer, on_read); in main()
|
| /third_party/libuv/test/ |
| H A D | benchmark-spawn.c | 91 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()
|
| H A D | test-spawn.c | 132 static void on_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in on_read() function
144 on_read(tcp, nread, buf); in on_read_once()
300 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
611 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
645 r = uv_read_start((uv_stream_t*) &pipe, on_alloc, on_read); in TEST_IMPL()
809 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
891 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
894 r = uv_read_start((uv_stream_t*) &err, on_alloc, on_read); in TEST_IMPL()
945 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
992 r = uv_read_start((uv_stream_t*) &out, on_alloc, on_read); in TEST_IMPL()
[all...] |
| /third_party/backends/testsuite/backend/genesys/ |
| H A D | tests_image_pipeline.cpp | 38 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_exact_reads() local
45 ImageBuffer buffer{1000, on_read}; in test_image_buffer_exact_reads()
65 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_smaller_reads() local
72 ImageBuffer buffer{1000, on_read}; in test_image_buffer_smaller_reads()
93 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_larger_reads() local
100 ImageBuffer buffer{1000, on_read}; in test_image_buffer_larger_reads()
118 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_uncapped_remaining_bytes() local
126 ImageBuffer buffer{1000, on_read}; in test_image_buffer_uncapped_remaining_bytes()
144 auto on_read = [&](std::size_t x, std::uint8_t* data) in test_image_buffer_capped_remaining_bytes() local
151 ImageBuffer buffer{1000, on_read}; in test_image_buffer_capped_remaining_bytes()
[all...] |