Home
last modified time | relevance | path

Searched refs:waitInterval (Results 1 – 25 of 37) sorted by relevance

12

/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/
H A DThrottlingException.java44 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 DTestRateLimiter.java61 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 DService.cpp69 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 DJobEndNotifier.java56 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 Dmock_backend_test.go81 waitInterval := time.Millisecond * 5
84 time.Sleep(waitInterval)
87 if waitInterval < time.Millisecond*500 {
88 waitInterval *= 2
H A Dtest_case.go278 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 Dutils.go81 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 Dutils.go81 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 Dutils.go81 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 DTimeBasedLimiter.java118 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 DRateLimiter.java186 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 Dtest_helper.go33 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 Dhost_port.go59 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 Dnet.go26 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 DTestJobEndNotifier.java92 + 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 Dcompact.go446 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 Drenderloop.cpp95 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 Dslavedbrmnode.cpp595 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 Dslavedbrmnode.cpp595 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 DWait.pm158 sub waitInterval subroutine
/dports/sysutils/kubectl/kubernetes-1.22.2/test/integration/job/
H A Djob_test.go47 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 DLog4jAuditLoggerTest.java404 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 DQueueCoordinator.cpp196 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 DimgFrame.cpp266 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 DMoveKeys.actor.cpp462 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()

12