| /dports/audio/noson-app/noson-app-4.5.0/backend/NosonThumbnailer/thumbnailer/ |
| H A D | ratelimiter.cpp | 29 RateLimiter::RateLimiter(int concurrency) in RateLimiter() function in thumbnailer::RateLimiter
37 RateLimiter::~RateLimiter() in ~RateLimiter()
45 RateLimiter::CancelFunc RateLimiter::schedule(function<void()> job) in schedule()
70 RateLimiter::CancelFunc RateLimiter::schedule_now(function<void()> job) in schedule_now()
81 void RateLimiter::done() in done()
88 void RateLimiter::pump() in pump()
113 void RateLimiter::suspend() in suspend()
118 void RateLimiter::resume() in resume()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/rocksdb-lite/rocksdb-6.26.1/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/rocksdb/rocksdb-6.26.1/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/java/src/test/java/org/rocksdb/ |
| H A D | RateLimiterTest.java | 11 import static org.rocksdb.RateLimiter.*;
21 try(final RateLimiter rateLimiter = in bytesPerSecond()
22 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in bytesPerSecond()
32 try(final RateLimiter rateLimiter = in getSingleBurstBytes()
33 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getSingleBurstBytes()
41 try(final RateLimiter rateLimiter = in getTotalBytesThrough()
42 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalBytesThrough()
50 try(final RateLimiter rateLimiter = in getTotalRequests()
51 new RateLimiter(1000, DEFAULT_REFILL_PERIOD_MICROS, in getTotalRequests()
59 try(final RateLimiter rateLimiter = in autoTune()
[all …]
|
| /dports/textproc/sonic/sonic-1.3.0/cargo-crates/librocksdb-sys-6.7.4/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
45 RateLimiter::OpType::kRead); in TEST_F()
46 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
54 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
134 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
45 RateLimiter::OpType::kRead); in TEST_F()
46 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
54 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
134 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
45 RateLimiter::OpType::kRead); in TEST_F()
46 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
54 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
134 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
45 RateLimiter::OpType::kRead); in TEST_F()
46 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
54 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
134 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
45 RateLimiter::OpType::kRead); in TEST_F()
46 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
54 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
134 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
45 RateLimiter::OpType::kRead); in TEST_F()
46 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
54 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
134 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
45 RateLimiter::OpType::kRead); in TEST_F()
46 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
53 RateLimiter::OpType::kWrite); in TEST_F()
54 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
134 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
138 std::shared_ptr<RateLimiter> limiter; in TEST_F()
151 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/devel/folly/folly-2021.12.27.00/folly/experimental/channels/ |
| H A D | RateLimiter.cpp | 22 std::shared_ptr<RateLimiter> RateLimiter::create(size_t maxConcurrent) { in create()
23 return std::shared_ptr<RateLimiter>(new RateLimiter(maxConcurrent)); in create()
26 RateLimiter::RateLimiter(size_t maxConcurrent) in RateLimiter() function in folly::channels::RateLimiter
29 void RateLimiter::executeWhenReady( in executeWhenReady()
30 RateLimiter::QueuedFunc func, in executeWhenReady()
45 RateLimiter::Token::Token(std::shared_ptr<RateLimiter> rateLimiter) in Token()
48 RateLimiter::Token::~Token() { in ~Token()
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/internal/ratelimiter/ |
| H A D | ratelimiter.go | 29 type Option func(*RateLimiter)
38 type RateLimiter struct { struct
51 func New(name string, opts ...Option) *RateLimiter {
52 rl := &RateLimiter{
71 return func(rl *RateLimiter) {
78 return func(rl *RateLimiter) {
85 return func(rl *RateLimiter) {
92 return func(rl *RateLimiter) {
99 return func(rl *RateLimiter) {
107 return func(rl *RateLimiter) {
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
46 RateLimiter::OpType::kRead); in TEST_F()
47 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
54 RateLimiter::OpType::kWrite); in TEST_F()
55 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
153 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
157 std::shared_ptr<RateLimiter> limiter; in TEST_F()
170 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
46 RateLimiter::OpType::kRead); in TEST_F()
47 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
54 RateLimiter::OpType::kWrite); in TEST_F()
55 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
153 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
157 std::shared_ptr<RateLimiter> limiter; in TEST_F()
170 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/rocksdb/rocksdb/util/ |
| H A D | rate_limiter_test.cc | 39 for (auto mode : {RateLimiter::Mode::kWritesOnly, in TEST_F()
40 RateLimiter::Mode::kReadsOnly, RateLimiter::Mode::kAllIo}) { in TEST_F()
46 RateLimiter::OpType::kRead); in TEST_F()
47 if (mode == RateLimiter::Mode::kWritesOnly) { in TEST_F()
54 RateLimiter::OpType::kWrite); in TEST_F()
55 if (mode == RateLimiter::Mode::kAllIo) { in TEST_F()
70 std::unique_ptr<RateLimiter> limiter; in TEST_F()
153 std::shared_ptr<RateLimiter> _limiter) in TEST_F()
157 std::shared_ptr<RateLimiter> limiter; in TEST_F()
170 std::shared_ptr<RateLimiter> limiter = in TEST_F()
[all …]
|