| /f-stack/app/redis-5.0.5/src/ |
| H A D | pubsub.c | 79 addReply(c,shared.mbulkhdr[3]); in pubsubSubscribeChannel()
80 addReply(c,shared.subscribebulk); in pubsubSubscribeChannel()
115 addReply(c,shared.mbulkhdr[3]); in pubsubUnsubscribeChannel()
116 addReply(c,shared.unsubscribebulk); in pubsubUnsubscribeChannel()
141 addReply(c,shared.mbulkhdr[3]); in pubsubSubscribePattern()
142 addReply(c,shared.psubscribebulk); in pubsubSubscribePattern()
166 addReply(c,shared.mbulkhdr[3]); in pubsubUnsubscribePattern()
190 addReply(c,shared.mbulkhdr[3]); in pubsubUnsubscribeAllChannels()
192 addReply(c,shared.nullbulk); in pubsubUnsubscribeAllChannels()
215 addReply(c,shared.mbulkhdr[3]); in pubsubUnsubscribeAllPatterns()
[all …]
|
| H A D | t_string.c | 133 addReply(c,shared.syntaxerr); in setCommand()
164 addReply(c,shared.wrongtypeerr); in getGenericCommand()
201 addReply(c,shared.czero); in setrangeCommand()
267 addReply(c,shared.emptybulk); in getrangeCommand()
279 addReply(c,shared.emptybulk); in getrangeCommand()
292 addReply(c,shared.nullbulk); in mgetCommand()
295 addReply(c,shared.nullbulk); in mgetCommand()
316 addReply(c, shared.czero); in msetGenericCommand()
372 addReply(c,shared.colon); in incrDecrCommand()
373 addReply(c,new); in incrDecrCommand()
[all …]
|
| H A D | t_list.c | 202 addReply(c,shared.wrongtypeerr); in pushGenericCommand()
276 addReply(c,shared.syntaxerr); in linsertCommand()
301 addReply(c,shared.cnegone); in linsertCommand()
334 addReply(c,shared.nullbulk); in lindexCommand()
357 addReply(c,shared.ok); in lsetCommand()
373 addReply(c,shared.nullbulk); in popGenericCommand()
417 addReply(c,shared.emptymultibulk); in lrangeCommand()
487 addReply(c,shared.ok); in ltrimCommand()
573 addReply(c,shared.nullbulk); in rpoplpushCommand()
734 addReply(c,shared.nullmultibulk); in blockingPopGenericCommand()
[all …]
|
| H A D | expire.c | 417 addReply(c,shared.czero); in expireGenericCommand()
440 addReply(c, shared.cone); in expireGenericCommand()
444 addReply(c,shared.cone); in expireGenericCommand()
509 addReply(c,shared.cone); in persistCommand()
512 addReply(c,shared.czero); in persistCommand()
515 addReply(c,shared.czero); in persistCommand()
|
| H A D | t_set.c | 326 addReply(c,shared.czero); in smoveCommand()
344 addReply(c,shared.czero); in smoveCommand()
370 addReply(c,shared.cone); in smoveCommand()
380 addReply(c,shared.cone); in sismemberCommand()
382 addReply(c,shared.czero); in sismemberCommand()
412 addReply(c,shared.outofrangeerr); in spopWithCountCommand()
424 addReply(c,shared.emptymultibulk); in spopWithCountCommand()
563 addReply(c,shared.syntaxerr); in spopCommand()
759 addReply(c,shared.syntaxerr); in srandmemberCommand()
906 addReply(c,shared.czero); in sinterGenericCommand()
[all …]
|
| H A D | db.c | 159 if (!o) addReply(c,reply); in lookupKeyReadOrReply()
165 if (!o) addReply(c,reply); in lookupKeyWriteOrReply()
438 addReply(c,shared.ok); in flushdbCommand()
450 addReply(c,shared.ok); in flushallCommand()
520 addReply(c,shared.ok); in selectCommand()
528 addReply(c,shared.nullbulk); in randomkeyCommand()
845 addReply(c,shared.syntaxerr); in shutdownCommand()
954 addReply(c,shared.czero); in moveCommand()
961 addReply(c,shared.czero); in moveCommand()
971 addReply(c,shared.cone); in moveCommand()
[all …]
|
| H A D | geo.c | 541 addReply(c, shared.syntaxerr); in georadiusGeneric()
569 addReply(c, shared.emptymultibulk); in georadiusGeneric()
713 addReply(c,shared.nullbulk); in geohashCommand()
724 addReply(c,shared.nullbulk); in geohashCommand()
766 addReply(c,shared.nullmultibulk); in geoposCommand()
771 addReply(c,shared.nullmultibulk); in geoposCommand()
794 addReply(c,shared.syntaxerr); in geodistCommand()
808 addReply(c,shared.nullbulk); in geodistCommand()
814 addReply(c,shared.nullbulk); in geodistCommand()
|
| H A D | networking.c | 521 addReply(c,shared.czero); in addReplyLongLong()
523 addReply(c,shared.cone); in addReplyLongLong()
564 addReply(c,obj); in addReplyBulk()
565 addReply(c,shared.crlf); in addReplyBulk()
572 addReply(c,shared.crlf); in addReplyBulkCBuffer()
579 addReply(c,shared.crlf); in addReplyBulkSds()
585 addReply(c,shared.nullbulk); in addReplyBulkCString()
1760 addReply(c,shared.ok); in clientCommand()
1897 addReply(c,shared.ok); in clientCommand()
1915 addReply(c,shared.ok); in clientCommand()
[all …]
|
| H A D | multi.c | 94 addReply(c,shared.ok); in multiCommand()
103 addReply(c,shared.ok); in discardCommand()
136 addReply(c, c->flags & CLIENT_DIRTY_EXEC ? shared.execaborterr : in execCommand()
348 addReply(c,shared.ok); in watchCommand()
354 addReply(c,shared.ok); in unwatchCommand()
|
| H A D | t_hash.c | 458 addReply(c,shared.wrongtypeerr); in hashTypeLookupWriteOrCreate()
520 addReply(c, shared.czero); in hsetnxCommand()
523 addReply(c, shared.cone); in hsetnxCommand()
552 addReply(c, shared.ok); in hsetCommand()
648 addReply(c, shared.nullbulk); in addHashFieldToReply()
659 addReply(c, shared.nullbulk); in addHashFieldToReply()
671 addReply(c, shared.nullbulk); in addHashFieldToReply()
696 addReply(c, shared.wrongtypeerr); in hmgetCommand()
818 addReply(c, hashTypeExists(o,c->argv[2]->ptr) ? shared.cone : shared.czero); in hexistsCommand()
|
| H A D | bitops.c | 560 addReply(c, bitval ? shared.cone : shared.czero); in setbitCommand()
587 addReply(c, bitval ? shared.cone : shared.czero); in getbitCommand()
612 addReply(c,shared.syntaxerr); in bitopCommand()
788 addReply(c,shared.czero); in bitcountCommand()
802 addReply(c,shared.syntaxerr); in bitcountCommand()
809 addReply(c,shared.czero); in bitcountCommand()
867 addReply(c,shared.syntaxerr); in bitposCommand()
953 addReply(c,shared.syntaxerr); in bitfieldCommand()
1056 addReply(c,shared.nullbulk); in bitfieldCommand()
1085 addReply(c,shared.nullbulk); in bitfieldCommand()
|
| H A D | t_stream.c | 1294 addReply(c,shared.nullmultibulk); in xrangeGenericCommand()
1383 addReply(c,shared.syntaxerr); in xreadCommand()
1390 addReply(c,shared.syntaxerr); in xreadCommand()
1573 addReply(c,shared.nullmultibulk); in xreadCommand()
1789 addReply(c,shared.ok); in xgroupCommand()
1805 addReply(c,shared.ok); in xgroupCommand()
1812 addReply(c,shared.cone); in xgroupCommand()
1817 addReply(c,shared.czero); in xgroupCommand()
1863 addReply(c,shared.ok); in xsetidCommand()
1887 addReply(c,shared.czero); in xackCommand()
[all …]
|
| H A D | debug.c | 350 addReply(c,shared.ok); in debugCommand()
355 addReply(c,shared.ok); in debugCommand()
360 addReply(c,shared.err); in debugCommand()
372 addReply(c,shared.ok); in debugCommand()
380 addReply(c,shared.err); in debugCommand()
385 addReply(c,shared.ok); in debugCommand()
508 addReply(c,shared.ok); in debugCommand()
540 addReply(c,shared.ok); in debugCommand()
545 addReply(c,shared.ok); in debugCommand()
550 addReply(c,shared.ok); in debugCommand()
[all …]
|
| H A D | t_zset.c | 1572 addReply(c,shared.syntaxerr); in zaddGenericCommand()
1734 addReply(c,shared.czero); in zremrangeGenericCommand()
2201 addReply(c,shared.syntaxerr); in zunionInterGenericCommand()
2393 addReply(c,shared.czero); in zunionInterGenericCommand()
2426 addReply(c,shared.syntaxerr); in zrangeGenericCommand()
2747 addReply(c, shared.czero); in zcountCommand()
2828 addReply(c, shared.czero); in zlexcountCommand()
3084 addReply(c,shared.nullbulk); in zscoreCommand()
3104 addReply(c,shared.nullbulk); in zrankGenericCommand()
3242 addReply(c,shared.syntaxerr); in zpopminCommand()
[all …]
|
| H A D | scripting.c | 285 addReply(c,lua_toboolean(lua,-1) ? shared.cone : shared.nullbulk); in luaReplyToRedisReply()
337 addReply(c,shared.nullbulk); in luaReplyToRedisReply()
1329 addReply(c, shared.noscripterr); in evalGenericCommand()
1479 addReply(c, shared.noscripterr); in evalShaCommand()
1503 addReply(c,shared.ok); in scriptCommand()
1512 addReply(c,shared.cone); in scriptCommand()
1514 addReply(c,shared.czero); in scriptCommand()
1530 addReply(c,shared.ok); in scriptCommand()
1539 addReply(c,shared.ok); in scriptCommand()
1542 addReply(c,shared.ok); in scriptCommand()
[all …]
|
| H A D | object.c | 398 addReply(c,shared.wrongtypeerr); in checkType()
1244 if (!o) addReply(c, reply); in objectCommandLookupOrReply()
1320 addReply(c,shared.syntaxerr); in memoryCommand()
1326 addReply(c,shared.syntaxerr); in memoryCommand()
1331 addReply(c, shared.nullbulk); in memoryCommand()
1451 addReply(c, shared.ok); in memoryCommand()
1457 addReply(c, shared.ok); in memoryCommand()
|
| H A D | cluster.c | 4274 addReply(c,shared.ok); in clusterCommand()
4324 addReply(c,shared.ok); in clusterCommand()
4421 addReply(c,shared.ok); in clusterCommand()
4576 addReply(c,shared.ok); in clusterCommand()
4613 addReply(c,shared.ok); in clusterCommand()
4703 addReply(c,shared.ok); in clusterCommand()
4766 addReply(c,shared.ok); in clusterCommand()
4935 addReply(c,shared.ok); in restoreCommand()
5399 addReply(c,shared.ok); in askingCommand()
5411 addReply(c,shared.ok); in readonlyCommand()
[all …]
|
| H A D | sort.c | 207 addReply(c,shared.wrongtypeerr); in sortCommand()
274 addReply(c,shared.syntaxerr); in sortCommand()
522 addReply(c,shared.nullbulk); in sortCommand()
|
| H A D | server.c | 2559 addReply(c,shared.ok); in processCommand()
2589 addReply(c,shared.noautherr); in processCommand()
2638 addReply(c, shared.oomerr); in processCommand()
2681 addReply(c, shared.roslaveerr); in processCommand()
2711 addReply(c, shared.loadingerr); in processCommand()
2737 addReply(c,shared.queued); in processCommand()
2941 addReply(c,shared.ok); in authCommand()
2967 addReply(c,shared.pong); in pingCommand()
3000 addReply(c, shared.nullbulk); in addReplyCommand()
3687 addReply(c,shared.syntaxerr); in infoCommand()
[all …]
|
| H A D | hyperloglog.c | 1217 addReply(c, updated ? shared.cone : shared.czero); in pfaddCommand()
1266 addReply(c,shared.czero); in pfcountCommand()
1381 addReply(c,shared.ok); in pfmergeCommand()
1485 addReply(c,shared.ok); in pfselftestCommand()
1585 addReply(c,conv ? shared.cone : shared.czero); in pfdebugCommand()
|
| H A D | slowlog.c | 155 addReply(c,shared.ok); in slowlogCommand()
|
| H A D | sentinel.c | 3067 addReply(c, isdown ? shared.cone : shared.czero); in sentinelCommand()
3082 addReply(c,shared.nullmultibulk); in sentinelCommand()
3109 addReply(c,shared.ok); in sentinelCommand()
3158 addReply(c,shared.ok); in sentinelCommand()
3163 addReply(c,shared.ok); in sentinelCommand()
3175 addReply(c,shared.ok); in sentinelCommand()
3250 addReply(c,shared.nullbulk); in sentinelCommand()
3262 addReply(c,shared.nullbulk); in sentinelCommand()
3294 addReply(c,shared.ok); in sentinelCommand()
3319 addReply(c,shared.syntaxerr); in sentinelInfoCommand()
[all …]
|
| H A D | replication.c | 219 addReply(slave,selectcmd); in replicationFeedSlaves()
338 addReply(monitor,cmdobj); in replicationFeedMonitors()
784 addReply(c,shared.syntaxerr); in replconfCommand()
842 addReply(c,shared.ok); in replconfCommand()
2072 addReply(c,shared.ok); in replicaofCommand()
|
| H A D | blocked.c | 190 addReply(c,shared.nullmultibulk); in replyToBlockedClientTimedOut()
|
| H A D | rdb.c | 2399 addReply(c,shared.ok); in saveCommand()
2401 addReply(c,shared.err); in saveCommand()
2415 addReply(c,shared.syntaxerr); in bgsaveCommand()
2438 addReply(c,shared.err); in bgsaveCommand()
|