Commit 480e2994 authored by zhaozhao.zz's avatar zhaozhao.zz
Browse files

Streams: rewrite id in XSTREAM CREATE *

parent 3094eb36
...@@ -1779,6 +1779,10 @@ NULL ...@@ -1779,6 +1779,10 @@ NULL
s->last_id = id; s->last_id = id;
dbAdd(c->db,c->argv[2],o); dbAdd(c->db,c->argv[2],o);
robj *idarg = createObjectFromStreamID(&id);
rewriteClientCommandArgument(c,3,idarg);
decrRefCount(idarg);
addReply(c,shared.ok); addReply(c,shared.ok);
server.dirty++; server.dirty++;
notifyKeyspaceEvent(NOTIFY_STREAM,"xstream-create", notifyKeyspaceEvent(NOTIFY_STREAM,"xstream-create",
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment