| 1005 | } |
| 1006 | |
| 1007 | Status DiskIoMgr::ReopenCachedHdfsFileHandle(const hdfsFS& fs, std::string* fname, |
| 1008 | int64_t mtime, RequestContext* reader, FileHandleCache::Accessor* accessor) { |
| 1009 | bool cache_hit; |
| 1010 | SCOPED_TIMER(reader->open_file_timer_); |
| 1011 | ImpaladMetrics::IO_MGR_CACHED_FILE_HANDLES_REOPENED->Increment(1L); |
| 1012 | |
| 1013 | accessor->Destroy(); |
| 1014 | |
| 1015 | Status status = |
| 1016 | file_handle_cache_.GetFileHandle(fs, fname, mtime, true, accessor, &cache_hit); |
| 1017 | if (!status.ok()) { |
| 1018 | return status; |
| 1019 | } |
| 1020 | DCHECK(!cache_hit); |
| 1021 | return Status::OK(); |
| 1022 | } |
| 1023 | |
| 1024 | void DiskQueue::ShutDown() { |
| 1025 | { |
no test coverage detected