| 118 | } |
| 119 | |
| 120 | Status Env::FlushFileSystemCaches() { |
| 121 | std::vector<string> schemes; |
| 122 | TF_RETURN_IF_ERROR(GetRegisteredFileSystemSchemes(&schemes)); |
| 123 | for (const string& scheme : schemes) { |
| 124 | FileSystem* fs = nullptr; |
| 125 | TF_RETURN_IF_ERROR( |
| 126 | GetFileSystemForFile(io::CreateURI(scheme, "", ""), &fs)); |
| 127 | fs->FlushCaches(); |
| 128 | } |
| 129 | return Status::OK(); |
| 130 | } |
| 131 | |
| 132 | Status Env::NewRandomAccessFile(const string& fname, |
| 133 | std::unique_ptr<RandomAccessFile>* result) { |