diff --git a/tests/integration/corrupt-dump-fuzzer.tcl b/tests/integration/corrupt-dump-fuzzer.tcl index 2406883daec..1e647ac90d6 100644 --- a/tests/integration/corrupt-dump-fuzzer.tcl +++ b/tests/integration/corrupt-dump-fuzzer.tcl @@ -15,6 +15,7 @@ if { ! [ catch { proc generate_collections {suffix elements} { set rd [valkey_deferring_client] + $rd client reply off for {set j 0} {$j < $elements} {incr j} { # add both string values and integers if {$j % 2 == 0} {set val $j} else {set val "_$j"} @@ -24,9 +25,8 @@ proc generate_collections {suffix elements} { $rd sadd set$suffix $val $rd xadd stream$suffix * item 1 value $val } - for {set j 0} {$j < $elements * 5} {incr j} { - $rd read ; # Discard replies - } + $rd client reply on + assert_equal OK [$rd read] $rd close } diff --git a/tests/integration/rdb.tcl b/tests/integration/rdb.tcl index da9608e0b25..fb43c142189 100644 --- a/tests/integration/rdb.tcl +++ b/tests/integration/rdb.tcl @@ -414,16 +414,15 @@ start_server {overrides {save ""}} { # changing some keys and read the reported COW size, we are using small key size to prevent from # the "dismiss mechanism" free memory and reduce the COW size) set rd [valkey_deferring_client 0] + $rd client reply off set size 500 ;# aim for the 512 bin (sds overhead) set cmd_count 10000 + set AAA [string repeat A $size] for {set k 0} {$k < $cmd_count} {incr k} { - $rd set key$k [string repeat A $size] + $rd set key$k $AAA } - - for {set k 0} {$k < $cmd_count} {incr k} { - catch { $rd read } - } - + $rd client reply on + assert_equal OK [$rd read] $rd close # start background rdb save @@ -452,8 +451,9 @@ start_server {overrides {save ""}} { # trigger copy-on-write set modified_keys 16 + set BBB [string repeat B $size] for {set k 0} {$k < $modified_keys} {incr k} { - r setrange key$key_idx 0 [string repeat B $size] + r setrange key$key_idx 0 $BBB incr key_idx 1 } diff --git a/tests/unit/cluster/diskless-load-swapdb.tcl b/tests/unit/cluster/diskless-load-swapdb.tcl index e237fd81de9..3153af7fc9a 100644 --- a/tests/unit/cluster/diskless-load-swapdb.tcl +++ b/tests/unit/cluster/diskless-load-swapdb.tcl @@ -48,12 +48,13 @@ test "Main db not affected when fail to diskless load" { set num 10000 set value [string repeat A 1024] set rd [valkey_deferring_client valkey $master_id] + $rd client reply off for {set j 0} {$j < $num} {incr j} { $rd set $j $value + if {$j % 1000 == 0} {$rd flush} } - for {set j 0} {$j < $num} {incr j} { - $rd read - } + $rd client reply on + assert_equal OK [$rd read] # Start the replica again resume_process [srv $replica_id pid] diff --git a/tests/unit/moduleapi/test_lazyfree.tcl b/tests/unit/moduleapi/test_lazyfree.tcl index 9e1e4680af5..0cf9aebda17 100644 --- a/tests/unit/moduleapi/test_lazyfree.tcl +++ b/tests/unit/moduleapi/test_lazyfree.tcl @@ -8,13 +8,13 @@ start_server {tags {"modules"}} { set rd [valkey_deferring_client] # LAZYFREE_THRESHOLD is 64 + $rd client reply off for {set i 0} {$i < 10000} {incr i} { $rd lazyfreelink.insert lazykey $i + if {$i % 1000 == 0} {$rd flush} } - - for {set j 0} {$j < 10000} {incr j} { - $rd read - } + $rd client reply on + assert_equal OK [$rd read] assert {[r lazyfreelink.len lazykey] == 10000}