blob: dc4e1a999d1d86dd74a0488b2dfd0fae34eb0a6b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
source tests/support/redis.tcl
source tests/support/util.tcl
set ::tlsdir "tests/tls"
# This function sometimes writes sometimes blocking-reads from lists/sorted
# sets. There are multiple processes like this executing at the same time
# so that we have some chance to trap some corner condition if there is
# a regression. For this to happen it is important that we narrow the key
# space to just a few elements, and balance the operations so that it is
# unlikely that lists and zsets just get more data without ever causing
# blocking.
proc bg_block_op {host port db ops tls} {
set r [redis $host $port 0 $tls]
$r client setname LOAD_HANDLER
$r select $db
for {set j 0} {$j < $ops} {incr j} {
# List side
set k list_[randomInt 10]
set k2 list_[randomInt 10]
set v [randomValue]
randpath {
randpath {
$r rpush $k $v
} {
$r lpush $k $v
}
} {
$r blpop $k 2
} {
$r blpop $k $k2 2
}
# Zset side
set k zset_[randomInt 10]
set k2 zset_[randomInt 10]
set v1 [randomValue]
set v2 [randomValue]
randpath {
$r zadd $k [randomInt 10000] $v
} {
$r zadd $k [randomInt 10000] $v [randomInt 10000] $v2
} {
$r bzpopmin $k 2
} {
$r bzpopmax $k 2
}
}
}
bg_block_op [lindex $argv 0] [lindex $argv 1] [lindex $argv 2] [lindex $argv 3] [lindex $argv 4]
|
