mirror of
https://git.anonymousland.org/anonymousland/synapse.git
synced 2024-09-07 12:02:08 +00:00
Do it in storage function
This commit is contained in:
parent
64a2acb161
commit
949629291c
@ -390,7 +390,7 @@ class ReplicationResource(Resource):
|
||||
|
||||
caches = request_streams.get("caches")
|
||||
|
||||
if caches is not None and current_position != caches:
|
||||
if caches is not None:
|
||||
updated_caches = yield self.store.get_all_updated_caches(
|
||||
caches, current_position, limit
|
||||
)
|
||||
|
@ -894,6 +894,9 @@ class SQLBaseStore(object):
|
||||
)
|
||||
|
||||
def get_all_updated_caches(self, last_id, current_id, limit):
|
||||
if last_id == current_id:
|
||||
return defer.succeed([])
|
||||
|
||||
def get_all_updated_caches_txn(txn):
|
||||
# We purposefully don't bound by the current token, as we want to
|
||||
# send across cache invalidations as quickly as possible. Cache
|
||||
|
Loading…
Reference in New Issue
Block a user