mirror of
https://github.com/element-hq/synapse
synced 2024-09-04 05:30:07 +00:00
Fixup
This commit is contained in:
parent
9b147cd730
commit
2347efc065
1 changed files with 4 additions and 10 deletions
|
@ -174,11 +174,9 @@ class FederationHandler(BaseHandler):
|
|||
|
||||
# Update the set of things we've seen after trying to
|
||||
# fetch the missing stuff
|
||||
have_seen = yield self.store.have_events(
|
||||
[ev for ev, _ in pdu.prev_events]
|
||||
)
|
||||
have_seen = yield self.store.have_events(prevs)
|
||||
|
||||
seen = set(have_seen.keys())
|
||||
seen = set(have_seen.iterkeys())
|
||||
if prevs - seen:
|
||||
logger.info(
|
||||
"Still missing %d prev events for %s: %r...",
|
||||
|
@ -231,19 +229,15 @@ class FederationHandler(BaseHandler):
|
|||
Args:
|
||||
origin (str): Origin of the pdu. Will be called to get the missing events
|
||||
pdu: received pdu
|
||||
prevs (str[]): List of event ids which we are missing
|
||||
prevs (set(str)): List of event ids which we are missing
|
||||
min_depth (int): Minimum depth of events to return.
|
||||
|
||||
Returns:
|
||||
Deferred<dict(str, str?)>: updated have_seen dictionary
|
||||
"""
|
||||
# We recalculate seen, since it may have changed.
|
||||
have_seen = yield self.store.have_events(prevs)
|
||||
seen = set(have_seen.keys())
|
||||
|
||||
if not prevs - seen:
|
||||
# nothing left to do
|
||||
defer.returnValue(have_seen)
|
||||
return
|
||||
|
||||
latest = yield self.store.get_latest_event_ids_in_room(
|
||||
pdu.room_id
|
||||
|
|
Loading…
Reference in a new issue