/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/ |
H A D | ThrottlingException.java | 44 private long waitInterval; field in ThrottlingException 57 waitInterval = timeFromString(waitTimeStr); in ThrottlingException() 65 this.waitInterval = waitInterval; in ThrottlingException() 74 return this.waitInterval; in getWaitInterval() 78 throwThrottlingException(Type.NumRequestsExceeded, waitInterval); in throwNumRequestsExceeded() 81 public static void throwRequestSizeExceeded(final long waitInterval) in throwRequestSizeExceeded() argument 83 throwThrottlingException(Type.RequestSizeExceeded, waitInterval); in throwRequestSizeExceeded() 88 throwThrottlingException(Type.NumReadRequestsExceeded, waitInterval); in throwNumReadRequestsExceeded() 97 throwThrottlingException(Type.WriteSizeExceeded, waitInterval); in throwWriteSizeExceeded() 101 throwThrottlingException(Type.ReadSizeExceeded, waitInterval); in throwReadSizeExceeded() [all …]
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/ |
H A D | TestRateLimiter.java | 61 long waitInterval = limiter.waitInterval(); in testWaitInterval() local 62 assertEquals(0, waitInterval); in testWaitInterval() 70 assertEquals(0, limiter.waitInterval()); in testWaitInterval() 73 long waitInterval = limiter.waitInterval(); in testWaitInterval() local 77 nowTs = waitInterval; in testWaitInterval() 98 assertEquals(100, limiter.waitInterval(1)); in testOverconsumptionAverageIntervalRefillStrategy() 100 assertEquals(1000, limiter.waitInterval(10)); in testOverconsumptionAverageIntervalRefillStrategy() 108 assertEquals(0, limiter.waitInterval()); in testOverconsumptionAverageIntervalRefillStrategy() 121 assertEquals(1000, limiter.waitInterval(1)); in testOverconsumptionFixedIntervalRefillStrategy() 123 assertEquals(1000, limiter.waitInterval(10)); in testOverconsumptionFixedIntervalRefillStrategy() [all …]
|
/dports/news/nzbget/nzbget-21.1/daemon/util/ |
H A D | Service.cpp | 69 int waitInterval = 60 * 60 * 24; // something very large in Run() local 78 waitInterval = std::min(waitInterval, remaining); in Run() 83 debug("Waiting in ServiceCoordinator: %i", waitInterval); in Run() 84 if (waitInterval > 0) in Run() 87 m_waitCond.WaitFor(m_waitMutex, waitInterval * 1000, [&] { return m_workenUp || IsStopped(); }); in Run()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/ |
H A D | JobEndNotifier.java | 56 protected int waitInterval; //Time (ms) to wait between retrying notification field in JobEndNotifier 74 waitInterval = Math.min( in setConf() 78 waitInterval = (waitInterval < 0) ? 5000 : waitInterval; in setConf() 181 Thread.sleep(waitInterval); in notify()
|
/dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/collector/testbed/testbed/ |
H A D | mock_backend_test.go | 81 waitInterval := time.Millisecond * 5 84 time.Sleep(waitInterval) 87 if waitInterval < time.Millisecond*500 { 88 waitInterval *= 2
|
H A D | test_case.go | 278 waitInterval := time.Millisecond * 5 286 case <-time.After(waitInterval): 292 if waitInterval < time.Millisecond*500 { 293 waitInterval *= 2
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/machine/libmachine/mcnutils/ |
H A D | utils.go | 81 func WaitForSpecificOrError(f func() (bool, error), maxAttempts int, waitInterval time.Duration) er… 90 time.Sleep(waitInterval) 95 func WaitForSpecific(f func() bool, maxAttempts int, waitInterval time.Duration) error { 98 }, maxAttempts, waitInterval)
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/docker/machine/machine-7b7a141da844/libmachine/mcnutils/ |
H A D | utils.go | 81 func WaitForSpecificOrError(f func() (bool, error), maxAttempts int, waitInterval time.Duration) er… 90 time.Sleep(waitInterval) 95 func WaitForSpecific(f func() bool, maxAttempts int, waitInterval time.Duration) error { 98 }, maxAttempts, waitInterval)
|
/dports/sysutils/docker-machine/machine-0.16.2/libmachine/mcnutils/ |
H A D | utils.go | 81 func WaitForSpecificOrError(f func() (bool, error), maxAttempts int, waitInterval time.Duration) er… 90 time.Sleep(waitInterval) 95 func WaitForSpecific(f func() bool, maxAttempts int, waitInterval time.Duration) error { 98 }, maxAttempts, waitInterval)
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/quotas/ |
H A D | TimeBasedLimiter.java | 118 ThrottlingException.throwNumRequestsExceeded(reqsLimiter.waitInterval()); in checkQuota() 122 .waitInterval(writeSize + readSize)); in checkQuota() 127 ThrottlingException.throwNumWriteRequestsExceeded(writeReqsLimiter.waitInterval()); in checkQuota() 130 ThrottlingException.throwWriteSizeExceeded(writeSizeLimiter.waitInterval(writeSize)); in checkQuota() 136 ThrottlingException.throwNumReadRequestsExceeded(readReqsLimiter.waitInterval()); in checkQuota() 139 ThrottlingException.throwReadSizeExceeded(readSizeLimiter.waitInterval(readSize)); in checkQuota()
|
H A D | RateLimiter.java | 186 public long waitInterval() { in waitInterval() method in RateLimiter 187 return waitInterval(1); in waitInterval() 193 public synchronized long waitInterval(final long amount) { in waitInterval() method in RateLimiter
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/e2e/network/netpol/ |
H A D | test_helper.go | 33 waitInterval = 1 * time.Second const 105 time.Sleep(waitInterval) 138 err = wait.PollImmediate(waitInterval, waitTimeout, func() (done bool, err error) { 166 err = wait.PollImmediate(waitInterval, waitTimeout, func() (done bool, err error) { 194 err = wait.PollImmediate(waitInterval, waitTimeout, func() (done bool, err error) {
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/testcontainers/testcontainers-go/wait/ |
H A D | host_port.go | 59 var waitInterval = 100 * time.Millisecond 71 case <-time.After(waitInterval): 92 time.Sleep(waitInterval)
|
/dports/sysutils/istio/istio-1.6.7/pilot/pkg/proxy/ |
H A D | net.go | 26 waitInterval = 100 * time.Millisecond const 47 time.Sleep(waitInterval)
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/ |
H A D | TestJobEndNotifier.java | 92 + waitInterval, waitInterval == 1000); in testWaitInterval() 97 + waitInterval, waitInterval == 5000); in testWaitInterval() 103 + waitInterval, waitInterval == 5000); in testWaitInterval()
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/thanos-io/thanos/cmd/thanos/ |
H A D | compact.go | 446 return runutil.Repeat(conf.waitInterval, ctx.Done(), func() error { 517 iterCtx, iterCancel := context.WithTimeout(ctx, conf.waitInterval) 524 iterCtx, iterCancel := context.WithTimeout(ctx, conf.waitInterval) 554 waitInterval time.Duration member 602 Default("5m").DurationVar(&cc.waitInterval)
|
/dports/x11-wm/plasma5-kwin/kwin-5.23.5/src/ |
H A D | renderloop.cpp | 95 const std::chrono::nanoseconds waitInterval = nextRenderTimestamp - currentTime; in scheduleRepaint() local 96 compositeTimer.start(std::chrono::duration_cast<std::chrono::milliseconds>(waitInterval)); in scheduleRepaint()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | slavedbrmnode.cpp | 595 uint64_t waitInterval = 50000; // usecs to sleep between retries in beginVBCopy() local 620 maxRetries = (60 * 1000000) / waitInterval; in beginVBCopy() 680 usleep(waitInterval); in beginVBCopy() 1404 uint64_t waitInterval = 50000; // usecs to sleep between retries in dmlLockLBIDRanges() local 1418 maxRetries = (60 * 1000000) / waitInterval; in dmlLockLBIDRanges() 1457 usleep(waitInterval); in dmlLockLBIDRanges()
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/versioning/BRM/ |
H A D | slavedbrmnode.cpp | 595 uint64_t waitInterval = 50000; // usecs to sleep between retries in beginVBCopy() local 620 maxRetries = (60 * 1000000) / waitInterval; in beginVBCopy() 680 usleep(waitInterval); in beginVBCopy() 1404 uint64_t waitInterval = 50000; // usecs to sleep between retries in dmlLockLBIDRanges() local 1418 maxRetries = (60 * 1000000) / waitInterval; in dmlLockLBIDRanges() 1457 usleep(waitInterval); in dmlLockLBIDRanges()
|
/dports/databases/pgbackrest/pgbackrest-release-2.35/test/lib/pgBackRestTest/Common/ |
H A D | Wait.pm | 158 sub waitInterval subroutine
|
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/job/ |
H A D | job_test.go | 47 const waitInterval = 500 * time.Millisecond const 424 if err := wait.Poll(waitInterval, wait.ForeverTestTimeout, func() (done bool, err error) { 580 if err := wait.Poll(waitInterval, wait.ForeverTestTimeout, func() (bool, error) { 596 if err := wait.PollImmediate(waitInterval, wait.ForeverTestTimeout, func() (bool, error) { 681 return wait.Poll(waitInterval, wait.ForeverTestTimeout, func() (bool, error) { 712 if err := wait.Poll(waitInterval, wait.ForeverTestTimeout, func() (bool, error) {
|
/dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/audit/ |
H A D | Log4jAuditLoggerTest.java | 404 long waitInterval = 10; in waitForDeletion() local 409 Thread.sleep(waitInterval); in waitForDeletion() 413 elapsedTime = elapsedTime + waitInterval; in waitForDeletion()
|
/dports/news/nzbget/nzbget-21.1/daemon/queue/ |
H A D | QueueCoordinator.cpp | 196 int waitInterval = 100; in Run() local 259 waitInterval = std::min(waitInterval * 2, 2000); in Run() 260 m_waitCond.WaitFor(m_waitMutex, waitInterval, [&]{ return m_hasMoreJobs || IsStopped(); }); in Run() 267 waitInterval = 100; in Run()
|
/dports/www/firefox/firefox-99.0/image/ |
H A D | imgFrame.cpp | 266 TimeDuration waitInterval = in InitForDecoderRecycle() local 271 mMonitor.Wait(waitInterval); in InitForDecoderRecycle()
|
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/ |
H A D | MoveKeys.actor.cpp | 462 state TraceInterval waitInterval(""); in finishMoveKeys() local 600 waitInterval = TraceInterval("RelocateShard_FinishMoveKeysWaitDurable"); in finishMoveKeys() 601 TraceEvent(SevDebug, waitInterval.begin(), relocationIntervalId) in finishMoveKeys() 641 TraceEvent(SevDebug, waitInterval.end(), relocationIntervalId).detail("ReadyServers", count); in finishMoveKeys()
|