Matrix-Mirrors/pantalaimon
1
0
Fork 0
mirror of https://github.com/matrix-org/pantalaimon.git synced 2024-10-01 03:35:38 -04:00
Code Issues Packages Projects Releases Wiki Activity

client: Allow the pan client sync loop to have a timeout between iterations.

Browse Source
This commit is contained in:
Damir Jelić 2019-07-03 17:42:14 +02:00
parent 53d1a2945d
commit 758ca1fd85
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pantalaimon/client.py
View File

@ -400,7 +400,7 @@ class PanClient(AsyncClient):
) )
await self.send_update_device(device) await self.send_update_device(device)
def start_loop(self): def start_loop(self, loop_sleep_time=None):
"""Start a loop that runs forever and keeps on syncing with the server. """Start a loop that runs forever and keeps on syncing with the server.
The loop can be stopped with the stop_loop() method. The loop can be stopped with the stop_loop() method.
@ -417,11 +417,18 @@ class PanClient(AsyncClient):
timeout = 30000 timeout = 30000
sync_filter = {"room": {"state": {"lazy_load_members": True}}} sync_filter = {"room": {"state": {"lazy_load_members": True}}}
next_batch = self.pan_store.load_token(self.server_name, self.user_id) next_batch = self.pan_store.load_token(self.server_name, self.user_id)
self.last_sync_token = next_batch
# We don't store any room state so initial sync needs to be with the # We don't store any room state so initial sync needs to be with the
# full_state parameter. Subsequent ones are normal. # full_state parameter. Subsequent ones are normal.
task = loop.create_task( task = loop.create_task(
self.sync_forever(timeout, sync_filter, full_state=True, since=next_batch) self.sync_forever(
timeout,
sync_filter,
full_state=True,
since=next_batch,
loop_sleep_time=loop_sleep_time
)
) )
self.task = task self.task = task