Write callback, which signals 'cb_cv_' and increments 'cb_counter_'.
| 344 | |
| 345 | // Write callback, which signals 'cb_cv_' and increments 'cb_counter_'. |
| 346 | void SignalCallback(const Status& write_status) { |
| 347 | { |
| 348 | lock_guard<mutex> lock(cb_cv_lock_); |
| 349 | ++cb_counter_; |
| 350 | } |
| 351 | cb_cv_.NotifyAll(); |
| 352 | } |
| 353 | |
| 354 | /// Wait until 'cb_counter_' reaches 'val'. |
| 355 | void WaitForCallbacks(int64_t val) { |