Helper for rewriteStreamObject() that generates a bulk string into the * AOF representing the ID 'id'. */
| 1234 | /* Helper for rewriteStreamObject() that generates a bulk string into the |
| 1235 | * AOF representing the ID 'id'. */ |
| 1236 | int 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 |
no test coverage detected