| /third_party/grpc/test/core/util/ |
| D | mock_endpoint.cc | 43 grpc_closure* on_read; member
55 m->on_read = cb; in me_read()
82 if (m->on_read) { in me_shutdown()
83 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, in me_shutdown()
86 m->on_read = nullptr; in me_shutdown()
135 m->on_read = nullptr; in grpc_mock_endpoint_create()
142 if (m->on_read != nullptr) { in grpc_mock_endpoint_put_read()
144 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, GRPC_ERROR_NONE); in grpc_mock_endpoint_put_read()
145 m->on_read = nullptr; in grpc_mock_endpoint_put_read()
|
| D | passthru_endpoint.cc | 47 grpc_closure* on_read; member
72 m->on_read = cb; in me_read()
91 } else if (m->on_read != nullptr) { in me_write()
95 grpc_core::ExecCtx::Run(DEBUG_LOCATION, m->on_read, GRPC_ERROR_NONE); in me_write()
96 m->on_read = nullptr; in me_write()
120 if (m->on_read) { in me_shutdown()
122 DEBUG_LOCATION, m->on_read, in me_shutdown()
124 m->on_read = nullptr; in me_shutdown()
127 if (m->on_read) { in me_shutdown()
129 DEBUG_LOCATION, m->on_read, in me_shutdown()
[all …]
|
| /third_party/libuv/docs/code/uvcat/ |
| D | main.c | 7 void on_read(uv_fs_t *req);
22 uv_fs_read(uv_default_loop(), &read_req, open_req.result, &iov, 1, -1, on_read); in on_write()
26 void on_read(uv_fs_t *req) { in on_read() function
48 &iov, 1, -1, on_read); in on_open()
|
| /third_party/boost/libs/beast/example/websocket/server/chat-multi/ |
| D | websocket_session.cpp | 56 &websocket_session::on_read, in on_accept()
62 on_read(beast::error_code ec, std::size_t) in on_read() function in websocket_session
78 &websocket_session::on_read, in on_read()
|
| D | http_session.hpp | 37 void on_read(beast::error_code ec, std::size_t);
|
| /third_party/grpc/src/core/lib/security/transport/ |
| D | secure_endpoint.cc | 46 static void on_read(void* user_data, grpc_error* error);
60 GRPC_CLOSURE_INIT(&on_read, ::on_read, this, grpc_schedule_on_exec_ctx); in secure_endpoint()
91 grpc_closure on_read; member
172 static void on_read(void* user_data, grpc_error* error) { in on_read() function
268 on_read(ep, GRPC_ERROR_NONE); in endpoint_read()
272 grpc_endpoint_read(ep->wrapped_ep, &ep->source_buffer, &ep->on_read, urgent); in endpoint_read()
|
| /third_party/grpc/src/core/lib/http/ |
| D | httpcli.cc | 62 grpc_closure on_read; member
127 grpc_endpoint_read(req->ep, &req->incoming, &req->on_read, /*urgent=*/true); in do_read()
130 static void on_read(void* user_data, grpc_error* error) { in on_read() function
250 GRPC_CLOSURE_INIT(&req->on_read, on_read, req, grpc_schedule_on_exec_ctx); in internal_request_begin()
|
| /third_party/libuv/docs/code/dns/ |
| 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/grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 108 grpc_closure on_read; member
180 static void on_read(void* tcpp, grpc_error* error) { in on_read() function
293 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &tcp->on_read, GRPC_ERROR_NONE); in win_read()
306 grpc_core::ExecCtx::Run(DEBUG_LOCATION, &tcp->on_read, in win_read()
312 grpc_socket_notify_on_read(tcp->socket, &tcp->on_read); in win_read()
530 GRPC_CLOSURE_INIT(&tcp->on_read, on_read, tcp, grpc_schedule_on_exec_ctx); in grpc_tcp_create()
|
| /third_party/libuv/test/ |
| 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()
|
| /third_party/grpc/test/core/end2end/ |
| D | bad_server_response_test.cc | 90 static grpc_closure on_read; variable
129 grpc_endpoint_read(state.tcp, &state.temp_incoming_buffer, &on_read, in handle_read()
139 GRPC_CLOSURE_INIT(&on_read, handle_read, nullptr, grpc_schedule_on_exec_ctx); in on_connect()
146 grpc_endpoint_read(tcp, &state.temp_incoming_buffer, &on_read, in on_connect()
|
| /third_party/libuv/docs/code/udp-dhcp/ |
| D | main.c | 17 void on_read(uv_udp_t *req, ssize_t nread, const uv_buf_t *buf, const struct sockaddr *addr, unsign… in on_read() function
111 uv_udp_recv_start(&recv_socket, alloc_buffer, on_read); in main()
|
| /third_party/boost/libs/beast/example/http/client/async/ |
| D | http_client_async.cpp | 131 &session::on_read, in on_write()
136 on_read( in on_read() function in session
|
| /third_party/boost/libs/beast/example/websocket/client/async/ |
| D | websocket_client_async.cpp | 161 &session::on_read, in on_write()
166 on_read( in on_read() function in session
|
| /third_party/nghttp2/src/ |
| D | shrpx_client_handler.cc | 117 if (rb_.rleft() && on_read() != 0) { in read_clear()
218 if (rb_.rleft() && on_read() != 0) { in read_tls()
292 if (upstream_->on_read() != 0) { in upstream_read()
331 if (on_read() != 0) { in upstream_http2_connhd_read()
354 if (on_read() != 0) { in upstream_http1_connhd_read()
376 if (on_read() != 0) { in upstream_http1_connhd_read()
599 if (on_read() != 0) { in validate_next_proto()
613 if (on_read() != 0) { in validate_next_proto()
628 int ClientHandler::on_read() { in on_read() function in shrpx::ClientHandler
1158 if (on_read() != 0) { in on_proxy_protocol_finish()
|
| D | h2load_session.h | 47 virtual int on_read(const uint8_t *data, size_t len) = 0;
|
| D | h2load_http2_session.h | 42 virtual int on_read(const uint8_t *data, size_t len);
|
| D | h2load_http1_session.h | 44 virtual int on_read(const uint8_t *data, size_t len);
|
| /third_party/libuv/docs/src/ |
| D | migration_010_100.rst | 154 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,
|
| /third_party/boost/libs/beast/test/extras/include/boost/beast/test/ |
| D | websocket.hpp | 196 &ws_echo_server::on_read, in do_read()
202 on_read(error_code ec) in on_read() function in boost::beast::test::ws_echo_server
|
| /third_party/boost/libs/beast/example/websocket/client/async-ssl/ |
| D | websocket_client_async_ssl.cpp | 184 &session::on_read, in on_write()
189 on_read( in on_read() function in session
|
| /third_party/boost/libs/beast/example/http/client/async-ssl/ |
| D | http_client_async_ssl.cpp | 157 &session::on_read, in on_write()
162 on_read( in on_read() function in session
|
| /third_party/boost/libs/beast/example/websocket/server/async/ |
| D | websocket_server_async.cpp | 113 &session::on_read, in do_read()
118 on_read( in on_read() function in session
|
| /third_party/boost/libs/beast/example/http/client/async-ssl-system-executor/ |
| D | http_client_async_ssl_system_executor.cpp | 165 &session::on_read, in on_write()
170 on_read( in on_read() function in session
|
| /third_party/boost/libs/beast/example/websocket/client/async-ssl-system-executor/ |
| D | websocket_client_async_ssl_system_executor.cpp | 192 &session::on_read, in on_write()
197 on_read( in on_read() function in session
|