Home
last modified time | relevance | path

Searched refs:rioWriteBulkCount (Results 1 – 5 of 5) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Daof.c934 if (rioWriteBulkCount(r,'*',2+cmd_items) == 0) return 0; in rewriteListObject()
968 if (rioWriteBulkCount(r,'*',2+cmd_items) == 0) return 0; in rewriteSetObject()
986 if (rioWriteBulkCount(r,'*',2+cmd_items) == 0) return 0; in rewriteSetObject()
1027 if (rioWriteBulkCount(r,'*',2+cmd_items*2) == 0) return 0; in rewriteSortedSetObject()
1054 if (rioWriteBulkCount(r,'*',2+cmd_items*2) == 0) return 0; in rewriteSortedSetObject()
1108 if (rioWriteBulkCount(r,'*',2+cmd_items*2) == 0) return 0; in rewriteHashObject()
1144 if (rioWriteBulkCount(r,'*',12) == 0) return 0; in rioWriteStreamPendingEntry()
1176 if (rioWriteBulkCount(r,'*',3+numfields*2) == 0) return 0; in rewriteStreamObject()
1192 if (rioWriteBulkCount(r,'*',7) == 0) return 0; in rewriteStreamObject()
1204 if (rioWriteBulkCount(r,'*',3) == 0) return 0; in rewriteStreamObject()
[all …]
H A Drio.c313 size_t rioWriteBulkCount(rio *r, char prefix, long count) { in rioWriteBulkCount() function
329 if ((nwritten = rioWriteBulkCount(r,'$',len)) == 0) return 0; in rioWriteBulkString()
H A Drio.h133 size_t rioWriteBulkCount(rio *r, char prefix, long count);
H A Dcluster.c5154 serverAssertWithInfo(c,NULL,rioWriteBulkCount(&cmd,'*',2)); in migrateCommand()
5163 serverAssertWithInfo(c,NULL,rioWriteBulkCount(&cmd,'*',2)); in migrateCommand()
5192 rioWriteBulkCount(&cmd,'*',replace ? 5 : 4)); in migrateCommand()
H A Dmodule.c3444 if (!io->error && rioWriteBulkCount(io->rio,'*',argc) == 0) in RM_EmitAOF()