fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-06-17 11:11:20 +00:00
Code Issues Projects Releases Wiki Activity

Streams: AOF rewriting + minor iterator improvements.

Browse Source
This commit is contained in:
antirez
2017-09-15 12:37:04 +02:00
parent 01ea018c40
commit 26d4f8e3ec
2 changed files with 42 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/t_stream.c
View File

@ -218,19 +218,23 @@ int streamAppendItem(stream *s, robj **argv, int numfields, streamID *added_id,
void streamIteratorStart(streamIterator *si, stream *s, streamID *start, streamID *end) {
/* Intialize the iterator and translates the iteration start/stop
* elements into a 128 big big-endian number. */
streamEncodeID(si->start_key,start);
if (start) {
streamEncodeID(si->start_key,start);
} else {
si->start_key[0] = 0;
si->start_key[0] = 0;
}
if (end) {
streamEncodeID(si->end_key,end);
} else {
/* We assume that UINT64_MAX is the same in little and big
* endian, that is, all bits set. */
si->end_key[0] = UINT64_MAX;
si->end_key[0] = UINT64_MAX;
}
raxStart(&si->ri,s->rax);
/* Seek the correct node in the radix tree. */
if (start->ms || start->seq) {
raxStart(&si->ri,s->rax);
if (start && (start->ms || start->seq)) {
raxSeek(&si->ri,"<=",(unsigned char*)si->start_key,
sizeof(si->start_key));
if (raxEOF(&si->ri))