| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-connectable_observable.hpp | 19 static auto check(int) -> decltype((*(CT*)nullptr).on_connect(composite_subscription()));
38 onconnect_type on_connect; member
55 state->on_connect = [so](composite_subscription cs) mutable { in construct()
56 so->on_connect(std::move(cs)); in construct()
82 state->on_connect = std::forward<CF>(cf); in dynamic_connectable_observable()
87 void on_connect(composite_subscription cs) const { in on_connect() function in rxcpp::dynamic_connectable_observable
88 state->on_connect(std::move(cs)); in on_connect()
161 base_type::source_operator.on_connect(cs); in connect()
|
| D | rx-grouped_observable.hpp | 88 state->on_connect = std::forward<CF>(cf); in dynamic_grouped_observable()
|
| /external/perfetto/src/ipc/ |
| D | client_impl_unittest.cc | 229 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
230 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
278 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
279 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
307 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
308 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
347 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
348 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
393 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in TEST_F() local
394 EXPECT_CALL(proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
[all …]
|
| D | host_impl_unittest.cc | 175 auto on_connect = task_runner_->CreateCheckpoint("on_connect"); in SetUp() local
176 EXPECT_CALL(*cli_, OnConnect()).WillOnce(Invoke(on_connect)); in SetUp()
|
| /external/grpc-grpc/test/core/util/ |
| D | test_tcp_server.cc | 44 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()
|
| D | test_tcp_server.h | 31 grpc_tcp_server_cb on_connect; member
36 grpc_tcp_server_cb on_connect, void* user_data);
|
| D | reconnect_server.cc | 59 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/ |
| D | tcp_client_windows.cc | 51 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()
|
| D | tcp_client.h | 31 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/ |
| D | tcp_server_uv_test.cc | 99 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()
|
| D | tcp_server_posix_test.cc | 147 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/ |
| D | ipc_integrationtest.cc | 80 auto on_connect = task_runner_.CreateCheckpoint("on_connect"); in TEST_F() local
81 EXPECT_CALL(svc_proxy_events_, OnConnect()).WillOnce(Invoke(on_connect)); in TEST_F()
|
| /external/perfetto/src/tracing/test/ |
| D | mock_consumer.cc | 46 auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name); in Connect() local
47 EXPECT_CALL(*this, OnConnect()).WillOnce(Invoke(on_connect)); in Connect()
|
| D | mock_producer.cc | 55 auto on_connect = task_runner_->CreateCheckpoint(checkpoint_name); in Connect() local
56 EXPECT_CALL(*this, OnConnect()).WillOnce(Invoke(on_connect)); in Connect()
|
| /external/grpc-grpc/test/core/surface/ |
| D | concurrent_connectivity_test.cc | 107 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/ |
| D | bad_server_response_test.cc | 133 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/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-multicast.hpp | 63 void on_connect(composite_subscription cs) const { in on_connect() function
|
| /external/iperf3/src/ |
| D | iperf_client_api.c | 251 if (test->on_connect) in iperf_handle_message_client()
252 test->on_connect(test); in iperf_handle_message_client()
|
| D | iperf.h | 341 void (*on_connect)(struct iperf_test *); member
|
| D | iperf_server_api.c | 136 if (test->on_connect) in iperf_accept()
137 test->on_connect(test); in iperf_accept()
|
| D | iperf_api.c | 2323 testp->on_connect = iperf_on_connect; in iperf_defaults()
|
| /external/iperf3/ |
| D | RELEASE_NOTES | 665 * on_connect - executes after a connection is made to the server
|