| 36 | } |
| 37 | |
| 38 | void BlockingRowBatchQueue::AddBatch(unique_ptr<RowBatch> batch) { |
| 39 | if (!batch_queue_->BlockingPut(move(batch))) { |
| 40 | lock_guard<SpinLock> l(lock_); |
| 41 | cleanup_queue_.push_back(move(batch)); |
| 42 | } |
| 43 | } |
| 44 | |
| 45 | bool BlockingRowBatchQueue::AddBatchWithTimeout( |
| 46 | unique_ptr<RowBatch>&& batch, int64_t timeout_micros) { |
nothing calls this directly
no test coverage detected