a round of renaming towards dc_io_* methods for start/stop/io scheduling

This commit is contained in:
holger krekel
2020-05-22 17:33:16 +02:00
parent c43285f6ac
commit d0686ada83
6 changed files with 34 additions and 56 deletions

View File

@@ -4,4 +4,4 @@ from deltachat.capi import ffi, lib
if __name__ == "__main__":
ctx = capi.lib.dc_context_new(ffi.NULL, ffi.NULL)
lib.dc_context_shutdown(ctx)
lib.dc_io_stop(ctx)

View File

@@ -575,7 +575,7 @@ class Account(object):
if not self.is_configured():
self.configure()
self.wait_configure_finish()
lib.dc_context_run(self._dc_context)
lib.dc_io_start(self._dc_context)
def configure(self):
assert not self.is_configured()
@@ -596,7 +596,7 @@ class Account(object):
del self._configtracker
def is_started(self):
return self._event_thread.is_alive() and bool(lib.dc_is_running(self._dc_context))
return self._event_thread.is_alive() and bool(lib.dc_io_status(self._dc_context))
def wait_shutdown(self):
""" wait until shutdown of this account has completed. """
@@ -607,9 +607,9 @@ class Account(object):
self.log("stop_ongoing")
self.stop_ongoing()
if bool(lib.dc_is_running(self._dc_context)):
if bool(lib.dc_io_status(self._dc_context)):
self.log("context_shutdown (stop core scheduler)")
lib.dc_context_shutdown(self._dc_context)
lib.dc_io_stop(self._dc_context)
else:
self.log("stop_scheduler called on non-running context")

View File

@@ -1,37 +0,0 @@
import deltachat
import os
import shutil
from deltachat.capi import lib
try:
os.remove("/tmp/db")
except:
pass
try:
shutil.rmtree("/tmp/db-blobs")
except:
pass
acc = deltachat.Account("/tmp/db", logging=True)
acc.set_config("addr", "tmp.hjfcq@five.chat")
acc.set_config("mail_pw", "aihWNtLuRJgV")
acc.start() # lib.dc_configure + lib.dc_context_run
assert acc.is_configured()
acc.stop_scheduler()
run = 0
while 1:
print("****** starting scheduler")
acc.start()
import time ; time.sleep(0.5)
print("******* stopping scheduler")
acc.stop_scheduler()
print("******* waiting", run)
import time ; time.sleep(1.0)
run += 1
contact = acc.create_contact("holger@deltachat.de")
chat = acc.create_chat_by_contact(contact)
chat.send_text("hello")