mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-10 18:05:44 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

fix(snapshot_test): Fix test_big_value_serialization_memory_limit after adding streams support

Browse source 
Signed-off-by: Stepan Bagritsevich <stefan@dragonflydb.io>
This commit is contained in:
Stepan Bagritsevich 2024-12-29 13:37:26 +04:00
parent c4be62edc8
commit f33036db2a
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
tests/dragonfly/snapshot_test.py
View file

@ -592,16 +592,20 @@ async def test_big_value_serialization_memory_limit(df_factory, cont_type):
f"debug populate 1 prefix {element_size} TYPE {cont_type} RAND ELEMENTS {elements}" f"debug populate 1 prefix {element_size} TYPE {cont_type} RAND ELEMENTS {elements}"
) )
await asyncio.sleep(1)
info = await client.info("ALL") info = await client.info("ALL")
# rss double's because of DEBUG POPULATE # rss double's because of DEBUG POPULATE
assert info["used_memory_peak_rss"] > (one_gb * 2) peak_rss_before_save = info["used_memory_peak_rss"]
assert peak_rss_before_save > (one_gb * 2)
# if we execute SAVE below without big value serialization we trigger the assertion below. # if we execute SAVE below without big value serialization we trigger the assertion below.
# note the peak would reach (one_gb * 3) without it. # note the peak would reach (one_gb * 3) without it.
await client.execute_command("SAVE") await client.execute_command("SAVE")
info = await client.info("ALL") info = await client.info("ALL")
upper_limit = 2_250_000_000 # 2.25 GB # verify that the big value serialization mechanism is working
assert info["used_memory_peak_rss"] < upper_limit # after executing the SAVE command, there should be no spike in RSS memory.
assert info["used_memory_peak_rss"] < peak_rss_before_save * 1.3
await client.execute_command("FLUSHALL") await client.execute_command("FLUSHALL")
await client.close() await client.close()