| /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/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 | 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.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 | 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 | ev_poll_posix.cc | 248 grpc_pollset** pollsets; member
1218 grpc_pollset* pollset = pollset_set->pollsets[i];
1231 gpr_free(pollset_set->pollsets);
1247 pollset_set->pollsets = static_cast<grpc_pollset**>(gpr_realloc(
1248 pollset_set->pollsets,
1249 pollset_set->pollset_capacity * sizeof(*pollset_set->pollsets)));
1251 pollset_set->pollsets[pollset_set->pollset_count++] = pollset;
1269 if (pollset_set->pollsets[i] == pollset) {
1271 GPR_SWAP(grpc_pollset*, pollset_set->pollsets[i],
1272 pollset_set->pollsets[pollset_set->pollset_count]);
[all …]
|
| 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
|
| D | tcp_server_custom.cc | 414 static void tcp_server_start(grpc_tcp_server* server, grpc_pollset** pollsets, in tcp_server_start() argument
418 (void)pollsets; in tcp_server_start()
|
| /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/grpc-grpc/src/core/ext/transport/chttp2/server/ |
| D | chttp2_server.cc | 208 grpc_pollset** pollsets, in server_start_listener() argument
214 grpc_tcp_server_start(state->tcp_server, pollsets, pollset_count, on_accept, in server_start_listener()
|