| /third_party/grpc/doc/core/ |
| D | grpc-polling-engines.md | 1 # Polling Engines
6 ## Why do we need a 'polling engine' ?
8 Polling engine component was created for the following reasons:
18 ## Polling Engine Implementations in gRPC
19 There are multiple polling engine implementations depending on the OS and the OS version. Fortunat…
28 - One-off polling engines:
29 - NodeJS : `libuv` polling engine implementation (requires different compile `#define`s)
31 ## Polling Engine Interface
33 ### Opaque Structures exposed by the polling engine
34 … following are the **Opaque** structures exposed by Polling Engine interface (NOTE: Different poll…
[all …]
|
| D | grpc-cq.md | 7 …ecture and focuses mainly on the interaction between completion queue and the Polling engine layer.
18 - GRPC_CQ_NON_POLLING: Threads calling completion_queue_next/pluck do not do any polling
19 - GRPC_CQ_DEFAULT_POLLING: Threads calling completion_queue_next/pluck do polling
20 …- GRPC_CQ_NON_LISTENING: Functionally similar to default polling except for a boolean attribute t…
41 \\ 4. Call grpc_pollset_work(cq’s-pollset, deadline) to do polling
|
| D | epoll-polling-engine.md | 57 ## 4. Proposed changes to the current `epoll`-based polling implementation:
66 …polling island into which this one merged. See section 4.2 (case 2) for more details on this. Also…
86 …ollset` point to different `polling_islands`: In this case we _merge_ both the polling islands i.e:
93 …woke up executes the callbacks and finally has to 'kick' the appropriate polling thread interested…
95 In the current implementation, every polling thread also had a `event_fd` on which it was listening…
107 **>> **(**NOTE**: Or alternatively, we can implement a turnstile polling (i.e having only one threa…
119 …polling threads typically when the event for which the polling thread is waiting is already comple…
|
| D | grpc-client-server-polling-engine-usage.md | 1 # Polling Engine Usage on gRPC client and Server
6 This document talks about how polling engine is used in gRPC core (both on client and server code p…
21 …eans that the polling engine must be monitoring all these sub-channel `fd`s for writable events an…
|
| /third_party/boost/boost/graph/distributed/detail/ |
| D | queue.ipp | 26 const Buffer& buffer, bool polling)
30 polling(polling)
32 if (!polling)
43 bool polling)
48 polling(polling)
50 if (!polling)
60 const UnaryPredicate& pred, bool polling)
64 polling(polling)
66 if (!polling)
|
| /third_party/grpc/doc/ |
| D | environment_variables.md | 33 Declares which polling engines to try when starting gRPC.
36 Available polling engines include:
37 - epoll (linux-only) - a polling engine based around the epoll family of
39 - poll - a portable polling engine based around poll(), intended to be a
41 - legacy - the (deprecated) original polling engine for gRPC
103 Also traces epoll fd create()/close() calls in epollex polling engine
104 traces epoll-fd creation/close calls for epollex polling engine
106 - polling - traces the selected polling engine
107 - polling_api - traces the api calls to polling engine
154 there is no active polling thread. They help reconnect disconnected client
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | iomgr.h | 43 /* Returns true if polling engine runs in the background, false otherwise.
48 /* Returns true if polling engine is non-polling, false otherwise.
49 * Currently only 'none' is non-polling.
53 /* Mark the polling engine as non-polling. For internal use only.
54 * Currently only 'none' is non-polling.
|
| D | is_epollexclusive_available.cc | 36 /* This polling engine is only relevant on linux kernels supporting epoll() */
44 "epoll_create1 failed with error: %d. Not using epollex polling " in grpc_is_epollexclusive_available()
55 "eventfd failed with error: %d. Not using epollex polling " in grpc_is_epollexclusive_available()
76 "%d. Not using epollex polling engine.", in grpc_is_epollexclusive_available()
89 "epollex polling engine."); in grpc_is_epollexclusive_available()
102 "%d. Not using epollex polling engine.", in grpc_is_epollexclusive_available()
|
| D | pollset.h | 68 May involve invoking asynchronous callbacks, or actually polling file
93 /* Break one polling thread out of polling work for this pollset.
|
| D | ev_epoll1_linux.h | 27 // a polling engine that utilizes a singleton epoll set and turnstile polling
|
| D | ev_posix.cc | 44 "Declares which polling engines to try when starting gRPC. "
49 false, "polling"); /* Disabled by default */
56 // Polling API trace only enabled in debug builds
60 gpr_log(GPR_INFO, "(polling-api) " format, __VA_ARGS__); \
97 gpr_log(GPR_ERROR, "Attempted a blocking poll when declared non-polling."); in dummy_poll()
175 gpr_log(GPR_DEBUG, "Using polling engine: %s", g_factories[i].name); in try_engine()
|
| /third_party/boost/libs/graph_parallel/doc/ |
| D | distributed_queue.rst | 24 bool polling = false);
26 distributed_queue(const ProcessGroup& process_group, bool polling);
39 bool polling = false);
82 during synchronization and when polling ``empty``. Messages are
86 constructor. Polling may be desired when the order in which
90 required, polling may be semantically incorrect. By disabling
91 polling, one ensures that parallel execution using the idiom above
108 bool polling = false);
118 distributed_queue(const ProcessGroup& process_group, bool polling);
133 process's local queue. If polling is enabled for this queue and
[all …]
|
| /third_party/boost/boost/graph/distributed/ |
| D | queue.hpp | 73 * during synchronization and when polling @ref empty. Messages are
77 * constructor. Polling may be desired when the order in which
81 * required, polling may be semantically incorrect. By disabling
82 * polling, one ensures that parallel execution using the idiom above
123 bool polling = false);
136 bool polling = false);
145 const UnaryPredicate& pred, bool polling = false);
155 * process's local queue. If polling is enabled for this queue and
228 bool polling; member in boost::graph::distributed::distributed_queue
265 bool polling = false) in make_distributed_queue() argument
[all …]
|
| /third_party/boost/libs/graph_parallel/doc/html/ |
| D | distributed_queue.html | 31 bool polling = false);
33 distributed_queue(const ProcessGroup& process_group, bool polling);
46 bool polling = false);
84 during synchronization and when polling <tt class="docutils literal"><span class="pre">empty</span>…
88 constructor. Polling may be desired when the order in which
92 required, polling may be semantically incorrect. By disabling
93 polling, one ensures that parallel execution using the idiom above
106 bool polling = false);
113 distributed_queue(const ProcessGroup& process_group, bool polling);
124 process's local queue. If polling is enabled for this queue and
[all …]
|
| /third_party/grpc/src/core/lib/debug/ |
| D | stats_data.yaml | 35 # polling
37 doc: Number of polling syscalls (epoll_wait, poll, etc) made by this process
45 doc: How many polling wakeups were performed by the process
48 doc: How many times was a polling wakeup requested without an active poller
51 doc: How many times was the same polling worker awoken repeatedly before
55 doc: How many times was an eventfd used as the wakeup vector for a polling
60 polling wakeup
63 doc: How many times could a polling wakeup be satisfied by keeping the waking
66 # polling
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | backup_poller.h | 30 /* Initializes backup polling. */
33 /* Starts polling \a interested_parties periodically in the timer thread. */
37 /* Stops polling \a interested_parties. */
|
| /third_party/node/deps/npm/node_modules/lockfile/ |
| D | CHANGELOG.md | 35 * manage 'retries' so it does not clash with 'wait' polling
40 * Fixed #6: polling period should be configurable
78 * Use polling instead of watchers
|
| /third_party/libuv/docs/src/ |
| D | poll.rst | 27 but it might also start polling another socket. However the fd can be safely
88 Starts polling the file descriptor. `events` is a bitmask made up of
100 If an error happens while polling, `status` will be < 0 and corresponds
119 Stop polling the file descriptor, the callback will no longer be called.
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_channel.c | 154 * connection polling mutex because we're in a finalizer, in grpc_rb_channel_free_internal()
333 // it's unsafe to do a "watch" after "channel polling abort" because the cq in wait_for_watch_state_op_complete_without_gvl()
603 // In the worst case, this stops polling channel connectivity
643 "GRPC_RUBY: run_poll_channels_loop_no_gil - exit connection polling " in run_poll_channels_loop_no_gil()
648 // Notify the channel polling loop to cleanup and shutdown.
656 "connection polling"); in run_poll_channels_loop_unblocking_func()
679 "connection polling"); in run_poll_channels_loop_unblocking_func()
687 "GRPC_RUBY: run_poll_channels_loop - create connection polling thread"); in run_poll_channels_loop()
697 gpr_log(GPR_DEBUG, "GRPC_RUBY: wait for channel polling thread to start"); in wait_until_channel_polling_thread_started_no_gil()
714 "GRPC_RUBY: interrupt wait for channel polling thread to start"); in wait_until_channel_polling_thread_started_unblocking_func()
[all …]
|
| /third_party/grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 130 "polling threads (i.e %d). Unable to start the thread manager", in Initialize()
193 // There is still at least some thread polling, so we can go on in MainWorkLoop()
205 // the work and continue polling with our existing poller threads in MainWorkLoop()
221 // Otherwise go back to polling as long as it doesn't exceed max_pollers_ in MainWorkLoop()
234 // very high, all the polling threads will return very quickly from in MainWorkLoop()
|
| /third_party/Linux_Kernel/include/linux/ |
| D | rfkill.h | 47 * when you need polling. When called, simply call one of the
105 * Pause polling -- say transmitter is off for other reasons.
107 * core stops polling anyway
114 * Pause polling -- say transmitter is off for other reasons.
116 * core stops polling anyway
|
| D | gpio_keys.h | 42 * @poll_interval: polling interval in msecs - for polling driver only
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_cq_multiple_threads.cc | 110 // This test should only ever be run with a non or any polling engine in setup()
111 // Override the polling engine for the non-polling engine in setup()
112 // and add a custom polling engine in setup()
|
| /third_party/glib/glib/ |
| D | gwakeup.c | 48 * #GPollFD from it using g_wakeup_get_pollfd(). Polling on the created
175 * Prepares a @poll_fd such that polling on it will succeed when
219 * Any future (or present) polling on the #GPollFD returned by
260 * You must not currently be polling on the #GPollFD returned by
|
| /third_party/Linux_Kernel/include/linux/input/ |
| D | gpio_tilt.h | 48 * @poll_interval: polling interval in msecs - for polling driver only
|