316590d1ea
We were incorrectly checking if the *local* token had been advanced, rather than the token for the remote instance. In practice, I don't think this has caused any bugs due to where we use `wait_for_stream_position`, as critically we don't use it on instances that also write to the given streams (and so the local token will lag behind all remote tokens). |
||
---|---|---|
.. | ||
http | ||
slave | ||
tcp | ||
__init__.py | ||
_base.py | ||
test_auth.py | ||
test_client_reader_shard.py | ||
test_federation_ack.py | ||
test_federation_sender_shard.py | ||
test_module_cache_invalidation.py | ||
test_multi_media_repo.py | ||
test_pusher_shard.py | ||
test_sharded_event_persister.py |