Home
last modified time | relevance | path

Searched refs:acceptor (Results 1 – 25 of 37) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dtcp_server_posix.cc258 grpc_tcp_server_acceptor* acceptor = in on_read() local
259 static_cast<grpc_tcp_server_acceptor*>(gpr_malloc(sizeof(*acceptor))); in on_read()
260 acceptor->from_server = sp->server; in on_read()
261 acceptor->port_index = sp->port_index; in on_read()
262 acceptor->fd_index = sp->fd_index; in on_read()
263 acceptor->external_connection = false; in on_read()
268 read_notifier_pollset, acceptor); in on_read()
600 grpc_tcp_server_acceptor* acceptor = in Handle() local
601 static_cast<grpc_tcp_server_acceptor*>(gpr_malloc(sizeof(*acceptor))); in Handle()
602 acceptor->from_server = s_; in Handle()
[all …]
Dtcp_server_custom.cc216 grpc_tcp_server_acceptor* acceptor = in finish_accept() local
217 static_cast<grpc_tcp_server_acceptor*>(gpr_malloc(sizeof(*acceptor))); in finish_accept()
240 acceptor->from_server = sp->server; in finish_accept()
241 acceptor->port_index = sp->port_index; in finish_accept()
242 acceptor->fd_index = 0; in finish_accept()
243 acceptor->external_connection = false; in finish_accept()
244 sp->server->on_accept_cb(sp->server->on_accept_cb_arg, ep, nullptr, acceptor); in finish_accept()
Dtcp_server_windows.cc372 grpc_tcp_server_acceptor* acceptor = in on_accept() local
373 (grpc_tcp_server_acceptor*)gpr_malloc(sizeof(*acceptor)); in on_accept()
374 acceptor->from_server = sp->server; in on_accept()
375 acceptor->port_index = sp->port_index; in on_accept()
376 acceptor->fd_index = 0; in on_accept()
377 acceptor->external_connection = false; in on_accept()
378 sp->server->on_accept_cb(sp->server->on_accept_cb_arg, ep, NULL, acceptor); in on_accept()
Dtcp_server.h53 grpc_tcp_server_acceptor* acceptor);
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dhandshaker.cc212 grpc_tcp_server_acceptor* acceptor, in DoHandshake() argument
228 if (acceptor != nullptr && acceptor->external_connection && in DoHandshake()
229 acceptor->pending_data != nullptr) { in DoHandshake()
231 &(acceptor->pending_data->data.raw.slice_buffer)); in DoHandshake()
234 acceptor_ = acceptor; in DoHandshake()
Dhandshaker.h82 virtual void DoHandshake(grpc_tcp_server_acceptor* acceptor,
132 grpc_tcp_server_acceptor* acceptor,
/external/grpc-grpc/test/core/iomgr/
Dtcp_server_uv_test.cc71 const grpc_tcp_server_acceptor* acceptor) { in on_connect_result_set() argument
72 result->server = grpc_tcp_server_ref(acceptor->from_server); in on_connect_result_set()
73 result->port_index = acceptor->port_index; in on_connect_result_set()
74 result->fd_index = acceptor->fd_index; in on_connect_result_set()
100 grpc_tcp_server_acceptor* acceptor) { in on_connect() argument
106 on_connect_result_set(&temp_result, acceptor); in on_connect()
107 gpr_free(acceptor); in on_connect()
Dtcp_server_posix_test.cc105 const grpc_tcp_server_acceptor* acceptor) { in on_connect_result_set() argument
106 result->server = grpc_tcp_server_ref(acceptor->from_server); in on_connect_result_set()
107 result->port_index = acceptor->port_index; in on_connect_result_set()
108 result->fd_index = acceptor->fd_index; in on_connect_result_set()
110 result->server, acceptor->port_index, acceptor->fd_index); in on_connect_result_set()
148 grpc_tcp_server_acceptor* acceptor) { in on_connect() argument
154 on_connect_result_set(&temp_result, acceptor); in on_connect()
155 gpr_free(acceptor); in on_connect()
/external/grpc-grpc/src/core/lib/channel/
Dhandshaker.cc53 grpc_tcp_server_acceptor* acceptor, in grpc_handshaker_do_handshake() argument
56 handshaker->vtable->do_handshake(handshaker, acceptor, on_handshake_done, in grpc_handshaker_do_handshake()
79 grpc_tcp_server_acceptor* acceptor; member
263 grpc_handshaker_do_handshake(mgr->handshakers[mgr->index], mgr->acceptor, in call_next_handshaker_locked()
298 grpc_millis deadline, grpc_tcp_server_acceptor* acceptor, in grpc_handshake_manager_do_handshake() argument
313 mgr->acceptor = acceptor; in grpc_handshake_manager_do_handshake()
Dhandshaker.h84 grpc_tcp_server_acceptor* acceptor,
105 grpc_tcp_server_acceptor* acceptor,
151 grpc_millis deadline, grpc_tcp_server_acceptor* acceptor,
/external/grpc-grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc62 grpc_tcp_server_acceptor* acceptor; member
162 gpr_free(connection_state->acceptor); in on_handshake_done()
169 grpc_tcp_server_acceptor* acceptor) { in on_accept() argument
176 gpr_free(acceptor); in on_accept()
190 connection_state->acceptor = acceptor; in on_accept()
202 state->args, connection_state->deadline, acceptor, on_handshake_done, in on_accept()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc122 grpc_tcp_server_acceptor* acceptor,
150 grpc_tcp_server_acceptor* acceptor);
185 grpc_tcp_server_acceptor* acceptor, in ConnectionState() argument
190 acceptor_(acceptor), in ConnectionState()
452 grpc_tcp_server_acceptor* acceptor) { in OnAccept() argument
459 gpr_free(acceptor); in OnAccept()
463 new ConnectionState(self, accepting_pollset, acceptor, in OnAccept()
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_server_custom.cc205 grpc_tcp_server_acceptor* acceptor = in finish_accept() local
206 (grpc_tcp_server_acceptor*)gpr_malloc(sizeof(*acceptor)); in finish_accept()
233 acceptor->from_server = sp->server; in finish_accept()
234 acceptor->port_index = sp->port_index; in finish_accept()
235 acceptor->fd_index = 0; in finish_accept()
236 sp->server->on_accept_cb(sp->server->on_accept_cb_arg, ep, nullptr, acceptor); in finish_accept()
Dtcp_server_windows.cc370 grpc_tcp_server_acceptor* acceptor = in on_accept() local
371 (grpc_tcp_server_acceptor*)gpr_malloc(sizeof(*acceptor)); in on_accept()
372 acceptor->from_server = sp->server; in on_accept()
373 acceptor->port_index = sp->port_index; in on_accept()
374 acceptor->fd_index = 0; in on_accept()
375 sp->server->on_accept_cb(sp->server->on_accept_cb_arg, ep, NULL, acceptor); in on_accept()
Dtcp_server_posix.cc239 grpc_tcp_server_acceptor* acceptor = in on_read() local
240 static_cast<grpc_tcp_server_acceptor*>(gpr_malloc(sizeof(*acceptor))); in on_read()
241 acceptor->from_server = sp->server; in on_read()
242 acceptor->port_index = sp->port_index; in on_read()
243 acceptor->fd_index = sp->fd_index; in on_read()
248 read_notifier_pollset, acceptor); in on_read()
Dtcp_server.h46 grpc_tcp_server_acceptor* acceptor);
/external/grpc-grpc/test/core/util/
Dreconnect_server.cc61 grpc_tcp_server_acceptor* acceptor) { in on_connect() argument
62 gpr_free(acceptor); in on_connect()
/external/rust/crates/tokio/tests/
Dio_copy_bidirectional.rs13 let acceptor = listener.accept(); in make_socketpair() localVariable
15 let (c1, c2) = tokio::join!(connector, acceptor); in make_socketpair()
/external/parameter-framework/asio-1.10.6/include/asio/local/
Dstream_protocol.hpp69 typedef basic_socket_acceptor<stream_protocol> acceptor; typedef in asio::local::stream_protocol
/external/rust/crates/grpcio-sys/grpc/src/cpp/server/
Dserver_cc.cc920 for (auto& acceptor : acceptors_) { in Server() local
921 acceptor->SetToChannelArgs(args); in Server()
1158 for (auto& acceptor : acceptors_) { in Start() local
1159 acceptor->GetCredentials()->AddPortToServer(acceptor->name(), server_); in Start()
1209 for (auto& acceptor : acceptors_) { in Start() local
1210 acceptor->Start(); in Start()
1222 for (auto& acceptor : acceptors_) { in ShutdownInternal() local
1223 acceptor->Shutdown(); in ShutdownInternal()
/external/parameter-framework/asio-1.10.6/include/asio/ip/
Dtcp.hpp82 typedef basic_socket_acceptor<tcp> acceptor; typedef in asio::ip::tcp
/external/grpc-grpc/test/core/handshake/
Dreadahead_handshaker_server_ssl.cc60 grpc_handshaker* handshaker, grpc_tcp_server_acceptor* acceptor, in readahead_handshaker_do_handshake() argument
/external/parameter-framework/upstream/asio/stub/
Dasio.hpp128 using acceptor = basic_socket_acceptor<void>; typedef
/external/grpc-grpc/test/core/surface/
Dconcurrent_connectivity_test.cc109 grpc_tcp_server_acceptor* acceptor) { in on_connect() argument
110 gpr_free(acceptor); in on_connect()
/external/grpc-grpc/test/core/end2end/
Dbad_server_response_test.cc135 grpc_tcp_server_acceptor* acceptor) { in on_connect() argument
136 gpr_free(acceptor); in on_connect()

12