diff options
| author | Amber Brown <hawkowl@atleastfornow.net> | 2018-06-22 09:37:10 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-06-22 09:37:10 +0100 |
| commit | 77ac14b960cb8daef76062ce85fc0427749b48af (patch) | |
| tree | 4a2b3af0e0404640a2ef251030cd3c2591a1d6ba /synapse/storage/client_ips.py | |
| parent | Populate synapse_federation_client_sent_pdu_destinations:count again (#3386) (diff) | |
| download | synapse-77ac14b960cb8daef76062ce85fc0427749b48af.tar.xz | |
Pass around the reactor explicitly (#3385)
Diffstat (limited to 'synapse/storage/client_ips.py')
| -rw-r--r-- | synapse/storage/client_ips.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/synapse/storage/client_ips.py b/synapse/storage/client_ips.py index ce338514e8..968d2fed22 100644 --- a/synapse/storage/client_ips.py +++ b/synapse/storage/client_ips.py @@ -15,7 +15,7 @@ import logging -from twisted.internet import defer, reactor +from twisted.internet import defer from ._base import Cache from . import background_updates @@ -70,7 +70,9 @@ class ClientIpStore(background_updates.BackgroundUpdateStore): self._client_ip_looper = self._clock.looping_call( self._update_client_ips_batch, 5 * 1000 ) - reactor.addSystemEventTrigger("before", "shutdown", self._update_client_ips_batch) + self.hs.get_reactor().addSystemEventTrigger( + "before", "shutdown", self._update_client_ips_batch + ) def insert_client_ip(self, user_id, access_token, ip, user_agent, device_id, now=None): |