| 345 | } |
| 346 | |
| 347 | void RowBatch::AddBuffer(BufferPool::ClientHandle* client, |
| 348 | BufferPool::BufferHandle&& buffer, FlushMode flush) { |
| 349 | attached_buffer_bytes_ += buffer.len(); |
| 350 | BufferInfo buffer_info; |
| 351 | buffer_info.client = client; |
| 352 | buffer_info.buffer = std::move(buffer); |
| 353 | buffers_.push_back(std::move(buffer_info)); |
| 354 | if (flush == FlushMode::FLUSH_RESOURCES) MarkFlushResources(); |
| 355 | } |
| 356 | |
| 357 | void RowBatch::FreeBuffers() { |
| 358 | for (BufferInfo& buffer_info : buffers_) { |
no test coverage detected