toxblh/podcasts
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

EpisodeWidget: Fix updating.

Browse Source
This commit is contained in:
Jordan Petridis 2018-01-09 10:52:52 +02:00
parent 0ba5e14d7f
commit d4e3bf696b
No known key found for this signature in database
GPG Key ID: CEABAD9F5683B9A6
1 changed files with 15 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
hammond-gtk/src/manager.rs
View File

@ -68,20 +68,16 @@ pub fn add(id: i32, directory: &str, sender: Sender<Action>) {
let prog = Arc::new(Mutex::new(Progress::default()));
{
ACTIVE_DOWNLOADS
.write()
.ok()
.map(|mut m| m.insert(id, prog.clone()));
if let Ok(mut m) = ACTIVE_DOWNLOADS.write() {
m.insert(id, prog.clone());
}
}
// {
// let m = ACTIVE_DOWNLOADS.read().unwrap();
// info!("ACTIVE DOWNLOADS: {:#?}", m);
// }
let dir = directory.to_owned();
thread::spawn(move || {
if let Ok(episode) = dbqueries::get_episode_from_rowid(id) {
let id = episode.podcast_id();
let pid = episode.podcast_id();
let id = episode.rowid();
get_episode(&mut episode.into(), dir.as_str(), Some(prog))
.err()
.map(|err| {
@ -90,11 +86,19 @@ pub fn add(id: i32, directory: &str, sender: Sender<Action>) {
});
{
ACTIVE_DOWNLOADS.write().ok().map(|mut x| x.remove(&id));
if let Ok(mut m) = ACTIVE_DOWNLOADS.write() {
info!("Removed: {:?}", m.remove(&id));
}
}
// {
// if let Ok(m) = ACTIVE_DOWNLOADS.read() {
// debug!("ACTIVE DOWNLOADS: {:#?}", m);
// }
// }
sender.send(Action::RefreshEpisodesView).unwrap();
sender.send(Action::RefreshWidgetIfSame(id)).unwrap();
sender.send(Action::RefreshWidgetIfSame(pid)).unwrap();
}
});
}