Start9/start-os
2
0
Fork 0
mirror of https://github.com/Start9Labs/start-os.git synced 2026-03-30 20:14:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

release lock on update progress (#1614)

Browse Source
This commit is contained in:
Aiden McClelland
2022-07-05 12:01:54 -06:00
committed by GitHub
parent 3cfc333512
commit e2d58c2959
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
backend/src/install/progress.rs
View File

@@ -44,10 +44,14 @@ impl InstallProgress {
mut db: Db, mut db: Db,
) -> Result<(), Error> { ) -> Result<(), Error> {
while !self.download_complete.load(Ordering::SeqCst) { while !self.download_complete.load(Ordering::SeqCst) {
model.put(&mut db, &self).await?; let mut tx = db.begin().await?;
model.put(&mut tx, &self).await?;
tx.save().await?;
tokio::time::sleep(Duration::from_secs(1)).await; tokio::time::sleep(Duration::from_secs(1)).await;
} }
model.put(&mut db, &self).await?; let mut tx = db.begin().await?;
model.put(&mut tx, &self).await?;
tx.save().await?;
Ok(()) Ok(())
} }
pub async fn track_download_during< pub async fn track_download_during<
@@ -74,10 +78,14 @@ impl InstallProgress {
complete: Arc<AtomicBool>, complete: Arc<AtomicBool>,
) -> Result<(), Error> { ) -> Result<(), Error> {
while !complete.load(Ordering::SeqCst) { while !complete.load(Ordering::SeqCst) {
model.put(&mut db, &self).await?; let mut tx = db.begin().await?;
model.put(&mut tx, &self).await?;
tx.save().await?;
tokio::time::sleep(Duration::from_secs(1)).await; tokio::time::sleep(Duration::from_secs(1)).await;
} }
model.put(&mut db, &self).await?; let mut tx = db.begin().await?;
model.put(&mut tx, &self).await?;
tx.save().await?;
Ok(()) Ok(())
} }
pub async fn track_read_during< pub async fn track_read_during<