s/get_forward_events/get_successor_events/
This commit is contained in:
parent
fbc047f2a5
commit
8b63fe4c26
|
@ -881,7 +881,7 @@ class FederationHandler(BaseHandler):
|
||||||
# join of the server where we are allowed to see the join event but
|
# join of the server where we are allowed to see the join event but
|
||||||
# not anything before it.
|
# not anything before it.
|
||||||
|
|
||||||
forward_events = yield self.store.get_forward_events(
|
forward_events = yield self.store.get_successor_events(
|
||||||
list(extremities),
|
list(extremities),
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -443,7 +443,7 @@ class EventFederationWorkerStore(EventsWorkerStore, SignatureWorkerStore,
|
||||||
return event_results
|
return event_results
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def get_forward_events(self, event_ids):
|
def get_successor_events(self, event_ids):
|
||||||
"""Fetch all events that have the given events as a prev event
|
"""Fetch all events that have the given events as a prev event
|
||||||
|
|
||||||
Args:
|
Args:
|
||||||
|
@ -457,7 +457,7 @@ class EventFederationWorkerStore(EventsWorkerStore, SignatureWorkerStore,
|
||||||
column="prev_event_id",
|
column="prev_event_id",
|
||||||
iterable=event_ids,
|
iterable=event_ids,
|
||||||
retcols=("event_id",),
|
retcols=("event_id",),
|
||||||
desc="get_forward_events"
|
desc="get_successor_events"
|
||||||
)
|
)
|
||||||
|
|
||||||
defer.returnValue([
|
defer.returnValue([
|
||||||
|
|
Loading…
Reference in New Issue