1 files changed, 5 insertions, 0 deletions
diff --git a/synapse/util/caches/stream_change_cache.py b/synapse/util/caches/stream_change_cache.py
index 22a9f8f467..c673b1bdfc 100644
--- a/synapse/util/caches/stream_change_cache.py
+++ b/synapse/util/caches/stream_change_cache.py
@@ -49,6 +49,11 @@ class StreamChangeCache(object):
cache_counter.inc_misses(self.name)
return True
+ if stream_pos == self._earliest_known_stream_pos:
+ # If the same as the earliest key, assume nothing has changed.
+ cache_counter.inc_hits(self.name)
+ return False
+
latest_entity_change_pos = self._entity_to_key.get(entity, None)
if latest_entity_change_pos is None:
cache_counter.inc_misses(self.name)
|