start_server {tags {"multi"}} { test {MUTLI / EXEC basics} { r del mylist r rpush mylist a r rpush mylist b r rpush mylist c r multi set v1 [r lrange mylist 0 -1] set v2 [r ping] set v3 [r exec] list $v1 $v2 $v3 } {QUEUED QUEUED {{a b c} PONG}} test {DISCARD} { r del mylist r rpush mylist a r rpush mylist b r rpush mylist c r multi set v1 [r del mylist] set v2 [r discard] set v3 [r lrange mylist 0 -1] list $v1 $v2 $v3 } {QUEUED OK {a b c}} test {Nested MULTI are not allowed} { set err {} r multi catch {[r multi]} err r exec set _ $err } {*ERR MULTI*} test {MULTI where commands alter argc/argv} { r sadd myset a r multi r spop myset list [r exec] [r exists myset] } {a 0} test {WATCH inside MULTI is not allowed} { set err {} r multi catch {[r watch x]} err r exec set _ $err } {*ERR WATCH*} test {EXEC fails if there are errors while queueing commands #1} { r del foo1 foo2 r multi r set foo1 bar1 catch {r non-existing-command} r set foo2 bar2 catch {r exec} e assert_match {EXECABORT*} $e list [r exists foo1] [r exists foo2] } {0 0} test {EXEC fails if there are errors while queueing commands #2} { set rd [redis_deferring_client] r del foo1 foo2 r multi r set foo1 bar1 $rd config set maxmemory 1 assert {[$rd read] eq {OK}} catch {r lpush mylist myvalue} $rd config set maxmemory 0 assert {[$rd read] eq {OK}} r set foo2 bar2 catch {r exec} e assert_match {EXECABORT*} $e $rd close list [r exists foo1] [r exists foo2] } {0 0} test {If EXEC aborts, the client MULTI state is cleared} { r del foo1 foo2 r multi r set foo1 bar1 catch {r non-existing-command} r set foo2 bar2 catch {r exec} e assert_match {EXECABORT*} $e r ping } {PONG} test {EXEC works on WATCHed key not modified} { r watch x y z r watch k r multi r ping r exec } {PONG} test {EXEC fail on WATCHed key modified (1 key of 1 watched)} { r set x 30 r watch x r set x 40 r multi r ping r exec } {} test {EXEC fail on WATCHed key modified (1 key of 5 watched)} { r set x 30 r watch a b x k z r set x 40 r multi r ping r exec } {} test {EXEC fail on WATCHed key modified by SORT with STORE even if the result is empty} { r flushdb r lpush foo bar r watch foo r sort emptylist store foo r multi r ping r exec } {} test {After successful EXEC key is no longer watched} { r set x 30 r watch x r multi r ping r exec r set x 40 r multi r ping r exec } {PONG} test {After failed EXEC key is no longer watched} { r set x 30 r watch x r set x 40 r multi r ping r exec r set x 40 r multi r ping r exec } {PONG} test {It is possible to UNWATCH} { r set x 30 r watch x r set x 40 r unwatch r multi r ping r exec } {PONG} test {UNWATCH when there is nothing watched works as expected} { r unwatch } {OK} test {FLUSHALL is able to touch the watched keys} { r set x 30 r watch x r flushall r multi r ping r exec } {} test {FLUSHALL does not touch non affected keys} { r del x r watch x r flushall r multi r ping r exec } {PONG} test {FLUSHDB is able to touch the watched keys} { r set x 30 r watch x r flushdb r multi r ping r exec } {} test {FLUSHDB does not touch non affected keys} { r del x r watch x r flushdb r multi r ping r exec } {PONG} test {WATCH is able to remember the DB a key belongs to} { r select 5 r set x 30 r watch x r select 1 r set x 10 r select 5 r multi r ping set res [r exec] # Restore original DB r select 9 set res } {PONG} test {WATCH will consider touched keys target of EXPIRE} { r del x r set x foo r watch x r expire x 10 r multi r ping r exec } {} test {WATCH will not consider touched expired keys} { r del x r set x foo r expire x 1 r watch x after 1100 r multi r ping r exec } {PONG} test {DISCARD should clear the WATCH dirty flag on the client} { r watch x r set x 10 r multi r discard r multi r incr x r exec } {11} test {DISCARD should UNWATCH all the keys} { r watch x r set x 10 r multi r discard r set x 10 r multi r incr x r exec } {11} test {MULTI / EXEC is propagated correctly (single write command)} { set repl [attach_to_replication_stream] r multi r set foo bar r exec assert_replication_stream $repl { {select *} {multi} {set foo bar} {exec} } close_replication_stream $repl } test {MULTI / EXEC is propagated correctly (empty transaction)} { set repl [attach_to_replication_stream] r multi r exec r set foo bar assert_replication_stream $repl { {select *} {set foo bar} } close_replication_stream $repl } test {MULTI / EXEC is propagated correctly (read-only commands)} { r set foo value1 set repl [attach_to_replication_stream] r multi r get foo r exec r set foo value2 assert_replication_stream $repl { {select *} {set foo value2} } close_replication_stream $repl } test {MULTI / EXEC is propagated correctly (write command, no effect)} { r del bar foo bar set repl [attach_to_replication_stream] r multi r del foo r exec assert_replication_stream $repl { {select *} {multi} {exec} } close_replication_stream $repl } }