Tair
/
RedisShake
mirror of https://github.com/tair-opensource/RedisShake.git
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: fix short inconsistency issue with ping command

This commit is contained in:
suxb201 2024-12-13 16:43:34 +08:00
parent 3496a398d5
commit 286ef6eb9a
3 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/cases/auth_acl.py
View File

@ -28,7 +28,7 @@ def acl():
shake = h.Shake(opts) shake = h.Shake(opts)
# wait sync done # wait sync done
p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent()) p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent(), interval=0.01)
p.log(shake.get_status()) p.log(shake.get_status())
# check data # check data

7
tests/cases/function.py
View File

@ -1,6 +1,5 @@
import pybbt as p
import helpers as h import helpers as h
import pybbt as p
@p.subcase() @p.subcase()
@ -26,7 +25,7 @@ def filter_db():
src.do("set", "key", "value") src.do("set", "key", "value")
# wait sync done # wait sync done
p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent(), timeout=10) p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent(), timeout=10, interval=0.01)
dst.do("select", 0) dst.do("select", 0)
p.ASSERT_EQ(dst.do("get", "key"), None) p.ASSERT_EQ(dst.do("get", "key"), None)
@ -55,7 +54,7 @@ def split_mset_to_set():
shake = h.Shake(opts) shake = h.Shake(opts)
src.do("mset", "k1", "v1", "k2", "v2", "k3", "v3") src.do("mset", "k1", "v1", "k2", "v2", "k3", "v3")
# wait sync done # wait sync done
p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent(), timeout=10) p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent(), timeout=10, interval=0.01)
dst.do("select", 1) dst.do("select", 1)
p.ASSERT_EQ(dst.do("get", "k1"), b"v1") p.ASSERT_EQ(dst.do("get", "k1"), b"v1")
p.ASSERT_EQ(dst.do("get", "k2"), b"v2") p.ASSERT_EQ(dst.do("get", "k2"), b"v2")

4
tests/cases/sync.py
View File

@ -18,7 +18,7 @@ def test(src, dst):
# wait sync done # wait sync done
try: # HTTPConnectionPool try: # HTTPConnectionPool
p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent(), timeout=10) p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent(), timeout=10, interval=0.01)
except Exception as e: except Exception as e:
with open(f"{shake.dir}/data/shake.log") as f: with open(f"{shake.dir}/data/shake.log") as f:
p.log(f.read()) p.log(f.read())
@ -28,7 +28,7 @@ def test(src, dst):
inserter.add_data(src, cross_slots_cmd=cross_slots_cmd) inserter.add_data(src, cross_slots_cmd=cross_slots_cmd)
# wait sync done # wait sync done
p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent()) p.ASSERT_TRUE_TIMEOUT(lambda: shake.is_consistent(), interval=0.01)
p.log(shake.get_status()) p.log(shake.get_status())
time.sleep(5) time.sleep(5)