| /third_party/node/deps/npm/node_modules/retry/test/integration/ |
| D | test-retry-operation.js | 9 var attempts = 0;
19 attempts++;
20 assert.equal(currentAttempt, attempts);
27 assert.strictEqual(attempts, 4);
28 assert.strictEqual(operation.attempts(), attempts);
32 attempts = 0;
97 var attempts = 0;
104 attempts++;
105 assert.equal(currentAttempt, attempts);
110 assert.strictEqual(attempts, 4);
[all …]
|
| /third_party/node/deps/npm/node_modules/promise-retry/node_modules/retry/test/integration/ |
| D | test-retry-operation.js | 59 var attempts = 0;
66 attempts++;
67 assert.equal(currentAttempt, attempts);
72 assert.strictEqual(attempts, 4);
73 assert.strictEqual(operation.attempts(), attempts);
85 var attempts = 0;
92 attempts++;
93 assert.equal(currentAttempt, attempts);
94 if (attempts !== 6 && operation.retry(error)) {
98 assert.strictEqual(attempts, 6);
[all …]
|
| /third_party/ffmpeg/libavformat/ |
| D | network.c | 407 struct ConnectionAttempt attempts[3]; in ff_connect_parallel() local
415 if (parallel > FF_ARRAY_ELEMS(attempts)) in ff_connect_parallel()
416 parallel = FF_ARRAY_ELEMS(attempts); in ff_connect_parallel()
433 last_err = start_connect_attempt(&attempts[nb_attempts], &addrs, in ff_connect_parallel()
444 closesocket(attempts[i].fd); in ff_connect_parallel()
445 *fd = attempts[nb_attempts].fd; in ff_connect_parallel()
448 pfd[nb_attempts].fd = attempts[nb_attempts].fd; in ff_connect_parallel()
457 next_deadline_us = attempts[0].deadline_us; in ff_connect_parallel()
474 if (getsockopt(attempts[i].fd, SOL_SOCKET, SO_ERROR, &last_err, &optlen)) in ff_connect_parallel()
483 closesocket(attempts[j].fd); in ff_connect_parallel()
[all …]
|
| /third_party/skia/third_party/externals/abseil-cpp/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()
|
| /third_party/flutter/skia/experimental/Networking/ |
| D | SkSockets.cpp | 97 int attempts = 0; in readPacket() local
108 ++attempts; in readPacket()
149 attempts = 0; in readPacket()
184 int attempts = 0; in writePacket() local
199 attempts++; in writePacket()
232 attempts = 0; in writePacket()
|
| /third_party/musl/src/network/ |
| D | resolvconf.c | 21 conf->attempts = 2; in __get_resolv_conf()
59 conf->attempts = 10; in __get_resolv_conf()
61 conf->attempts = config.retry_count; in __get_resolv_conf()
106 if (z != p) conf->attempts = x > 10 ? 10 : x; in __get_resolv_conf()
|
| D | res_msend.c | 35 int timeout, attempts, retry_interval, servfail_retry; in __res_msend_rc() local
53 attempts = conf->attempts; in __res_msend_rc()
111 retry_interval = timeout / attempts; in __res_msend_rc()
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/base/ |
| D | net.dart | 19 int attempts = 0;
22 attempts += 1;
26 if (maxAttempts != null && attempts >= maxAttempts) {
27 printStatus('Download failed -- retry $attempts');
30 printStatus('Download failed -- attempting retry $attempts in '
|
| /third_party/musl/porting/linux/user/src/network/ |
| D | resolvconf.c | 117 conf->attempts = 2; in __get_resolv_conf()
146 conf->attempts = 10; in __get_resolv_conf()
148 conf->attempts = config.retry_count; in __get_resolv_conf()
197 if (z != p) conf->attempts = x > 10 ? 10 : x; in __get_resolv_conf()
|
| /third_party/skia/modules/canvaskit/tests/ |
| D | util.js | 64 let attempts = 0; variable
66 attempts++;
69 if (attempts < MAX_ATTEMPTS) {
73 … console.error(`got error in fetching ${url} even after ${attempts} attempts`, err);
|
| /third_party/node/deps/npm/node_modules/promise-retry/node_modules/retry/ |
| D | README.md | 44 currentAttempt is an int representing the number of attempts so far.
88 to tune for `10` attempts in `5 minutes`, you can use this equation:
109 …ou then want to calculate a new timeout, you should set `attempt` to 4 (attempts are zero-indexed).
162 …ive an optional `currentAttempt` callback that represents the number of attempts to execute `fn` s…
188 #### retryOperation.attempts()
190 Returns an int representing the number of attempts it took to call `fn` before it was successful.
215 0.2.0 Added attempts() function and parameter to retryOperation.try() representing the number of at…
|
| /third_party/gstreamer/gstplugins_bad/sys/dshowvideosink/ |
| D | dshowvideofakesrc.cpp | 255 int attempts = 0; in PushBuffer() local
265 while (attempts < MAX_ATTEMPTS) in PushBuffer()
270 attempts++; in PushBuffer()
305 while (attempts < MAX_ATTEMPTS) in PushBuffer()
310 attempts++; in PushBuffer()
|
| /third_party/skia/infra/bots/recipe_modules/run/ |
| D | api.py | 81 def with_retry(self, steptype, name, attempts, between_attempts_fn=None, argument
83 for attempt in range(attempts):
94 if attempt == attempts - 1:
|
| /third_party/flutter/skia/infra/bots/recipe_modules/run/ |
| D | api.py | 81 def with_retry(self, steptype, name, attempts, between_attempts_fn=None, argument
83 for attempt in xrange(attempts):
94 if attempt == attempts - 1:
|
| /third_party/flutter/flutter/packages/flutter/lib/src/widgets/ |
| D | will_pop_scope.dart | 9 /// Registers a callback to veto attempts by the user to dismiss the enclosing
17 /// Creates a widget that registers a callback to veto attempts by the user to
33 /// Called to veto attempts by the user to dismiss the enclosing [ModalRoute].
|
| /third_party/python/Objects/stringlib/ |
| D | replace.h | 22 int attempts = 10; in STRINGLIB() local
29 if (!--attempts) { in STRINGLIB()
|
| /third_party/openssl/providers/implementations/rands/seeding/ |
| D | rand_unix.c | 641 int attempts = 3; in ossl_pool_acquire_entropy()
644 while (bytes_needed != 0 && attempts-- > 0) { in ossl_pool_acquire_entropy()
650 attempts = 3; /* reset counter after successful attempt */ in ossl_pool_acquire_entropy()
678 int attempts = 3; in ossl_pool_acquire_entropy()
684 while (bytes_needed != 0 && attempts-- > 0) { in ossl_pool_acquire_entropy()
691 attempts = 3; /* reset counter on successful attempt */ in ossl_pool_acquire_entropy()
|
| /third_party/openssl/doc/man3/ |
| D | BIO_read.pod | 24 BIO_read_ex() attempts to read I<dlen> bytes from BIO I<b> and places the data
28 BIO_write_ex() attempts to write I<dlen> bytes from I<data> to BIO I<b>.
32 BIO_read() attempts to read I<len> bytes from BIO I<b> and places
45 BIO_get_line() attempts to read from BIO <b> a line of data up to the next '\n'
53 BIO_write() attempts to write I<len> bytes from I<buf> to BIO I<b>.
55 BIO_puts() attempts to write a NUL-terminated string I<buf> to BIO I<b>.
|
| D | X509_get_pubkey.pod | 26 X509_get_pubkey() attempts to decode the public key for certificate B<x>. If
37 X509_set_pubkey() attempts to set the public key for certificate B<x> to
|
| /third_party/libbpf/src/ |
| D | bpf.c | 87 int sys_bpf_prog_load(union bpf_attr *attr, unsigned int size, int attempts) in sys_bpf_prog_load() argument
93 } while (fd < 0 && errno == EAGAIN && --attempts > 0); in sys_bpf_prog_load()
240 int fd, attempts; in bpf_prog_load() local
249 attempts = OPTS_GET(opts, attempts, 0); in bpf_prog_load()
250 if (attempts < 0) in bpf_prog_load()
252 if (attempts == 0) in bpf_prog_load()
253 attempts = PROG_LOAD_ATTEMPTS; in bpf_prog_load()
318 fd = sys_bpf_prog_load(&attr, attr_sz, attempts); in bpf_prog_load()
358 fd = sys_bpf_prog_load(&attr, attr_sz, attempts); in bpf_prog_load()
372 fd = sys_bpf_prog_load(&attr, attr_sz, attempts); in bpf_prog_load()
|
| /third_party/skia/infra/bots/recipe_modules/docker/ |
| D | api.py | 32 … script, args=None, docker_args=None, copies=None, recursive_read=None, attempts=1, match_director… argument
97 self.m.run.with_retry(self.m.step, name, attempts, cmd=cmd)
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/radius/ |
| D | radius_client.c | 115 int attempts; member
389 if (entry->attempts == 0) in radius_client_retransmit()
406 if (entry->attempts == 0) in radius_client_retransmit()
467 entry->attempts++; in radius_client_retransmit()
510 if (entry->attempts > RADIUS_CLIENT_NUM_FAILOVER || in radius_client_timer()
511 (s < 0 && entry->attempts > 0)) { in radius_client_timer()
696 entry->attempts = 1; in radius_client_list_add()
1119 entry->attempts = 1; in radius_change_server()
|
| /third_party/flutter/engine/flutter/tools/licenses/lib/ |
| D | README | 4 the code is less than clear. This file attempts to provide an overview.
76 removes comment syntax), the code that attempts to determine what
77 copyrights apply to which licenses, and the code that attempts to
|
| /third_party/flutter/flutter/dev/tools/ |
| D | java_and_objc_doc.dart | 28 /// Returns null if the archive fails to download after [maxTries] attempts.
51 stderr.writeln('Failed to fetch zip archive from: $url after $maxTries attempts. Giving up.');
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/radius/ |
| D | radius_client.c | 116 int attempts; member
390 if (entry->attempts == 0) in radius_client_retransmit()
407 if (entry->attempts == 0) in radius_client_retransmit()
468 entry->attempts++; in radius_client_retransmit()
511 if (entry->attempts >= RADIUS_CLIENT_NUM_FAILOVER || in radius_client_timer()
512 (s < 0 && entry->attempts > 0)) { in radius_client_timer()
697 entry->attempts = 1; in radius_client_list_add()
1129 entry->attempts = 0; in radius_change_server()
|