| /dports/www/py-prawcore/prawcore-1.0.1/tests/ |
| H A D | test_rate_limit.py | 15 self.rate_limiter = RateLimiter()
22 self.rate_limiter.delay()
30 self.rate_limiter.delay()
36 self.rate_limiter.delay()
43 self.rate_limiter.delay()
50 self.rate_limiter.remaining = -1
59 self.rate_limiter.remaining = 0
92 prev = copy(self.rate_limiter)
93 self.rate_limiter.update({})
101 self.rate_limiter.used = 99
[all …]
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/rtc_base/ |
| H A D | rate_limiter_unittest.cc | 37 std::unique_ptr<RateLimiter> rate_limiter; member in webrtc::RateLimitTest
47 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
50 rate_limiter->SetMaxRate(kMaxRateBps * 2); in TEST_F()
54 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
64 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
67 rate_limiter->SetMaxRate(kMaxRateBps / 2); in TEST_F()
71 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
114 : rate_limiter_(rate_limiter) {} in ThreadTask()
145 : ThreadTask(rate_limiter) {} in TEST_F()
158 : ThreadTask(rate_limiter) {} in TEST_F()
[all …]
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/rtc_base/ |
| H A D | rate_limiter_unittest.cc | 37 std::unique_ptr<RateLimiter> rate_limiter; member in webrtc::RateLimitTest
47 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
50 rate_limiter->SetMaxRate(kMaxRateBps * 2); in TEST_F()
54 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
64 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
67 rate_limiter->SetMaxRate(kMaxRateBps / 2); in TEST_F()
71 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
114 : rate_limiter_(rate_limiter) {} in ThreadTask()
145 : ThreadTask(rate_limiter) {} in TEST_F()
158 : ThreadTask(rate_limiter) {} in TEST_F()
[all …]
|
| /dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/base/ |
| H A D | rate_limiter_unittest.cc | 38 std::unique_ptr<RateLimiter> rate_limiter; member in webrtc::RateLimitTest
48 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
51 rate_limiter->SetMaxRate(kMaxRateBps * 2); in TEST_F()
55 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
65 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
68 rate_limiter->SetMaxRate(kMaxRateBps / 2); in TEST_F()
72 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
115 : rate_limiter_(rate_limiter), in ThreadTask()
149 : ThreadTask(rate_limiter) {} in TEST_F()
162 : ThreadTask(rate_limiter) {} in TEST_F()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/rtc_base/ |
| H A D | rate_limiter_unittest.cc | 37 std::unique_ptr<RateLimiter> rate_limiter; member in webrtc::RateLimitTest
47 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
50 rate_limiter->SetMaxRate(kMaxRateBps * 2); in TEST_F()
54 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
64 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
67 rate_limiter->SetMaxRate(kMaxRateBps / 2); in TEST_F()
71 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
114 : rate_limiter_(rate_limiter) {} in ThreadTask()
145 : ThreadTask(rate_limiter) {} in TEST_F()
158 : ThreadTask(rate_limiter) {} in TEST_F()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/libwebrtc/rtc_base/ |
| H A D | rate_limiter_unittest.cc | 37 std::unique_ptr<RateLimiter> rate_limiter; member in webrtc::RateLimitTest
47 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
50 rate_limiter->SetMaxRate(kMaxRateBps * 2); in TEST_F()
54 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
64 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
67 rate_limiter->SetMaxRate(kMaxRateBps / 2); in TEST_F()
71 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
114 : rate_limiter_(rate_limiter) {} in ThreadTask()
145 : ThreadTask(rate_limiter) {} in TEST_F()
158 : ThreadTask(rate_limiter) {} in TEST_F()
[all …]
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/libwebrtc/webrtc/rtc_base/ |
| H A D | rate_limiter_unittest.cc | 38 std::unique_ptr<RateLimiter> rate_limiter; member in webrtc::RateLimitTest
48 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
51 rate_limiter->SetMaxRate(kMaxRateBps * 2); in TEST_F()
55 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
65 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
68 rate_limiter->SetMaxRate(kMaxRateBps / 2); in TEST_F()
72 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
115 : rate_limiter_(rate_limiter), in ThreadTask()
148 : ThreadTask(rate_limiter) {} in TEST_F()
161 : ThreadTask(rate_limiter) {} in TEST_F()
[all …]
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/libwebrtc/webrtc/rtc_base/ |
| H A D | rate_limiter_unittest.cc | 38 std::unique_ptr<RateLimiter> rate_limiter; member in webrtc::RateLimitTest
48 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
51 rate_limiter->SetMaxRate(kMaxRateBps * 2); in TEST_F()
55 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
65 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
68 rate_limiter->SetMaxRate(kMaxRateBps / 2); in TEST_F()
72 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
115 : rate_limiter_(rate_limiter), in ThreadTask()
148 : ThreadTask(rate_limiter) {} in TEST_F()
161 : ThreadTask(rate_limiter) {} in TEST_F()
[all …]
|
| /dports/lang/spidermonkey78/firefox-78.9.0/media/webrtc/trunk/webrtc/rtc_base/ |
| H A D | rate_limiter_unittest.cc | 38 std::unique_ptr<RateLimiter> rate_limiter; member in webrtc::RateLimitTest
48 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
51 rate_limiter->SetMaxRate(kMaxRateBps * 2); in TEST_F()
55 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
65 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
68 rate_limiter->SetMaxRate(kMaxRateBps / 2); in TEST_F()
72 EXPECT_FALSE(rate_limiter->TryUseRate(1)); in TEST_F()
115 : rate_limiter_(rate_limiter), in ThreadTask()
148 : ThreadTask(rate_limiter) {} in TEST_F()
161 : ThreadTask(rate_limiter) {} in TEST_F()
[all …]
|
| /dports/sysutils/vector/lucet-d4fc14a03bdb99ac83173d27fddf1aca48412a86/sightglass/benchmarks/shootout/ |
| H A D | ratelimit.c | 25 if ((rate_limiter->slots = calloc(slots_len, sizeof *rate_limiter->slots)) == NULL) { in ratelimiter_init()
32 rate_limiter->period = period; in ratelimiter_init()
43 free(rate_limiter->slots); in ratelimiter_free()
44 memset(rate_limiter, 0, sizeof *rate_limiter); in ratelimiter_free()
45 rate_limiter->slots = NULL; in ratelimiter_free()
103 if (rate_limiter->pos <= rate_limiter->slots_mask) { in ratelimiter_hit()
104 rate_limiter->slots[rate_limiter->pos] /= 2U; in ratelimiter_hit()
106 rate_limiter->pos++; in ratelimiter_hit()
107 if (rate_limiter->pos >= rate_limiter->period) { in ratelimiter_hit()
108 rate_limiter->pos = 0U; in ratelimiter_hit()
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/app/services/concerns/ |
| H A D | rate_limited_service.rb | 9 def initialize(key:, rate_limiter:) argument
11 @rate_limiter = rate_limiter
20 rate_limiter.class.log_request(request, "#{key}_request_limit".to_sym, current_user)
41 rate_limiter = new_rate_limiter(evaluated_scope)
42 if rate_limiter.throttled?
43 …raise RateLimitedError.new(key: key, rate_limiter: rate_limiter), _('This endpoint has been reques…
|
| /dports/devel/py-botocore/botocore-1.21.61/tests/unit/retries/ |
| H A D | test_adaptive.py | 44 rate_limiter = adaptive.ClientRateLimiter(
51 return rate_limiter
54 rate_limiter = self.create_client_limiter()
55 rate_limiter.on_sending_request(request=mock.sentinel.request)
59 rate_limiter = self.create_client_limiter()
63 rate_limiter.on_receiving_response()
67 rate_limiter.on_sending_request(request=mock.sentinel.request)
71 rate_limiter = self.create_client_limiter()
75 rate_limiter.on_receiving_response()
79 rate_limiter = self.create_client_limiter()
[all …]
|
| /dports/ftp/libfilezilla/libfilezilla-0.31.1/lib/libfilezilla/ |
| H A D | rate_limiter.hpp | 33 class rate_limiter;
57 void add(rate_limiter* limiter);
63 friend class rate_limiter;
72 void process(rate_limiter* limiter, bool locked);
76 std::vector<rate_limiter*> limiters_;
97 friend class rate_limiter;
184 class FZ_PUBLIC_SYMBOL rate_limiter final : public bucket_base class
187 rate_limiter() = default;
188 explicit rate_limiter(rate_limit_manager * mgr);
189 virtual ~rate_limiter();
|
| /dports/ftp/libfilezilla/libfilezilla-0.31.1/lib/ |
| H A D | rate_limiter.cpp | 66 void rate_limit_manager::add(rate_limiter* limiter) in add()
148 auto * parent = reinterpret_cast<rate_limiter*>(parent_); in remove_bucket()
180 rate_limiter::rate_limiter(rate_limit_manager *mgr) in rate_limiter() function in fz::rate_limiter
187 rate_limiter::~rate_limiter() in ~rate_limiter()
201 void rate_limiter::set_mgr_recursive(rate_limit_manager * mgr) in set_mgr_recursive()
237 rate::type rate_limiter::limit(direction::type const d) in limit()
243 void rate_limiter::add(bucket_base* bucket) in add()
292 void rate_limiter::lock_tree() in lock_tree()
300 void rate_limiter::unlock_tree() in unlock_tree()
308 void rate_limiter::pay_debt(direction::type const d) in pay_debt()
[all …]
|
| /dports/ftp/filezilla/filezilla-3.55.1/src/engine/ |
| H A D | engine_context.cpp | 21 …s, fz::event_loop & loop, fz::rate_limit_manager & rate_limit_mgr, fz::rate_limiter & rate_limiter) in option_change_handler() argument
25 , rate_limiter_(rate_limiter) in option_change_handler()
54 fz::rate_limiter & rate_limiter_;
108 fz::rate_limiter rate_limiter_;
138 fz::rate_limiter& CFileZillaEngineContext::GetRateLimiter() in GetRateLimiter()
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/api/helpers/ |
| H A D | rate_limiter.rb | 13 return unless rate_limiter.throttled?(key, scope: scope, **options)
15 rate_limiter.log_request(request, "#{key}_request_limit".to_sym, current_user)
24 def rate_limiter method
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/app/controllers/concerns/ |
| H A D | check_rate_limit.rb | 11 return unless rate_limiter.throttled?(key, scope: scope, **options)
13 rate_limiter.log_request(request, "#{key}_request_limit".to_sym, current_user)
28 def rate_limiter method
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 188 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F() local
206 int64_t orig_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
214 int64_t new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
226 new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 188 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F() local
206 int64_t orig_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
214 int64_t new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
226 new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 188 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F() local
206 int64_t orig_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
214 int64_t new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
226 new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 188 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F() local
206 int64_t orig_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
214 int64_t new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
226 new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 188 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F() local
206 int64_t orig_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
214 int64_t new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
226 new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 188 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F() local
206 int64_t orig_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
214 int64_t new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
226 new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 188 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F() local
206 int64_t orig_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
207 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
211 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
214 int64_t new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
224 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
226 new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 205 std::unique_ptr<RateLimiter> rate_limiter(new GenericRateLimiter( in TEST_F() local
224 int64_t orig_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
225 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
229 rate_limiter->Request(orig_bytes_per_sec, Env::IO_HIGH, stats.get(), in TEST_F()
232 int64_t new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
242 rate_limiter->Request(1 /* bytes */, Env::IO_HIGH, stats.get(), in TEST_F()
244 new_bytes_per_sec = rate_limiter->GetSingleBurstBytes(); in TEST_F()
|