| 415 | } |
| 416 | |
| 417 | void TmpFileMgr::CleanupAtShutdown() { |
| 418 | // Try to clear the host-level remote temporary directory. |
| 419 | if (tmp_dirs_remote_ == nullptr) return; |
| 420 | hdfsFS hdfs_conn; |
| 421 | Status status = tmp_dirs_remote_->GetConnection(this, &hdfs_conn); |
| 422 | if (!status.ok()) { |
| 423 | LOG(WARNING) << "Unable to get a connection to " << tmp_dirs_remote_->path_ |
| 424 | << " for clearing the directory on shutdown"; |
| 425 | return; |
| 426 | } |
| 427 | RemoveRemoteDirForHost(tmp_dirs_remote_->path_, hdfs_conn); |
| 428 | } |
| 429 | |
| 430 | Status TmpFileMgr::CreateTmpFileBufferPoolThread(MetricGroup* metrics) { |
| 431 | DCHECK(metrics != nullptr); |
no test coverage detected