-
Notifications
You must be signed in to change notification settings - Fork 583
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'unstable' into RELEASE_5
- Loading branch information
Showing
1 changed file
with
13 additions
and
13 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,47 +1,47 @@ | ||
start_server {tags {"CRON"}} { | ||
test {cron singleshot past tense} { | ||
test {keydb.cron singleshot past tense} { | ||
r flushall | ||
r cron testjob single 0 1 {redis.call("incr", "testkey")} 1 testkey | ||
r keydb.cron testjob single 0 1 {redis.call("incr", "testkey")} 1 testkey | ||
after 300 | ||
assert_equal 1 [r get testkey] | ||
assert_equal 0 [r exists testjob] | ||
} | ||
|
||
test {cron repeat past tense next exec is in the future} { | ||
test {keydb.cron repeat past tense next exec is in the future} { | ||
r flushall | ||
r cron testjob repeat 0 1000000 {redis.call("incr", "testkey")} 1 testkey | ||
r keydb.cron testjob repeat 0 1000000 {redis.call("incr", "testkey")} 1 testkey | ||
after 300 | ||
assert_equal 1 [r get testkey] | ||
assert_equal 1 [r exists testjob] | ||
r del testjob | ||
} | ||
|
||
test {cron repeat works} { | ||
test {keydb.cron repeat works} { | ||
r flushall | ||
r cron testjob repeat 0 600 {redis.call("incr","testkey")} | ||
r keydb.cron testjob repeat 0 600 {redis.call("incr","testkey")} | ||
after 1000 | ||
assert_equal 2 [r get testkey] | ||
} | ||
|
||
test {cron overwrite works} { | ||
test {keydb.cron overwrite works} { | ||
r flushall | ||
r cron testjob single 500 {redis.call("set","testkey","a")} 1 testkey | ||
r cron testjob single 500 {redis.call("set","anotherkey","b")} 1 anotherkey | ||
r keydb.cron testjob single 500 {redis.call("set","testkey","a")} 1 testkey | ||
r keydb.cron testjob single 500 {redis.call("set","anotherkey","b")} 1 anotherkey | ||
after 1000 | ||
assert_equal 0 [r exists testkey] | ||
assert_equal b [r get anotherkey] | ||
} | ||
|
||
test {cron delete key stops job} { | ||
test {keydb.cron delete key stops job} { | ||
r flushall | ||
r cron testjob single 500 {redis.call("set","testkey","a")} | ||
r keydb.cron testjob single 500 {redis.call("set","testkey","a")} | ||
r del testjob | ||
after 1000 | ||
assert_equal 0 [r exists testkey] | ||
} | ||
|
||
test {cron zero interval rejected} { | ||
catch {r cron testjob single 0 0 {redis.call("incr","testkey")} 1 testkey} e | ||
test {keydb.cron zero interval rejected} { | ||
catch {r keydb.cron testjob single 0 0 {redis.call("incr","testkey")} 1 testkey} e | ||
assert_match {ERR*} $e | ||
} | ||
} |