Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-04-17 21:46:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

fixup paused flag use

Browse Source
This commit is contained in:
Floris Bruynooghe
2023-03-08 14:39:40 +01:00
committed by link2xt
parent 1d42e4743f
commit 097113f01e
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/scheduler.rs
View File

@@ -49,7 +49,7 @@ impl SchedulerState {
pub(crate) async fn start(&self, context: Context) {
let mut inner = self.inner.write().await;
inner.started = true;
if inner.scheduler.is_none() {
if inner.scheduler.is_none() && !inner.paused {
Self::do_start(inner, context).await;
}
}
@@ -204,7 +204,8 @@ pub(crate) struct IoPausedGuard<'a> {
impl<'a> IoPausedGuard<'a> {
pub(crate) async fn resume(&mut self) {
self.done = true;
let inner = self.context.scheduler.inner.write().await;
let mut inner = self.context.scheduler.inner.write().await;
inner.paused = false;
if inner.started && inner.scheduler.is_none() {
SchedulerState::do_start(inner, self.context.clone()).await;
}
@@ -218,7 +219,8 @@ impl<'a> Drop for IoPausedGuard<'a> {
}
let context = self.context.clone();
tokio::spawn(async move {
let inner = context.scheduler.inner.write().await;
let mut inner = context.scheduler.inner.write().await;
inner.paused = false;
if inner.started && inner.scheduler.is_none() {
SchedulerState::do_start(inner, context.clone()).await;
}