Home
last modified time | relevance | path

Searched defs:grpc_pollset (Results 1 – 24 of 24) sorted by relevance

/third_party/grpc/src/core/lib/iomgr/
Dpollset_windows.h48 typedef struct grpc_pollset grpc_pollset; typedef
57 struct grpc_pollset { struct
61 grpc_pollset_worker root_worker; argument
65 void grpc_pollset_global_init(void); argument
Dpollset_custom.cc40 struct grpc_pollset { struct
44 static size_t pollset_size() { return sizeof(grpc_pollset); } in pollset_size() argument
56 static void pollset_shutdown(grpc_pollset* /*pollset*/, grpc_closure* closure) { in pollset_shutdown() argument
90 static grpc_error* pollset_kick(grpc_pollset* /*pollset*/, in pollset_kick() argument
Dev_epoll1_linux.cc211 struct grpc_pollset { struct
215 grpc_pollset_worker* root_worker; argument
228 grpc_pollset* next; argument
229 grpc_pollset* prev; argument
666 static grpc_error* process_epoll_events(grpc_pollset* /*pollset*/) { in process_epoll_events() argument
1226 static void pollset_add_fd(grpc_pollset* /*pollset*/, grpc_fd* /*fd*/) {} in pollset_add_fd() argument
1243 grpc_pollset* /*ps*/) {} in pollset_set_add_pollset() argument
1246 grpc_pollset* /*ps*/) {} in pollset_set_del_pollset() argument
Dpollset_set_custom.cc32 grpc_pollset* /*pollset*/) {} in pollset_set_add_pollset() argument
35 grpc_pollset* /*pollset*/) {} in pollset_set_del_pollset() argument
Dev_poll_posix.cc197 struct grpc_pollset { struct
199 grpc_pollset_worker root_worker; argument
214 static void pollset_add_fd(grpc_pollset* pollset, struct grpc_fd* fd); argument
711 static void remove_worker(grpc_pollset* /*p*/, grpc_pollset_worker* worker) { argument
Dpollset.h38 typedef struct grpc_pollset grpc_pollset; typedef
Dev_epollex_linux.cc283 struct grpc_pollset { struct
291 grpc_pollset_worker* root_worker; argument
306 grpc_pollset** pollsets; argument
Dtcp_server_custom.cc427 const std::vector<grpc_pollset*>* /*pollsets*/, in tcp_server_start()
Dtcp_server_windows.cc524 const std::vector<grpc_pollset*>* /*pollsets*/, in tcp_server_start()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_cq_multiple_threads.cc34 struct grpc_pollset { struct
48 static void pollset_shutdown(grpc_pollset* /*ps*/, grpc_closure* closure) { in pollset_shutdown() argument
59 static grpc_error* pollset_kick(grpc_pollset* /*p*/, in pollset_kick() argument
Dbm_chttp2_transport.cc104 static void add_to_pollset(grpc_endpoint* /*ep*/, grpc_pollset* /*pollset*/) { in add_to_pollset() argument
Dbm_call_create.cc408 grpc_pollset* /*pollset*/) {} in SetPollset() argument
/third_party/grpc/doc/core/
Dgrpc-polling-engines.md59 #### grpc_pollset subsubsection
/third_party/grpc/test/core/util/
Dreconnect_server.cc59 grpc_pollset* /*accepting_pollset*/, in on_connect() argument
Dmock_endpoint.cc71 grpc_pollset* /*pollset*/) {} in me_add_to_pollset() argument
Dpassthru_endpoint.cc108 grpc_pollset* /*pollset*/) {} in me_add_to_pollset() argument
/third_party/grpc/test/core/surface/
Dconcurrent_connectivity_test.cc120 grpc_pollset* /*accepting_pollset*/, in on_connect() argument
/third_party/grpc/test/core/end2end/
Dbad_server_response_test.cc135 grpc_pollset* /*accepting_pollset*/, in on_connect() argument
/third_party/grpc/test/cpp/end2end/
Dport_sharing_end2end_test.cc157 void OnConnect(grpc_endpoint* tcp, grpc_pollset* /*accepting_pollset*/, in OnConnect() argument
/third_party/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc422 Server* /*server*/, const std::vector<grpc_pollset*>* /* pollsets */) { in Start()
/third_party/grpc/test/core/iomgr/
Dtcp_server_posix_test.cc145 grpc_pollset* /*pollset*/, in on_connect() argument
/third_party/grpc/test/core/end2end/fixtures/
Dhttp_proxy_fixture.cc555 grpc_pollset* /*accepting_pollset*/, in on_accept() argument
/third_party/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc1209 grpc_pollset* /*pollset*/) { in set_pollset() argument
/third_party/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc1430 grpc_pollset* /*pollset*/) {} in set_pollset_do_nothing() argument