kaslo/synapse
1
0
Fork 0
Code Wiki Activity

The early bird gets the early return

Browse Source 
(hopefully with a worm as the return value)
This commit is contained in:
Olivier Wilkinson (reivilibre)
2020-08-26 20:49:50 +01:00
parent c1a2b680c4
commit 16eec5cbfa
1 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
synapse/federation/sender/per_destination_queue.py
View File

@@ -518,18 +518,19 @@ class PerDestinationQueue(object):
success = await self._transaction_manager.send_new_transaction(
self._destination, catch_up_pdus, []
)
if success:
sent_transactions_counter.inc()
final_pdu, _ = catch_up_pdus[-1]
self._last_successful_stream_order = cast(
int, final_pdu.internal_metadata.stream_ordering
)
await self._store.set_last_successful_stream_ordering(
self._destination, self._last_successful_stream_order
)
else:
if not success:
return
sent_transactions_counter.inc()
final_pdu, _ = catch_up_pdus[-1]
self._last_successful_stream_order = cast(
int, final_pdu.internal_metadata.stream_ordering
)
await self._store.set_last_successful_stream_ordering(
self._destination, self._last_successful_stream_order
)
# once we have reached this point, catch-up is done!
self._catching_up = False