47 lines
1.6 KiB
Tcl
47 lines
1.6 KiB
Tcl
proc get_reply_buffer_size {cname} {
|
|
|
|
set clients [split [string trim [r client list]] "\r\n"]
|
|
set c [lsearch -inline $clients *name=$cname*]
|
|
if {![regexp rbs=(\[a-zA-Z0-9-\]+) $c - rbufsize]} {
|
|
error "field rbs not found in $c"
|
|
}
|
|
return $rbufsize
|
|
}
|
|
|
|
start_server {tags {"replybufsize"}} {
|
|
|
|
test {verify reply buffer limits} {
|
|
# In order to reduce test time we can set the peak reset time very low
|
|
r debug replybuffer peak-reset-time 100
|
|
|
|
# Create a simple idle test client
|
|
variable tc [redis_client]
|
|
$tc client setname test_client
|
|
|
|
# make sure the client is idle for 1 seconds to make it shrink the reply buffer
|
|
wait_for_condition 10 100 {
|
|
[get_reply_buffer_size test_client] >= 1024 && [get_reply_buffer_size test_client] < 2046
|
|
} else {
|
|
set rbs [get_reply_buffer_size test_client]
|
|
fail "reply buffer of idle client is $rbs after 1 seconds"
|
|
}
|
|
|
|
r set bigval [string repeat x 32768]
|
|
|
|
# In order to reduce test time we can set the peak reset time very low
|
|
r debug replybuffer peak-reset-time never
|
|
|
|
wait_for_condition 10 100 {
|
|
[$tc get bigval ; get_reply_buffer_size test_client] >= 16384 && [get_reply_buffer_size test_client] < 32768
|
|
} else {
|
|
set rbs [get_reply_buffer_size test_client]
|
|
fail "reply buffer of busy client is $rbs after 1 seconds"
|
|
}
|
|
|
|
# Restore the peak reset time to default
|
|
r debug replybuffer peak-reset-time reset
|
|
|
|
$tc close
|
|
} {0} {needs:debug}
|
|
}
|
|
|