| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | pollset.h | 38 typedef struct grpc_pollset grpc_pollset; typedef
44 void (*init)(grpc_pollset* pollset, gpr_mu** mu);
45 void (*shutdown)(grpc_pollset* pollset, grpc_closure* closure);
46 void (*destroy)(grpc_pollset* pollset);
47 grpc_error* (*work)(grpc_pollset* pollset, grpc_pollset_worker** worker,
49 grpc_error* (*kick)(grpc_pollset* pollset,
61 void grpc_pollset_init(grpc_pollset* pollset, gpr_mu** mu);
64 void grpc_pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure);
65 void grpc_pollset_destroy(grpc_pollset* pollset);
89 grpc_error* grpc_pollset_work(grpc_pollset* pollset,
[all …]
|
| D | ev_posix.h | 59 void (*pollset_init)(grpc_pollset* pollset, gpr_mu** mu);
60 void (*pollset_shutdown)(grpc_pollset* pollset, grpc_closure* closure);
61 void (*pollset_destroy)(grpc_pollset* pollset);
62 grpc_error* (*pollset_work)(grpc_pollset* pollset,
65 grpc_error* (*pollset_kick)(grpc_pollset* pollset,
67 void (*pollset_add_fd)(grpc_pollset* pollset, struct grpc_fd* fd);
72 grpc_pollset* pollset);
74 grpc_pollset* pollset);
170 void grpc_pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd);
|
| D | pollset_custom.cc | 40 struct grpc_pollset { struct
44 static size_t pollset_size() { return sizeof(grpc_pollset); } in pollset_size() argument
50 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
56 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
61 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
66 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work()
90 static grpc_error* pollset_kick(grpc_pollset* pollset, in pollset_kick()
|
| D | pollset_windows.h | 47 struct grpc_pollset;
48 typedef struct grpc_pollset grpc_pollset; typedef
53 struct grpc_pollset* pollset;
57 struct grpc_pollset { struct
|
| D | pollset.cc | 33 void grpc_pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in grpc_pollset_init()
37 void grpc_pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in grpc_pollset_shutdown()
41 void grpc_pollset_destroy(grpc_pollset* pollset) { in grpc_pollset_destroy()
45 grpc_error* grpc_pollset_work(grpc_pollset* pollset, in grpc_pollset_work()
51 grpc_error* grpc_pollset_kick(grpc_pollset* pollset, in grpc_pollset_kick()
|
| D | pollset_set.h | 36 void (*add_pollset)(grpc_pollset_set* pollset_set, grpc_pollset* pollset);
37 void (*del_pollset)(grpc_pollset_set* pollset_set, grpc_pollset* pollset);
47 grpc_pollset* pollset);
49 grpc_pollset* pollset);
|
| D | ev_epoll1_linux.cc | 197 grpc_pollset* active_root;
201 struct grpc_pollset { struct
218 grpc_pollset* next; argument
219 grpc_pollset* prev; argument
458 static bool worker_insert(grpc_pollset* pollset, grpc_pollset_worker* worker) { in worker_insert()
475 static worker_remove_result worker_remove(grpc_pollset* pollset, in worker_remove()
531 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
545 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
573 static grpc_error* pollset_kick_all(grpc_pollset* pollset) { in pollset_kick_all()
607 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) { in pollset_maybe_finish_shutdown()
[all …]
|
| D | polling_entity.h | 39 grpc_pollset* pollset;
48 grpc_pollset* pollset);
51 grpc_pollset* grpc_polling_entity_pollset(grpc_polling_entity* pollent);
|
| D | pollset_windows.cc | 83 static size_t pollset_size(void) { return sizeof(grpc_pollset); } in pollset_size()
90 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
97 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
107 static void pollset_destroy(grpc_pollset* pollset) {} in pollset_destroy()
109 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work()
185 static grpc_error* pollset_kick(grpc_pollset* p, in pollset_kick()
|
| D | ev_posix.cc | 298 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) { in pollset_init()
303 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { in pollset_shutdown()
308 static void pollset_destroy(grpc_pollset* pollset) { in pollset_destroy()
313 static grpc_error* pollset_work(grpc_pollset* pollset, in pollset_work()
324 static grpc_error* pollset_kick(grpc_pollset* pollset, in pollset_kick()
330 void grpc_pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd) { in grpc_pollset_add_fd()
357 grpc_pollset* pollset) { in pollset_set_add_pollset()
364 grpc_pollset* pollset) { in pollset_set_del_pollset()
|
| D | ev_poll_posix.cc | 58 grpc_pollset* pollset;
147 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset,
195 struct grpc_pollset { struct
212 static void pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd); argument
231 static grpc_error* pollset_kick_ext(grpc_pollset* p,
237 static bool pollset_has_workers(grpc_pollset* pollset);
248 grpc_pollset** pollsets;
639 static uint32_t fd_begin_poll(grpc_fd* fd, grpc_pollset* pollset,
750 static void remove_worker(grpc_pollset* p, grpc_pollset_worker* worker) {
755 static bool pollset_has_workers(grpc_pollset* p) {
[all …]
|
| D | ev_epollex_linux.cc | 252 grpc_pollset* pollset;
258 struct grpc_pollset { struct
280 grpc_pollset** pollsets; argument
716 static void pollset_maybe_finish_shutdown(grpc_pollset* pollset) {
779 static grpc_error* pollset_kick(grpc_pollset* pollset,
830 static grpc_error* pollset_kick_all(grpc_pollset* pollset) {
845 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) {
906 static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) {
914 static grpc_error* pollable_process_events(grpc_pollset* pollset,
978 static void pollset_destroy(grpc_pollset* pollset) {
[all …]
|
| D | tcp_server.h | 45 grpc_pollset* accepting_pollset,
52 void (*start)(grpc_tcp_server* server, grpc_pollset** pollsets,
74 void grpc_tcp_server_start(grpc_tcp_server* server, grpc_pollset** pollsets,
|
| D | ev_epollsig_linux.cc | 224 struct grpc_pollset { struct
1005 static int pollset_has_workers(grpc_pollset* p) {
1009 static void remove_worker(grpc_pollset* p, grpc_pollset_worker* worker) {
1014 static grpc_pollset_worker* pop_front_worker(grpc_pollset* p) {
1024 static void push_back_worker(grpc_pollset* p, grpc_pollset_worker* worker) {
1030 static void push_front_worker(grpc_pollset* p, grpc_pollset_worker* worker) {
1037 static grpc_error* pollset_kick(grpc_pollset* p,
1087 static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) {
1114 static void pollset_release_polling_island(grpc_pollset* ps,
1122 static void finish_shutdown_locked(grpc_pollset* pollset) {
[all …]
|
| D | pollset_set_windows.cc | 35 grpc_pollset* pollset) {} in pollset_set_add_pollset()
38 grpc_pollset* pollset) {} in pollset_set_del_pollset()
|
| D | pollset_set_custom.cc | 32 grpc_pollset* pollset) {} in pollset_set_add_pollset()
35 grpc_pollset* pollset) {} in pollset_set_del_pollset()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_cq_multiple_threads.cc | 33 struct grpc_pollset { struct
47 static void pollset_shutdown(grpc_pollset* ps, grpc_closure* closure) { in pollset_shutdown() argument
51 static void pollset_init(grpc_pollset* ps, gpr_mu** mu) { in pollset_init()
56 static void pollset_destroy(grpc_pollset* ps) { gpr_mu_destroy(&ps->mu); } in pollset_destroy()
58 static grpc_error* pollset_kick(grpc_pollset* p, grpc_pollset_worker* worker) { in pollset_kick()
69 static grpc_error* pollset_work(grpc_pollset* ps, grpc_pollset_worker** worker, in pollset_work()
91 g_vtable.pollset_size = sizeof(grpc_pollset); in init_engine_vtable()
|
| D | bm_pollset.cc | 46 grpc_pollset_destroy(static_cast<grpc_pollset*>(ps)); in shutdown_ps()
52 grpc_pollset* ps = static_cast<grpc_pollset*>(gpr_malloc(ps_sz)); in BM_CreateDestroyPollset()
115 grpc_pollset* ps = static_cast<grpc_pollset*>(gpr_zalloc(ps_sz)); in BM_PollEmptyPollset()
137 grpc_pollset* ps = static_cast<grpc_pollset*>(gpr_zalloc(ps_sz)); in BM_PollAddFd()
219 grpc_pollset* ps = static_cast<grpc_pollset*>(gpr_zalloc(ps_sz)); in BM_SingleThreadPollOneFd()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.h | 39 grpc_pollset** pollsets,
47 grpc_pollset* accepting_pollset,
59 void grpc_server_get_pollsets(grpc_server* server, grpc_pollset*** pollsets,
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | endpoint_pair_test.cc | 30 static grpc_pollset* g_pollset;
58 grpc_pollset_destroy(static_cast<grpc_pollset*>(p)); in destroy_pollset()
67 g_pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in main()
|
| D | ev_epollex_linux_test.cc | 31 grpc_pollset_destroy(static_cast<grpc_pollset*>(ps)); in pollset_destroy()
43 grpc_pollset* ps; in test_pollable_owner_fd()
60 ps = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in test_pollable_owner_fd()
|
| D | ev_epollsig_linux_test.cc | 39 grpc_pollset* pollset;
94 static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in test_pollset_init()
100 grpc_pollset_destroy(static_cast<grpc_pollset*>(p)); in destroy_pollset()
221 grpc_pollset* pollset;
258 shared.pollset = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in test_threading()
|
| /external/grpc-grpc/test/core/util/ |
| D | port_server_client.cc | 44 grpc_pollset* pollset = in destroy_pops_and_shutdown()
75 grpc_pollset* pollset = in grpc_free_port_using_server()
76 static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in grpc_free_port_using_server()
207 grpc_pollset* pollset = in grpc_pick_port_using_server()
208 static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in grpc_pick_port_using_server()
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 107 pollset_ = static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in Connect()
206 grpc_pollset* pollset = static_cast<grpc_pollset*>(arg); in PollsetDestroy()
214 grpc_pollset* pollset_;
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.cc | 44 grpc_pollset* pollset; // guarded by pollset_mu
134 static_cast<grpc_pollset*>(gpr_zalloc(grpc_pollset_size())); in g_poller_init_locked()
161 grpc_pollset* pollset = g_poller->pollset; in grpc_client_channel_start_backup_polling()
|