| /dports/databases/hbase/hbase-1.2.1/hbase-common/src/main/java/org/apache/hadoop/hbase/util/ |
| H A D | RetryCounter.java | 35 private long sleepInterval; field in RetryCounter.RetryConfig
44 sleepInterval = 1000; in RetryConfig()
50 public RetryConfig(int maxAttempts, long sleepInterval, long maxSleepTime, in RetryConfig() argument
53 this.sleepInterval = sleepInterval; in RetryConfig()
74 public RetryConfig setSleepInterval(long sleepInterval) { in setSleepInterval() argument
75 this.sleepInterval = sleepInterval; in setSleepInterval()
93 return sleepInterval; in getSleepInterval()
135 public RetryCounter(int maxAttempts, long sleepInterval, TimeUnit timeUnit) { in RetryCounter() argument
136 this(new RetryConfig(maxAttempts, sleepInterval, -1, timeUnit, new ExponentialBackoffPolicy())); in RetryCounter()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/balancer/ |
| H A D | KeyManager.java | 138 private final long sleepInterval; field in KeyManager.BlockKeyUpdater
140 BlockKeyUpdater(final long sleepInterval) { in BlockKeyUpdater() argument
141 this.sleepInterval = sleepInterval; in BlockKeyUpdater()
142 LOG.info("Update block keys every " + StringUtils.formatTime(sleepInterval)); in BlockKeyUpdater()
154 Thread.sleep(sleepInterval); in run()
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/ |
| H A D | watcher.go | 20 const sleepInterval = 50 * time.Millisecond
24 time.Sleep(sleepInterval)
33 time.Sleep(sleepInterval)
|
| /dports/www/trafficserver/trafficserver-9.1.1/plugins/experimental/ssl_session_reuse/src/ |
| H A D | ssl_key_utils.cc | 253 int sleepInterval; in STEK_Update_Setter_Thread() local
279 sleepInterval = 60; // short sleep for error retry in STEK_Update_Setter_Thread()
280 …rror("Could not create/send new STEK for key rotation... Try again in %d seconds.", sleepInterval); in STEK_Update_Setter_Thread()
286 sleepInterval = ssl_param.key_update_interval; in STEK_Update_Setter_Thread()
289 ::sleep(sleepInterval); in STEK_Update_Setter_Thread()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/capacity-scheduler/src/java/org/apache/hadoop/mapred/ |
| H A D | CapacitySchedulerConf.java | 445 long sleepInterval = rmConf.getLong( in getSleepInterval() local
449 if(sleepInterval <= 0) { in getSleepInterval()
451 "Invalid initializater poller interval " + sleepInterval); in getSleepInterval()
454 return sleepInterval; in getSleepInterval()
|
| H A D | JobInitializationPoller.java | 76 private long sleepInterval; field in JobInitializationPoller
111 Thread.sleep(sleepInterval); in run()
243 sleepInterval = capacityConf.getSleepInterval(); in init()
285 Thread.sleep(sleepInterval); in run()
|
| /dports/devel/ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/ |
| H A D | ProxyFactory.java | 80 …tryAfterException(Ice.LocalException ex, Reference ref, Ice.Holder<Integer> sleepInterval, int cnt) in checkRetryAfterException() argument
119 if(sleepInterval != null) in checkRetryAfterException()
121 sleepInterval.value = 0; in checkRetryAfterException()
248 sleepInterval.value = interval; in checkRetryAfterException()
|
| /dports/devel/py-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/ |
| H A D | ProxyFactory.java | 80 …tryAfterException(Ice.LocalException ex, Reference ref, Ice.Holder<Integer> sleepInterval, int cnt) in checkRetryAfterException() argument
119 if(sleepInterval != null) in checkRetryAfterException()
121 sleepInterval.value = 0; in checkRetryAfterException()
248 sleepInterval.value = interval; in checkRetryAfterException()
|
| /dports/devel/php-ice37/ice-3.7.2/java-compat/src/Ice/src/main/java/IceInternal/ |
| H A D | ProxyFactory.java | 80 …tryAfterException(Ice.LocalException ex, Reference ref, Ice.Holder<Integer> sleepInterval, int cnt) in checkRetryAfterException() argument
119 if(sleepInterval != null) in checkRetryAfterException()
121 sleepInterval.value = 0; in checkRetryAfterException()
248 sleepInterval.value = interval; in checkRetryAfterException()
|
| /dports/devel/ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/ |
| H A D | ProxyFactory.java | 78 …erException(com.zeroc.Ice.LocalException ex, Reference ref, Holder<Integer> sleepInterval, int cnt) in checkRetryAfterException() argument
116 if(sleepInterval != null) in checkRetryAfterException()
118 sleepInterval.value = 0; in checkRetryAfterException()
246 sleepInterval.value = interval; in checkRetryAfterException()
|
| /dports/devel/php-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/ |
| H A D | ProxyFactory.java | 78 …erException(com.zeroc.Ice.LocalException ex, Reference ref, Holder<Integer> sleepInterval, int cnt) in checkRetryAfterException() argument
116 if(sleepInterval != null) in checkRetryAfterException()
118 sleepInterval.value = 0; in checkRetryAfterException()
246 sleepInterval.value = interval; in checkRetryAfterException()
|
| /dports/devel/py-ice37/ice-3.7.2/java/src/Ice/src/main/java/com/zeroc/IceInternal/ |
| H A D | ProxyFactory.java | 78 …erException(com.zeroc.Ice.LocalException ex, Reference ref, Holder<Integer> sleepInterval, int cnt) in checkRetryAfterException() argument
116 if(sleepInterval != null) in checkRetryAfterException()
118 sleepInterval.value = 0; in checkRetryAfterException()
246 sleepInterval.value = interval; in checkRetryAfterException()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/test/java/org/apache/hadoop/yarn/sls/nodemanager/ |
| H A D | TestNMSimulator.java | 59 int sleepInterval = 100; in testNMSimulator() local
62 Thread.sleep(sleepInterval); in testNMSimulator()
63 cumulativeSleepTime = cumulativeSleepTime + sleepInterval; in testNMSimulator()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-common/src/test/java/org/apache/hadoop/hbase/ |
| H A D | Waiter.java | 184 long sleepInterval = 0; in waitFor() local
195 sleepInterval = (remainderWait > interval) ? interval : remainderWait; in waitFor()
196 Thread.sleep(sleepInterval); in waitFor()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongostat/main/ |
| H A D | mongostat.go | 83 sleepInterval := 1
90 sleepInterval, err = strconv.Atoi(args[0])
95 if sleepInterval < 1 {
235 SleepInterval: time.Duration(sleepInterval) * time.Second,
|
| /dports/databases/mongodb42-tools/mongo-tools-r4.2.17/mongostat/main/ |
| H A D | mongostat.go | 88 sleepInterval := 1
95 sleepInterval, err = strconv.Atoi(args[0])
100 if sleepInterval < 1 {
245 SleepInterval: time.Duration(sleepInterval) * time.Second,
|
| /dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Data/System/Data/SqlClient/ |
| H A D | SqlInternalConnectionTds.cs | 1427 int sleepInterval = 100; //milliseconds to sleep (back off) between attempts. in SqlInternalConnectionTds()
1561 if (timeout.MillisecondsRemaining <= sleepInterval) { in SqlInternalConnectionTds()
1600 Thread.Sleep(sleepInterval); in SqlInternalConnectionTds()
1601 sleepInterval = (sleepInterval < 500) ? sleepInterval * 2 : 1000; in SqlInternalConnectionTds()
1772 if (timeout.MillisecondsRemaining <= sleepInterval) { in SqlInternalConnectionTds()
1788 Thread.Sleep(sleepInterval); in SqlInternalConnectionTds()
1789 sleepInterval = (sleepInterval < 500) ? sleepInterval * 2 : 1000; in SqlInternalConnectionTds()
2263 int sleepInterval = 100; in SqlInternalConnectionTds()
2321 || _timeout.MillisecondsRemaining <= sleepInterval) { in SqlInternalConnectionTds()
2346 Thread.Sleep(sleepInterval); in SqlInternalConnectionTds()
[all …]
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Data.SqlClient/src/System/Data/SqlClient/ |
| H A D | SqlInternalConnectionTds.cs | 1221 int sleepInterval = 100; //milliseconds to sleep (back off) between attempts. in LoginNoFailover()
1330 if (timeout.MillisecondsRemaining <= sleepInterval) in LoginNoFailover()
1364 Thread.Sleep(sleepInterval); in LoginNoFailover()
1365 sleepInterval = (sleepInterval < 500) ? sleepInterval * 2 : 1000; in LoginNoFailover()
1405 int sleepInterval = 100; //milliseconds to sleep (back off) between attempts. in LoginWithFailover()
1511 if (timeout.MillisecondsRemaining <= sleepInterval) in LoginWithFailover()
1524 Thread.Sleep(sleepInterval); in LoginWithFailover()
1525 sleepInterval = (sleepInterval < 500) ? sleepInterval * 2 : 1000; in LoginWithFailover()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/ |
| H A D | TestContainerResourceUsage.java | 104 int sleepInterval = 1000; in testUsageWithOneAttemptAndOneContainer() local
107 Thread.sleep(sleepInterval); in testUsageWithOneAttemptAndOneContainer()
108 cumulativeSleepTime += sleepInterval; in testUsageWithOneAttemptAndOneContainer()
190 int sleepInterval = 1000; in testUsageWithMultipleContainersAndRMRestart() local
194 Thread.sleep(sleepInterval); in testUsageWithMultipleContainersAndRMRestart()
195 cumulativeSleepTime += sleepInterval; in testUsageWithMultipleContainersAndRMRestart()
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/executor/ |
| H A D | TestExecutorService.java | 49 int sleepInterval = 10; in testExecutorService() local
80 Thread.sleep(sleepInterval); in testExecutorService()
103 Thread.sleep(sleepInterval); in testExecutorService()
|
| /dports/deskutils/mindforger/mindforger-1.52.0/app/src/qt/gear/ |
| H A D | async_task_notifications_distributor.cpp | 28 sleepInterval = Configuration::getInstance().getDistributorSleepInterval(); in AsyncTaskNotificationsDistributor()
68 msleep(static_cast<unsigned long>(sleepInterval)); in run()
223 sleepInterval = Configuration::getInstance().getDistributorSleepInterval(); in slotConfigurationUpdated()
|
| /dports/devel/spark/spark-2.1.1/yarn/src/main/scala/org/apache/spark/deploy/yarn/ |
| H A D | ApplicationMaster.scala | 483 var sleepInterval = 200L // ms variable
485 sleepInterval =
496 allocatorLock.wait(sleepInterval)
499 if (sleepDuration < sleepInterval) {
502 s"Slept for $sleepDuration/$sleepInterval ms.")
514 s"Slept for $sleepDuration/$sleepInterval.")
|
| /dports/misc/concourse/concourse-6.7.2/vendor/k8s.io/client-go/util/certificate/ |
| H A D | certificate_manager.go | 254 if sleepInterval := deadline.Sub(time.Now()); sleepInterval > 0 {
255 klog.V(2).Infof("Waiting %v for next certificate rotation", sleepInterval)
257 timer := time.NewTimer(sleepInterval)
|
| /dports/sysutils/gomplate/gomplate-3.9.0/vendor/k8s.io/client-go/util/certificate/ |
| H A D | certificate_manager.go | 254 if sleepInterval := deadline.Sub(time.Now()); sleepInterval > 0 {
255 klog.V(2).Infof("Waiting %v for next certificate rotation", sleepInterval)
257 timer := time.NewTimer(sleepInterval)
|
| /dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/k8s.io/client-go/client-go-0.16.8/util/certificate/ |
| H A D | certificate_manager.go | 259 if sleepInterval := deadline.Sub(time.Now()); sleepInterval > 0 {
260 klog.V(2).Infof("Waiting %v for next certificate rotation", sleepInterval)
262 timer := time.NewTimer(sleepInterval)
|