mirror of
https://github.com/element-hq/synapse.git
synced 2026-03-29 08:50:09 +00:00
@@ -274,18 +274,18 @@ main() {
|
||||
# We pick and choose the specific MSC's that Synapse supports.
|
||||
default_complement_test_packages=(
|
||||
./tests/csapi
|
||||
# ./tests
|
||||
# ./tests/msc3874
|
||||
# ./tests/msc3890
|
||||
# ./tests/msc3391
|
||||
# ./tests/msc3757
|
||||
# ./tests/msc3930
|
||||
# ./tests/msc3902
|
||||
# ./tests/msc3967
|
||||
# ./tests/msc4140
|
||||
# ./tests/msc4155
|
||||
# ./tests/msc4306
|
||||
# ./tests/msc4222
|
||||
./tests
|
||||
./tests/msc3874
|
||||
./tests/msc3890
|
||||
./tests/msc3391
|
||||
./tests/msc3757
|
||||
./tests/msc3930
|
||||
./tests/msc3902
|
||||
./tests/msc3967
|
||||
./tests/msc4140
|
||||
./tests/msc4155
|
||||
./tests/msc4306
|
||||
./tests/msc4222
|
||||
)
|
||||
|
||||
# Export the list of test packages as a space-separated environment variable, so other
|
||||
|
||||
@@ -255,8 +255,7 @@ class FederationHandler:
|
||||
room_id=room_id,
|
||||
# Per the docstring, it's best to pad the `current_depth` by the
|
||||
# number of messages you plan to backfill from these points.
|
||||
# current_depth=current_depth + limit,
|
||||
current_depth=current_depth,
|
||||
current_depth=current_depth + limit,
|
||||
# We only need to end up with 5 extremities combined with the
|
||||
# insertion event extremities to make the `/backfill` request
|
||||
# but fetch an order of magnitude more to make sure there is
|
||||
@@ -268,25 +267,6 @@ class FederationHandler:
|
||||
)
|
||||
]
|
||||
|
||||
all_backwards_extremities = [
|
||||
_BackfillPoint(event_id, depth, _BackfillPointType.BACKWARDS_EXTREMITY)
|
||||
for event_id, depth in await self.store.get_backfill_points_in_room(
|
||||
room_id=room_id,
|
||||
current_depth=999999,
|
||||
limit=50,
|
||||
)
|
||||
]
|
||||
logger.info(
|
||||
"asdf all_backwards_extremities=%s",
|
||||
all_backwards_extremities,
|
||||
)
|
||||
|
||||
logger.info(
|
||||
"asdf current_depth=%s backwards_extremities=%s",
|
||||
current_depth,
|
||||
backwards_extremities,
|
||||
)
|
||||
|
||||
# we now have a list of potential places to backpaginate from. We prefer to
|
||||
# start with the most recent (ie, max depth), so let's sort the list.
|
||||
sorted_backfill_points: list[_BackfillPoint] = sorted(
|
||||
@@ -333,7 +313,6 @@ class FederationHandler:
|
||||
logger.debug(
|
||||
"_maybe_backfill_inner: all backfill points are *after* current depth. Trying again with later backfill points."
|
||||
)
|
||||
logger.info("asdf: backfill in the background")
|
||||
self.hs.run_as_background_process(
|
||||
"_maybe_backfill_inner_anyway_with_max_depth",
|
||||
self.maybe_backfill,
|
||||
|
||||
@@ -566,13 +566,6 @@ class PaginationHandler:
|
||||
StreamKeyType.ROOM, leave_token
|
||||
)
|
||||
|
||||
logger.info(
|
||||
"asdf get_messages backfill=%s pagin_config.from_token=%s curr_topo=%s",
|
||||
backfill,
|
||||
pagin_config.from_token,
|
||||
curr_topo,
|
||||
)
|
||||
|
||||
to_room_key = None
|
||||
if pagin_config.to_token:
|
||||
to_room_key = pagin_config.to_token.room_key
|
||||
|
||||
Reference in New Issue
Block a user