Home
last modified time | relevance | path

Searched refs:on_connect (Results 1 – 25 of 26) sorted by relevance

12

/external/perfetto/src/ipc/
Dclient_impl_unittest.cc259 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
260 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
308 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
309 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
337 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
338 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
380 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
381 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
426 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
427 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
[all …]
Dhost_impl_unittest.cc198 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in SetUp() local
199 EXPECT_CALL(*cli_, OnConnect()).WillOnce(Invoke(on_connect)); in SetUp()
/external/grpc-grpc/test/core/util/
Dtest_tcp_server.cc44 grpc_tcp_server_cb on_connect, void* user_data) { in test_tcp_server_init() argument
52 server->on_connect = on_connect; in test_tcp_server_init()
76 server->on_connect, server->cb_data); in test_tcp_server_start()
Dtest_tcp_server.h31 grpc_tcp_server_cb on_connect; member
36 grpc_tcp_server_cb on_connect, void* user_data);
Dreconnect_server.cc59 static void on_connect(void* arg, grpc_endpoint* tcp, in on_connect() function
100 test_tcp_server_init(&server->tcp_server, on_connect, server); in reconnect_server_init()
/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_client_windows.cc51 grpc_closure on_connect; member
80 static void on_connect(void* acp, grpc_error* error) { in on_connect() function
206 GRPC_CLOSURE_INIT(&ac->on_connect, on_connect, ac, grpc_schedule_on_exec_ctx); in tcp_connect()
210 grpc_socket_notify_on_write(socket, &ac->on_connect); in tcp_connect()
Dtcp_client.h31 void (*connect)(grpc_closure* on_connect, grpc_endpoint** endpoint,
42 void grpc_tcp_client_connect(grpc_closure* on_connect, grpc_endpoint** endpoint,
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dtcp_client_windows.cc52 grpc_closure on_connect; member
80 static void on_connect(void* acp, grpc_error_handle error) { in on_connect() function
206 GRPC_CLOSURE_INIT(&ac->on_connect, on_connect, ac, grpc_schedule_on_exec_ctx); in tcp_connect()
210 grpc_socket_notify_on_write(socket, &ac->on_connect); in tcp_connect()
Dtcp_client.cc25 void grpc_tcp_client_connect(grpc_closure* on_connect, grpc_endpoint** endpoint, in grpc_tcp_client_connect() argument
30 grpc_tcp_client_impl->connect(on_connect, endpoint, interested_parties, in grpc_tcp_client_connect()
Dtcp_client.h31 void (*connect)(grpc_closure* on_connect, grpc_endpoint** endpoint,
42 void grpc_tcp_client_connect(grpc_closure* on_connect, grpc_endpoint** endpoint,
/external/grpc-grpc/test/core/iomgr/
Dtcp_server_uv_test.cc99 static void on_connect(void* arg, grpc_endpoint* tcp, grpc_pollset* pollset, in on_connect() function
129 grpc_tcp_server_start(s, NULL, 0, on_connect, NULL); in test_no_op_with_start()
168 grpc_tcp_server_start(s, NULL, 0, on_connect, NULL); in test_no_op_with_port_and_start()
249 grpc_tcp_server_start(s, &g_pollset, 1, on_connect, NULL); in test_connect()
Dtcp_server_posix_test.cc147 static void on_connect(void* arg, grpc_endpoint* tcp, grpc_pollset* pollset, in on_connect() function
177 grpc_tcp_server_start(s, nullptr, 0, on_connect, nullptr); in test_no_op_with_start()
218 grpc_tcp_server_start(s, nullptr, 0, on_connect, nullptr); in test_no_op_with_port_and_start()
349 grpc_tcp_server_start(s, &g_pollset, 1, on_connect, nullptr); in test_connect()
/external/perfetto/src/ipc/test/
Dipc_integrationtest.cc88 auto on_connect = task_runner_.CreateCheckpoint("on_connect"); in TEST_F() local
89 EXPECT_CALL(svc_proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
/external/perfetto/test/
Dfake_producer.cc49 std::function<void()> on_connect, in Connect() argument
61 on_connect_ = std::move(on_connect); in Connect()
Dfake_producer.h46 std::function<void()> on_connect,
/external/perfetto/src/tracing/test/
Dmock_consumer.cc47 auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name); in Connect() local
48 EXPECT_CALL(*this, OnConnect()).WillOnce(Invoke(on_connect)); in Connect()
Dmock_producer.cc82 auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name); in Connect() local
83 EXPECT_CALL(*this, OnConnect()).WillOnce(Invoke(on_connect)); in Connect()
/external/grpc-grpc/test/core/surface/
Dconcurrent_connectivity_test.cc107 static void on_connect(void* vargs, grpc_endpoint* tcp, in on_connect() function
139 grpc_tcp_server_start(s, &args->pollset, 1, on_connect, args); in bad_server_thread()
/external/grpc-grpc/test/core/end2end/
Dbad_server_response_test.cc133 static void on_connect(void* arg, grpc_endpoint* tcp, in on_connect() function
281 test_tcp_server_init(&test_server, on_connect, &test_server); in run_test()
/external/rust/crates/grpcio-sys/grpc/include/grpc/event_engine/
Devent_engine.h217 virtual absl::Status Connect(OnConnectCallback on_connect,
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/event_engine/
Devent_engine.h217 virtual absl::Status Connect(OnConnectCallback on_connect,
/external/iperf3/src/
Diperf_client_api.c251 if (test->on_connect) in iperf_handle_message_client()
252 test->on_connect(test); in iperf_handle_message_client()
Diperf.h353 void (*on_connect)(struct iperf_test *); member
Diperf_server_api.c136 if (test->on_connect) in iperf_accept()
137 test->on_connect(test); in iperf_accept()
/external/iperf3/
DRELNOTES.md808 * on_connect - executes after a connection is made to the server

12