| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/ |
| H A D | TestRateLimiter.java | 214 limiter.setNextRefillTime(limiter.getNextRefillTime() - limiter.getTimeUnitInMillis() / rate); in testCanExecuteByRate()
229 assertEquals(60, limiter.refill(limiter.getLimit())); in testRefillOfAverageIntervalRateLimiter()
235 assertEquals(12, limiter.refill(limiter.getLimit())); in testRefillOfAverageIntervalRateLimiter()
239 assertEquals(30, limiter.refill(limiter.getLimit())); in testRefillOfAverageIntervalRateLimiter()
243 assertEquals(60, limiter.refill(limiter.getLimit())); in testRefillOfAverageIntervalRateLimiter()
247 assertEquals(60, limiter.refill(limiter.getLimit())); in testRefillOfAverageIntervalRateLimiter()
249 assertEquals(60, limiter.refill(limiter.getLimit())); in testRefillOfAverageIntervalRateLimiter()
258 assertEquals(60, limiter.refill(limiter.getLimit())); in testRefillOfFixedIntervalRateLimiter()
264 assertEquals(0, limiter.refill(limiter.getLimit())); in testRefillOfFixedIntervalRateLimiter()
268 assertEquals(0, limiter.refill(limiter.getLimit())); in testRefillOfFixedIntervalRateLimiter()
[all …]
|
| /dports/devel/py-ddtrace/ddtrace-0.56.1/tests/tracer/ |
| H A D | test_rate_limiter.py | 11 limiter = RateLimiter(rate_limit=100)
12 assert limiter.rate_limit == 100
13 assert limiter.tokens == 100
14 assert limiter.max_tokens == 100
19 limiter = RateLimiter(rate_limit=0)
20 assert limiter.rate_limit == 0
21 assert limiter.tokens == 0
22 assert limiter.max_tokens == 0
34 assert limiter.rate_limit == -1
35 assert limiter.tokens == -1
[all …]
|
| /dports/multimedia/handbrake/fdk-aac-2.0.1/libPCMutils/src/ |
| H A D | limiter.cpp | 130 limiter->delayBuf = in pcmLimiter_Create()
133 if (!limiter->maxBuf || !limiter->delayBuf) { in pcmLimiter_Create()
163 return limiter; in pcmLimiter_Create()
351 limiter->max = max; in pcmLimiter_Apply()
353 limiter->cor = cor; in pcmLimiter_Apply()
380 if (limiter != NULL) { in pcmLimiter_Reset()
395 FDKmemset(limiter->maxBuf, 0, (limiter->attack + 1) * sizeof(FIXP_DBL)); in pcmLimiter_Reset()
397 limiter->attack * limiter->channels * sizeof(FIXP_DBL)); in pcmLimiter_Reset()
407 if (limiter != NULL) { in pcmLimiter_Destroy()
411 FDKfree(limiter); in pcmLimiter_Destroy()
[all …]
|
| /dports/audio/fdk-aac/fdk-aac-2.0.2/libPCMutils/src/ |
| H A D | limiter.cpp | 130 limiter->delayBuf = in pcmLimiter_Create()
133 if (!limiter->maxBuf || !limiter->delayBuf) { in pcmLimiter_Create()
163 return limiter; in pcmLimiter_Create()
345 limiter->max = max; in pcmLimiter_Apply()
347 limiter->cor = cor; in pcmLimiter_Apply()
370 if (limiter != NULL) { in pcmLimiter_Reset()
377 limiter->scaling = 0; in pcmLimiter_Reset()
379 FDKmemset(limiter->maxBuf, 0, (limiter->attack + 1) * sizeof(FIXP_DBL)); in pcmLimiter_Reset()
381 limiter->attack * limiter->channels * sizeof(FIXP_DBL)); in pcmLimiter_Reset()
391 if (limiter != NULL) { in pcmLimiter_Destroy()
[all …]
|
| /dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-core-tests/utils/ratelimiter/ |
| H A D | RateLimiterTests.cpp | 86 limiter.ApplyCost(10); in TEST_F()
100 limiter.ApplyCost(10); in TEST_F()
116 limiter.ApplyCost(150); in TEST_F()
175 limiter.SetRate(10); in TEST_F()
178 limiter.ApplyCost(5); in TEST_F()
192 limiter.SetRate(100); in TEST_F()
195 limiter.ApplyCost(60); in TEST_F()
218 limiter.SetRate(10); in TEST_F()
221 limiter.ApplyCost(5); in TEST_F()
235 limiter.SetRate(100); in TEST_F()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/perfetto/src/perfetto_cmd/ |
| H A D | rate_limiter_unittest.cc | 80 NiceMock<MockRateLimiter> limiter; in TEST() local
93 NiceMock<MockRateLimiter> limiter; in TEST() local
128 NiceMock<MockRateLimiter> limiter; in TEST() local
142 NiceMock<MockRateLimiter> limiter; in TEST() local
149 NiceMock<MockRateLimiter> limiter; in TEST() local
182 EXPECT_CALL(limiter, SaveState(_)); in TEST()
183 EXPECT_CALL(limiter, LoadState(_)); in TEST()
186 EXPECT_CALL(limiter, SaveState(_)); in TEST()
204 EXPECT_CALL(limiter, SaveState(_)); in TEST()
205 EXPECT_CALL(limiter, LoadState(_)); in TEST()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/perfetto/src/perfetto_cmd/ |
| H A D | rate_limiter_unittest.cc | 80 NiceMock<MockRateLimiter> limiter; in TEST() local
93 NiceMock<MockRateLimiter> limiter; in TEST() local
128 NiceMock<MockRateLimiter> limiter; in TEST() local
142 NiceMock<MockRateLimiter> limiter; in TEST() local
149 NiceMock<MockRateLimiter> limiter; in TEST() local
182 EXPECT_CALL(limiter, SaveState(_)); in TEST()
183 EXPECT_CALL(limiter, LoadState(_)); in TEST()
186 EXPECT_CALL(limiter, SaveState(_)); in TEST()
204 EXPECT_CALL(limiter, SaveState(_)); in TEST()
205 EXPECT_CALL(limiter, LoadState(_)); in TEST()
[all …]
|
| /dports/multimedia/mswebrtc/mswebrtc-1.1.1/webrtc/webrtc/base/ |
| H A D | ratelimiter_unittest.cc | 24 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
30 limiter.Use(1000, monday); in TEST()
32 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
33 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
37 limiter.Use(1000, monday); in TEST()
39 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
40 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
42 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
48 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/rtc_base/ |
| H A D | data_rate_limiter_unittest.cc | 25 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
31 limiter.Use(1000, monday); in TEST()
33 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
34 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
38 limiter.Use(1000, monday); in TEST()
40 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
41 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
44 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
49 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/base/ |
| H A D | ratelimiter_unittest.cc | 41 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
47 limiter.Use(1000, monday); in TEST()
49 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
50 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
54 limiter.Use(1000, monday); in TEST()
56 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
57 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
59 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
60 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
65 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/rtc_base/ |
| H A D | data_rate_limiter_unittest.cc | 25 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
31 limiter.Use(1000, monday); in TEST()
33 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
34 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
38 limiter.Use(1000, monday); in TEST()
40 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
41 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
44 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
49 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/base/ |
| H A D | ratelimiter_unittest.cc | 24 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
30 limiter.Use(1000, monday); in TEST()
32 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
33 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
37 limiter.Use(1000, monday); in TEST()
39 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
40 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
42 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
48 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/rtc_base/ |
| H A D | data_rate_limiter_unittest.cc | 25 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
31 limiter.Use(1000, monday); in TEST()
33 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
34 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
38 limiter.Use(1000, monday); in TEST()
40 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
41 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
44 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
49 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/libwebrtc/rtc_base/ |
| H A D | data_rate_limiter_unittest.cc | 25 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
31 limiter.Use(1000, monday); in TEST()
33 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
34 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
38 limiter.Use(1000, monday); in TEST()
40 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
41 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
44 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
49 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/rtc_base/ |
| H A D | ratelimiter_unittest.cc | 24 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
30 limiter.Use(1000, monday); in TEST()
32 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
33 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
37 limiter.Use(1000, monday); in TEST()
39 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
40 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
42 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
48 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/media/webrtc/trunk/webrtc/base/ |
| H A D | ratelimiter_unittest.cc | 24 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
30 limiter.Use(1000, monday); in TEST()
32 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
33 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
37 limiter.Use(1000, monday); in TEST()
39 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
40 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
42 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
48 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/rtc_base/ |
| H A D | ratelimiter_unittest.cc | 24 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
30 limiter.Use(1000, monday); in TEST()
32 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
33 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
37 limiter.Use(1000, monday); in TEST()
39 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
40 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
42 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
48 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/trunk/webrtc/rtc_base/ |
| H A D | ratelimiter_unittest.cc | 24 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
30 limiter.Use(1000, monday); in TEST()
32 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
33 EXPECT_TRUE(limiter.CanUse(999, monday)); in TEST()
37 limiter.Use(1000, monday); in TEST()
39 EXPECT_TRUE(limiter.CanUse(0, monday)); in TEST()
40 EXPECT_FALSE(limiter.CanUse(1, monday)); in TEST()
42 EXPECT_TRUE(limiter.CanUse(0, tuesday)); in TEST()
43 EXPECT_TRUE(limiter.CanUse(1, tuesday)); in TEST()
48 limiter.Use(1000, tuesday); in TEST()
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/k8s.io/client-go/util/workqueue/ |
| H A D | default_rate_limiters_test.go | 58 limiter.Forget("one")
71 limiter.When("one")
78 limiter.When("overflow1")
86 limiter.When("two")
93 limiter.When("overflow2")
105 if got := limiter.When("one"); got != 0 {
109 limiter.When("one")
121 limiter.Forget("one")
160 limiter.Forget("one")
171 limiter := NewMaxOfRateLimiter(
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/k8s.io/client-go/util/workqueue/ |
| H A D | default_rate_limiters_test.go | 58 limiter.Forget("one")
71 limiter.When("one")
78 limiter.When("overflow1")
86 limiter.When("two")
93 limiter.When("overflow2")
105 if got := limiter.When("one"); got != 0 {
109 limiter.When("one")
121 limiter.Forget("one")
160 limiter.Forget("one")
171 limiter := NewMaxOfRateLimiter(
[all …]
|
| /dports/net/gscloud/gscloud-0.11.0/vendor/k8s.io/client-go/util/workqueue/ |
| H A D | default_rate_limiters_test.go | 42 if e, a := 5, limiter.NumRequeues("one"); e != a {
52 if e, a := 2, limiter.NumRequeues("two"); e != a {
56 limiter.Forget("one")
57 if e, a := 0, limiter.NumRequeues("one"); e != a {
69 limiter.When("one")
76 limiter.When("overflow1")
84 limiter.When("two")
91 limiter.When("overflow2")
131 limiter.Forget("one")
142 limiter := NewMaxOfRateLimiter(
[all …]
|
| /dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/k8s.io/client-go/client-go-0.16.8/util/workqueue/ |
| H A D | default_rate_limiters_test.go | 42 if e, a := 5, limiter.NumRequeues("one"); e != a {
52 if e, a := 2, limiter.NumRequeues("two"); e != a {
56 limiter.Forget("one")
57 if e, a := 0, limiter.NumRequeues("one"); e != a {
69 limiter.When("one")
76 limiter.When("overflow1")
84 limiter.When("two")
91 limiter.When("overflow2")
131 limiter.Forget("one")
142 limiter := NewMaxOfRateLimiter(
[all …]
|
| /dports/sysutils/chaoskube/chaoskube-0.22.0/vendor/k8s.io/client-go/util/workqueue/ |
| H A D | default_rate_limiters_test.go | 42 if e, a := 5, limiter.NumRequeues("one"); e != a {
52 if e, a := 2, limiter.NumRequeues("two"); e != a {
56 limiter.Forget("one")
57 if e, a := 0, limiter.NumRequeues("one"); e != a {
69 limiter.When("one")
76 limiter.When("overflow1")
84 limiter.When("two")
91 limiter.When("overflow2")
131 limiter.Forget("one")
142 limiter := NewMaxOfRateLimiter(
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/k8s.io/client-go/util/workqueue/ |
| H A D | default_rate_limiters_test.go | 42 if e, a := 5, limiter.NumRequeues("one"); e != a {
52 if e, a := 2, limiter.NumRequeues("two"); e != a {
56 limiter.Forget("one")
57 if e, a := 0, limiter.NumRequeues("one"); e != a {
69 limiter.When("one")
76 limiter.When("overflow1")
84 limiter.When("two")
91 limiter.When("overflow2")
131 limiter.Forget("one")
142 limiter := NewMaxOfRateLimiter(
[all …]
|
| /dports/sysutils/go-wtf/wtf-0.21.0/vendor/k8s.io/client-go/client-go-12.0.0/util/workqueue/ |
| H A D | default_rate_limiters_test.go | 42 if e, a := 5, limiter.NumRequeues("one"); e != a {
52 if e, a := 2, limiter.NumRequeues("two"); e != a {
56 limiter.Forget("one")
57 if e, a := 0, limiter.NumRequeues("one"); e != a {
69 limiter.When("one")
76 limiter.When("overflow1")
84 limiter.When("two")
91 limiter.When("overflow2")
131 limiter.Forget("one")
142 limiter := NewMaxOfRateLimiter(
[all …]
|