| 331 | } |
| 332 | |
| 333 | Status RowBatch::AllocateBuffer(BufferPool::ClientHandle* client, int64_t len, |
| 334 | BufferPool::BufferHandle* buffer_handle) { |
| 335 | BufferPool* buffer_pool = ExecEnv::GetInstance()->buffer_pool(); |
| 336 | int64_t buffer_len = BitUtil::RoundUpToPowerOfTwo(len); |
| 337 | buffer_len = max(buffer_pool->min_buffer_len(), buffer_len); |
| 338 | RETURN_IF_ERROR( |
| 339 | buffer_pool->AllocateUnreservedBuffer(client, buffer_len, buffer_handle)); |
| 340 | if (UNLIKELY(!buffer_handle->is_open())) { |
| 341 | return mem_tracker_->MemLimitExceeded( |
| 342 | nullptr, "Failed to allocate row batch", buffer_len); |
| 343 | } |
| 344 | return Status::OK(); |
| 345 | } |
| 346 | |
| 347 | void RowBatch::AddBuffer(BufferPool::ClientHandle* client, |
| 348 | BufferPool::BufferHandle&& buffer, FlushMode flush) { |
no test coverage detected