| 71 | } |
| 72 | |
| 73 | unique_ptr<BufferDescriptor> ScanBufferManager::GetUnusedBuffer( |
| 74 | const unique_lock<mutex>& scan_range_lock) { |
| 75 | DCHECK(scan_range_->is_locked(scan_range_lock)); |
| 76 | if (unused_iomgr_buffers_.empty()) return nullptr; |
| 77 | unique_ptr<BufferDescriptor> result = move(unused_iomgr_buffers_.back()); |
| 78 | unused_iomgr_buffers_.pop_back(); |
| 79 | unused_iomgr_buffer_bytes_ -= result->buffer_len(); |
| 80 | return result; |
| 81 | } |
| 82 | |
| 83 | void ScanBufferManager::EnqueueReadyBuffer( |
| 84 | const std::unique_lock<std::mutex>& scan_range_lock, |
no test coverage detected