| /redis-3.2.3/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()
319 addReply(c, shared.czero); in msetGenericCommand()
374 addReply(c,shared.colon); in incrDecrCommand()
375 addReply(c,new); in incrDecrCommand()
[all …]
|
| H A D | db.c | 143 if (!o) addReply(c,reply); in lookupKeyReadOrReply()
149 if (!o) addReply(c,reply); in lookupKeyWriteOrReply()
323 addReply(c,shared.ok); in flushdbCommand()
329 addReply(c,shared.ok); in flushallCommand()
387 addReply(c,shared.ok); in selectCommand()
816 addReply(c,shared.czero); in moveCommand()
823 addReply(c,shared.czero); in moveCommand()
833 addReply(c,shared.cone); in moveCommand()
955 addReply(c,shared.czero); in expireGenericCommand()
977 addReply(c, shared.cone); in expireGenericCommand()
[all …]
|
| H A D | t_set.c | 335 addReply(c,shared.czero); in smoveCommand()
352 addReply(c,shared.czero); in smoveCommand()
378 addReply(c,shared.cone); in smoveCommand()
389 addReply(c,shared.cone); in sismemberCommand()
391 addReply(c,shared.czero); in sismemberCommand()
421 addReply(c,shared.outofrangeerr); in spopWithCountCommand()
571 addReply(c,shared.syntaxerr); in spopCommand()
764 addReply(c,shared.syntaxerr); in srandmemberCommand()
812 addReply(c,shared.czero); in sinterGenericCommand()
914 addReply(c,shared.czero); in sinterGenericCommand()
[all …]
|
| H A D | t_list.c | 202 addReply(c,shared.wrongtypeerr); in pushGenericCommand()
263 addReply(c,shared.cnegone); in pushxGenericCommand()
295 addReply(c,shared.syntaxerr); in linsertCommand()
325 addReply(c,shared.nullbulk); in lindexCommand()
348 addReply(c,shared.ok); in lsetCommand()
364 addReply(c,shared.nullbulk); in popGenericCommand()
408 addReply(c,shared.emptymultibulk); in lrangeCommand()
478 addReply(c,shared.ok); in ltrimCommand()
564 addReply(c,shared.nullbulk); in rpoplpushCommand()
919 addReply(c,shared.nullmultibulk); in blockingPopGenericCommand()
[all …]
|
| H A D | multi.c | 92 addReply(c,shared.ok); in multiCommand()
101 addReply(c,shared.ok); in discardCommand()
133 addReply(c, c->flags & CLIENT_DIRTY_EXEC ? shared.execaborterr : in execCommand()
316 addReply(c,shared.ok); in watchCommand()
322 addReply(c,shared.ok); in unwatchCommand()
|
| H A D | networking.c | 518 addReply(c,shared.czero); in addReplyLongLong()
520 addReply(c,shared.cone); in addReplyLongLong()
561 addReply(c,obj); in addReplyBulk()
562 addReply(c,shared.crlf); in addReplyBulk()
569 addReply(c,shared.crlf); in addReplyBulkCBuffer()
577 addReply(c,shared.crlf); in addReplyBulkSds()
583 addReply(c,shared.nullbulk); in addReplyBulkCString()
1499 addReply(c,shared.ok); in clientCommand()
1604 addReply(c,shared.ok); in clientCommand()
1622 addReply(c,shared.ok); in clientCommand()
[all …]
|
| H A D | geo.c | 513 addReply(c, shared.syntaxerr); in georadiusGeneric()
541 addReply(c, shared.emptymultibulk); in georadiusGeneric()
679 addReply(c,shared.nullbulk); in geohashCommand()
690 addReply(c,shared.nullbulk); in geohashCommand()
733 addReply(c,shared.nullmultibulk); in geoposCommand()
738 addReply(c,shared.nullmultibulk); in geoposCommand()
761 addReply(c,shared.syntaxerr); in geodistCommand()
775 addReply(c,shared.nullbulk); in geodistCommand()
781 addReply(c,shared.nullbulk); in geodistCommand()
|
| H A D | t_hash.c | 425 addReply(c,shared.wrongtypeerr); in hashTypeLookupWriteOrCreate()
494 addReply(c, update ? shared.czero : shared.cone); in hsetCommand()
506 addReply(c, shared.czero); in hsetnxCommand()
510 addReply(c, shared.cone); in hsetnxCommand()
532 addReply(c, shared.ok); in hmsetCommand()
612 addReply(c, shared.nullbulk); in addHashFieldToReply()
623 addReply(c, shared.nullbulk); in addHashFieldToReply()
637 addReply(c, shared.nullbulk); in addHashFieldToReply()
664 addReply(c, shared.wrongtypeerr); in hmgetCommand()
791 addReply(c, hashTypeExists(o,c->argv[2]) ? shared.cone : shared.czero); in hexistsCommand()
|
| H A D | bitops.c | 553 addReply(c, bitval ? shared.cone : shared.czero); in setbitCommand()
580 addReply(c, bitval ? shared.cone : shared.czero); in getbitCommand()
605 addReply(c,shared.syntaxerr); in bitopCommand()
777 addReply(c,shared.czero); in bitcountCommand()
791 addReply(c,shared.syntaxerr); in bitcountCommand()
798 addReply(c,shared.czero); in bitcountCommand()
856 addReply(c,shared.syntaxerr); in bitposCommand()
942 addReply(c,shared.syntaxerr); in bitfieldCommand()
1038 addReply(c,shared.nullbulk); in bitfieldCommand()
1067 addReply(c,shared.nullbulk); in bitfieldCommand()
|
| H A D | debug.c | 330 addReply(c,shared.ok); in debugCommand()
336 addReply(c,shared.err); in debugCommand()
345 addReply(c,shared.ok); in debugCommand()
350 addReply(c,shared.err); in debugCommand()
355 addReply(c,shared.ok); in debugCommand()
362 addReply(c,shared.nokeyerr); in debugCommand()
414 addReply(c,shared.nokeyerr); in debugCommand()
454 addReply(c,shared.ok); in debugCommand()
473 addReply(c,shared.ok); in debugCommand()
478 addReply(c,shared.ok); in debugCommand()
[all …]
|
| H A D | t_zset.c | 1251 addReply(c,shared.syntaxerr); in zaddGenericCommand()
1389 addReply(c,shared.nullbulk); in zaddGenericCommand()
1515 addReply(c,shared.czero); in zremrangeGenericCommand()
1962 addReply(c,shared.syntaxerr); in zunionInterGenericCommand()
2164 addReply(c,shared.czero); in zunionInterGenericCommand()
2197 addReply(c,shared.syntaxerr); in zrangeGenericCommand()
2513 addReply(c, shared.czero); in zcountCommand()
2594 addReply(c, shared.czero); in zlexcountCommand()
2847 addReply(c,shared.nullbulk); in zscoreCommand()
2889 addReply(c,shared.nullbulk); in zrankGenericCommand()
[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()
1274 addReply(c, shared.noscripterr); in evalGenericCommand()
1413 addReply(c, shared.noscripterr); in evalShaCommand()
1427 addReply(c,shared.ok); in scriptCommand()
1436 addReply(c,shared.cone); in scriptCommand()
1438 addReply(c,shared.czero); in scriptCommand()
1465 addReply(c,shared.ok); in scriptCommand()
1474 addReply(c,shared.ok); in scriptCommand()
1477 addReply(c,shared.ok); in scriptCommand()
[all …]
|
| H A D | cluster.c | 3925 addReply(c,shared.ok); in clusterCommand()
3975 addReply(c,shared.ok); in clusterCommand()
4072 addReply(c,shared.ok); in clusterCommand()
4195 addReply(c,shared.ok); in clusterCommand()
4232 addReply(c,shared.ok); in clusterCommand()
4321 addReply(c,shared.ok); in clusterCommand()
4384 addReply(c,shared.ok); in clusterCommand()
4524 addReply(c,shared.ok); in restoreCommand()
4921 addReply(c,shared.ok); in askingCommand()
4933 addReply(c,shared.ok); in readonlyCommand()
[all …]
|
| H A D | blocked.c | 159 addReply(c,shared.nullmultibulk); in replyToBlockedClientTimedOut()
|
| H A D | server.c | 2348 addReply(c,shared.ok); in processCommand()
2373 addReply(c,shared.noautherr); in processCommand()
2418 addReply(c, shared.oomerr); in processCommand()
2463 addReply(c, shared.roslaveerr); in processCommand()
2492 addReply(c, shared.loadingerr); in processCommand()
2518 addReply(c,shared.queued); in processCommand()
2663 addReply(c,shared.ok); in authCommand()
2689 addReply(c,shared.pong); in pingCommand()
2722 addReply(c, shared.nullbulk); in addReplyCommand()
3305 addReply(c,shared.syntaxerr); in infoCommand()
[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 | hyperloglog.c | 1191 addReply(c, updated ? shared.cone : shared.czero); in pfaddCommand()
1240 addReply(c,shared.czero); in pfcountCommand()
1342 addReply(c,shared.ok); in pfmergeCommand()
1446 addReply(c,shared.ok); in pfselftestCommand()
1546 addReply(c,conv ? shared.cone : shared.czero); in pfdebugCommand()
|
| H A D | slowlog.c | 133 addReply(c,shared.ok); in slowlogCommand()
|
| H A D | object.c | 344 addReply(c,shared.wrongtypeerr); in checkType()
704 if (!o) addReply(c, reply); in objectCommandLookupOrReply()
|
| H A D | sentinel.c | 2961 addReply(c, isdown ? shared.cone : shared.czero); in sentinelCommand()
2976 addReply(c,shared.nullmultibulk); in sentinelCommand()
3003 addReply(c,shared.ok); in sentinelCommand()
3052 addReply(c,shared.ok); in sentinelCommand()
3057 addReply(c,shared.ok); in sentinelCommand()
3069 addReply(c,shared.ok); in sentinelCommand()
3144 addReply(c,shared.nullbulk); in sentinelCommand()
3156 addReply(c,shared.nullbulk); in sentinelCommand()
3188 addReply(c,shared.ok); in sentinelCommand()
3213 addReply(c,shared.syntaxerr); in sentinelInfoCommand()
[all …]
|
| H A D | replication.c | 211 addReply(slave,selectcmd); in replicationFeedSlaves()
302 addReply(monitor,cmdobj); in replicationFeedMonitors()
712 addReply(c,shared.syntaxerr); in replconfCommand()
768 addReply(c,shared.ok); in replconfCommand()
1813 addReply(c,shared.ok); in slaveofCommand()
|
| H A D | rdb.c | 1738 addReply(c,shared.ok); in saveCommand()
1740 addReply(c,shared.err); in saveCommand()
1754 addReply(c,shared.syntaxerr); in bgsaveCommand()
1774 addReply(c,shared.err); in bgsaveCommand()
|
| H A D | latency.c | 613 addReply(c,shared.syntaxerr); in latencyCommand()
|
| H A D | config.c | 1005 addReply(c,shared.ok);
1893 addReply(c,shared.ok);
1905 addReply(c,shared.ok);
|