github-mirrors/librespot
1
0
Fork 0
mirror of https://github.com/librespot-org/librespot.git synced 2024-12-18 17:11:53 +00:00
Code Issues Projects Releases Packages Wiki Activity

Handle cache full situation

Browse source
This commit is contained in:
johannesd3 2021-01-31 10:00:02 +01:00
parent fd1f049572
commit efedc678d0
1 changed files with 27 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
core/src/cache.rs
View file

@ -131,15 +131,35 @@ impl Cache {
} }
pub fn save_file<F: Read>(&self, file: FileId, contents: &mut F) { pub fn save_file<F: Read>(&self, file: FileId, contents: &mut F) {
if let Some(path) = self.file_path(file) { let path = if let Some(path) = self.file_path(file) {
let parent = path.parent().unwrap(); path
let result = fs::create_dir_all(parent) } else {
.and_then(|_| File::create(path)) return;
.and_then(|mut file| io::copy(contents, &mut file)); };
let parent = path.parent().unwrap();
if let Err(e) = result { let result = fs::create_dir_all(parent)
warn!("Cannot save file to cache: {}", e) .and_then(|_| File::create(&path))
.and_then(|mut file| io::copy(contents, &mut file));
if let Err(e) = result {
if e.kind() == ErrorKind::Other {
// Perhaps there's no space left in the cache
// TODO: try to narrow down the error (platform-dependently)
info!("An error occured while writing to cache, trying to flush the cache");
if fs::remove_dir_all(self.audio_location.as_ref().unwrap())
.and_then(|_| fs::create_dir_all(parent))
.and_then(|_| File::create(&path))
.and_then(|mut file| io::copy(contents, &mut file))
.is_ok()
{
// It worked, there's no need to print a warning
return;
}
} }
warn!("Cannot save file to cache: {}", e)
} }
} }
} }