| /external/cronet/stable/net/socket/ |
| D | transport_connect_job_unittest.cc | 187 // Make connection attempts hang. in TEST_F()
351 ConnectionAttempts attempts = transport_connect_job.GetConnectionAttempts(); in TEST_F() local
352 ASSERT_EQ(1u, attempts.size()); in TEST_F()
353 EXPECT_THAT(attempts[0].result, test::IsError(ERR_CONNECTION_FAILED)); in TEST_F()
354 EXPECT_EQ(attempts[0].endpoint, IPEndPoint(ParseIP("1:abcd::3:4:ff"), 80)); in TEST_F()
398 ConnectionAttempts attempts = transport_connect_job.GetConnectionAttempts(); in TEST_F() local
399 ASSERT_EQ(1u, attempts.size()); in TEST_F()
400 EXPECT_THAT(attempts[0].result, test::IsError(ERR_CONNECTION_FAILED)); in TEST_F()
401 EXPECT_EQ(attempts[0].endpoint, IPEndPoint(ParseIP("2.2.2.2"), 80)); in TEST_F()
424 ConnectionAttempts attempts = transport_connect_job.GetConnectionAttempts(); in TEST_F() local
[all …]
|
| /external/cronet/tot/net/socket/ |
| D | transport_connect_job_unittest.cc | 187 // Make connection attempts hang. in TEST_F()
351 ConnectionAttempts attempts = transport_connect_job.GetConnectionAttempts(); in TEST_F() local
352 ASSERT_EQ(1u, attempts.size()); in TEST_F()
353 EXPECT_THAT(attempts[0].result, test::IsError(ERR_CONNECTION_FAILED)); in TEST_F()
354 EXPECT_EQ(attempts[0].endpoint, IPEndPoint(ParseIP("1:abcd::3:4:ff"), 80)); in TEST_F()
398 ConnectionAttempts attempts = transport_connect_job.GetConnectionAttempts(); in TEST_F() local
399 ASSERT_EQ(1u, attempts.size()); in TEST_F()
400 EXPECT_THAT(attempts[0].result, test::IsError(ERR_CONNECTION_FAILED)); in TEST_F()
401 EXPECT_EQ(attempts[0].endpoint, IPEndPoint(ParseIP("2.2.2.2"), 80)); in TEST_F()
424 ConnectionAttempts attempts = transport_connect_job.GetConnectionAttempts(); in TEST_F() local
[all …]
|
| /external/cronet/tot/net/http/ |
| D | http_stream_pool_attempt_manager.h | 53 // Time to delay connection attempts more than one when the destination is
112 // Returns the number of in-flight attempts.
115 // Cancels all in-flight attempts.
125 // calculated by subtracting the number of in-flight attempts (excluding slow
126 // attempts) from the number of total jobs.
143 // Returns whether attempts is "SVCB-optional". See
165 // Represents failure of connection attempts. Used to notify job of completion
173 // Represents reasons if future connection attempts could be blocked or not.
183 // The state of TCP/TLS connection attempts.
237 // Runs the stream attempt delay timer if stream attempts are blocked and the
[all …]
|
| /external/cronet/stable/net/http/ |
| D | http_stream_pool_attempt_manager.h | 53 // Time to delay connection attempts more than one when the destination is
112 // Returns the number of in-flight attempts.
115 // Cancels all in-flight attempts.
125 // calculated by subtracting the number of in-flight attempts (excluding slow
126 // attempts) from the number of total jobs.
143 // Returns whether attempts is "SVCB-optional". See
165 // Represents failure of connection attempts. Used to notify job of completion
173 // Represents reasons if future connection attempts could be blocked or not.
183 // The state of TCP/TLS connection attempts.
237 // Runs the stream attempt delay timer if stream attempts are blocked and the
[all …]
|
| /external/sdk-platform-java/showcase/proto-gapic-showcase-v1beta1/src/main/java/com/google/showcase/v1beta1/ |
| D | SequenceReportOrBuilder.java | 24 * The set of RPC attempts received by the server for a Sequence.
27 * <code>repeated .google.showcase.v1beta1.SequenceReport.Attempt attempts = 2;</code>
33 * The set of RPC attempts received by the server for a Sequence.
36 * <code>repeated .google.showcase.v1beta1.SequenceReport.Attempt attempts = 2;</code>
41 * The set of RPC attempts received by the server for a Sequence.
44 * <code>repeated .google.showcase.v1beta1.SequenceReport.Attempt attempts = 2;</code>
49 * The set of RPC attempts received by the server for a Sequence.
52 * <code>repeated .google.showcase.v1beta1.SequenceReport.Attempt attempts = 2;</code>
58 * The set of RPC attempts received by the server for a Sequence.
61 * <code>repeated .google.showcase.v1beta1.SequenceReport.Attempt attempts = 2;</code>
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/helpers/ |
| D | retryers.py | 89 attempts: int = 0,
99 if attempts < 1 and timeout is None:
100 raise ValueError('The number of attempts or the timeout must be set')
102 if attempts > 0:
103 stops.append(stop.stop_after_attempt(attempts))
110 attempts=attempts,
121 attempts: int = 0,
124 it can assemble a helpful message containing timeout/number of attempts.
130 attempts=attempts,
203 attempts: int = 0,
[all …]
|
| /external/tensorflow/tensorflow/python/distribute/integration_test/ |
| D | mwms_peer_failure_test.py | 41 def get_attempt(strategy, attempts): argument
44 attempts[(task_type, task_id)] = attempts.get((task_type, task_id), 0) + 1
45 return task_id, attempts[(task_type, task_id)]
66 # We use a multiprocessing.Manager().dict() object to track the attempts of
67 # each worker. We take different actions in different attempts to simuate the
137 def worker_fn(attempts): argument
139 task_id, attempt = get_attempt(strategy, attempts)
149 attempts = multi_process_runner.manager().dict()
154 args=(attempts,),
163 def worker_fn(attempts): argument
[all …]
|
| /external/coreboot/src/commonlib/bsd/include/commonlib/bsd/ |
| D | helpers.h | 94 #define _retry_impl(attempts, condition, expr, ...) \ argument
98 int _retry_attempts = (attempts); \
114 * of attempts is reached. Two forms are supported:
116 * 1. retry(attempts, condition)
117 * 2. retry(attempts, condition, expr)
119 * @param attempts Maximum attempts.
123 * @return Condition value if it evaluates to true within the maximum attempts;
126 #define retry(attempts, condition, ...) \ argument
127 _retry_impl(attempts, condition, __VA_ARGS__)
|
| /external/autotest/utils/frozen_chromite/lib/ |
| D | retry_stats.py | 27 # attempts: a list of all attempts to perform the action.
30 ('category', 'attempts'))
63 # If all attempts contain an exception, they all failed.
64 return not all(a.exception for a in entry.attempts)
69 # If all attempts contain an exception, they all failed.
70 return max(len(entry.attempts) - 1, 0)
160 statEntry = StatEntry(category, attempts=[])
171 statEntry.attempts.append(Attempt(end - start, e_description))
175 statEntry.attempts.append(Attempt(end - start, None))
|
| /external/cronet/tot/net/dns/public/ |
| D | dns_config_overrides.cc | 33 attempts == other.attempts && doh_attempts == other.doh_attempts && in operator ==()
58 overrides.attempts = defaults.attempts; in CreateOverridingEverythingWithDefaults()
74 attempts && doh_attempts && rotate && use_local_ipv6 && in OverridesEverything()
99 if (attempts) in ApplyOverrides()
100 overridden.attempts = attempts.value(); in ApplyOverrides()
|
| /external/cronet/stable/net/dns/public/ |
| D | dns_config_overrides.cc | 33 attempts == other.attempts && doh_attempts == other.doh_attempts && in operator ==()
58 overrides.attempts = defaults.attempts; in CreateOverridingEverythingWithDefaults()
74 attempts && doh_attempts && rotate && use_local_ipv6 && in OverridesEverything()
99 if (attempts) in ApplyOverrides()
100 overridden.attempts = attempts.value(); in ApplyOverrides()
|
| /external/autotest/server/cros/dynamic_suite/ |
| D | frontend_wrappers_unittest.py | 20 """Test converting timeout and delay values to retry attempts."""
47 # Eight attempts with a backoff factor of two should be sufficient
52 # We expect to see nine attempts, as we are above the 42.5 minute
57 """Test converting to retry attempts when a small timeout is used."""
65 # The number of attempts should be less than one using the formula
71 """Test converting to retry attempts when the delay is small."""
|
| /external/iptables/iptables/tests/shell/testcases/ipt-restore/ |
| D | 0004-restore-race_0 | 89 attempts=$((RANDOM%10))
90 attempts=$((attempts+1))
93 attempts=1
97 while [ $attempts -gt 0 ]; do
98 attempts=$((attempts-1))
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/retrying/ |
| D | RetryingFuture.java | 47 * java.util.concurrent.ScheduledExecutorService}, or an already completed future if the attempts
74 * attempts, since only a completed attempt has a result and not all attempts complete (some of
75 * the service attempts, needed for proper execution of the actual attempts).
116 * attempts, since only a completed attempt has a result and not all attempts complete (some of
117 * the service attempts, needed for proper execution of the actual attempts).
|
| D | ExponentialPollAlgorithm.java | 37 * attempts is reached.
55 * if either total timeout or total number of attempts is exceeded.
59 * @return {@code true} if more attempts should be made, never returns {@code false} (throws
61 * @throws PollException if no more attempts should be made
69 "total timeout or maximum number of attempts exceeded; current settings: " in shouldRetry()
|
| /external/vboot_reference/utility/ |
| D | tpm-dad-lock | 24 attempts=0
29 attempts=$(( $attempts + 1 ))
48 echo delay of $elapsed seconds after $attempts attempts
|
| /external/rust/beto-rust/nearby/presence/np_c_ffi/include/cpp/ |
| D | np_cpp_ffi_functions.h | 142 /// of the byte buffer containing the decrypted metadata. There can be a data-race between attempts
143 /// to access the contents of the buffer and attempts to free the handle from different threads.
146 /// Attempts to deserialize an advertisement with the given service-data
194 /// Attempts to get the data-element with the given index in the passed v0 adv payload
197 /// Attempts to decrypt the metadata for the matched credential for this V0 payload (if any)
265 /// Attempts to decrypt the metadata for the matched credential for this V0 payload (if any)
268 /// Attempts to derive a 16-byte DE salt for a DE in this section with the given DE offset. This
289 /// Attempts to add the given data element to the V0
298 /// Attempts to serialize the contents of the advertisement builder
304 /// Attempts to deallocate the v0 advertisement builder behind
[all …]
|
| /external/sdk-platform-java/java-core/google-cloud-core/src/test/java/com/google/cloud/testing/junit4/ |
| D | MultipleAttemptsRule.java | 29 * A JUnit rule that allows multiple attempts of a test execution before ultimately reporting
30 * failure for the test. Attempts will be attempted with an exponential backoff which defaults to a
33 * <p>If after the maximum number of attempts the test has still not succeeded, all failures will be
58 * @param maxAttemptCount max number of attempts before reporting failure, must be greater than 0
72 * @param maxAttemptCount max number of attempts before reporting failure, must be greater than 0
73 * @param initialBackoffMillis initial duration in millis to wait between attempts, must be
|
| /external/cronet/tot/net/dns/ |
| D | dns_config.cc | 51 (attempts == d.attempts) && (doh_attempts == d.doh_attempts) && in EqualsIgnoreHosts()
67 attempts = d.attempts; in CopyIgnoreHosts()
95 dict.Set("attempts", attempts); in ToDict()
|
| /external/cronet/stable/net/dns/ |
| D | dns_config.cc | 51 (attempts == d.attempts) && (doh_attempts == d.doh_attempts) && in EqualsIgnoreHosts()
67 attempts = d.attempts; in CopyIgnoreHosts()
95 dict.Set("attempts", attempts); in ToDict()
|
| /external/openthread/src/cli/ |
| D | README_COAPS.md | 239 ### start \[check-peer-cert\|max-conn-attempts\]
243 …attempts` parameter sets the maximum number of allowed attempts, successful or failed, to connect …
246 …ument, which is that the `check-peer-cert` value is `true`, and the `max-conn-attempts` value is 0.
247 …eer-cert` to `false`: `check-peer-cert` value is `false`, and the `max-conn-attempts` value is `0`.
248 - Specifying a number: `check-peer-cert` is `true`, and the `max-conn-attempts` value is the number…
|
| /external/ltp/testcases/kernel/syscalls/request_key/ |
| D | request_key05.c | 23 #define ATTEMPTS 0x100 macro
30 for (i = 0; i < ATTEMPTS; i++) in run()
33 tst_res(TPASS, "No crash after %d attempts", ATTEMPTS); in run()
|
| /external/autotest/server/site_tests/servo_ConsoleStress/ |
| D | control | 30 attempts = int(args_dict.get("attempts", 1000))
36 attempts=attempts, cmd_type=cmd_type, cmd=cmd)
|
| D | control.ec | 30 attempts = int(args_dict.get("attempts", 1000))
36 attempts=attempts, cmd_type=cmd_type, cmd=cmd)
|
| /external/openscreen/third_party/abseil/src/absl/time/ |
| D | clock_test.cc | 54 AlarmPolicy alarm_policy, int* attempts) { in SleepForBounded() argument
67 ++*attempts; in SleepForBounded()
91 int attempts = 0; in AssertSleepForBounded() local
93 &attempts)) { in AssertSleepForBounded()
98 << ":" << upper_bound << "] in " << attempts << " attempt" in AssertSleepForBounded()
99 << (attempts == 1 ? "" : "s") << " over " << timeout in AssertSleepForBounded()
|