| 292 | } |
| 293 | |
| 294 | Stream::~Stream() { |
| 295 | VLOG_CALL(); |
| 296 | |
| 297 | // Ensure the stream is completed. |
| 298 | auto status = BlockHostUntilDone(); |
| 299 | if (!status.ok()) { |
| 300 | LOG(WARNING) << "Error blocking host until done in stream destructor: " |
| 301 | << status; |
| 302 | } |
| 303 | temporary_memory_manager_.ForceDeallocateAll(); |
| 304 | RunAfterBlockHostUntilDoneCallbacks(); |
| 305 | |
| 306 | if (allocated_) { |
| 307 | parent_->DeallocateStream(this); |
| 308 | } |
| 309 | } |
| 310 | |
| 311 | port::Status Stream::RefreshStatus() { |
| 312 | port::Status status = parent_->GetStatus(this); |
nothing calls this directly
no test coverage detected