Home
last modified time | relevance | path

Searched refs:rioWriteBulkString (Results 1 – 4 of 4) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Daof.c1089 return rioWriteBulkString(r, value, sdslen(value)); in rioWriteHashIteratorCursor()
1145 if (rioWriteBulkString(r,"XCLAIM",6) == 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()
1155 if (rioWriteBulkString(r,"JUSTID",6) == 0) return 0; in rioWriteStreamPendingEntry()
1156 if (rioWriteBulkString(r,"FORCE",5) == 0) return 0; in rioWriteStreamPendingEntry()
1193 if (rioWriteBulkString(r,"XADD",4) == 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()
[all …]
H A Drio.c326 size_t rioWriteBulkString(rio *r, const char *buf, size_t len) { in rioWriteBulkString() function
341 return rioWriteBulkString(r,lbuf,llen); in rioWriteBulkLongLong()
350 return rioWriteBulkString(r,dbuf,dlen); in rioWriteBulkDouble()
H A Drio.h134 size_t rioWriteBulkString(rio *r, const char *buf, size_t len);
H A Dcluster.c5155 serverAssertWithInfo(c,NULL,rioWriteBulkString(&cmd,"AUTH",4)); in migrateCommand()
5156 serverAssertWithInfo(c,NULL,rioWriteBulkString(&cmd,password, in migrateCommand()
5164 serverAssertWithInfo(c,NULL,rioWriteBulkString(&cmd,"SELECT",6)); in migrateCommand()
5196 rioWriteBulkString(&cmd,"RESTORE-ASKING",14)); in migrateCommand()
5198 serverAssertWithInfo(c,NULL,rioWriteBulkString(&cmd,"RESTORE",7)); in migrateCommand()
5200 serverAssertWithInfo(c,NULL,rioWriteBulkString(&cmd,kv[j]->ptr, in migrateCommand()
5208 rioWriteBulkString(&cmd,payload.io.buffer.ptr, in migrateCommand()
5215 serverAssertWithInfo(c,NULL,rioWriteBulkString(&cmd,"REPLACE",7)); in migrateCommand()