| /external/grpc-grpc/test/core/iomgr/ |
| D | pollset_set_test.cc | 67 static void init_test_pollsets(test_pollset* pollsets, const int num_pollsets) { in init_test_pollsets() argument
69 pollsets[i].ps = in init_test_pollsets()
71 grpc_pollset_init(pollsets[i].ps, &pollsets[i].mu); in init_test_pollsets()
79 static void cleanup_test_pollsets(test_pollset* pollsets, in cleanup_test_pollsets() argument
83 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, pollsets[i].ps, in cleanup_test_pollsets()
85 grpc_pollset_shutdown(pollsets[i].ps, &destroyed); in cleanup_test_pollsets()
88 gpr_free(pollsets[i].ps); in cleanup_test_pollsets()
89 pollsets[i].ps = nullptr; in cleanup_test_pollsets()
206 test_pollset pollsets[3]; in pollset_set_test_basic() local
209 const int num_ps = GPR_ARRAY_SIZE(pollsets); in pollset_set_test_basic()
[all …]
|
| D | ev_epollsig_linux_test.cc | 90 static void test_pollset_init(test_pollset* pollsets, int num_pollsets) { in test_pollset_init() argument
93 pollsets[i].pollset = in test_pollset_init()
95 grpc_pollset_init(pollsets[i].pollset, &pollsets[i].mu); in test_pollset_init()
103 static void test_pollset_cleanup(test_pollset* pollsets, int num_pollsets) { in test_pollset_cleanup() argument
108 GRPC_CLOSURE_INIT(&destroyed, destroy_pollset, pollsets[i].pollset, in test_pollset_cleanup()
110 grpc_pollset_shutdown(pollsets[i].pollset, &destroyed); in test_pollset_cleanup()
113 gpr_free(pollsets[i].pollset); in test_pollset_cleanup()
135 test_pollset pollsets[NUM_POLLSETS]; in test_add_fd_to_pollset() local
140 test_pollset_init(pollsets, NUM_POLLSETS); in test_add_fd_to_pollset()
169 grpc_pollset_add_fd(pollsets[0].pollset, tfds[i].fd); in test_add_fd_to_pollset()
[all …]
|
| D | udp_server_test.cc | 303 grpc_pollset* pollsets[1]; in test_receive() local
323 pollsets[0] = g_pollset; in test_receive()
324 grpc_udp_server_start(s, pollsets, 1, nullptr); in test_receive()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_server_posix.cc | 250 read_notifier_pollset = (*(sp->server->pollsets)) in on_read()
253 sp->server->pollsets->size()]; in on_read()
491 const std::vector<grpc_pollset*>* pollsets, in tcp_server_start() argument
502 s->pollsets = pollsets; in tcp_server_start()
506 pollsets->size() > 1) { in tcp_server_start()
508 "clone_port", clone_port(sp, (unsigned)(pollsets->size() - 1)))); in tcp_server_start()
509 for (i = 0; i < pollsets->size(); i++) { in tcp_server_start()
510 grpc_pollset_add_fd((*pollsets)[i], sp->emfd); in tcp_server_start()
518 for (i = 0; i < pollsets->size(); i++) { in tcp_server_start()
519 grpc_pollset_add_fd((*pollsets)[i], sp->emfd); in tcp_server_start()
[all …]
|
| D | ev_epollex_linux.cc | 306 grpc_pollset** pollsets; member
1338 gpr_mu_lock(&pss->pollsets[i]->mu);
1339 if (0 == --pss->pollsets[i]->containing_pollset_set_count) {
1340 pollset_maybe_finish_shutdown(pss->pollsets[i]);
1342 gpr_mu_unlock(&pss->pollsets[i]->mu);
1347 gpr_free(pss->pollsets);
1361 append_error(&error, pollable_add_fd(pss->pollsets[i]->active_pollable, fd),
1405 if (pss->pollsets[i] == ps) {
1411 pss->pollsets[i] = pss->pollsets[i + 1];
1425 grpc_pollset** pollsets, argument
[all …]
|
| D | udp_server.cc | 81 void StartListening(const std::vector<grpc_pollset*>* pollsets,
191 const std::vector<grpc_pollset*>* pollsets; member
704 const std::vector<grpc_pollset*>* pollsets, in grpc_udp_server_start() argument
709 udp_server->pollsets = pollsets; in grpc_udp_server_start()
713 listener.StartListening(pollsets, udp_server->handler_factory); in grpc_udp_server_start()
719 void GrpcUdpListener::StartListening(const std::vector<grpc_pollset*>* pollsets, in StartListening() argument
724 for (grpc_pollset* pollset : *pollsets) { in StartListening()
|
| D | tcp_server.cc | 32 const std::vector<grpc_pollset*>* pollsets, in grpc_tcp_server_start() argument
34 grpc_tcp_server_impl->start(server, pollsets, on_accept_cb, cb_arg); in grpc_tcp_server_start()
|
| D | tcp_server.h | 70 const std::vector<grpc_pollset*>* pollsets,
93 const std::vector<grpc_pollset*>* pollsets,
|
| D | ev_poll_posix.cc | 250 grpc_pollset** pollsets; member
1182 grpc_pollset* pollset = pollset_set->pollsets[i];
1195 gpr_free(pollset_set->pollsets);
1211 pollset_set->pollsets = static_cast<grpc_pollset**>(gpr_realloc(
1212 pollset_set->pollsets,
1213 pollset_set->pollset_capacity * sizeof(*pollset_set->pollsets)));
1215 pollset_set->pollsets[pollset_set->pollset_count++] = pollset;
1233 if (pollset_set->pollsets[i] == pollset) {
1235 GPR_SWAP(grpc_pollset*, pollset_set->pollsets[i],
1236 pollset_set->pollsets[pollset_set->pollset_count]);
[all …]
|
| D | udp_server.h | 78 const std::vector<grpc_pollset*>* pollsets,
|
| D | tcp_server_utils_posix.h | 87 const std::vector<grpc_pollset*>* pollsets; member
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/server/insecure/ |
| D | server_chttp2_posix.cc | 56 grpc_pollset** pollsets; in grpc_server_add_insecure_channel_from_fd() local
58 grpc_server_get_pollsets(server, &pollsets, &num_pollsets); in grpc_server_add_insecure_channel_from_fd()
61 grpc_endpoint_add_to_pollset(server_endpoint, pollsets[i]); in grpc_server_add_insecure_channel_from_fd()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_epollex_linux.cc | 280 grpc_pollset** pollsets; member
1370 gpr_mu_lock(&pss->pollsets[i]->mu);
1371 if (0 == --pss->pollsets[i]->containing_pollset_set_count) {
1372 pollset_maybe_finish_shutdown(pss->pollsets[i]);
1374 gpr_mu_unlock(&pss->pollsets[i]->mu);
1379 gpr_free(pss->pollsets);
1393 append_error(&error, pollable_add_fd(pss->pollsets[i]->active_pollable, fd),
1437 if (pss->pollsets[i] == ps) {
1443 pss->pollsets[i] = pss->pollsets[i + 1];
1457 grpc_pollset** pollsets, argument
[all …]
|
| D | tcp_server.cc | 31 void grpc_tcp_server_start(grpc_tcp_server* server, grpc_pollset** pollsets, in grpc_tcp_server_start() argument
34 grpc_tcp_server_impl->start(server, pollsets, pollset_count, on_accept_cb, in grpc_tcp_server_start()
|
| D | udp_server.cc | 76 void StartListening(grpc_pollset** pollsets, size_t pollset_count,
189 grpc_pollset** pollsets; member
702 void grpc_udp_server_start(grpc_udp_server* s, grpc_pollset** pollsets, in grpc_udp_server_start() argument
707 s->pollsets = pollsets; in grpc_udp_server_start()
711 s->listeners[i].StartListening(pollsets, pollset_count, s->handler_factory); in grpc_udp_server_start()
717 void GrpcUdpListener::StartListening(grpc_pollset** pollsets, in StartListening() argument
724 grpc_pollset_add_fd(pollsets[i], emfd_); in StartListening()
|
| D | tcp_server.h | 52 void (*start)(grpc_tcp_server* server, grpc_pollset** pollsets,
74 void grpc_tcp_server_start(grpc_tcp_server* server, grpc_pollset** pollsets,
|
| D | tcp_server_posix.cc | 232 sp->server->pollsets[static_cast<size_t>(gpr_atm_no_barrier_fetch_add( in on_read()
473 static void tcp_server_start(grpc_tcp_server* s, grpc_pollset** pollsets, in tcp_server_start() argument
485 s->pollsets = pollsets; in tcp_server_start()
494 grpc_pollset_add_fd(pollsets[i], sp->emfd); in tcp_server_start()
503 grpc_pollset_add_fd(pollsets[i], sp->emfd); in tcp_server_start()
|
| D | udp_server.h | 81 void grpc_udp_server_start(grpc_udp_server* udp_server, grpc_pollset** pollsets,
|
| D | tcp_server_utils_posix.h | 86 grpc_pollset** pollsets; member
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.h | 39 grpc_pollset** pollsets,
59 void grpc_server_get_pollsets(grpc_server* server, grpc_pollset*** pollsets,
|
| D | server.cc | 53 void (*start)(grpc_server* server, void* arg, grpc_pollset** pollsets,
188 grpc_pollset** pollsets; member
393 gpr_free(server->pollsets); in server_delete()
1047 l->start(server, l->arg, server->pollsets, server->pollset_count); in start_listeners()
1066 server->pollsets = static_cast<grpc_pollset**>( in grpc_server_start()
1070 server->pollsets[server->pollset_count++] = in grpc_server_start()
1087 void grpc_server_get_pollsets(grpc_server* server, grpc_pollset*** pollsets, in grpc_server_get_pollsets() argument
1090 *pollsets = server->pollsets; in grpc_server_get_pollsets()
1319 grpc_pollset** pollsets, in grpc_server_add_listener() argument
|
| /external/grpc-grpc/doc/ |
| D | epoll-polling-engine.md | 12 The document talks about the proposed changes to `epoll`-based implementation of pollsets in gRPC. …
36 …pollsets` and that each `pollset` might have multiple poller threads, it means that whenever an `f…
45 …l the server completion queues' pollsets. (Currently we do not do any sharding of the listening fd…
47 This means that for every incoming new channel, all the threads waiting on all the pollsets are wok…
51 …ccept()` on the new incoming channel) is added to all the server completion queues' pollsets [^5]).
54 … especially on the client side where an fd can end up being on multiple pollsets which would cause…
76 * An `fd` may belong to multiple `pollsets` but belongs to exactly one `polling_island`
119 …he last scenario is only in case of `poll`-based (not `epoll`-based) implementation of `pollsets`).
|
| /external/grpc-grpc/test/cpp/performance/ |
| D | writes_per_rpc_test.cc | 94 grpc_pollset** pollsets; in EndpointPairFixture() local
96 grpc_server_get_pollsets(server_->c_server(), &pollsets, &num_pollsets); in EndpointPairFixture()
99 grpc_endpoint_add_to_pollset(endpoints.server, pollsets[i]); in EndpointPairFixture()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_fixtures.h | 194 grpc_pollset** pollsets; in EndpointPairFixture() local
196 grpc_server_get_pollsets(server_->c_server(), &pollsets, &num_pollsets); in EndpointPairFixture()
199 grpc_endpoint_add_to_pollset(endpoints.server, pollsets[i]); in EndpointPairFixture()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/server/insecure/ |
| D | server_chttp2_posix.cc | 57 for (grpc_pollset* pollset : core_server->pollsets()) { in grpc_server_add_insecure_channel_from_fd()
|