fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-19 17:10:50 +00:00
Code Issues Projects Releases Wiki Activity

Streams: XRANGE fuzz testing.

Browse Source
This commit is contained in:
antirez 2017-09-18 10:48:27 +02:00
parent fa707ca154
commit eb1230c999
1 changed files with 52 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
tests/unit/type/stream.tcl
View File

@ -1,6 +1,6 @@
# return value is like strcmp() and similar. # return value is like strcmp() and similar.
proc streamCompareID {a b} { proc streamCompareID {a b} {
if {$a == $b} {return 0} if {$a eq $b} {return 0}
lassign [split $a .] a_ms a_seq lassign [split $a .] a_ms a_seq
lassign [split $b .] b_ms b_seq lassign [split $b .] b_ms b_seq
if {$a_ms > $b_ms} {return 1} if {$a_ms > $b_ms} {return 1}
@ -19,6 +19,36 @@ proc streamNextID {id} {
join [list $ms $seq] . join [list $ms $seq] .
} }
# Generate a random stream entry ID with the ms part between min and max
# and a low sequence number (0 - 999 range), in order to stress test
# XRANGE against a Tcl implementation implementing the same concept
# with Tcl-only code in a linear array.
proc streamRandomID {min_id max_id} {
lassign [split $min_id .] min_ms min_seq
lassign [split $max_id .] max_ms max_seq
set delta [expr {$max_ms-$min_ms+1}]
set ms [expr {$min_ms+[randomInt $delta]}]
set seq [randomInt 1000]
return $ms.$seq
}
# Tcl-side implementation of XRANGE to perform fuzz testing in the Redis
# XRANGE implementation.
proc streamSimulateXRANGE {items start end} {
set res {}
foreach i $items {
set this_id [lindex $i 0]
if {[streamCompareID $this_id $start] >= 0} {
if {[streamCompareID $this_id $end] <= 0} {
lappend res $i
}
}
}
return $res
}
set content {} ;# Will be populated with Tcl side copy of the stream content.
start_server { start_server {
tags {"stream"} tags {"stream"}
} { } {
@ -82,4 +112,25 @@ start_server {
} }
assert {$j == 10000} assert {$j == 10000}
} }
test {XRANGE fuzzing} {
# puts $items
set low_id [lindex $items 0 0]
set high_id [lindex $items end 0]
for {set j 0} {$j < 100} {incr j} {
set start [streamRandomID $low_id $high_id]
set end [streamRandomID $low_id $high_id]
set range [r xrange mystream $start $end]
set tcl_range [streamSimulateXRANGE $items $start $end]
if {$range ne $tcl_range} {
puts "*** WARNING *** - XRANGE fuzzing mismatch: $start - $end"
puts "---"
puts "XRANGE: '$range'"
puts "---"
puts "TCL: '$tcl_range'"
puts "---"
fail "XRANGE fuzzing failed, check logs for details"
}
}
}
} }