Home
last modified time | relevance | path

Searched refs:streamCompareID (Results 1 – 5 of 5) sorted by relevance

/f-stack/app/redis-5.0.5/tests/unit/type/
H A Dstream.tcl2 proc streamCompareID {a b} { procedure
41 if {[streamCompareID $this_id $start] >= 0} {
42 if {[streamCompareID $this_id $end] <= 0} {
68 assert {[streamCompareID $id1 $id2] == -1}
69 assert {[streamCompareID $id2 $id3] == -1}
78 assert {[streamCompareID $id1 $id2] == -1}
79 assert {[streamCompareID $id2 $id3] == -1}
/f-stack/app/redis-5.0.5/src/
H A Dstream.h111 int streamCompareID(streamID *a, streamID *b);
H A Dt_stream.c153 int streamCompareID(streamID *a, streamID *b) { in streamCompareID() function
178 if (use_id && streamCompareID(use_id,&s->last_id) <= 0) return C_ERR; in streamAppendItem()
921 if (group && streamCompareID(&id,&group->last_id) > 0) { in streamReplyWithRange()
1493 if (s->length && (streamCompareID(&s->last_id, last) > 0)) { in xreadCommand()
1501 if (s->length && (streamCompareID(&s->last_id, gt) > 0)) { in xreadCommand()
1856 if (streamCompareID(&id,&maxid) < 0) { in xsetidCommand()
2203 if (streamCompareID(&last_id,&group->last_id) > 0) { in xclaimCommand()
H A Dblocked.c420 if (streamCompareID(&s->last_id, gt) > 0) { in handleClientsBlockedOnKeys()
/f-stack/app/redis-5.0.5/
H A D00-RELEASENOTES2209 Streams: using streamCompareID() instead of direct compare in block.c.
2213 Streams: add streamCompareID() declaration in stream.h.
2217 Streams: using streamCompareID() instead of direct compare.