| /external/rust/crates/futures-executor/src/ |
| D | unpark_mutex.rs | 14 // The actual task data, accessible only in the POLLING state
20 // re-polling.
32 const WAITING: usize = 0; // --> POLLING
36 const POLLING: usize = 1; // --> WAITING, REPOLL, or COMPLETE constant
40 const REPOLL: usize = 2; // --> POLLING
52 /// An `Ok` result indicates that the `POLLING` state has been entered, and
54 /// that polling is not necessary (because the task is finished or the
55 /// polling has been delegated).
62 match self.status.compare_exchange(WAITING, POLLING, SeqCst, SeqCst) { in notify()
67 // that has transitioned to the POLLING state, in notify()
[all …]
|
| /external/grpc-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 ## Polling Engine Interface
30 ### Opaque Structures exposed by the polling engine
31 … following are the **Opaque** structures exposed by Polling Engine interface (NOTE: Different poll…
35 - **grpc_pollset_worker:** Structure representing a ‘polling thread’ - more specifically, the threa…
38 ### Polling engine API
[all …]
|
| 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-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
|
| /external/googleapis/google/cloud/ |
| D | extended_operations.proto | 32 // polling request and operation response messages.
45 // In a polling request message (the one which is used to poll for an LRO
68 // (the one which started the LRO) to their counterparts in the polling
69 // request message. For non-standard LRO, the polling response may be missing
70 // some of the information needed to make a subsequent polling request. The
74 // counterpart field in the polling request message that the annotated field's
78 // A field annotation that maps fields in the polling request message to their
79 // counterparts in the initial and/or polling response message. The initial
80 // and the polling methods return an API-specific Operation object. Some of
83 // This annotation must be applied to the fields in the polling request
[all …]
|
| /external/sdk-platform-java/java-common-protos/proto-google-common-protos/src/main/proto/google/cloud/ |
| D | extended_operations.proto | 32 // polling request and operation response messages.
45 // In a polling request message (the one which is used to poll for an LRO
68 // (the one which started the LRO) to their counterparts in the polling
69 // request message. For non-standard LRO, the polling response may be missing
70 // some of the information needed to make a subsequent polling request. The
74 // counterpart field in the polling request message that the annotated field's
78 // A field annotation that maps fields in the polling request message to their
79 // counterparts in the initial and/or polling response message. The initial
80 // and the polling methods return an API-specific Operation object. Some of
83 // This annotation must be applied to the fields in the polling request
[all …]
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/rtsp/src/test/java/com/google/android/exoplayer2/source/rtsp/ |
| D | RtpPacketReorderingQueueTest.java | 77 // arrive in time, so the polling order is: 1, null, 2, 3, 4, 5, 6. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
90 // polling 1, queue after polling: [4]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
98 // polling 2, queue after polling: [4, 5]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
102 // polling 3, queue after polling: [4, 5]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
106 // polling 4, queue after polling: [5, 6]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
108 // polling 5, queue after polling: [6]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
110 // polling 6, queue after polling: []. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
133 // polling 1, queue after polling: [3]. in reorder_withPacketArriveOutOfOrderMissedDeadline_returnsPacketsWithSequenceNumberJump()
138 // polling 3, queue after polling: [4]. in reorder_withPacketArriveOutOfOrderMissedDeadline_returnsPacketsWithSequenceNumberJump()
142 // polling 4, queue after polling: []. in reorder_withPacketArriveOutOfOrderMissedDeadline_returnsPacketsWithSequenceNumberJump()
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/rtsp/src/test/java/com/google/android/exoplayer2/source/rtsp/ |
| D | RtpPacketReorderingQueueTest.java | 77 // arrive in time, so the polling order is: 1, null, 2, 3, 4, 5, 6. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
90 // polling 1, queue after polling: [4]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
98 // polling 2, queue after polling: [4, 5]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
102 // polling 3, queue after polling: [4, 5]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
106 // polling 4, queue after polling: [5, 6]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
108 // polling 5, queue after polling: [6]. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
110 // polling 6, queue after polling: []. in reorder_withPacketArriveOutOfOrderButInTime_returnsPacketsInCorrectOrder()
133 // polling 1, queue after polling: [3]. in reorder_withPacketArriveOutOfOrderMissedDeadline_returnsPacketsWithSequenceNumberJump()
138 // polling 3, queue after polling: [4]. in reorder_withPacketArriveOutOfOrderMissedDeadline_returnsPacketsWithSequenceNumberJump()
142 // polling 4, queue after polling: []. in reorder_withPacketArriveOutOfOrderMissedDeadline_returnsPacketsWithSequenceNumberJump()
|
| /external/cronet/third_party/libc++/src/include/__thread/ |
| D | poll_with_backoff.h | 27 // before polling again.
29 // - __f is the "test function" that should return true if polling succeeded, and false if it faile…
31 // - __bf is the "backoff policy", which is called with the duration since we started polling. It s…
32 // return false in order to resume polling, and true if polling should stop entirely for some rea…
33 // In general, backoff policies sleep for some time before returning control to the polling loop.
35 // - __max_elapsed is the maximum duration to try polling for. If the maximum duration is exceeded,
36 // the polling loop will return false to report a timeout.
57 // the polling loop.
59 // This is not very well-behaved since it will cause the polling loop to spin,
|
| /external/rust/crates/futures-util/src/stream/stream/ |
| D | flatten_unordered.rs | 43 const POLLING: u8 = 0b100; constant
51 /// Internal polling state of the stream.
63 /// Attempts to start polling, returning stored state in case of success.
72 Some(POLLING) in start_polling()
95 if value & (WOKEN | POLLING) == NONE { in start_waking()
107 …// Only start the waking process if we're not in the polling/waking phase and the stream isn't wok… in start_waking()
108 if value & (WOKEN | POLLING | WAKING) == NONE { in start_waking()
118 /// - `!POLLING` allowing to use wakers
119 /// - `WOKEN` if the state was changed during `POLLING` phase as waker will be called,
122 /// * Wakers called during the `POLLING` phase won't propagate their calls
[all …]
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/longrunning/ |
| D | OperationTimedPollAlgorithm.java | 41 * Operation timed polling algorithm, which uses exponential backoff factor for determining when the
42 * next polling operation should be executed. If the polling exceeds the total timeout this
43 * algorithm cancels polling.
47 * Creates the polling algorithm, using the default {@code NanoClock} for time computations.
85 // enforce it, it could have potentially negative side effects on LRO polling.
86 // Specifically, if a polling retry attempt is denied, the LRO is canceled, and
87 // if a polling retry attempt is denied because its delay would *reach* the
89 // totalTimeout doubles as the polling threshold and also the time limit for an
|
| /external/v4l2_codec2/v4l2/include/v4l2_codec2/v4l2/ |
| D | V4L2DevicePoller.h | 22 // dequeued or a V4L2 event has been received. Polling is done on a dedicated thread, and
43 // Starts polling. |mEventCallback| will be posted on the caller's sequence every time an event
48 // If an error occurs during polling, |mErrorCallback| will be posted on the caller's sequence.
50 // Stop polling and stop the thread. The poller won't post any new event to the caller's
53 // Returns true if currently polling, false otherwise.
55 // Attempts polling the V4L2 device. This method should be called whenever doing something that
67 // V4L2 device we are polling.
69 // Thread on which polling is done.
78 // Set to true when we wish to stop polling, instructing the poller thread to break its loop.
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/waiters/ |
| D | AsyncWaiter.java | 29 * @param <T> the type of the resource returned from the polling function
35 …* Runs the provided polling function. It completes successfully when the resource enters into a de…
38 * @param asyncPollingFunction the polling function to trigger
46 …* Runs the provided polling function. It completes successfully when the resource enters into a de…
49 * @param asyncPollingFunction the polling function to trigger
59 …* Runs the provided polling function. It completes successfully when the resource enters into a de…
62 * @param asyncPollingFunction the polling function to trigger
89 * Defines the {@link ScheduledExecutorService} used to schedule async polling attempts.
|
| /external/v4l2_codec2/v4l2/ |
| D | V4L2DevicePoller.cpp | 41 ALOGV("Starting polling"); in startPolling()
57 ALOGV("Polling thread started"); in startPolling()
69 ALOGV("Stopping polling"); in stopPolling()
86 ALOGV("Polling thread stopped"); in stopPolling()
100 // A call to DevicePollTask() will be posted when we actually start polling. in schedulePoll()
127 ALOGV("Polling device."); in devicePollTask()
130 ALOGE("An error occurred while polling, calling error callback"); in devicePollTask()
136 // If buffer polling was requested but the buffers are not pending, in devicePollTask()
|
| /external/grpc-grpc/src/core/resolver/ |
| D | polling_resolver.cc | 63 gpr_log(GPR_INFO, "[polling resolver %p] created", this); in PollingResolver()
69 gpr_log(GPR_INFO, "[polling resolver %p] destroying", this); in ~PollingResolver()
100 gpr_log(GPR_INFO, "[polling resolver %p] shutting down", this); in ShutdownLocked()
123 "[polling resolver %p] re-resolution timer fired: shutdown_=%d", in OnNextResolutionLocked()
136 gpr_log(GPR_INFO, "[polling resolver %p] cancel re-resolution timer", in MaybeCancelNextResolutionTimer()
154 gpr_log(GPR_INFO, "[polling resolver %p] request complete", this); in OnRequestCompleteLocked()
160 "[polling resolver %p] returning result: " in OnRequestCompleteLocked()
189 gpr_log(GPR_INFO, "[polling resolver %p] result status from channel: %s", in GetResultStatus()
213 gpr_log(GPR_INFO, "[polling resolver %p] retrying in %" PRId64 " ms", in GetResultStatus()
216 gpr_log(GPR_INFO, "[polling resolver %p] retrying immediately", this); in GetResultStatus()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/ |
| D | polling_resolver.cc | 63 gpr_log(GPR_INFO, "[polling resolver %p] created", this); in PollingResolver()
69 gpr_log(GPR_INFO, "[polling resolver %p] destroying", this); in ~PollingResolver()
100 gpr_log(GPR_INFO, "[polling resolver %p] shutting down", this); in ShutdownLocked()
124 "[polling resolver %p] re-resolution timer fired: shutdown_=%d", in OnNextResolutionLocked()
137 gpr_log(GPR_INFO, "[polling resolver %p] cancel re-resolution timer", in MaybeCancelNextResolutionTimer()
155 gpr_log(GPR_INFO, "[polling resolver %p] request complete", this); in OnRequestCompleteLocked()
161 "[polling resolver %p] returning result: " in OnRequestCompleteLocked()
190 gpr_log(GPR_INFO, "[polling resolver %p] result status from channel: %s", in GetResultStatus()
214 gpr_log(GPR_INFO, "[polling resolver %p] retrying in %" PRId64 " ms", in GetResultStatus()
217 gpr_log(GPR_INFO, "[polling resolver %p] retrying immediately", this); in GetResultStatus()
[all …]
|
| /external/rust/crates/grpcio/src/task/ |
| D | executor.rs | 74 /// begins to poll the future, it's marked as POLLING. When the executor finishes
75 /// polling, the future can either be ready or not ready. In the former case, it's
78 /// Note it's possible the future is notified during polling, in which case, executor
79 /// should polling it when last polling is finished unless it returns ready.
82 const POLLING: u8 = 3; constant
120 Err(POLLING) => match self.state.compare_exchange_weak( in mark_notified()
121 POLLING, in mark_notified()
126 Err(IDLE) | Err(POLLING) => continue, in mark_notified()
191 .compare_exchange(init_state, POLLING, Ordering::AcqRel, Ordering::Acquire) in poll()
214 POLLING, in poll()
|
| /external/grpc-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
115 - polling - traces the selected polling engine
116 - polling_api - traces the api calls to polling engine
174 there is no active polling thread. They help reconnect disconnected client
|
| /external/python/python-api-core/tests/unit/future/ |
| D | test_polling.py | 23 from google.api_core.future import polling
26 class PollingFutureImpl(polling.PollingFuture):
92 def done(self, retry=polling.DEFAULT_RETRY):
107 # Repeated calls should not cause additional polling
113 def done(self, retry=polling.DEFAULT_RETRY):
135 def done(self, retry=polling.DEFAULT_RETRY):
155 # Repeated calls should not cause additional polling
187 # only one polling thread should be created.
|
| /external/google-cloud-java/java-compute/ |
| D | .readme-partials.yaml | 5 …- Everything except polling methods which used to return `Operation` now returns `OperationFuture`…
8 …Polling is now done automatically, manual polling is no longer required. Calling `opFuture.get()` …
10 …- If you wish to stop automatic polling call `opFuture.cancel()` - it will cancel the future on th…
11 …- The calls still may be done without relying on automatic polling and/or OperationFuture. To do s…
|
| /external/sdk-platform-java/java-common-protos/proto-google-common-protos/src/main/java/com/google/cloud/ |
| D | ExtendedOperationsProto.java | 61 * (the one which started the LRO) to their counterparts in the polling
62 * request message. For non-standard LRO, the polling response may be missing
63 * some of the information needed to make a subsequent polling request. The
67 * counterpart field in the polling request message that the annotated field's
84 * A field annotation that maps fields in the polling request message to their
85 * counterparts in the initial and/or polling response message. The initial
86 * and the polling methods return an API-specific Operation object. Some of
89 * This annotation must be applied to the fields in the polling request
128 * A method annotation that marks methods that can be used for polling
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/tracing/ |
| D | OpencensusTracer.java | 156 * number of polling RPCs will be represented as a tree of spans. The top level span will be named
166 * <li>{@code Polling was cancelled} with the following attributes:
179 * <dd>The number of milliseconds to wait before polling again
181 * <li>{@code Polling attempts exhausted} with the following attributes:
188 * <li>{@code Polling failed} with the following attributes:
195 * <li>{@code Polling completed} with the following attributes:
321 // Same infrastructure is used for both polling and retries, so need to disambiguate it here.
323 span.addAnnotation("Polling completed", attributes);
334 // Same infrastructure is used for both polling and retries, so need to disambiguate it here.
336 span.addAnnotation("Polling was cancelled", attributes);
[all …]
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/core/src/main/java/com/google/android/exoplayer2/audio/ |
| D | AudioTimestampPoller.java | 34 * Polls the {@link AudioTrack} timestamp, if the platform supports it, taking care of polling at
52 /** Timestamp polling states. */
75 /** The polling interval for {@link #STATE_INITIALIZING} and {@link #STATE_TIMESTAMP}. */
78 * The polling interval for {@link #STATE_TIMESTAMP_ADVANCING} and {@link #STATE_NO_TIMESTAMP}.
81 /** The polling interval for {@link #STATE_ERROR}. */
161 // The audio route may have changed, so reset polling. in maybePollTimestamp()
167 // The audio route may have changed, so reset polling. in maybePollTimestamp()
172 // Do nothing. If the caller accepts any new timestamp we'll reset polling. in maybePollTimestamp()
218 /** Resets polling. Should be called whenever the audio track is paused or resumed. */
247 // Force polling a timestamp immediately, and poll quickly. in updateState()
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/core/src/main/java/com/google/android/exoplayer2/audio/ |
| D | AudioTimestampPoller.java | 31 * Polls the {@link AudioTrack} timestamp, if the platform supports it, taking care of polling at
49 /** Timestamp polling states. */
71 /** The polling interval for {@link #STATE_INITIALIZING} and {@link #STATE_TIMESTAMP}. */
74 * The polling interval for {@link #STATE_TIMESTAMP_ADVANCING} and {@link #STATE_NO_TIMESTAMP}.
77 /** The polling interval for {@link #STATE_ERROR}. */
157 // The audio route may have changed, so reset polling. in maybePollTimestamp()
163 // The audio route may have changed, so reset polling. in maybePollTimestamp()
168 // Do nothing. If the caller accepts any new timestamp we'll reset polling. in maybePollTimestamp()
214 /** Resets polling. Should be called whenever the audio track is paused or resumed. */
243 // Force polling a timestamp immediately, and poll quickly. in updateState()
|
| /external/arm-trusted-firmware/plat/hisilicon/hikey/ |
| D | hisi_dvfs.c | 134 * - Polling ACPU_SC_CPU_STAT.clk_div_status_vd == 0x3; in acpu_dvfs_syspll_cfg()
221 * - Polling PMCTRL_ACPUPLLSEL.syspll_sw_stat == 0x1 in acpu_dvfs_freq_ascend()
317 * - Polling PMCTRL_ACPUDESTVOL.acpu_vol_using == ACPUDESTVOL.acpu_dest_vol in acpu_dvfs_freq_ascend()
318 * - Polling ACPUVOLTIMEOUT.acpu_vol_timeout == 0x1 in acpu_dvfs_freq_ascend()
340 * - Polling PMCTRL_ACPUCLKDIV.cpuext_clk_div_stat; in acpu_dvfs_freq_ascend()
341 * - Polling ACPUCLKDIV.acpu_ddr_clk_div_stat; in acpu_dvfs_freq_ascend()
366 * - Polling PMCTRL_ACPUPLLSEL.acpupll_sw_stat == 0x1; in acpu_dvfs_freq_ascend()
414 * - Polling PMCTRL_ACPUPLLSEL.syspll_sw_stat == 0x1 in acpu_dvfs_freq_descend()
515 * - Polling PMCTRL_ACPUPLLSEL.acpupll_sw_stat == 0x1; in acpu_dvfs_freq_descend()
549 * - Polling ACPU_SC_CPU_STAT.clk_div_status_vd == 0x0; in acpu_dvfs_freq_descend()
[all …]
|