| /third_party/grpc/src/core/lib/iomgr/ |
| D | pollset_windows.cc | 33 #define GRPC_POLLSET_KICK_BROADCAST ((grpc_pollset_worker*)1)
38 static grpc_pollset_worker* g_active_poller;
39 static grpc_pollset_worker g_global_root_worker;
51 static void remove_worker(grpc_pollset_worker* worker, in remove_worker()
58 static int has_workers(grpc_pollset_worker* root, in has_workers()
63 static grpc_pollset_worker* pop_front_worker( in pop_front_worker()
64 grpc_pollset_worker* root, grpc_pollset_worker_link_type type) { in pop_front_worker()
66 grpc_pollset_worker* w = root->links[type].next; in pop_front_worker()
74 static void push_front_worker(grpc_pollset_worker* root, in push_front_worker()
76 grpc_pollset_worker* worker) { in push_front_worker()
[all …]
|
| D | pollset.h | 39 typedef struct grpc_pollset_worker grpc_pollset_worker; typedef
47 grpc_error* (*work)(grpc_pollset* pollset, grpc_pollset_worker** worker,
50 grpc_pollset_worker* specific_worker);
90 grpc_pollset_worker** worker,
96 grpc_pollset_worker* specific_worker)
|
| D | pollset_windows.h | 43 struct grpc_pollset_worker* next;
44 struct grpc_pollset_worker* prev;
50 typedef struct grpc_pollset_worker { struct
55 } grpc_pollset_worker; typedef
61 grpc_pollset_worker root_worker;
|
| D | ev_epoll1_linux.cc | 183 struct grpc_pollset_worker { struct
187 grpc_pollset_worker* next; argument
188 grpc_pollset_worker* prev; argument
215 grpc_pollset_worker* root_worker;
477 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert()
495 grpc_pollset_worker* worker) { in worker_remove()
596 grpc_pollset_worker* worker = pollset->root_worker; in pollset_kick_all()
749 static bool begin_worker(grpc_pollset* pollset, grpc_pollset_worker* worker, in begin_worker()
750 grpc_pollset_worker** worker_hdl, in begin_worker()
884 grpc_pollset_worker* inspect_worker = inspect->root_worker; in check_neighborhood_for_available_poller()
[all …]
|
| D | ev_epollex_linux.cc | 108 grpc_pollset_worker* root_worker;
264 grpc_pollset_worker* next;
265 grpc_pollset_worker* prev;
269 struct grpc_pollset_worker { struct
291 grpc_pollset_worker* root_worker; argument
684 static grpc_error* kick_one_worker(grpc_pollset_worker* specific_worker) {
729 grpc_pollset_worker* specific_worker) {
784 grpc_pollset_worker* w = pollset->root_worker;
969 static bool worker_insert(grpc_pollset_worker** root_worker,
970 grpc_pollset_worker* worker, pwlinks link) {
[all …]
|
| D | ev_poll_posix.cc | 52 #define GRPC_POLLSET_KICK_BROADCAST ((grpc_pollset_worker*)1)
61 grpc_pollset_worker* worker;
150 grpc_pollset_worker* worker, uint32_t read_mask,
189 struct grpc_pollset_worker { struct
193 struct grpc_pollset_worker* next; argument
194 struct grpc_pollset_worker* prev; argument
199 grpc_pollset_worker root_worker;
234 grpc_pollset_worker* specific_worker,
601 grpc_pollset_worker* worker, uint32_t read_mask,
711 static void remove_worker(grpc_pollset* /*p*/, grpc_pollset_worker* worker) {
[all …]
|
| D | pollset.cc | 46 grpc_pollset_worker** worker, in grpc_pollset_work()
52 grpc_pollset_worker* specific_worker) { in grpc_pollset_kick()
|
| D | ev_apple.cc | 53 #define GRPC_POLLSET_KICK_BROADCAST ((grpc_pollset_worker*)1)
223 grpc_pollset_worker** worker, in pollset_work()
231 *worker = reinterpret_cast<grpc_pollset_worker*>(&actual_worker); in pollset_work()
276 grpc_pollset_worker* specific_worker) { in pollset_kick()
|
| D | pollset_custom.cc | 67 grpc_pollset_worker** /*worker_hdl*/, in pollset_work() argument
91 grpc_pollset_worker* /*specific_worker*/) { in pollset_kick() argument
|
| D | ev_posix.h | 68 grpc_pollset_worker** worker,
71 grpc_pollset_worker* specific_worker);
|
| D | ev_posix.cc | 319 grpc_pollset_worker** worker, in pollset_work()
330 grpc_pollset_worker* specific_worker) { in pollset_kick()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 65 grpc_pollset_worker** worker;
74 grpc_pollset_worker* specific_worker);
75 grpc_error* (*work)(grpc_pollset* pollset, grpc_pollset_worker** worker,
107 grpc_pollset_worker** worker, in non_polling_poller_work()
117 if (worker != nullptr) *worker = reinterpret_cast<grpc_pollset_worker*>(&w); in non_polling_poller_work()
149 grpc_pollset_worker* specific_worker) { in non_polling_poller_kick()
152 specific_worker = reinterpret_cast<grpc_pollset_worker*>(p->root); in non_polling_poller_kick()
815 grpc_pollset_worker* pluck_worker = nullptr;
1139 grpc_pollset_worker** worker) {
1151 grpc_pollset_worker** worker) {
[all …]
|
| /third_party/grpc/test/core/iomgr/ |
| D | tcp_posix_test.cc | 237 grpc_pollset_worker* worker = nullptr; in read_test()
288 grpc_pollset_worker* worker = nullptr; in large_read_test()
356 grpc_pollset_worker* worker = nullptr; in drain_socket_blocking()
456 grpc_pollset_worker* worker = nullptr; in write_test()
527 grpc_pollset_worker* worker = nullptr; in release_fd_test()
544 grpc_pollset_worker* worker = nullptr; in release_fd_test()
|
| D | fd_posix_test.cc | 251 grpc_pollset_worker* worker = nullptr; in server_wait_and_shutdown()
366 grpc_pollset_worker* worker = nullptr; in client_wait_and_shutdown()
469 grpc_pollset_worker* worker = nullptr; in test_grpc_fd_change()
493 grpc_pollset_worker* worker = nullptr; in test_grpc_fd_change()
|
| D | tcp_client_posix_test.cc | 125 grpc_pollset_worker* worker = nullptr; in test_succeeds()
166 grpc_pollset_worker* worker = nullptr; in test_fails()
|
| D | tcp_client_uv_test.cc | 117 grpc_pollset_worker* worker = NULL; in test_succeeds()
161 grpc_pollset_worker* worker = NULL; in test_fails()
|
| D | endpoint_tests.cc | 260 grpc_pollset_worker* worker = nullptr; in read_and_write_test()
289 grpc_pollset_worker* worker = nullptr; in wait_for_fail_count()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_cq_multiple_threads.cc | 60 grpc_pollset_worker* /*worker*/) { in pollset_kick() argument
72 grpc_pollset_worker** /*worker*/, in pollset_work() argument
|
| /third_party/grpc/test/core/http/ |
| D | httpcli_test.cc | 89 grpc_pollset_worker* worker = nullptr; in test_get()
128 grpc_pollset_worker* worker = nullptr; in test_post()
|
| D | httpscli_test.cc | 93 grpc_pollset_worker* worker = nullptr; in test_get()
133 grpc_pollset_worker* worker = nullptr; in test_post()
|
| /third_party/grpc/test/core/util/ |
| D | port_server_client.cc | 99 grpc_pollset_worker* worker = nullptr; in grpc_free_port_using_server()
233 grpc_pollset_worker* worker = nullptr; in grpc_pick_port_using_server()
|
| /third_party/grpc/test/core/security/ |
| D | oauth2_utils.cc | 100 grpc_pollset_worker* worker = nullptr; in grpc_test_fetch_oauth2_token_with_credentials()
|
| D | verify_jwt.cc | 101 grpc_pollset_worker* worker = nullptr; in main()
|
| D | print_google_default_creds_token.cc | 110 grpc_pollset_worker* worker = nullptr; in main()
|
| /third_party/grpc/test/cpp/naming/ |
| D | cancel_ares_query_test.cc | 125 grpc_pollset_worker* worker = nullptr; in PollPollsetUntilRequestDone()
218 grpc_pollset_worker* worker = nullptr; in MaybePollArbitraryPollsetTwice()
|