Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-19 06:46:32 +03:00
Code Issues Packages Projects Releases Wiki Activity

safer interruptability of fake-idle -- reusing the same skip_next_idle pattern as with idle

Browse Source
This commit is contained in:
holger krekel
2019-11-25 23:45:57 +01:00
parent 59700cb477
commit 618d74cd67
3 changed files with 37 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
src/imap.rs
View File

@@ -886,37 +886,43 @@ impl Imap {
let interval = async_std::stream::interval(Duration::from_secs(60)); let interval = async_std::stream::interval(Duration::from_secs(60));
let mut interrupt_interval = interrupt.stop_token().stop_stream(interval); let mut interrupt_interval = interrupt.stop_token().stop_stream(interval);
*self.interrupt.lock().await = Some(interrupt); *self.interrupt.lock().await = Some(interrupt);
if self.skip_next_idle_wait.load(Ordering::SeqCst) {
// interrupt_idle has happened before we
// provided self.interrupt
self.skip_next_idle_wait.store(false, Ordering::SeqCst);
info!(context, "fake-idle wait was skipped");
} else {
// loop until we are interrupted or if we fetched something
while let Some(_) = interrupt_interval.next().await {
// try to connect with proper login params
// (setup_handle_if_needed might not know about them if we
// never successfully connected)
if let Err(err) = self.connect_configured(context) {
warn!(context, "fake_idle: could not connect: {}", err);
continue;
}
if self.config.read().await.can_idle {
// we only fake-idled because network was gone during IDLE, probably
break;
}
info!(context, "fake_idle is connected");
// we are connected, let's see if fetching messages results
// in anything. If so, we behave as if IDLE had data but
// will have already fetched the messages so perform_*_fetch
// will not find any new.
// loop until we are interrupted or if we fetched something if let Some(ref watch_folder) = watch_folder {
while let Some(_) = interrupt_interval.next().await { match self.fetch_from_single_folder(context, watch_folder).await {
// try to connect with proper login params Ok(res) => {
// (setup_handle_if_needed might not know about them if we info!(context, "fetch_from_single_folder returned {:?}", res);
// never successfully connected) if res {
if let Err(err) = self.connect_configured(context) { break;
warn!(context, "fake_idle: could not connect: {}", err); }
continue; }
} Err(err) => {
if self.config.read().await.can_idle { error!(context, "could not fetch from folder: {}", err);
// we only fake-idled because network was gone during IDLE, probably self.trigger_reconnect()
break;
}
info!(context, "fake_idle is connected");
// we are connected, let's see if fetching messages results
// in anything. If so, we behave as if IDLE had data but
// will have already fetched the messages so perform_*_fetch
// will not find any new.
if let Some(ref watch_folder) = watch_folder {
match self.fetch_from_single_folder(context, watch_folder).await {
Ok(res) => {
info!(context, "fetch_from_single_folder returned {:?}", res);
if res {
break;
} }
}
Err(err) => {
error!(context, "could not fetch from folder: {}", err);
self.trigger_reconnect()
} }
} }
} }

1
src/job.rs
View File

@@ -1011,4 +1011,5 @@ pub fn interrupt_smtp_idle(context: &Context) {
state.perform_jobs_needed = 1; state.perform_jobs_needed = 1;
state.idle = true; state.idle = true;
cvar.notify_one(); cvar.notify_one();
info!(context, "Interrupting SMTP-idle... ended",);
} }

1
src/job_thread.rs
View File

@@ -70,6 +70,7 @@ impl JobThread {
state.idle = true; state.idle = true;
cvar.notify_one(); cvar.notify_one();
info!(context, "Interrupting {}-IDLE... finished", self.name);
} }
pub fn fetch(&mut self, context: &Context, use_network: bool) { pub fn fetch(&mut self, context: &Context, use_network: bool) {