Lines Matching refs:rioWriteBulkString

914         return rioWriteBulkString(r,obj->ptr,sdslen(obj->ptr));  in rioWriteBulkObject()
935 if (rioWriteBulkString(r,"RPUSH",5) == 0) return 0; in rewriteListObject()
940 if (rioWriteBulkString(r,(char*)entry.value,entry.sz) == 0) return 0; in rewriteListObject()
969 if (rioWriteBulkString(r,"SADD",4) == 0) return 0; in rewriteSetObject()
987 if (rioWriteBulkString(r,"SADD",4) == 0) return 0; in rewriteSetObject()
990 if (rioWriteBulkString(r,ele,sdslen(ele)) == 0) return 0; in rewriteSetObject()
1028 if (rioWriteBulkString(r,"ZADD",4) == 0) return 0; in rewriteSortedSetObject()
1033 if (rioWriteBulkString(r,(char*)vstr,vlen) == 0) return 0; in rewriteSortedSetObject()
1055 if (rioWriteBulkString(r,"ZADD",4) == 0) return 0; in rewriteSortedSetObject()
1059 if (rioWriteBulkString(r,ele,sdslen(ele)) == 0) return 0; in rewriteSortedSetObject()
1084 return rioWriteBulkString(r, (char*)vstr, vlen); in rioWriteHashIteratorCursor()
1089 return rioWriteBulkString(r, value, sdslen(value)); in rioWriteHashIteratorCursor()
1109 if (rioWriteBulkString(r,"HMSET",5) == 0) return 0; in rewriteHashObject()
1130 if ((retval = rioWriteBulkString(r,replyid,sdslen(replyid))) == 0) return 0; in rioWriteBulkStreamID()
1145 if (rioWriteBulkString(r,"XCLAIM",6) == 0) return 0; in rioWriteStreamPendingEntry()
1147 if (rioWriteBulkString(r,groupname,groupname_len) == 0) return 0; in rioWriteStreamPendingEntry()
1148 if (rioWriteBulkString(r,consumer->name,sdslen(consumer->name)) == 0) return 0; in rioWriteStreamPendingEntry()
1149 if (rioWriteBulkString(r,"0",1) == 0) return 0; in rioWriteStreamPendingEntry()
1151 if (rioWriteBulkString(r,"TIME",4) == 0) return 0; in rioWriteStreamPendingEntry()
1153 if (rioWriteBulkString(r,"RETRYCOUNT",10) == 0) return 0; in rioWriteStreamPendingEntry()
1155 if (rioWriteBulkString(r,"JUSTID",6) == 0) return 0; in rioWriteStreamPendingEntry()
1156 if (rioWriteBulkString(r,"FORCE",5) == 0) return 0; in rioWriteStreamPendingEntry()
1177 if (rioWriteBulkString(r,"XADD",4) == 0) return 0; in rewriteStreamObject()
1184 if (rioWriteBulkString(r,(char*)field,field_len) == 0) return 0; in rewriteStreamObject()
1185 if (rioWriteBulkString(r,(char*)value,value_len) == 0) return 0; in rewriteStreamObject()
1193 if (rioWriteBulkString(r,"XADD",4) == 0) return 0; in rewriteStreamObject()
1195 if (rioWriteBulkString(r,"MAXLEN",6) == 0) return 0; in rewriteStreamObject()
1196 if (rioWriteBulkString(r,"0",1) == 0) return 0; in rewriteStreamObject()
1198 if (rioWriteBulkString(r,"x",1) == 0) return 0; in rewriteStreamObject()
1199 if (rioWriteBulkString(r,"y",1) == 0) return 0; in rewriteStreamObject()
1205 if (rioWriteBulkString(r,"XSETID",6) == 0) return 0; in rewriteStreamObject()
1219 if (rioWriteBulkString(r,"XGROUP",6) == 0) return 0; in rewriteStreamObject()
1220 if (rioWriteBulkString(r,"CREATE",6) == 0) return 0; in rewriteStreamObject()
1222 if (rioWriteBulkString(r,(char*)ri.key,ri.key_len) == 0) return 0; in rewriteStreamObject()