MCPcopy Create free account
hub / github.com/Snapchat/KeyDB / addReplyStreamID

Function addReplyStreamID

src/t_stream.cpp:1348–1351  ·  view source on GitHub ↗

Emit a reply in the client output buffer by formatting a Stream ID * in the standard - format, using the simple string protocol * of REPL. */

Source from the content-addressed store, hash-verified

1346 * in the standard <ms>-<seq> format, using the simple string protocol
1347 * of REPL. */
1348static void addReplyStreamID(client *c, streamID *id) {
1349 sds replyid = sdscatfmt(sdsempty(),"%U-%U",id->ms,id->seq);
1350 addReplyBulkSds(c,replyid);
1351}
1352
1353void setDeferredReplyStreamID(client *c, void *dr, streamID *id) {
1354 sds replyid = sdscatfmt(sdsempty(),"%U-%U",id->ms,id->seq);

Callers 8

streamReplyWithRangeFunction · 0.85
xaddCommandFunction · 0.85
xpendingCommandFunction · 0.85
xclaimCommandFunction · 0.85
xautoclaimCommandFunction · 0.85
xinfoReplyWithStreamInfoFunction · 0.85
xinfoCommandFunction · 0.85

Calls 3

sdscatfmtFunction · 0.85
sdsemptyFunction · 0.85
addReplyBulkSdsFunction · 0.85

Tested by

no test coverage detected