upstream/redis
1
0
Fork 0
mirror of https://github.com/redis/redis.git synced 2026-05-28 04:02:46 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Merge e029dd7a17 into 30f57f32bd

Browse source
This commit is contained in:
Vitah Lin 2026-05-28 04:00:22 +02:00 committed by GitHub
commit 9392d3db90
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 31 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
tests/unit/moduleapi/datatype.tcl
View file

@ -151,8 +151,22 @@ start_server {tags {"modules external:skip"}} {
set n 20000
set dummy "[string repeat x 400]"
set rd [redis_deferring_client]
for {set i 0} {$i < $n} {incr i} { $rd datatype.set k$i 1 $dummy }
for {set i 0} {$i < [expr $n]} {incr i} { $rd read } ;# Discard replies
# Use batching to avoid TCP deadlock when deferred replies accumulate.
set batch_size 1000
for {set i 0} {$i < $n} {incr i} {
$rd datatype.set k$i 1 $dummy
if {($i + 1) % $batch_size == 0} {
for {set j 0} {$j < $batch_size} {incr j} {
$rd read
}
}
}
set remaining [expr {$n % $batch_size}]
for {set i 0} {$i < $remaining} {incr i} {
$rd read
}
after 120 ;# serverCron only updates the info once in 100ms
if {$::verbose} {
@ -163,8 +177,21 @@ start_server {tags {"modules external:skip"}} {
}
assert_lessthan [s allocator_frag_ratio] 1.05
for {set i 0} {$i < $n} {incr i 2} { $rd del k$i }
for {set j 0} {$j < $n} {incr j 2} { $rd read } ; # Discard del replies
set del_replies 0
for {set i 0} {$i < $n} {incr i 2} {
$rd del k$i
incr del_replies
if {$del_replies % $batch_size == 0} {
for {set j 0} {$j < $batch_size} {incr j} {
$rd read
}
}
}
set remaining [expr {$del_replies % $batch_size}]
for {set i 0} {$i < $remaining} {incr i} {
$rd read
}
after 120 ;# serverCron only updates the info once in 100ms
assert_morethan [s allocator_frag_ratio] 1.4