| 136 | } |
| 137 | |
| 138 | int64_t Throttle::take(int64_t c) |
| 139 | { |
| 140 | if (0 == max) { |
| 141 | return 0; |
| 142 | } |
| 143 | ceph_assert(c >= 0); |
| 144 | ldout(cct, 10) << "take " << c << dendl; |
| 145 | count += c; |
| 146 | if (logger) { |
| 147 | logger->inc(l_throttle_take); |
| 148 | logger->inc(l_throttle_take_sum, c); |
| 149 | logger->set(l_throttle_val, count); |
| 150 | } |
| 151 | return count; |
| 152 | } |
| 153 | |
| 154 | bool Throttle::get(int64_t c, int64_t m) |
| 155 | { |