kaslo/synapse
1
0
Fork 0
Code Wiki Activity

Pipe through the feature flag

Browse Source
This commit is contained in:
Olivier Wilkinson (reivilibre)
2021-12-10 14:48:14 +00:00
parent c5d7988ad0
commit 4cba87c025
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
synapse/appservice/scheduler.py
View File

@@ -92,7 +92,7 @@ class ApplicationServiceScheduler:
self.as_api = hs.get_application_service_api()
self.txn_ctrl = _TransactionController(self.clock, self.store, self.as_api)
self.queuer = _ServiceQueuer(self.txn_ctrl, self.clock)
self.queuer = _ServiceQueuer(self.txn_ctrl, self.clock, hs)
async def start(self) -> None:
logger.info("Starting appservice scheduler")
@@ -148,7 +148,7 @@ class _ServiceQueuer:
appservice at a given time.
"""
def __init__(self, txn_ctrl: "_TransactionController", clock: Clock):
def __init__(self, txn_ctrl: "_TransactionController", clock: Clock, hs: "HomeServer"):
# dict of {service_id: [events]}
self.queued_events: Dict[str, List[EventBase]] = {}
# dict of {service_id: [event_json]}
@@ -160,6 +160,9 @@ class _ServiceQueuer:
self.requests_in_flight: Set[str] = set()
self.txn_ctrl = txn_ctrl
self.clock = clock
self._msc3202_transaction_extensions_enabled: bool = (
hs.config.experimental.msc3202_transaction_extensions
)
def start_background_request(self, service: ApplicationService) -> None:
# start a sender for this appservice if we don't already have one