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

make python tests run the mvbox thread

Browse Source
This commit is contained in:
holger krekel
2019-08-21 07:39:41 +02:00
parent 9227c4b55c
commit 6b044dd85a
2 changed files with 16 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
python/src/deltachat/account.py
View File

@@ -377,12 +377,15 @@ class IOThreads:
def is_started(self): def is_started(self):
return len(self._name2thread) > 0 return len(self._name2thread) > 0
def start(self, imap=True, smtp=True): def start(self, imap=True, smtp=True, mvbox=True):
assert not self.is_started() assert not self.is_started()
if imap: if imap:
self._start_one_thread("imap", self.imap_thread_run) self._start_one_thread("inbox", self.inbox_thread_run)
if smtp: if smtp:
self._start_one_thread("smtp", self.smtp_thread_run) self._start_one_thread("smtp", self.smtp_thread_run)
if mvbox:
self._start_one_thread("mvbox", self.mvbox_thread_run)
def _start_one_thread(self, name, func): def _start_one_thread(self, name, func):
self._name2thread[name] = t = threading.Thread(target=func, name=name) self._name2thread[name] = t = threading.Thread(target=func, name=name)
@@ -397,13 +400,20 @@ class IOThreads:
for name, thread in self._name2thread.items(): for name, thread in self._name2thread.items():
thread.join() thread.join()
def imap_thread_run(self): def inbox_thread_run(self):
self._log_event("py-bindings-info", 0, "IMAP THREAD START") self._log_event("py-bindings-info", 0, "INBOX IMAP THREAD START")
while not self._thread_quitflag: while not self._thread_quitflag:
lib.dc_perform_imap_jobs(self._dc_context) lib.dc_perform_imap_jobs(self._dc_context)
lib.dc_perform_imap_fetch(self._dc_context) lib.dc_perform_imap_fetch(self._dc_context)
lib.dc_perform_imap_idle(self._dc_context) lib.dc_perform_imap_idle(self._dc_context)
self._log_event("py-bindings-info", 0, "IMAP THREAD FINISHED") self._log_event("py-bindings-info", 0, "INBOX IMAP THREAD FINISHED")
def mvbox_thread_run(self):
self._log_event("py-bindings-info", 0, "MVBOX IMAP THREAD START")
while not self._thread_quitflag:
lib.dc_perform_mvbox_fetch(self._dc_context)
lib.dc_perform_mvbox_idle(self._dc_context)
self._log_event("py-bindings-info", 0, "MVBOX IMAP THREAD FINISHED")
def smtp_thread_run(self): def smtp_thread_run(self):
self._log_event("py-bindings-info", 0, "SMTP THREAD START") self._log_event("py-bindings-info", 0, "SMTP THREAD START")

2
src/imap.rs
View File

@@ -673,7 +673,7 @@ impl Imap {
} else { } else {
unreachable!(); unreachable!();
} }
self.config.write().unwrap().selected_folder_needs_expunge = true; self.config.write().unwrap().selected_folder_needs_expunge = false;
} }
} }