/third_party/node/deps/npm/node_modules/promise-retry/test/ |
H A D | test.js | 7 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 D | options.js | 16 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 D | test-retry-operation.js | 4 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 D | test-timeouts.js | 3 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 D | test-retry-wrap.js | 4 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 D | test-forever.js | 3 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 D | random_seed.c | 33 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()
|
/foundation/window/window_manager/wmserver/src/ |
H A D | window_common_event.cpp | 58 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()
|
/third_party/curl/tests/libtest/ |
H A D | lib1594.c | 34 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/communication/netmanager_base/services/netmanagernative/src/netsys/ |
H A D | netsys_tcp_client.c | 60 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 D | monitor.c | 165 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...] |
/third_party/toybox/toys/pending/ |
H A D | tftp.c | 219 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/communication/dsoftbus/adapter/common/bus_center/driver/ |
H A D | lnn_hdf_driver_monitor.c | 125 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 D | config.js | 72 retry: options.retry ?? exports.DEFAULT_RETRY, 96 retry: options.retry ?? exports.DEFAULT_RETRY, 103 retry: options.retry ?? exports.DEFAULT_RETRY,
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/ |
H A D | softbus_adapter.cpp | 96 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 D | distributed_module_config.cpp | 59 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 D | rdrand_sanitytest.c | 34 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 D | stop.js | 1 var retry = require('../lib/retry'); variable 11 var operation = retry.operation(opts); 21 if (operation.retry(err)) {
|
H A D | dns.js | 2 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 D | index.js | 4 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 D | app_spawn_client.cpp | 78 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 D | sync_event.cpp | 19 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()
|
/third_party/ltp/tools/genload/ |
H A D | stress.c | 38 /* 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...] |
H A D | genload.c | 38 /* 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...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/account/src/ |
H A D | account_delegate_normal_impl.cpp | 139 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()
|