| 235 | |
| 236 | private: |
| 237 | void NotifyAll() { |
| 238 | if (current_waiter_.is_valid()) { |
| 239 | Future<> to_unlock = current_waiter_; |
| 240 | current_waiter_ = {}; |
| 241 | to_unlock.MarkFinished(); |
| 242 | } |
| 243 | } |
| 244 | |
| 245 | Future<> current_waiter_; |
| 246 | int num_released_batches_ = 0; |
nothing calls this directly
no test coverage detected