Home
last modified time | relevance | path

Searched refs:retry (Results 1 - 25 of 352) sorted by relevance

12345678910>>...15

/third_party/node/deps/npm/node_modules/promise-retry/test/
H A Dtest.js7 describe('promise-retry', function () {
8 it('should call fn again if retry was called', function () {
11 return promiseRetry(function (retry) {
17 retry(new Error('foo'));
34 return promiseRetry(function (retry, number) {
41 retry(new Error('foo'));
55 it('should not retry on fulfillment if retry was not called', function () {
74 it('should not retry on rejection if retry wa
[all...]
/third_party/node/deps/npm/node_modules/make-fetch-happen/lib/
H A Doptions.js16 if (!options.retry) {
17 options.retry = { retries: 0 }
18 } else if (typeof options.retry === 'string') {
19 const retries = parseInt(options.retry, 10)
21 options.retry = { retries }
23 options.retry = { retries: 0 }
25 } else if (typeof options.retry === 'number') {
26 options.retry = { retries: options.retry }
28 options.retry
[all...]
/third_party/node/deps/npm/node_modules/retry/test/integration/
H A Dtest-retry-operation.js4 var retry = require(common.dir.lib + '/retry'); variable
8 var operation = retry.operation([1, 2, 3]);
21 if (operation.retry(error)) {
46 var operation = retry.operation();
57 var operation = retry.operation();
69 var operation = retry.operation();
80 var operation = retry.operation();
96 var operation = retry.operation([1, 2, 3]);
106 if (operation.retry(erro
[all...]
H A Dtest-timeouts.js3 var retry = require(common.dir.lib + '/retry'); variable
6 var timeouts = retry.timeouts();
16 var timeouts = retry.timeouts({
29 var timeouts = retry.timeouts(timeoutsArray);
37 var timeouts = retry.timeouts({
48 var timeouts = retry.timeouts();
57 var timeouts = retry.timeouts({
67 var timeouts = retry.timeouts({retries: 2});
H A Dtest-retry-wrap.js4 var retry = require(common.dir.lib + '/retry'); variable
16 retry.wrap(lib);
24 retry.wrap(lib, {retries: 2});
35 retry.wrap(lib, ['fn2', 'fn3']);
43 retry.wrap(lib, {retries: 2}, ['fn2', 'fn3']);
59 retry.wrap(lib);
80 retry.wrap(lib, {}, ['fn1', 'fn2']);
95 retry.wrap(lib, {retries: 1});
H A Dtest-forever.js3 var retry = require(common.dir.lib + '/retry'); variable
6 var operation = retry.operation({
20 if (operation.retry(err)) {
/third_party/ffmpeg/libavutil/tests/
H A Drandom_seed.c33 int i, j, rsf, retry; in main() local
38 for (retry=0; retry<3; retry++){ in main()
43 goto retry; in main()
47 retry:; in main()
49 if (retry >= 3) { in main()
/third_party/curl/tests/libtest/
H A Dlib1594.c34 curl_off_t retry; in test() local
48 res = curl_easy_getinfo(curl, CURLINFO_RETRY_AFTER, &retry); in test()
55 retry += time(NULL); in test()
56 retry /= 10000; in test()
58 printf("Retry-After %" CURL_FORMAT_CURL_OFF_T "\n", retry); in test()
/foundation/window/window_manager/wmserver/src/
H A Dwindow_common_event.cpp58 int retry = RETRY_MAX_COUNT; in SubscriberEvent() local
59 SubscriberEventInner(retry); in SubscriberEvent()
62 void WindowCommonEvent::SubscriberEventInner(int retry) in SubscriberEventInner() argument
64 if (retry <= 0) { in SubscriberEventInner()
67 retry--; in SubscriberEventInner()
68 WLOGI("called action = %{public}d", retry); in SubscriberEventInner()
72 std::function<void()> func = [this, retry]() { this->SubscriberEventInner(retry); }; in SubscriberEventInner()
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dnetsys_tcp_client.c60 int64_t Poll(int sock, short event, int *retry) in Poll() argument
73 if (*retry < MAX_POLL_RETRY) { in Poll()
74 ++(*retry); in Poll()
88 int retry = 0; in ProcData() local
90 int32_t resPoll = Poll(sock, event, &retry); in ProcData()
99 if (errno == EAGAIN && retry < MAX_POLL_RETRY) { in ProcData()
100 ++retry; in ProcData()
/third_party/alsa-utils/alsactl/
H A Dmonitor.c165 static int check_control_cdev(int infd, bool *retry) in check_control_cdev() argument
190 *retry = true; in check_control_cdev()
303 bool *retry) in run_dispatcher()
339 err = check_control_cdev(infd, retry); in run_dispatcher()
340 if (err < 0 || *retry) in run_dispatcher()
399 bool retry; in monitor() local
422 retry: in monitor()
423 retry = false; in monitor()
430 err = run_dispatcher(epfd, sigfd, infd, &srcs, &retry); in monitor()
433 if (retry) { in monitor()
302 run_dispatcher(int epfd, int sigfd, int infd, struct list_head *srcs, bool *retry) run_dispatcher() argument
[all...]
/foundation/communication/dsoftbus/adapter/common/bus_center/driver/
H A Dlnn_hdf_driver_monitor.c125 static int32_t retry = 0; in DelayInitFunction() local
128 if (retry >= MAX_BIND_HDF_RETRY_COUNT) { in DelayInitFunction()
133 LNN_LOGE(LNN_INIT, "get hdf dsoftbus service fail=%{public}d", retry); in DelayInitFunction()
135 ++retry; in DelayInitFunction()
139 LNN_LOGI(LNN_INIT, "init hdf driver monitor=%{public}d, result=%{public}d", retry, rc); in DelayInitFunction()
145 ++retry; in DelayInitFunction()
/third_party/node/deps/npm/node_modules/sigstore/dist/
H A Dconfig.js72 retry: options.retry ?? exports.DEFAULT_RETRY,
96 retry: options.retry ?? exports.DEFAULT_RETRY,
103 retry: options.retry ?? exports.DEFAULT_RETRY,
/third_party/toybox/toys/pending/
H A Dtftp.c219 int packetlen, retry; in read_ack() local
221 for (retry = 0; retry < TFTP_RETRIES; retry++) { in read_ack()
272 int len, sd, fd, retry, nbytesrecvd = 0, ndatabytes, ret, result = -1; in file_get() local
290 for (retry = 0 ; retry < TFTP_RETRIES; retry++) { in file_get()
302 retry--; in file_get()
314 retry in file_get()
388 int packetlen, sd, fd, retry = 0, ret, result = -1; file_put() local
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/
H A Dsoftbus_adapter.cpp96 int32_t SoftbusAdapter::DealSendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry) in DealSendSoftbusEvent() argument
118 return RetrySendSoftbusEvent(buffer, retry); in DealSendSoftbusEvent()
123 int32_t SoftbusAdapter::RetrySendSoftbusEvent(std::shared_ptr<DSchedDataBuffer> buffer, const int32_t retry) in RetrySendSoftbusEvent() argument
125 HILOGI("Retry post broadcast, current retry times %{public}d", retry); in RetrySendSoftbusEvent()
126 if (retry == RETRY_SENT_EVENT_MAX_TIME) { in RetrySendSoftbusEvent()
127 HILOGE("meet max retry time!"); in RetrySendSoftbusEvent()
130 auto feedfunc = [this, buffer, retry]() mutable { in RetrySendSoftbusEvent()
131 DealSendSoftbusEvent(buffer, retry + 1); in RetrySendSoftbusEvent()
/foundation/distributeddatamgr/pasteboard/framework/framework/device/
H A Ddistributed_module_config.cpp59 uint32_t retry = 0; in GetRetryTask()
61 while (retry < RETRY_TIMES) { in GetRetryTask()
62 ++retry; in GetRetryTask()
66 "dp load err, retry:%{public}d, status_:%{public}d" in GetRetryTask()
68 retry, status_, status); in GetRetryTask()
77 retry, status_, status); in GetRetryTask()
/third_party/openssl/test/
H A Drdrand_sanitytest.c34 int retry; in sanity_check_bytes() local
35 for (retry = 0; retry < max_retries; retry++) { in sanity_check_bytes()
89 * multiplied by the 8x retry loop in asm, and failure probabilities are in sanity_check_rdseed_bytes()
/third_party/node/deps/npm/node_modules/retry/example/
H A Dstop.js1 var retry = require('../lib/retry'); variable
11 var operation = retry.operation(opts);
21 if (operation.retry(err)) {
H A Ddns.js2 var retry = require('../lib/retry'); variable
12 var operation = retry.operation(opts);
16 if (operation.retry(err)) {
/third_party/node/deps/npm/node_modules/promise-retry/
H A Dindex.js4 var retry = require('retry'); variable
23 operation = retry.operation(options);
41 if (operation.retry(err || new Error())) {
/foundation/ability/ability_lite/services/abilitymgr_lite/src/client/
H A Dapp_spawn_client.cpp78 int retry = 0; in CallingInnerSpawnProcess() local
79 while (result != EC_SUCCESS && retry < RETRY_TIMES_MAX) { in CallingInnerSpawnProcess()
80 ++retry; in CallingInnerSpawnProcess()
81 PRINTI("AppManager", "invoke fail: %{public}d, retry times: %{public}d", result, retry); in CallingInnerSpawnProcess()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dsync_event.cpp19 SyncEvent::EventInfo::EventInfo(int32_t mode, int32_t wait, bool retry, std::shared_ptr<GenQuery> query, GenAsync async) in EventInfo() argument
20 : retry_(retry), mode_(mode), wait_(wait), query_(std::move(query)), asyncDetail_(std::move(async)) in EventInfo()
24 SyncEvent::EventInfo::EventInfo(const SyncParam &syncParam, bool retry, std::shared_ptr<GenQuery> query, GenAsync async) in EventInfo() argument
25 : retry_(retry), mode_(syncParam.mode), wait_(syncParam.wait), query_(std::move(query)), in EventInfo()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/
H A Daccount_delegate_normal_impl.cpp139 ExecutorPool::Task AccountDelegateNormalImpl::GetTask(uint32_t retry) in GetTask() argument
141 return [this, retry] { in GetTask()
147 ZLOGD("fail to register subscriber, error:%{public}d, time:%{public}d", result, retry); in GetTask()
149 if (retry + 1 > MAX_RETRY_TIME) { in GetTask()
153 executors_->Schedule(std::chrono::seconds(RETRY_WAIT_TIME_S), GetTask(retry + 1)); in GetTask()
/third_party/skia/infra/bots/task_drivers/canary/
H A Dcanary.go81 for retry := 0; ; retry++ {
83 if retry > 0 {
84 retryText = fmt.Sprintf(" (Retry #%d)", retry)
109 if retry >= (retryAttempts - 1) {
119 // retry loop.
/third_party/ltp/tools/genload/
H A Dstress.c38 /* By default, retry on non-critical errors every 50ms. */
136 } else if (strcmp(arg, "--no-retry") == 0) { in main()
140 } else if (strcmp(arg, "--retry-delay") == 0) { in main()
141 assert_arg("--retry-delay"); in main()
143 dbg(stdout, "setting retry delay to %dus\n", in main()
341 " --no-retry exit rather than retry non-critical errors\n" in usage()
342 " --retry-delay n wait n us before continuing past error\n" in usage()
473 int retry = global_retry; in hogcpu() local
496 usleep(retry); in hogcpu()
549 int retry = global_retry; hogio() local
625 int retry = global_retry; hogvm() local
748 int retry = global_retry; hoghdd() local
[all...]

Completed in 8 milliseconds

12345678910>>...15