| 133 | } |
| 134 | |
| 135 | void FlowControlProtocol::stop() { |
| 136 | if (!running_) |
| 137 | return; |
| 138 | running_ = false; |
| 139 | logger_->log_info("FlowControl Protocol Stop"); |
| 140 | } |
| 141 | |
| 142 | void FlowControlProtocol::run(FlowControlProtocol *protocol) { |
| 143 | while (protocol->running_) { |