Home
last modified time | relevance | path

Searched refs:g_pollset (Results 1 – 10 of 10) sorted by relevance

/external/grpc-grpc/test/core/iomgr/
Dendpoint_pair_test.cc30 static grpc_pollset* g_pollset; variable
47 grpc_endpoint_add_to_pollset(f.client_ep, g_pollset); in create_fixture_endpoint_pair()
48 grpc_endpoint_add_to_pollset(f.server_ep, g_pollset); in create_fixture_endpoint_pair()
67 g_pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in main()
68 grpc_pollset_init(g_pollset, &g_mu); in main()
69 grpc_endpoint_tests(configs[0], g_pollset, g_mu); in main()
70 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
72 grpc_pollset_shutdown(g_pollset, &destroyed); in main()
75 gpr_free(g_pollset); in main()
Dudp_server_test.cc48 static grpc_pollset* g_pollset; variable
83 grpc_pollset_kick(g_pollset, nullptr))); in Read()
94 grpc_pollset_kick(g_pollset, nullptr))); in OnCanWrite()
179 auto closure = GRPC_CLOSURE_CREATE(destroy_pollset, g_pollset, in shutdown_and_destroy_pollset()
181 grpc_pollset_shutdown(g_pollset, closure); in shutdown_and_destroy_pollset()
188 grpc_pollset_init(g_pollset, &g_mu); in test_no_op()
197 grpc_pollset_init(g_pollset, &g_mu); in test_no_op_with_start()
207 grpc_pollset_init(g_pollset, &g_mu); in test_no_op_with_port()
231 grpc_pollset_init(g_pollset, &g_mu); in test_no_op_with_port_and_socket_factory()
267 grpc_pollset_init(g_pollset, &g_mu); in test_no_op_with_port_and_start()
[all …]
Dtcp_client_posix_test.cc45 static grpc_pollset* g_pollset; variable
58 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr))); in finish_connection()
128 grpc_pollset_work(g_pollset, &worker, in test_succeeds()
177 grpc_pollset_work(g_pollset, &worker, polling_deadline))); in test_fails()
200 g_pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in main()
201 grpc_pollset_init(g_pollset, &g_mu); in main()
202 grpc_pollset_set_add_pollset(g_pollset_set, g_pollset); in main()
208 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
210 grpc_pollset_shutdown(g_pollset, &destroyed); in main()
214 gpr_free(g_pollset); in main()
Dfd_posix_test.cc50 static grpc_pollset* g_pollset; variable
179 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr))); in listen_shutdown_cb()
208 grpc_pollset_add_fd(g_pollset, se->em_fd); in listen_cb()
237 grpc_pollset_add_fd(g_pollset, sv->em_fd); in server_start()
254 grpc_pollset_work(g_pollset, &worker, GRPC_MILLIS_INF_FUTURE))); in server_wait_and_shutdown()
295 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr))); in client_session_shutdown_cb()
357 grpc_pollset_add_fd(g_pollset, cl->em_fd); in client_start()
370 grpc_pollset_work(g_pollset, &worker, GRPC_MILLIS_INF_FUTURE))); in client_wait_and_shutdown()
413 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr))); in first_read_callback()
424 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr))); in second_read_callback()
[all …]
Dtcp_client_uv_test.cc41 static grpc_pollset* g_pollset; variable
53 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, NULL))); in finish_connection()
120 grpc_pollset_work(g_pollset, &worker, in test_succeeds()
172 grpc_pollset_work(g_pollset, &worker, polling_deadline))); in test_fails()
192 g_pollset = static_cast<grpc_pollset*>(gpr_malloc(grpc_pollset_size())); in main()
193 grpc_pollset_init(g_pollset, &g_mu); in main()
198 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
200 grpc_pollset_shutdown(g_pollset, &destroyed); in main()
203 gpr_free(g_pollset); in main()
Dtcp_posix_test.cc47 static grpc_pollset* g_pollset; variable
191 GRPC_LOG_IF_ERROR("kick", grpc_pollset_kick(g_pollset, nullptr))); in read_cb()
221 grpc_endpoint_add_to_pollset(ep, g_pollset); in read_test()
238 "pollset_work", grpc_pollset_work(g_pollset, &worker, deadline))); in read_test()
272 grpc_endpoint_add_to_pollset(ep, g_pollset); in large_read_test()
289 "pollset_work", grpc_pollset_work(g_pollset, &worker, deadline))); in large_read_test()
338 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr))); in write_done()
359 grpc_pollset_work(g_pollset, &worker, in drain_socket_blocking()
433 grpc_endpoint_add_to_pollset(ep, g_pollset); in write_test()
462 "pollset_work", grpc_pollset_work(g_pollset, &worker, deadline))); in write_test()
[all …]
Dtcp_server_uv_test.cc45 static grpc_pollset* g_pollset; variable
113 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, NULL))); in on_connect()
201 grpc_pollset_work(g_pollset, &worker, in tcp_connect()
249 grpc_tcp_server_start(s, &g_pollset, 1, on_connect, NULL); in test_connect()
290 g_pollset = static_cast<grpc_pollset*>(gpr_malloc(grpc_pollset_size())); in main()
291 grpc_pollset_init(g_pollset, &g_mu); in main()
300 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
302 grpc_pollset_shutdown(g_pollset, &destroyed); in main()
305 gpr_free(g_pollset); in main()
Dendpoint_tests.cc50 static grpc_pollset* g_pollset; variable
129 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr)); in read_and_write_test_read_handler()
163 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr)); in read_and_write_test_write_handler()
236 "pollset_work", grpc_pollset_work(g_pollset, &worker, deadline))); in read_and_write_test()
251 GPR_ASSERT(GRPC_LOG_IF_ERROR("kick", grpc_pollset_kick(g_pollset, nullptr))); in inc_on_failure()
264 "pollset_work", grpc_pollset_work(g_pollset, &worker, deadline))); in wait_for_fail_count()
282 grpc_endpoint_add_to_pollset(f.client_ep, g_pollset); in multiple_shutdown_test()
313 g_pollset = pollset; in grpc_endpoint_tests()
322 g_pollset = nullptr; in grpc_endpoint_tests()
Dtcp_server_posix_test.cc51 static grpc_pollset* g_pollset; variable
161 GRPC_LOG_IF_ERROR("pollset_kick", grpc_pollset_kick(g_pollset, nullptr))); in on_connect()
253 if ((err = grpc_pollset_work(g_pollset, &worker, deadline)) != in tcp_connect()
349 grpc_tcp_server_start(s, &g_pollset, 1, on_connect, nullptr); in test_connect()
444 g_pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in main()
445 grpc_pollset_init(g_pollset, &g_mu); in main()
493 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
495 grpc_pollset_shutdown(g_pollset, &destroyed); in main()
499 gpr_free(g_pollset); in main()
/external/grpc-grpc/test/core/security/
Dsecure_endpoint_test.cc36 static grpc_pollset* g_pollset; variable
63 grpc_endpoint_add_to_pollset(tcp.client, g_pollset); in secure_endpoint_create_fixture_tcp_socketpair()
64 grpc_endpoint_add_to_pollset(tcp.server, g_pollset); in secure_endpoint_create_fixture_tcp_socketpair()
216 g_pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in main()
217 grpc_pollset_init(g_pollset, &g_mu); in main()
218 grpc_endpoint_tests(configs[0], g_pollset, g_mu); in main()
219 grpc_endpoint_tests(configs[1], g_pollset, g_mu); in main()
222 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, g_pollset, in main()
224 grpc_pollset_shutdown(g_pollset, &destroyed); in main()
229 gpr_free(g_pollset); in main()