tests/integration/aof.tcl

   1 set defaults { appendonly {yes} appendfilename {appendonly.aof} }
   2 set server_path [tmpdir server.aof]
   3 set aof_path "$server_path/appendonly.aof"
   4
   5 proc append_to_aof {str} {
   6     upvar fp fp
   7     puts -nonewline $fp $str
   8 }
   9
  10 proc create_aof {code} {
  11     upvar fp fp aof_path aof_path
  12     set fp [open $aof_path w+]
  13     uplevel 1 $code
  14     close $fp
  15 }
  16
  17 proc start_server_aof {overrides code} {
  18     upvar defaults defaults srv srv server_path server_path
  19     set config [concat $defaults $overrides]
  20     set srv [start_server [list overrides $config]]
  21     uplevel 1 $code
  22     kill_server $srv
  23 }
  24
  25 tags {"aof"} {
  26     ## Test the server doesn't start when the AOF contains an unfinished MULTI
  27     create_aof {
  28         append_to_aof [formatCommand set foo hello]
  29         append_to_aof [formatCommand multi]
  30         append_to_aof [formatCommand set bar world]
  31     }
  32
  33     start_server_aof [list dir $server_path] {
  34         test "Unfinished MULTI: Server should have logged an error" {
  35             set result [exec cat [dict get $srv stdout] | tail -n1]
  36             assert_match "*Unexpected end of file reading the append only file*" $result
  37         }
  38     }
  39
  40     ## Test that the server exits when the AOF contains a short read
  41     create_aof {
  42         append_to_aof [formatCommand set foo hello]
  43         append_to_aof [string range [formatCommand set bar world] 0 end-1]
  44     }
  45
  46     start_server_aof [list dir $server_path] {
  47         test "Short read: Server should have logged an error" {
  48             set result [exec cat [dict get $srv stdout] | tail -n1]
  49             assert_match "*Bad file format reading the append only file*" $result
  50         }
  51     }
  52
  53     ## Test that redis-check-aof indeed sees this AOF is not valid
  54     test "Short read: Utility should confirm the AOF is not valid" {
  55         catch {
  56             exec src/redis-check-aof $aof_path
  57         } result
  58         assert_match "*not valid*" $result
  59     }
  60
  61     test "Short read: Utility should be able to fix the AOF" {
  62         set result [exec echo y | src/redis-check-aof --fix $aof_path]
  63         assert_match "*Successfully truncated AOF*" $result
  64     }
  65
  66     ## Test that the server can be started using the truncated AOF
  67     start_server_aof [list dir $server_path] {
  68         test "Fixed AOF: Server should have been started" {
  69             assert_equal 1 [is_alive $srv]
  70         }
  71
  72         test "Fixed AOF: Keyspace should contain values that were parsable" {
  73             set client [redis [dict get $srv host] [dict get $srv port]]
  74             assert_equal "hello" [$client get foo]
  75             assert_equal "" [$client get bar]
  76         }
  77     }
  78
  79     ## Test that SPOP (that modifies the client its argc/argv) is correctly free'd
  80     create_aof {
  81         append_to_aof [formatCommand sadd set foo]
  82         append_to_aof [formatCommand sadd set bar]
  83         append_to_aof [formatCommand spop set]
  84     }
  85
  86     start_server_aof [list dir $server_path] {
  87         test "AOF+SPOP: Server should have been started" {
  88             assert_equal 1 [is_alive $srv]
  89         }
  90
  91         test "AOF+SPOP: Set should have 1 member" {
  92             set client [redis [dict get $srv host] [dict get $srv port]]
  93             assert_equal 1 [$client scard set]
  94         }
  95     }
  96
  97     ## Test that EXPIREAT is loaded correctly
  98     create_aof {
  99         append_to_aof [formatCommand rpush list foo]
 100         append_to_aof [formatCommand expireat list 1000]
 101         append_to_aof [formatCommand rpush list bar]
 102     }
 103
 104     start_server_aof [list dir $server_path] {
 105         test "AOF+EXPIRE: Server should have been started" {
 106             assert_equal 1 [is_alive $srv]
 107         }
 108
 109         test "AOF+EXPIRE: List should be empty" {
 110             set client [redis [dict get $srv host] [dict get $srv port]]
 111             assert_equal 0 [$client llen list]
 112         }
 113     }
 114
 115     start_server {overrides {appendonly {yes} appendfilename {appendonly.aof}}} {
 116         test {Redis should not try to convert DEL into EXPIREAT for EXPIRE -1} {
 117             r set x 10
 118             r expire x -1
 119         }
 120     }
 121 }