MCPcopy Create free account
hub / github.com/F-Stack/f-stack / rioWriteBulkStreamID

Function rioWriteBulkStreamID

app/redis-6.2.6/src/aof.c:1236–1243  ·  view source on GitHub ↗

Helper for rewriteStreamObject() that generates a bulk string into the * AOF representing the ID 'id'. */

Source from the content-addressed store, hash-verified

1234/* Helper for rewriteStreamObject() that generates a bulk string into the
1235 * AOF representing the ID 'id'. */
1236int rioWriteBulkStreamID(rio *r,streamID *id) {
1237 int retval;
1238
1239 sds replyid = sdscatfmt(sdsempty(),"%U-%U",id->ms,id->seq);
1240 retval = rioWriteBulkString(r,replyid,sdslen(replyid));
1241 sdsfree(replyid);
1242 return retval;
1243}
1244
1245/* Helper for rewriteStreamObject(): emit the XCLAIM needed in order to
1246 * add the message described by 'nack' having the id 'rawid', into the pending

Callers 2

rewriteStreamObjectFunction · 0.85

Calls 5

sdscatfmtFunction · 0.85
sdsemptyFunction · 0.85
rioWriteBulkStringFunction · 0.85
sdslenFunction · 0.85
sdsfreeFunction · 0.85

Tested by

no test coverage detected