mirror of
https://codeberg.org/redict/redict.git
synced 2025-01-23 08:38:27 -05:00
Streams: add tests for aof rewrite
This commit is contained in:
parent
b3e80d2f65
commit
3094eb3626
@ -402,3 +402,26 @@ start_server {tags {"xstream command"}} {
|
|||||||
set _ $err
|
set _ $err
|
||||||
} {ERR no such key}
|
} {ERR no such key}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
start_server {tags {"stream"} overrides {appendonly yes aof-use-rdb-preamble no}} {
|
||||||
|
test {Empty stream can be rewrite into AOF correctly} {
|
||||||
|
r XSTREAM CREATE mystream 0
|
||||||
|
assert {[dict get [r xinfo stream mystream] length] == 0}
|
||||||
|
r bgrewriteaof
|
||||||
|
waitForBgrewriteaof r
|
||||||
|
r debug loadaof
|
||||||
|
assert {[dict get [r xinfo stream mystream] length] == 0}
|
||||||
|
}
|
||||||
|
|
||||||
|
test {Stream can be rewrite into AOF correctly after XDEL lastid} {
|
||||||
|
r XADD mystream 1-1 a b
|
||||||
|
r XADD mystream 2-2 a b
|
||||||
|
assert {[dict get [r xinfo stream mystream] length] == 2}
|
||||||
|
r XDEL mystream 2-2
|
||||||
|
r bgrewriteaof
|
||||||
|
waitForBgrewriteaof r
|
||||||
|
r debug loadaof
|
||||||
|
assert {[dict get [r xinfo stream mystream] length] == 1}
|
||||||
|
assert {[dict get [r xinfo stream mystream] last-generated-id] == "2-2"}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user