start_server {tags {"other"}} { if {$::force_failure} { # This is used just for test suite development purposes. test {Failing test} { format err } {ok} } test {SAVE - make sure there are all the types as values} { # Wait for a background saving in progress to terminate waitForBgsave r r lpush mysavelist hello r lpush mysavelist world r set myemptykey {} r set mynormalkey {blablablba} r zadd mytestzset 10 a r zadd mytestzset 20 b r zadd mytestzset 30 c r save } {OK} tags {slow} { if {$::accurate} {set iterations 10000} else {set iterations 1000} foreach fuzztype {binary alpha compr} { test "FUZZ stresser with data model $fuzztype" { set err 0 for {set i 0} {$i < $iterations} {incr i} { set fuzz [randstring 0 512 $fuzztype] r set foo $fuzz set got [r get foo] if {$got ne $fuzz} { set err [list $fuzz $got] break } } set _ $err } {0} } } test {BGSAVE} { waitForBgsave r r flushdb r save r set x 10 r bgsave waitForBgsave r r debug reload r get x } {10} test {SELECT an out of range DB} { catch {r select 1000000} err set _ $err } {*index is out of range*} tags {consistency} { if {true} { if {$::accurate} {set numops 10000} else {set numops 1000} test {Check consistency of different data types after a reload} { r flushdb createComplexDataset r $numops set dump [csvdump r] set sha1 [r debug digest] r debug reload set sha1_after [r debug digest] if {$sha1 eq $sha1_after} { set _ 1 } else { set newdump [csvdump r] puts "Consistency test failed!" puts "You can inspect the two dumps in /tmp/repldump*.txt" set fd [open /tmp/repldump1.txt w] puts $fd $dump close $fd set fd [open /tmp/repldump2.txt w] puts $fd $newdump close $fd set _ 0 } } {1} test {Same dataset digest if saving/reloading as AOF?} { r config set aof-use-rdb-preamble no r bgrewriteaof waitForBgrewriteaof r r debug loadaof set sha1_after [r debug digest] if {$sha1 eq $sha1_after} { set _ 1 } else { set newdump [csvdump r] puts "Consistency test failed!" puts "You can inspect the two dumps in /tmp/aofdump*.txt" set fd [open /tmp/aofdump1.txt w] puts $fd $dump close $fd set fd [open /tmp/aofdump2.txt w] puts $fd $newdump close $fd set _ 0 } } {1} } } test {EXPIRES after a reload (snapshot + append only file rewrite)} { r flushdb r set x 10 r expire x 1000 r save r debug reload set ttl [r ttl x] set e1 [expr {$ttl > 900 && $ttl <= 1000}] r bgrewriteaof waitForBgrewriteaof r r debug loadaof set ttl [r ttl x] set e2 [expr {$ttl > 900 && $ttl <= 1000}] list $e1 $e2 } {1 1} test {EXPIRES after AOF reload (without rewrite)} { r flushdb r config set appendonly yes r config set aof-use-rdb-preamble no r set x somevalue r expire x 1000 r setex y 2000 somevalue r set z somevalue r expireat z [expr {[clock seconds]+3000}] # Milliseconds variants r set px somevalue r pexpire px 1000000 r psetex py 2000000 somevalue r set pz somevalue r pexpireat pz [expr {([clock seconds]+3000)*1000}] # Reload and check waitForBgrewriteaof r # We need to wait two seconds to avoid false positives here, otherwise # the DEBUG LOADAOF command may read a partial file. # Another solution would be to set the fsync policy to no, since this # prevents write() to be delayed by the completion of fsync(). after 2000 r debug loadaof set ttl [r ttl x] assert {$ttl > 900 && $ttl <= 1000} set ttl [r ttl y] assert {$ttl > 1900 && $ttl <= 2000} set ttl [r ttl z] assert {$ttl > 2900 && $ttl <= 3000} set ttl [r ttl px] assert {$ttl > 900 && $ttl <= 1000} set ttl [r ttl py] assert {$ttl > 1900 && $ttl <= 2000} set ttl [r ttl pz] assert {$ttl > 2900 && $ttl <= 3000} r config set appendonly no } tags {protocol} { test {PIPELINING stresser (also a regression for the old epoll bug)} { if {$::tls} { set fd2 [::tls::socket [srv host] [srv port]] } else { set fd2 [socket [srv host] [srv port]] } fconfigure $fd2 -encoding binary -translation binary puts -nonewline $fd2 "SELECT 9\r\n" flush $fd2 gets $fd2 for {set i 0} {$i < 100000} {incr i} { set q {} set val "0000${i}0000" append q "SET key:$i $val\r\n" puts -nonewline $fd2 $q set q {} append q "GET key:$i\r\n" puts -nonewline $fd2 $q } flush $fd2 for {set i 0} {$i < 100000} {incr i} { gets $fd2 line gets $fd2 count set count [string range $count 1 end] set val [read $fd2 $count] read $fd2 2 } close $fd2 set _ 1 } {1} } test {APPEND basics} { r del foo list [r append foo bar] [r get foo] \ [r append foo 100] [r get foo] } {3 bar 6 bar100} test {APPEND basics, integer encoded values} { set res {} r del foo r append foo 1 r append foo 2 lappend res [r get foo] r set foo 1 r append foo 2 lappend res [r get foo] } {12 12} test {APPEND fuzzing} { set err {} foreach type {binary alpha compr} { set buf {} r del x for {set i 0} {$i < 1000} {incr i} { set bin [randstring 0 10 $type] append buf $bin r append x $bin } if {$buf != [r get x]} { set err "Expected '$buf' found '[r get x]'" break } } set _ $err } {} # Leave the user with a clean DB before to exit test {FLUSHDB} { set aux {} r select 9 r flushdb lappend aux [r dbsize] r select 10 r flushdb lappend aux [r dbsize] } {0 0} test {Perform a final SAVE to leave a clean DB on disk} { waitForBgsave r r save } {OK} test {RESET clears client state} { r client setname test-client r client tracking on assert_equal [r reset] "RESET" set client [r client list] assert_match {*name= *} $client assert_match {*flags=N *} $client } test {RESET clears MONITOR state} { set rd [redis_deferring_client] $rd monitor assert_equal [$rd read] "OK" $rd reset # skip reset ouptut $rd read assert_equal [$rd read] "RESET" assert_no_match {*flags=O*} [r client list] } test {RESET clears and discards MULTI state} { r multi r set key-a a r reset catch {r exec} err assert_match {*EXEC without MULTI*} $err } test {RESET clears Pub/Sub state} { r subscribe channel-1 r reset # confirm we're not subscribed by executing another command r set key val } test {RESET clears authenticated state} { r acl setuser user1 on >secret +@all r auth user1 secret assert_equal [r acl whoami] user1 r reset assert_equal [r acl whoami] default } } start_server {tags {"other"}} { test {Don't rehash if redis has child proecess} { r config set save "" r config set rdb-key-save-delay 1000000 populate 4096 "" 1 r bgsave r mset k1 v1 k2 v2 # Hash table should not rehash assert_no_match "*table size: 8192*" [r debug HTSTATS 9] exec kill -9 [get_child_pid 0] after 200 # Hash table should rehash since there is no child process, # size is power of two and over 4098, so it is 8192 r set k3 v3 assert_match "*table size: 8192*" [r debug HTSTATS 9] } } proc read_proc_title {pid} { set fd [open "/proc/$pid/cmdline" "r"] set cmdline [read $fd 1024] close $fd return $cmdline } start_server {tags {"other"}} { test {Process title set as expected} { # Test only on Linux where it's easy to get cmdline without relying on tools. # Skip valgrind as it messes up the arguments. set os [exec uname] if {$os == "Linux" && !$::valgrind} { # Set a custom template r config set "proc-title-template" "TEST {title} {listen-addr} {port} {tls-port} {unixsocket} {config-file}" set cmdline [read_proc_title [srv 0 pid]] assert_equal "TEST" [lindex $cmdline 0] assert_match "*/redis-server" [lindex $cmdline 1] if {$::tls} { set expect_port 0 set expect_tls_port [srv 0 port] } else { set expect_port [srv 0 port] set expect_tls_port 0 } set port [srv 0 port] assert_equal "$::host:$port" [lindex $cmdline 2] assert_equal $expect_port [lindex $cmdline 3] assert_equal $expect_tls_port [lindex $cmdline 4] assert_match "*/tests/tmp/server.*/socket" [lindex $cmdline 5] assert_match "*/tests/tmp/redis.conf.*" [lindex $cmdline 6] # Try setting a bad template catch {r config set "proc-title-template" "{invalid-var}"} err assert_match {*template format is invalid*} $err } } }