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

XSETID: accept IDs based on last entry.

Browse Source 
Related to #5426.
This commit is contained in:
antirez 2018-10-16 16:46:13 +02:00
parent e3446fea9e
commit ea78a1db32
1 changed files with 18 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/t_stream.c
View File

@ -1782,12 +1782,25 @@ void xsetidCommand(client *c) {
stream *s = o->ptr; stream *s = o->ptr;
streamID id; streamID id;
if (streamParseStrictIDOrReply(c,c->argv[3],&id,0) != C_OK) return; if (streamParseStrictIDOrReply(c,c->argv[2],&id,0) != C_OK) return;
if (streamCompareID(&id,&s->last_id) < 0) {
/* If the stream has at least one item, we want to check that the user
* is setting a last ID that is equal or greater than the current top
* item, otherwise the fundamental ID monotonicity assumption is violated. */
if (s->length > 0) {
streamID maxid;
streamIterator si;
streamIteratorStart(&si,s,NULL,NULL,1);
int64_t numfields;
streamIteratorGetID(&si,&maxid,&numfields);
streamIteratorStop(&si);
if (streamCompareID(&id,&maxid) < 0) {
addReplyError(c,"The ID specified in XSETID is smaller than the " addReplyError(c,"The ID specified in XSETID is smaller than the "
"target stream top item"); "target stream top item");
return; return;
} }
}
s->last_id = id; s->last_id = id;
addReply(c,shared.ok); addReply(c,shared.ok);
server.dirty++; server.dirty++;