OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:RateLimiter
(Results
1 - 16
of
16
) sorted by null
/external/guava/guava-tests/test/com/google/common/util/concurrent/
PackageSanityTests.java
20
import com.google.common.util.concurrent.
RateLimiter
.SleepingStopwatch;
41
setDefault(
RateLimiter
.class,
RateLimiter
.create(1.0));
RateLimiterTest.java
30
import com.google.common.util.concurrent.
RateLimiter
.SleepingStopwatch;
44
* Tests for
RateLimiter
.
54
RateLimiter
limiter =
RateLimiter
.create(stopwatch, 5.0);
62
RateLimiter
r =
RateLimiter
.create(1);
68
RateLimiter
limiter =
RateLimiter
.create(5.0, 5, SECONDS);
84
RateLimiter
limiter =
RateLimiter
.create(999)
[
all
...]
MoreExecutorsTest.java
606
.setDefault(
RateLimiter
.class,
RateLimiter
.create(1.0))
/external/webrtc/webrtc/base/
ratelimiter.h
25
class
RateLimiter
{
28
RateLimiter
(size_t max, double period)
35
virtual ~
RateLimiter
() {}
ratelimiter.cc
11
#include "webrtc/base/
ratelimiter
.h"
15
bool
RateLimiter
::CanUse(size_t desired, double time) {
20
void
RateLimiter
::Use(size_t used, double time) {
ratelimiter_unittest.cc
12
#include "webrtc/base/
ratelimiter
.h"
18
RateLimiter
limiter =
RateLimiter
(2000, 1.0);
/external/guava/guava/src/com/google/common/util/concurrent/
RateLimiter.java
46
* <p>A {@code
RateLimiter
} is defined primarily by the rate at which permits
52
* <p>It is possible to configure a {@code
RateLimiter
} to have a warmup
59
* final
RateLimiter
rateLimiter
=
RateLimiter
.create(2.0); // rate is "2 permits per second"
62
*
rateLimiter
.acquire(); // may wait
72
* final
RateLimiter
rateLimiter
=
RateLimiter
.create(5000.0); // rate = 5000 permits per second
74
*
rateLimiter
.acquire(packet.length)
[
all
...]
SmoothRateLimiter.java
24
abstract class SmoothRateLimiter extends
RateLimiter
{
26
* How is the
RateLimiter
designed, and why?
28
* The primary feature of a
RateLimiter
is its "stable rate", the maximum rate that
41
* It is important to realize that such a
RateLimiter
has a very superficial memory
42
* of the past: it only remembers the last request. What if the
RateLimiter
was unused for
44
* This
RateLimiter
would immediately forget about that past underutilization. This may
48
* Past underutilization could mean that excess resources are available. Then, the
RateLimiter
69
* For a
RateLimiter
that produces 1 token per second, every second
70
* that goes by with the
RateLimiter
being unused, we increase storedPermits by 1.
71
* Say we leave the
RateLimiter
unused for 10 seconds (i.e., we expected a request at tim
[
all
...]
/external/webrtc/talk/media/base/
rtpdataengine.h
136
rtc::scoped_ptr<rtc::
RateLimiter
> send_limiter_;
rtpdataengine.cc
37
#include "webrtc/base/
ratelimiter
.h"
93
send_limiter_.reset(new rtc::
RateLimiter
(kDataMaxBandwidth / 8, 1.0));
289
send_limiter_.reset(new rtc::
RateLimiter
(bps / 8, 1.0));
mediachannel.h
50
class
RateLimiter
;
[
all
...]
/prebuilts/devtools/tools/lib/
guava-13.0.1.jar
/prebuilts/tools/common/guava-tools/
guava-13.0.1.jar
/prebuilts/tools/common/m2/repository/com/google/guava/guava/13.0.1/
guava-13.0.1.jar
/prebuilts/eclipse/maven/apache-maven-3.2.1/lib/
guava-14.0.1.jar
/prebuilts/tools/common/gradle-plugins/repository/com/google/guava/guava/14.0/
guava-14.0.jar
Completed in 141 milliseconds