Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-08 09:26:29 +03:00
Code Issues Packages Projects Releases Wiki Activity

less randomness

Browse Source
This commit is contained in:
holger krekel
2020-05-18 08:43:48 +02:00
parent 9c02f6db6e
commit b0dbb28422
1 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
python/tests/stress_test_db.py
View File

@@ -37,7 +37,7 @@ def test_db_busy_error(acfactory, tmpdir):
# each replier receives all events and sends report events to receive_queue # each replier receives all events and sends report events to receive_queue
repliers = [] repliers = []
for acc in accounts: for acc in accounts:
replier = AutoReplier(acc, big_probability=0.1, exit_probability=0.01, report_func=report_func) replier = AutoReplier(acc, num_send=1000, big_probability=1.0/300, report_func=report_func)
acc.add_account_plugin(replier) acc.add_account_plugin(replier)
repliers.append(replier) repliers.append(replier)
@@ -72,25 +72,20 @@ class ReportType:
class AutoReplier: class AutoReplier:
def __init__(self, account, big_probability, exit_probability, report_func): def __init__(self, account, report_func, num_send, big_probability):
assert 0 < exit_probability < 1 assert 0 < big_probability < 1
self.account = account self.account = account
self.report_func = report_func self.report_func = report_func
self.exit_probability = exit_probability self.num_remaining = num_send
self.big_probability = big_probability self.big_probability = big_probability
self.exiting = False
@deltachat.account_hookimpl @deltachat.account_hookimpl
def ac_incoming_message(self, message): def ac_incoming_message(self, message):
if self.exiting: if self.num_remaining == 0:
return return
message.accept_sender_contact() message.accept_sender_contact()
message.mark_seen() message.mark_seen()
self.report_func(self, ReportType.message_incoming, message) self.report_func(self, ReportType.message_incoming, message)
if random.random() <= self.exit_probability:
self.exiting = True
self.report_func(self, ReportType.exit)
return
# we are still alive, let's send a reply # we are still alive, let's send a reply
if random.random() <= self.big_probability: if random.random() <= self.big_probability:
@@ -100,6 +95,10 @@ class AutoReplier:
msg = message.chat.send_text("got message id {}, small text reply".format(message.id)) msg = message.chat.send_text("got message id {}, small text reply".format(message.id))
assert msg.text assert msg.text
self.report_func(self, ReportType.message_sent, msg) self.report_func(self, ReportType.message_sent, msg)
self.num_remaining -= 1
if self.num_remaining == 0:
self.report_func(self, ReportType.exit)
return
@deltachat.account_hookimpl @deltachat.account_hookimpl
def ac_process_ffi_event(self, ffi_event): def ac_process_ffi_event(self, ffi_event):