mirror of
https://mau.dev/maunium/synapse.git
synced 2024-09-02 23:52:00 +00:00
Limit the number of PDUs/EDUs per fedreation transaction
This commit is contained in:
parent
2608ebc04c
commit
6707a3212c
@ -463,7 +463,19 @@ class TransactionQueue(object):
|
|||||||
# pending_transactions flag.
|
# pending_transactions flag.
|
||||||
|
|
||||||
pending_pdus = self.pending_pdus_by_dest.pop(destination, [])
|
pending_pdus = self.pending_pdus_by_dest.pop(destination, [])
|
||||||
|
|
||||||
|
# We can only include at most 50 PDUs per transactions
|
||||||
|
pending_pdus, leftover_pdus = pending_pdus[:50], pending_pdus[50:]
|
||||||
|
if leftover_pdus:
|
||||||
|
self.pending_pdus_by_dest[destination] = leftover_pdus
|
||||||
|
|
||||||
pending_edus = self.pending_edus_by_dest.pop(destination, [])
|
pending_edus = self.pending_edus_by_dest.pop(destination, [])
|
||||||
|
|
||||||
|
# We can only include at most 100 EDUs per transactions
|
||||||
|
pending_edus, leftover_edus = pending_edus[:100], pending_edus[100:]
|
||||||
|
if leftover_edus:
|
||||||
|
self.pending_edus_by_dest[destination] = leftover_edus
|
||||||
|
|
||||||
pending_presence = self.pending_presence_by_dest.pop(destination, {})
|
pending_presence = self.pending_presence_by_dest.pop(destination, {})
|
||||||
|
|
||||||
pending_edus.extend(
|
pending_edus.extend(
|
||||||
|
Loading…
Reference in New Issue
Block a user