| 79 | } |
| 80 | |
| 81 | void LeaveFlowControlMode() { |
| 82 | std::lock_guard<std::mutex> _{mu_}; |
| 83 | status_.store(FlowControlStatus::kNormal); |
| 84 | limiter_.SetLimit(std::numeric_limits<uint64_t>::max()); |
| 85 | } |
| 86 | |
| 87 | bool InFlowControlMode() { return status_.load() == FlowControlStatus::kFlowControlMode; } |
| 88 |
no test coverage detected