| /external/python/python-api-core/google/api_core/gapic_v1/ |
| D | method.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
15 """Helpers for wrapping low-level gRPC methods with common functionality.
17 This is used by gapic clients to provide common error mapping, retry, timeout,
18 pagination, and long-running operations to gRPC methods.
41 """Sentinel value indicating that a retry or timeout argument was unspecified,
63 def _determine_timeout(default_timeout, specified_timeout, retry): argument
72 retry (Optional[Retry]): The retry specified at invocation time.
89 # a non-default retry is specified, make sure the timeout's deadline
90 # matches the retry's. This handles the case where the user leaves
91 # the timeout default but specifies a lower deadline via the retry.
[all …]
|
| D | config.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
26 from google.api_core import retry
47 def _retry_from_retry_config(retry_params, retry_codes, retry_impl=retry.Retry):
48 """Creates a Retry object given a gapic retry configuration.
51 retry_params (dict): The retry parameter values, for example::
67 google.api_core.retry.Retry: The default retry object for the method.
73 retry.if_exception_type(*exception_classes),
82 """Creates a ExponentialTimeout object given a gapic retry configuration.
85 retry_params (dict): The retry parameter values, for example::
98 google.api_core.retry.ExponentialTimeout: The default time object for
[all …]
|
| /external/python/python-api-core/google/api_core/ |
| D | retry.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
15 """Helpers for retrying functions with exponential back-off.
17 The :class:`Retry` decorator can be used to retry functions that raise
19 used, the retry is limited by a `deadline`. The deadline is the maxmimum amount
24 By default, this decorator will retry transient
27 .. code-block:: python
29 @retry.Retry()
33 # Will retry flaky_rpc() if it raises transient API errors.
36 You can pass a custom predicate to retry on different exceptions, such as
39 .. code-block:: python
[all …]
|
| D | retry_async.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
15 """Helpers for retrying coroutine functions with exponential back-off.
18 :class:`Retry`, but supports coroutine functions. Please refer to description
19 of :class:`Retry` for more details.
21 By default, this decorator will retry transient
24 .. code-block:: python
30 # Will retry flaky_rpc() if it raises transient API errors.
33 You can pass a custom predicate to retry on different exceptions, such as
36 .. code-block:: python
44 Some client library methods apply retry automatically. These methods can accept
[all …]
|
| D | operation.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
15 """Futures for long-running operations returned from Google Cloud APIs.
18 long-running operation using :meth:`Operation.result`:
21 .. code-block:: python
28 .. code-block:: python
51 """A Future for interacting with a Google API Long-Running Operation.
64 retry (google.api_core.retry.Retry): The retry configuration used
66 is polled. Regardless of the retry's ``deadline``, it will be
77 retry=polling.DEFAULT_RETRY, argument
79 super(Operation, self).__init__(retry=retry)
[all …]
|
| D | operation_async.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
15 """AsyncIO futures for long-running operations returned from Google Cloud APIs.
17 These futures can be used to await for the result of a long-running operation
21 .. code-block:: python
28 .. code-block:: python
50 """A Future for interacting with a Google API Long-Running Operation.
63 retry (google.api_core.retry.Retry): The retry configuration used
65 is polled. Regardless of the retry's ``deadline``, it will be
76 retry=async_future.DEFAULT_RETRY, argument
78 super().__init__(retry=retry)
[all …]
|
| /external/python/python-api-core/google/api_core/operations_v1/ |
| D | operations_client.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
15 """A client for the google.longrunning.operations meta-API.
17 This is a client that deals with long-running operations that follow the
26 service. The protocol-level definition is available at
47 """Client for interacting with long-running operations within a service.
62 # The interface config contains all of the default settings for retry
70 default_retry=method_configs["GetOperation"].retry,
76 default_retry=method_configs["ListOperations"].retry,
82 default_retry=method_configs["CancelOperation"].retry,
88 default_retry=method_configs["DeleteOperation"].retry,
[all …]
|
| D | operations_async_client.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
15 """An async client for the google.longrunning.operations meta-API.
33 """Async client for interacting with long-running operations.
49 # The interface config contains all of the default settings for retry
57 default_retry=method_configs["GetOperation"].retry,
63 default_retry=method_configs["ListOperations"].retry,
69 default_retry=method_configs["CancelOperation"].retry,
75 default_retry=method_configs["DeleteOperation"].retry,
82 retry=gapic_v1.method_async.DEFAULT, argument
86 """Gets the latest state of a long-running operation.
[all …]
|
| D | abstract_operations_client.py | 1 # -*- coding: utf-8 -*-
8 # http://www.apache.org/licenses/LICENSE-2.0
24 from google.api_core import retry as retries # type: ignore
37 OptionalRetry = Union[retries.Retry, object]
43 This provides class-level methods for building and retrieving
53 ) -> Type[OperationsTransport]:
73 """Manages long-running operations with an API service.
81 long-running operations should implement the ``Operations``
158 def transport(self) -> OperationsTransport:
168 def common_billing_account_path(billing_account: str,) -> str:
[all …]
|
| /external/python/python-api-core/google/api_core/future/ |
| D | polling.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
21 from google.api_core import retry
27 """Private exception used for polling via retry."""
32 RETRY_PREDICATE = retry.if_exception_type(
39 DEFAULT_RETRY = retry.Retry(predicate=RETRY_PREDICATE)
54 retry (google.api_core.retry.Retry): The retry configuration used
56 is polled. Regardless of the retry's ``deadline``, it will be
60 def __init__(self, retry=DEFAULT_RETRY): argument
62 self._retry = retry
72 def done(self, retry=DEFAULT_RETRY): argument
[all …]
|
| D | async_future.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
20 from google.api_core import retry
26 """Private exception used for polling via retry."""
31 RETRY_PREDICATE = retry.if_exception_type(
41 """A Future that polls peer service to self-update.
52 retry (google.api_core.retry.Retry): The retry configuration used
54 is polled. Regardless of the retry's ``deadline``, it will be
58 def __init__(self, retry=DEFAULT_RETRY): argument
60 self._retry = retry
64 async def done(self, retry=DEFAULT_RETRY): argument
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-retry.hpp | 5 /*! \file rx-retry.hpp
7 \brief Retry this observable for the given number of times.
11 …he total number of tries (optional), i.e. retry(2) means one normal try, before an error occurs, a…
16 \snippet retry.cpp retry count sample
17 \snippet output.txt retry count sample
23 #include "../rx-includes.hpp"
24 #include "rx-retry-repeat-common.hpp"
42 // Contain retry variations in a namespace
43 namespace retry { namespace
47 state->update(); in on_error()
[all …]
|
| /external/curl/docs/cmdline-opts/ |
| D | retry-all-errors.d | 1 Long: retry-all-errors
2 Help: Retry all errors (use with --retry)
5 Example: --retry-all-errors $URL
6 ---
7 Retry on any error. This option is used together with --retry.
15 **WARNING**: For server compatibility curl attempts to retry failed flaky
27 --retry is used then curl will retry on some HTTP response codes that indicate
29 as 404. If you want to retry on all response codes that indicate HTTP errors
30 (4xx and 5xx) then combine with --fail.
|
| D | retry.d | 1 Long: retry
4 Help: Retry request if transient problems occur
6 Example: --retry 7 $URL
7 ---
9 will retry this number of times before giving up. Setting the number to 0
14 When curl is about to retry a transfer, it will first wait one second and then
17 using --retry-delay you disable this exponential backoff algorithm. See also
18 --retry-max-time to limit the total time allowed for retries.
20 Since curl 7.66.0, curl will comply with the Retry-After: response header if
21 one was present to know when to issue the next retry.
|
| D | retry-connrefused.d | 1 Long: retry-connrefused
2 Help: Retry on connection refused (use with --retry)
5 Example: --retry-connrefused --retry $URL
6 ---
8 error too for --retry. This option is used together with --retry.
|
| /external/libwebsockets/include/libwebsockets/ |
| D | lws-retry.h | 2 * libwebsockets - small server side websockets and web server implementation
4 * Copyright (C) 2010 - 2019 Andy Green <andy@warmcat.com>
37 * lws_retry_get_delay_ms() - get next delay from backoff table
40 * \param retry: the retry backoff table we are using, or NULL for default
46 * next connection retry, according to the backoff table \p retry. *\p conceal is
51 * If \p retry is NULL, a default of 3s + (0..300ms jitter) is used. If it's
52 * non-NULL but jitter_percent is 0, the default of 30% jitter is retained.
56 lws_retry_get_delay_ms(struct lws_context *context, const lws_retry_bo_t *retry,
60 * lws_retry_sul_schedule() - schedule a sul according to the backoff table
64 * \param retry: the retry backoff table we are using, or NULL for default
[all …]
|
| /external/python/python-api-core/tests/unit/ |
| D | test_operation.py | 7 # http://www.apache.org/licenses/LICENSE-2.0
27 from google.api_core import retry
125 RETRY_PREDICATE = retry.if_exception_type(exceptions.TooManyRequests)
126 test_retry = retry.Retry(predicate=RETRY_PREDICATE)
137 future.done(retry=test_retry)
138 future._refresh.assert_called_once_with(retry=test_retry)
168 # https://developers.google.com/maps-booking/reference/grpc-api/status_codes
203 retry = mock.Mock()
204 retry.return_value.return_value = json_response
206 result = operation._refresh_http(api_request, TEST_OPERATION_NAME, retry=retry)
[all …]
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | suite.py | 3 # Use of this source code is governed by a BSD-style license that can be
48 print(' - Be run in the chroot.')
49 print(' - (not yet supported) be run after running ')
52 _FILE_BUG_SUITES = ['au', 'bvt', 'bvt-cq', 'bvt-inline', 'paygen_au_beta',
60 """Maintain retry information.
62 @var _retry_map: A dictionary that stores retry history.
65 - state:
66 The retry state of a job.
70 We've made an attempt to schedule a retry job. The
73 in scheduling a retry is different from a retry job failure.
[all …]
|
| /external/skia/infra/bots/recipe_modules/run/examples/full.expected/ |
| D | test.json | 53 "-u",
55 "--json-output",
70 "-u",
72 "--json-output",
88 "-u",
90 "--json-output",
101 "-u",
103 "--json-output",
134 "name": "retry fail",
158 "name": "retry fail (attempt 2)",
[all …]
|
| /external/autotest/server/cros/ |
| D | goofy_client.py | 3 # Use of this source code is governed by a BSD-style license that can be
17 from autotest_lib.client.common_lib.cros import retry
41 retry.retry decorator hits it's timeout.
49 want to retry the call after recreating the proxy.
52 the retry decorator. Any of these exceptions will result
55 retry the method ignoring any exception in exception_tuple.
58 """Inner retry decorator applied to the method.
62 @return A wrapper function that implements the retry.
65 @retry.retry(exception_tuple, timeout_min=timeout_min)
71 socket.error, retry for timeout_min through retry.retry.
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Errors.kt | 2 …* Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 licen… in <lambda>()
39 * flow.catch { e -> in <lambda>()
50 * flow.catch { e -> emit(ErrorWrapperValue(e)) } in <lambda>()
54 * retry an original flow use [retryWhen] operator that can retry the flow multiple times without in <lambda>()
55 * introducing ever-growing stack of suspending calls. in <lambda>()
57 public fun <T> Flow<T>.catch(action: suspend FlowCollector<T>.(cause: Throwable) -> Unit): Flow<T> = in <lambda>()
66 * in downstream flow and does not retry on exceptions that are thrown to cancel the flow.
70 …lt value of [retries] parameter is [Long.MAX_VALUE]. This value effectively means to retry forever.
75 * retryWhen { cause, attempt -> attempt < retries && predicate(cause) }
79 * so it can be also used to introduce delay before retry, for example:
[all …]
|
| /external/autotest/client/common_lib/cros/ |
| D | retry_unittest.py | 4 # Use of this source code is governed by a BSD-style license that can be
7 """Unit tests for client/common_lib/cros/retry.py."""
18 from autotest_lib.client.common_lib.cros import retry
23 """Unit tests for retry decorators.
45 @retry.retry(Exception)
53 """Tests that a wrapped function can retry and succeed."""
56 @retry.retry(Exception, delay_sec=delay_sec)
69 @retry.retry(Exception, delay_sec=delay_sec)
76 """Tests that dynamic_suite exceptions raise immediately, no retry."""
77 @retry.retry(Exception)
[all …]
|
| /external/arm-trusted-firmware/plat/mediatek/common/drivers/pmic_wrap/ |
| D | pmic_wrap_init_v2.c | 4 * SPDX-License-Identifier: BSD-3-Clause
22 uint32_t reg_rdata = 0U, retry; in pwrap_check_idle() local
24 retry = (timeout_us + WAIT_IDLE_POLLING_DELAY_US) / in pwrap_check_idle()
26 while (retry != 0) { in pwrap_check_idle()
30 * read command state machine:FSM_REQ-->wfdle-->WFVLDCLR; in pwrap_check_idle()
31 * write:FSM_REQ-->idle in pwrap_check_idle()
35 mmio_write_32((uintptr_t)&mtk_pwrap->wacs2_vldclr, 0x1); in pwrap_check_idle()
49 retry--; in pwrap_check_idle()
53 if (retry == 0) { in pwrap_check_idle()
63 uint32_t reg_rdata = 0U, retry; in pwrap_check_vldclr() local
[all …]
|
| /external/volley/core/src/test/java/com/android/volley/toolbox/ |
| D | BasicNetworkTest.java | 8 * http://www.apache.org/licenses/LICENSE-2.0
85 assertEquals("foobar", mockHttpStack.getLastHeaders().get("If-None-Match")); in headersAndPostParams()
88 mockHttpStack.getLastHeaders().get("If-Modified-Since")); in headersAndPostParams()
169 doThrow(new VolleyError()).when(mMockRetryPolicy).retry(any(VolleyError.class)); in socketTimeout()
175 // should retry socket timeouts in socketTimeout()
176 verify(mMockRetryPolicy).retry(any(TimeoutError.class)); in socketTimeout()
186 doThrow(new VolleyError()).when(mMockRetryPolicy).retry(any(VolleyError.class)); in noConnectionDefault()
192 // should not retry when there is no connection in noConnectionDefault()
193 verify(mMockRetryPolicy, never()).retry(any(VolleyError.class)); in noConnectionDefault()
204 doThrow(new VolleyError()).when(mMockRetryPolicy).retry(any(VolleyError.class)); in noConnectionRetry()
[all …]
|
| /external/llvm/test/CodeGen/PowerPC/ |
| D | ctrloop-reg.ll | 1 ; ModuleID = 'bugpoint-reduced-simplified.bc'
2 target datalayout = "E-p:64:64:64-i1:8:8-i8:8:8-i16:16:16-i32:32:32-i64:64:64-f32:32:32-f64:64:64-v…
3 target triple = "powerpc64-unknown-linux-gnu"
4 ; RUN: llc < %s -march=ppc64 | FileCheck %s
50 br i1 undef, label %retry.us, label %retry
52 retry.us: ; preds = %if.end18, %retry, %retry, %retry, %ret…
55 retry: ; preds = %if.end18, %entry
59 i32 -3, label %retry.us
60 i32 -5, label %retry.us
61 i32 -16, label %retry.us
[all …]
|