Home
last modified time | relevance | path

Searched refs:pollsets (Results 1 – 13 of 13) sorted by relevance

/third_party/grpc/src/core/lib/iomgr/
Dtcp_server_posix.cc250 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 …]
Dev_epollex_linux.cc306 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 …]
Dudp_server.cc81 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()
Dtcp_server.cc32 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()
Dtcp_server.h70 const std::vector<grpc_pollset*>* pollsets,
93 const std::vector<grpc_pollset*>* pollsets,
Dev_poll_posix.cc250 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 …]
Dudp_server.h78 const std::vector<grpc_pollset*>* pollsets,
Dtcp_server_utils_posix.h87 const std::vector<grpc_pollset*>* pollsets; member
/third_party/grpc/doc/core/
Depoll-polling-engine.md12 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`).
Dgrpc-polling-engines.md64 …ause calling `grpc_fd_orphan()` will effectively remove the fd from all the pollsets it’s a part of
133 …- If multiple pollsets are pointing to the same `Pollable`, then the `pollable` MUST be either emp…
141 …- With these new types of `Pollable`s, all pollsets (corresponding to the new per-call completion …
/third_party/grpc/src/core/ext/transport/chttp2/server/insecure/
Dserver_chttp2_posix.cc57 for (grpc_pollset* pollset : core_server->pollsets()) { in grpc_server_add_insecure_channel_from_fd()
/third_party/grpc/src/core/lib/surface/
Dserver.h79 const std::vector<grpc_pollset*>* pollsets) = 0;
104 const std::vector<grpc_pollset*>& pollsets() const { return pollsets_; } in pollsets() function
/third_party/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc79 const std::vector<grpc_pollset*>* pollsets) override;
440 grpc_tcp_server_start(tcp_server_, &server_->pollsets(), OnAccept, this); in StartListening()