forked from MirrorHub/synapse
Fix inequalities
This commit is contained in:
parent
03b2c2577c
commit
82cf3a8043
1 changed files with 2 additions and 2 deletions
|
@ -45,7 +45,7 @@ class StreamChangeCache(object):
|
||||||
"""
|
"""
|
||||||
assert type(stream_pos) is int
|
assert type(stream_pos) is int
|
||||||
|
|
||||||
if stream_pos <= self._earliest_known_stream_pos:
|
if stream_pos < self._earliest_known_stream_pos:
|
||||||
cache_counter.inc_misses(self.name)
|
cache_counter.inc_misses(self.name)
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
@ -67,7 +67,7 @@ class StreamChangeCache(object):
|
||||||
"""
|
"""
|
||||||
assert type(stream_pos) is int
|
assert type(stream_pos) is int
|
||||||
|
|
||||||
if stream_pos > self._earliest_known_stream_pos:
|
if stream_pos >= self._earliest_known_stream_pos:
|
||||||
keys = self._cache.keys()
|
keys = self._cache.keys()
|
||||||
i = keys.bisect_right(stream_pos)
|
i = keys.bisect_right(stream_pos)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue