| /dports/net/rclone/rclone-1.57.0/lib/pacer/ |
| H A D | pacer.go | 37 retries int // Max number of retries member
55 func RetriesOption(retries int) Option {
56 return func(p *pacerOptions) { p.retries = retries }
79 retries: 3,
122 func (p *Pacer) SetRetries(retries int) {
125 p.retries = retries
193 func (p *Pacer) call(fn Paced, retries int) (err error) {
195 for i := 1; i <= retries; i++ {
197 retry, err = p.invoker(i, retries, fn)
214 retries := p.retries
[all …]
|
| /dports/net-mgmt/icingaweb2-module-reactbundle/icingaweb2-module-reactbundle-0.9.0/vendor/react/dns/src/Query/ |
| H A D | RetryExecutor.php | 12 private $retries; variable in React\\Dns\\Query\\RetryExecutor
14 public function __construct(ExecutorInterface $executor, $retries = 2) argument
17 $this->retries = $retries;
22 return $this->tryQuery($query, $this->retries);
25 public function tryQuery(Query $query, $retries) argument
39 …k = function ($e) use ($deferred, &$promise, $query, $success, &$errorback, &$retries, $executor) {
43 } elseif ($retries <= 0) {
71 --$retries;
|
| /dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/general/tests/unit/plugins/module_utils/cloud/ |
| H A D | test_backoff.py | 15 strategy = _exponential_backoff(retries=0)
20 strategy = _exponential_backoff(retries=5, delay=1, backoff=2)
25 strategy = _exponential_backoff(retries=7, delay=1, backoff=2, max_delay=60)
30 strategy = _exponential_backoff(retries=7, delay=1, backoff=2, max_delay=None)
37 strategy = _full_jitter_backoff(retries=0)
42 retries = 5
46 expected = [r.randint(0, 2**i) for i in range(0, retries)]
49 retries=retries, delay=1, _random=random.Random(seed))
|
| /dports/audio/ampache/ampache-php74-5.0.0/vendor/react/dns/src/Query/ |
| H A D | RetryExecutor.php | 12 private $retries; variable in React\\Dns\\Query\\RetryExecutor
14 public function __construct(ExecutorInterface $executor, $retries = 2) argument
17 $this->retries = $retries;
22 return $this->tryQuery($query, $this->retries);
25 public function tryQuery(Query $query, $retries) argument
39 …k = function ($e) use ($deferred, &$promise, $query, $success, &$errorback, &$retries, $executor) {
43 } elseif ($retries <= 0) {
71 --$retries;
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/urllib3/test/with_dummyserver/ |
| H A D | test_connectionpool.py | 132 pool.request("GET", url, retries=retries)
445 retries=0,
770 retries=0,
778 retries=1,
937 retries=10,
979 retries=True,
1002 retries=True,
1012 retries=True,
1114 self.host, self.port, maxsize=10, retries=retries, block=True
1122 retries = Retry(
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/retry/ |
| H A D | RetryPolicies.java | 208 if (retries >= maxRetries) { in shouldRetry()
212 timeUnit.toMillis(calculateSleepTime(retries))); in shouldRetry()
215 protected abstract long calculateSleepTime(int retries); in calculateSleepTime() argument
248 protected long calculateSleepTime(int retries) { in calculateSleepTime() argument
265 protected long calculateSleepTime(int retries) { in calculateSleepTime() argument
266 return sleepTime * (retries + 1); in calculateSleepTime()
397 if (retries == -1) { in parseCommaSeparatedString()
503 protected long calculateSleepTime(int retries) { in calculateSleepTime() argument
566 if (retries - failovers > maxRetries) { in shouldRetry()
583 getFailoverOrRetrySleepTime(retries)); in shouldRetry()
[all …]
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/third_party/botocore/ |
| H A D | args.py | 168 retries=client_config.retries,
328 retries = config_kwargs.get('retries')
329 if retries is not None:
333 if 'max_attempts' in retries:
345 if retries is None:
346 retries = {}
351 retries = config_kwargs.get('retries')
352 if retries is None:
353 retries = {}
355 elif 'mode' in retries:
[all …]
|
| /dports/devel/py-botocore/botocore-1.21.61/botocore/ |
| H A D | args.py | 170 retries=client_config.retries,
330 retries = config_kwargs.get('retries')
331 if retries is not None:
335 if 'max_attempts' in retries:
347 if retries is None:
348 retries = {}
353 retries = config_kwargs.get('retries')
354 if retries is None:
355 retries = {}
357 elif 'mode' in retries:
[all …]
|
| /dports/devel/py-botocore/botocore-1.21.61/tests/unit/ |
| H A D | test_args.py | 328 self.assertEqual(config.retries['total_max_attempts'], 4)
332 client_config=Config(retries={'max_attempts': 2})
334 self.assertEqual(config.retries['total_max_attempts'], 3)
339 client_config=Config(retries={'max_attempts': 2})
352 client_config=Config(retries=None)
354 self.assertEqual(config.retries, {'mode': 'legacy'})
359 self.assertEqual(config.retries['mode'], 'standard')
363 client_config=Config(retries={'mode': 'standard'})
365 self.assertEqual(config.retries['mode'], 'standard')
370 client_config=Config(retries={'mode': 'standard'})
[all …]
|
| /dports/textproc/write-good/write-good-1.0.8/node_modules/rxjs/src/internal/operators/ |
| H A D | retryWhen.ts | 46 private retries?: Observable<any>;
59 let retries: any = this.retries; variable
62 if (!retries) {
66 retries = notifier(errors);
70 retriesSubscription = innerSubscribe(retries, new SimpleInnerSubscriber(this));
79 this.retries = retries;
97 this.retries = undefined;
|
| /dports/www/py-google-cloud-bigtable/google-cloud-bigtable-2.4.0/google/cloud/bigtable_admin_v2/services/bigtable_instance_admin/transports/ |
| H A D | base.py | 176 default_retry=retries.Retry(
191 default_retry=retries.Retry(
206 default_retry=retries.Retry(
221 default_retry=retries.Retry(
242 default_retry=retries.Retry(
257 default_retry=retries.Retry(
272 default_retry=retries.Retry(
293 default_retry=retries.Retry(
308 default_retry=retries.Retry(
323 default_retry=retries.Retry(
[all …]
|
| /dports/multimedia/ustreamer/ustreamer-4.10/src/ustreamer/encoders/omx/ |
| H A D | component.c | 84 int retries = 50; in omx_component_set_state() local
89 } else if (error == OMX_ErrorInsufficientResources && retries) { in omx_component_set_state()
91 if (retries > 45) { in omx_component_set_state()
97 retries -= 1; in omx_component_set_state()
102 } while (retries); in omx_component_set_state()
116 int retries = 50; in _omx_component_wait_port_changed() local
125 retries -= 1; in _omx_component_wait_port_changed()
128 } while (portdef.bEnabled != enabled && retries); in _omx_component_wait_port_changed()
138 int retries = 50; in _omx_component_wait_state_changed() local
147 retries -= 1; in _omx_component_wait_state_changed()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/catapult/devil/docs/ |
| H A D | adb_wrapper.md | 21 retries: (optional) Number of retries to attempt.
43 retries: (optional) Number of retries to attempt.
78 retries: (optional) Number of retries to attempt.
88 retries: (optional) Number of retries to attempt.
101 retries: (optional) Number of retries to attempt.
111 retries: (optional) Number of retries to attempt.
133 retries: (optional) Number of retries to attempt.
155 retries: (optional) Number of retries to attempt.
175 retries: (optional) Number of retries to attempt.
198 retries: (optional) Number of retries to attempt.
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/devtools-frontend/src/node_modules/rxjs/src/internal/operators/ |
| H A D | retryWhen.ts | 49 private retries: Observable<any>; property in RetryWhenSubscriber
62 let retries: any = this.retries;
65 if (!retries) {
69 retries = notifier(errors);
73 retriesSubscription = subscribeToResult(this, retries);
82 this.retries = retries;
100 this.retries = null;
|
| /dports/misc/netron/node_modules/rxjs/src/internal/operators/ |
| H A D | retryWhen.ts | 49 private retries: Observable<any>; property in RetryWhenSubscriber
62 let retries: any = this.retries;
65 if (!retries) {
69 retries = notifier(errors);
73 retriesSubscription = subscribeToResult(this, retries);
82 this.retries = retries;
100 this.retries = null;
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/node_modules/rxjs/src/internal/operators/ |
| H A D | retryWhen.ts | 49 private retries: Observable<any>; property in RetryWhenSubscriber
62 let retries: any = this.retries;
65 if (!retries) {
69 retries = notifier(errors);
73 retriesSubscription = subscribeToResult(this, retries);
82 this.retries = retries;
100 this.retries = null;
|
| /dports/lang/spidermonkey60/firefox-60.9.0/third_party/python/requests/requests/packages/urllib3/ |
| H A D | connectionpool.py | 174 if retries is None:
175 retries = Retry.DEFAULT
178 self.retries = retries
523 retries = Retry.from_int(retries, redirect=redirect, default=self.retries)
608 retries = retries.increment(method, url, error=e, _pool=self,
610 retries.sleep()
638 retries = retries.increment(method, url, response=response, _pool=self)
650 retries=retries, redirect=redirect,
657 retries = retries.increment(method, url, response=response, _pool=self)
658 retries.sleep()
[all …]
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/python/requests/requests/packages/urllib3/ |
| H A D | connectionpool.py | 174 if retries is None:
175 retries = Retry.DEFAULT
178 self.retries = retries
523 retries = Retry.from_int(retries, redirect=redirect, default=self.retries)
608 retries = retries.increment(method, url, error=e, _pool=self,
610 retries.sleep()
638 retries = retries.increment(method, url, response=response, _pool=self)
650 retries=retries, redirect=redirect,
657 retries = retries.increment(method, url, response=response, _pool=self)
658 retries.sleep()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/requests/requests/packages/urllib3/ |
| H A D | connectionpool.py | 174 if retries is None:
175 retries = Retry.DEFAULT
178 self.retries = retries
523 retries = Retry.from_int(retries, redirect=redirect, default=self.retries)
608 retries = retries.increment(method, url, error=e, _pool=self,
610 retries.sleep()
638 retries = retries.increment(method, url, response=response, _pool=self)
650 retries=retries, redirect=redirect,
657 retries = retries.increment(method, url, response=response, _pool=self)
658 retries.sleep()
[all …]
|
| /dports/net-mgmt/php80-snmp/php-8.0.15/ext/snmp/tests/ |
| H A D | snmpget.phpt | 18 echo "Single OID, default timeout and retries\n";
20 echo "Single OID, default retries\n";
23 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1.1.1.0', $timeout, $retries));
25 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1.1.1.0'), $timeout, $retries));
27 …get($hostname, $community, array('.1.3.6.1.2.1.1.1.0', '.1.3.6.1.2.1.1.3.0'), $timeout, $retries));
31 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1..1.1.0', $timeout, $retries));
33 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1...1.1.0'), $timeout, $retries));
39 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1.1.1.110', $timeout, $retries));
41 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1.1.1.110'), $timeout, $retries));
49 Single OID, default timeout and retries
[all …]
|
| /dports/lang/php80/php-8.0.15/ext/snmp/tests/ |
| H A D | snmpget.phpt | 18 echo "Single OID, default timeout and retries\n";
20 echo "Single OID, default retries\n";
23 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1.1.1.0', $timeout, $retries));
25 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1.1.1.0'), $timeout, $retries));
27 …get($hostname, $community, array('.1.3.6.1.2.1.1.1.0', '.1.3.6.1.2.1.1.3.0'), $timeout, $retries));
31 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1..1.1.0', $timeout, $retries));
33 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1...1.1.0'), $timeout, $retries));
39 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1.1.1.110', $timeout, $retries));
41 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1.1.1.110'), $timeout, $retries));
49 Single OID, default timeout and retries
[all …]
|
| /dports/www/mod_php80/php-8.0.15/ext/snmp/tests/ |
| H A D | snmpget.phpt | 18 echo "Single OID, default timeout and retries\n";
20 echo "Single OID, default retries\n";
23 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1.1.1.0', $timeout, $retries));
25 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1.1.1.0'), $timeout, $retries));
27 …get($hostname, $community, array('.1.3.6.1.2.1.1.1.0', '.1.3.6.1.2.1.1.3.0'), $timeout, $retries));
31 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1..1.1.0', $timeout, $retries));
33 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1...1.1.0'), $timeout, $retries));
39 var_dump(snmpget($hostname, $community, '.1.3.6.1.2.1.1.1.110', $timeout, $retries));
41 var_dump(snmpget($hostname, $community, array('.1.3.6.1.2.1.1.1.110'), $timeout, $retries));
49 Single OID, default timeout and retries
[all …]
|
| /dports/finance/electrum/Electrum-4.1.5/packages/pip/_vendor/urllib3/ |
| H A D | connectionpool.py | 177 retries=None, argument
195 self.retries = retries
524 retries=None, argument
634 retries = Retry.from_int(retries, redirect=redirect, default=self.retries)
723 retries=retries,
755 retries = retries.increment(
788 retries,
821 retries=retries,
851 retries=retries,
891 retries=None, argument
[all …]
|
| /dports/multimedia/tautulli/Tautulli-2.8.0/lib/urllib3/ |
| H A D | connectionpool.py | 177 retries=None, argument
195 self.retries = retries
524 retries=None, argument
634 retries = Retry.from_int(retries, redirect=redirect, default=self.retries)
723 retries=retries,
755 retries = retries.increment(
788 retries,
821 retries=retries,
851 retries=retries,
891 retries=None, argument
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/python/pip/pip/_vendor/urllib3/ |
| H A D | connectionpool.py | 177 retries=None, argument
195 self.retries = retries
524 retries=None, argument
634 retries = Retry.from_int(retries, redirect=redirect, default=self.retries)
723 retries=retries,
755 retries = retries.increment(
788 retries,
821 retries=retries,
851 retries=retries,
891 retries=None, argument
[all …]
|