Lines Matching refs:tb
63 TokenBucket tb = new TokenBucket(FILL_DELTA_VERY_LONG, 100, 10);
64 drain(tb, 10);
66 tb.reset(50);
67 drain(tb, 50);
69 tb.reset(50);
70 getOneByOne(tb, 10);
71 assertTrue(tb.has());
73 tb.reset(30);
74 drain(tb, 30);
79 TokenBucket tb = new TokenBucket(delta, 10, 0);
81 assertEmpty(tb);
85 assertTrue(tb.has());
89 TokenBucket tb = new TokenBucket(FILL_DELTA_VERY_SHORT, 10, 10);
91 assertEquals(5, tb.get(5));
92 assertEquals(5, tb.get(5));
94 while (tb.available() < 10) {
98 assertEquals(10, tb.get(10));
100 while (tb.available() < 10) {
104 assertEquals(10, tb.get(100));
112 TokenBucket tb = new TokenBucket(delta, 20, 0);
115 while (!tb.has()) {
118 tb.get();
130 TokenBucket tb = new TokenBucket(delta, capacity, 0);
134 while (!tb.has()) {
137 total += tb.get(tb.available());
143 static void getOneByOne(TokenBucket tb, int n) {
145 assertTrue(tb.has());
146 assertTrue(tb.available() >= n);
147 assertTrue(tb.get());
148 assertTrue(tb.available() >= n - 1);
153 void assertEmpty(TokenBucket tb) {
154 assertFalse(tb.has());
155 assertEquals(0, tb.available());
156 assertFalse(tb.get());
159 void drain(TokenBucket tb, int n) {
160 getOneByOne(tb, n);
161 assertEmpty(tb);