| /third_party/node/deps/npm/node_modules/retry/test/integration/ |
| H A D | test-retry-operation.js | 9 var attempts = 0; variable
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; variable
104 attempts++;
105 assert.equal(currentAttempt, attempts);
123 var attempts = 0; global() variable
156 var attempts = 0; global() variable
188 var attempts = 0; global() variable
223 var attempts = 0; global() variable
[all...] |
| /third_party/ffmpeg/libavformat/ |
| H A 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()
455 // The connection attempts are sorted from oldest to newest, so the in ff_connect_parallel()
457 next_deadline_us = attempts[0].deadline_us; in ff_connect_parallel()
474 if (getsockopt(attempts[ in ff_connect_parallel()
[all...] |
| H A D | http.c | 356 int ret, attempts = 0, redirects = 0; in http_open_cnx() local
399 attempts++; in http_open_cnx()
402 s->auth_state.auth_type != HTTP_AUTH_NONE && attempts < 4) { in http_open_cnx()
410 s->proxy_auth_state.auth_type != HTTP_AUTH_NONE && attempts < 4) { in http_open_cnx()
439 attempts = 0; in http_open_cnx()
2050 int port, ret = 0, attempts = 0; in http_proxy_open() local
2110 attempts++; in http_proxy_open()
2113 s->proxy_auth_state.auth_type != HTTP_AUTH_NONE && attempts < 2) { in http_proxy_open()
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/time/ |
| H A D | clock_test.cc | 54 AlarmPolicy alarm_policy, int* attempts) { in SleepForBounded()
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()
52 SleepForBounded(absl::Duration d, absl::Duration lower_bound, absl::Duration upper_bound, absl::Duration timeout, AlarmPolicy alarm_policy, int* attempts) SleepForBounded() argument
|
| /third_party/skia/modules/canvaskit/tests/ |
| H A D | util.js | 64 let attempts = 0;
66 attempts++;
69 if (attempts < MAX_ATTEMPTS) {
73 console.error(`got error in fetching ${url} even after ${attempts} attempts`, err);
|
| /third_party/ltp/testcases/kernel/controllers/memcg/ |
| H A D | memcontrol03.c | 157 size_t attempts; in test_memcg_min() local
196 for (attempts = 0; attempts < 5; attempts++) { in test_memcg_min()
|
| /third_party/python/Objects/stringlib/ |
| H A D | replace.h | 22 int attempts = 10; in replace_1char_inplace() local
29 if (!--attempts) { in replace_1char_inplace()
30 /* if u1 was not found for attempts iterations, in replace_1char_inplace()
|
| /third_party/skia/infra/bots/recipe_modules/run/ |
| H A D | api.py | 81 def with_retry(self, steptype, name, attempts, between_attempts_fn=None,
83 for attempt in range(attempts):
94 if attempt == attempts - 1:
|
| /third_party/musl/porting/linux/user/src/network/ |
| H A D | resolvconf.c | 132 conf->attempts = 2; in get_resolv_conf_ext()
161 conf->attempts = 10; in get_resolv_conf_ext()
163 conf->attempts = config.retry_count; in get_resolv_conf_ext()
208 p = strstr(line, "attempts:"); in get_resolv_conf_ext()
212 if (z != p) conf->attempts = x > 10 ? 10 : x; in get_resolv_conf_ext()
|
| H A D | res_msend.c | 43 int timeout, attempts, retry_interval, servfail_retry; in res_msend_rc_ext() local
61 attempts = conf->attempts; in res_msend_rc_ext()
126 retry_interval = timeout / attempts; in res_msend_rc_ext()
|
| /third_party/musl/src/network/ |
| H A D | resolvconf.c | 118 conf->attempts = 2; in get_resolv_conf_ext()
151 conf->attempts = 10; in get_resolv_conf_ext()
153 conf->attempts = config.retry_count; in get_resolv_conf_ext()
202 p = strstr(line, "attempts:"); in get_resolv_conf_ext()
206 if (z != p) conf->attempts = x > 10 ? 10 : x; in get_resolv_conf_ext()
|
| H A D | res_msend.c | 104 int timeout, attempts, retry_interval, servfail_retry; in res_msend_rc_ext() local
125 attempts = conf->attempts; in res_msend_rc_ext()
216 retry_interval = timeout / attempts; in res_msend_rc_ext()
|
| /third_party/musl/libc-test/src/functionalext/supplement/network/ |
| H A D | nameservercheck_client.c | 45 unsigned nns, attempts, ndots; member
112 int timeout, attempts, retry_interval, servfail_retry; in res_msend_rc_ext() local
133 attempts = conf->attempts; in res_msend_rc_ext()
201 retry_interval = timeout / attempts; in res_msend_rc_ext()
396 // timeout: 查询超时时间，attempts: 失败重试次数, nns: nameserver数量 in main()
399 .attempts = 2, in main()
|
| /third_party/node/deps/openssl/openssl/providers/implementations/rands/seeding/ |
| H A D | rand_unix.c | 640 /* Maximum allowed number of consecutive unsuccessful attempts */ in ossl_pool_acquire_entropy()
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()
677 /* Maximum number of consecutive unsuccessful attempts */ 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/providers/implementations/rands/seeding/ |
| H A D | rand_unix.c | 640 /* Maximum allowed number of consecutive unsuccessful attempts */ in ossl_pool_acquire_entropy()
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()
677 /* Maximum number of consecutive unsuccessful attempts */ 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/skia/infra/bots/recipe_modules/docker/ |
| H A D | api.py | 32 def run(self, name, docker_image, src_dir, out_dir, script, args=None, docker_args=None, copies=None, recursive_read=None, attempts=1, match_directory_structure=False):
97 self.m.run.with_retry(self.m.step, name, attempts, cmd=cmd)
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/radius/ |
| H A D | radius_client.c | 47 * The number of failed retry attempts after which the RADIUS server will be
113 * attempts - Number of transmission attempts for one server
115 int attempts; member
118 * accu_attempts - Number of accumulated attempts
323 * transmission attempts of interim accounting update messages.
389 if (entry->attempts == 0) in radius_client_retransmit()
406 if (entry->attempts == 0) in radius_client_retransmit()
459 /* retransmit; remove entry if too many attempts */ in radius_client_retransmit()
463 "RADIUS: Removing un-ACKed message due to too many failed retransmit attempts"); in radius_client_retransmit()
[all...] |
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/radius/ |
| H A D | radius_client.c | 48 * The number of failed retry attempts after which the RADIUS server will be
114 * attempts - Number of transmission attempts for one server
116 int attempts; member
119 * accu_attempts - Number of accumulated attempts
324 * transmission attempts of interim accounting update messages.
390 if (entry->attempts == 0) in radius_client_retransmit()
407 if (entry->attempts == 0) in radius_client_retransmit()
460 /* retransmit; remove entry if too many attempts */ in radius_client_retransmit()
464 "RADIUS: Removing un-ACKed message due to too many failed retransmit attempts"); in radius_client_retransmit()
[all...] |
| /third_party/libbpf/src/ |
| H A 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()
314 fd = sys_bpf_prog_load(&attr, attr_sz, attempts); in bpf_prog_load()
355 fd = sys_bpf_prog_load(&attr, attr_sz, attempts); in bpf_prog_load()
[all...] |
| /third_party/mbedtls/library/ |
| H A D | entropy.c | 500 size_t attempts = buf_len; in mbedtls_entropy_source_self_test_gather() local
502 while (attempts > 0 && entropy_len < buf_len) { in mbedtls_entropy_source_self_test_gather()
509 attempts--; in mbedtls_entropy_source_self_test_gather()
|
| /third_party/skia/infra/bots/recipes/ |
| H A D | perf_pathkit.py | 93 attempts=3,
|
| H A D | test_lottie_web.py | 88 attempts=3,
|
| H A D | test_canvaskit.py | 77 attempts=3,
|
| H A D | perf_skottiewasm_lottieweb.py | 149 attempts = 3
151 api.run.with_retry(api.step, 'Run perf cmd line app', attempts,
|
| /third_party/skia/infra/bots/gen_tasks_logic/ |
| H A D | gen_tasks_logic.go | 604 b.attempts(1)
607 b.attempts(2)
1297 b.attempts(2)
1368 b.attempts(1)
1623 b.attempts(1)
1668 b.attempts(1)
1911 b.attempts(1)
1944 b.attempts(1)
|