Home
last modified time | relevance | path

Searched refs:addReplyLongLong (Results 1 – 25 of 25) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dpubsub.c82 addReplyLongLong(c,clientSubscriptionsCount(c)); in pubsubSubscribeChannel()
118 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeChannel()
144 addReplyLongLong(c,clientSubscriptionsCount(c)); in pubsubSubscribePattern()
169 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribePattern()
193 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeAllChannels()
218 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeAllPatterns()
323 addReplyLongLong(c,receivers); in publishCommand()
369 addReplyLongLong(c,l ? listLength(l) : 0); in pubsubCommand()
373 addReplyLongLong(c,listLength(server.pubsub_patterns)); in pubsubCommand()
H A Dobject.c1265 addReplyLongLong(c,o->refcount); in objectCommand()
1337 addReplyLongLong(c,usage); in memoryCommand()
1344 addReplyLongLong(c,mh->peak_allocated); in memoryCommand()
1353 addReplyLongLong(c,mh->repl_backlog); in memoryCommand()
1356 addReplyLongLong(c,mh->clients_slaves); in memoryCommand()
1359 addReplyLongLong(c,mh->clients_normal); in memoryCommand()
1362 addReplyLongLong(c,mh->aof_buffer); in memoryCommand()
1365 addReplyLongLong(c,mh->lua_caches); in memoryCommand()
1384 addReplyLongLong(c,mh->total_keys); in memoryCommand()
1387 addReplyLongLong(c,mh->bytes_per_key); in memoryCommand()
[all …]
H A Dslowlog.c157 addReplyLongLong(c,listLength(server.slowlog)); in slowlogCommand()
178 addReplyLongLong(c,se->id); in slowlogCommand()
179 addReplyLongLong(c,se->time); in slowlogCommand()
180 addReplyLongLong(c,se->duration); in slowlogCommand()
H A Dlatency.c487 addReplyLongLong(c,ts->samples[i].time); in latencyCommandReplyWithSamples()
488 addReplyLongLong(c,ts->samples[i].latency); in latencyCommandReplyWithSamples()
509 addReplyLongLong(c,ts->samples[last].time); in latencyCommandReplyWithLatestEvents()
510 addReplyLongLong(c,ts->samples[last].latency); in latencyCommandReplyWithLatestEvents()
511 addReplyLongLong(c,ts->max); in latencyCommandReplyWithLatestEvents()
616 addReplyLongLong(c,latencyResetEvent(NULL)); in latencyCommand()
622 addReplyLongLong(c,resets); in latencyCommand()
H A Dexpire.c478 addReplyLongLong(c,-2); in ttlGenericCommand()
489 addReplyLongLong(c,-1); in ttlGenericCommand()
491 addReplyLongLong(c,output_ms ? ttl : ((ttl+500)/1000)); in ttlGenericCommand()
524 addReplyLongLong(c,touched); in touchCommand()
H A Dbitops.c765 addReplyLongLong(c,maxlen); /* Return the output string length in bytes. */ in bitopCommand()
813 addReplyLongLong(c,redisPopcount(p+start,bytes)); in bitcountCommand()
838 addReplyLongLong(c, bit ? -1 : 0); in bitposCommand()
874 addReplyLongLong(c, -1); in bitposCommand()
887 addReplyLongLong(c,-1); in bitposCommand()
891 addReplyLongLong(c,pos); in bitposCommand()
1052 addReplyLongLong(c,retval); in bitfieldCommand()
1081 addReplyLongLong(c,retval); in bitfieldCommand()
1116 addReplyLongLong(c,val); in bitfieldCommand()
1120 addReplyLongLong(c,val); in bitfieldCommand()
H A Dt_stream.c1317 addReplyLongLong(c,s->length); in xlenCommand()
1823 addReplyLongLong(c,pending); in xgroupCommand()
1910 addReplyLongLong(c,acknowledged); in xackCommand()
1967 addReplyLongLong(c,raxSize(group->pel)); in xpendingCommand()
2051 addReplyLongLong(c,elapsed); in xpendingCommand()
2346 addReplyLongLong(c,deleted); in xdelCommand()
2424 addReplyLongLong(c,deleted); in xtrimCommand()
2489 addReplyLongLong(c,idle); in xinfoCommand()
2520 addReplyLongLong(c,s->length); in xinfoCommand()
2522 addReplyLongLong(c,raxSize(s->rax)); in xinfoCommand()
[all …]
H A Dt_string.c221 addReplyLongLong(c,olen); in setrangeCommand()
241 addReplyLongLong(c,sdslen(o->ptr)); in setrangeCommand()
463 addReplyLongLong(c,totlen); in appendCommand()
470 addReplyLongLong(c,stringObjectLen(o)); in strlenCommand()
H A Dt_hash.c549 addReplyLongLong(c, created); in hsetCommand()
588 addReplyLongLong(c,value); in hincrbyCommand()
731 addReplyLongLong(c,deleted); in hdelCommand()
740 addReplyLongLong(c,hashTypeLength(o)); in hlenCommand()
748 addReplyLongLong(c,hashTypeGetValueLength(o,c->argv[2]->ptr)); in hstrlenCommand()
H A Dt_list.c216 addReplyLongLong(c, (lobj ? listTypeLength(lobj) : 0)); in pushGenericCommand()
246 addReplyLongLong(c,listTypeLength(subject)); in pushxGenericCommand()
305 addReplyLongLong(c,listTypeLength(subject)); in linsertCommand()
311 addReplyLongLong(c,listTypeLength(o)); in llenCommand()
531 addReplyLongLong(c,removed); in lremCommand()
H A Dt_set.c287 addReplyLongLong(c,added); in saddCommand()
315 addReplyLongLong(c,deleted); in sremCommand()
391 addReplyLongLong(c,setTypeSize(o)); in scardCommand()
901 addReplyLongLong(c,setTypeSize(dstset)); in sinterGenericCommand()
1074 addReplyLongLong(c,setTypeSize(dstset)); in sunionDiffGenericCommand()
H A Dreplication.c2087 addReplyLongLong(c,server.master_repl_offset); in roleCommand()
2113 addReplyLongLong(c,server.masterport); in roleCommand()
2127 addReplyLongLong(c,server.master ? server.master->reploff : -1); in roleCommand()
2455 addReplyLongLong(c,ackreplicas); in waitCommand()
2503 addReplyLongLong(c,last_numreplicas); in processClientsWaitingReplicas()
2511 addReplyLongLong(c,numreplicas); in processClientsWaitingReplicas()
H A Ddb.c483 addReplyLongLong(c,numdel); in delGenericCommand()
503 addReplyLongLong(c,count); in existsCommand()
809 addReplyLongLong(c,dictSize(c->db->dict)); in dbsizeCommand()
813 addReplyLongLong(c,server.lastsave); in lastsaveCommand()
H A Dgeo.c625 addReplyLongLong(c, gp->score); in georadiusGeneric()
670 addReplyLongLong(c, returned_items); in georadiusGeneric()
H A Dhyperloglog.c1254 addReplyLongLong(c,hllCount(hdr,NULL)); in pfcountCommand()
1306 addReplyLongLong(c,card); in pfcountCommand()
1527 addReplyLongLong(c,val); in pfdebugCommand()
H A Dt_zset.c1643 addReplyLongLong(c,ch ? added+updated : added); in zaddGenericCommand()
1687 addReplyLongLong(c,deleted); in zremCommand()
1788 addReplyLongLong(c,deleted); in zremrangeGenericCommand()
2385 addReplyLongLong(c,zsetLength(dstobj)); in zunionInterGenericCommand()
2795 addReplyLongLong(c, count); in zcountCommand()
2874 addReplyLongLong(c, count); in zlexcountCommand()
3072 addReplyLongLong(c,zsetLength(zobj)); in zcardCommand()
3102 addReplyLongLong(c,rank); in zrankGenericCommand()
H A Dblocked.c192 addReplyLongLong(c,replicationCountAcksByOffset(c->bpop.reploffset)); in replyToBlockedClientTimedOut()
H A Dcluster.c4157 addReplyLongLong(c, start); /* only one slot; low==high */ in clusterReplyMultiBulkSlots()
4158 addReplyLongLong(c, start); in clusterReplyMultiBulkSlots()
4160 addReplyLongLong(c, start); /* low */ in clusterReplyMultiBulkSlots()
4161 addReplyLongLong(c, j-1); /* high */ in clusterReplyMultiBulkSlots()
4168 addReplyLongLong(c, node->port); in clusterReplyMultiBulkSlots()
4178 addReplyLongLong(c, node->slaves[i]->port); in clusterReplyMultiBulkSlots()
4517 addReplyLongLong(c,keyHashSlot(key,sdslen(key))); in clusterCommand()
4528 addReplyLongLong(c,countKeysInSlot(slot)); in clusterCommand()
4647 addReplyLongLong(c,clusterNodeFailureReportsCount(n)); in clusterCommand()
H A Dsort.c576 addReplyLongLong(c,outputlen); in sortCommand()
H A Dnetworking.c519 void addReplyLongLong(client *c, long long ll) { in addReplyLongLong() function
1738 addReplyLongLong(c,c->id); in clientCommand()
1850 addReplyLongLong(c,killed); in clientCommand()
H A Dserver.c3005 addReplyLongLong(c, cmd->arity); in addReplyCommand()
3030 addReplyLongLong(c, cmd->firstkey); in addReplyCommand()
3031 addReplyLongLong(c, cmd->lastkey); in addReplyCommand()
3032 addReplyLongLong(c, cmd->keystep); in addReplyCommand()
3064 addReplyLongLong(c, dictSize(server.commands)); in commandCommand()
H A Dsentinel.c3069 addReplyLongLong(c, (long long)leader_epoch); in sentinelCommand()
3074 addReplyLongLong(c,sentinelResetMastersByPattern(c->argv[2]->ptr,SENTINEL_GENERATE_EVENT)); in sentinelCommand()
3246 addReplyLongLong(c, now - ri->info_refresh); in sentinelCommand()
3258 addReplyLongLong(c, now - sri->info_refresh); in sentinelCommand()
3568 addReplyLongLong(c,1); in sentinelPublishCommand()
H A Dmodule.c1117 addReplyLongLong(c,ll); in RM_ReplyWithLongLong()
5291 addReplyLongLong(c,module->ver); in moduleCommand()
H A Dserver.h1454 void addReplyLongLong(client *c, long long ll);
H A Dscripting.c288 addReplyLongLong(c,(long long)lua_tonumber(lua,-1)); in luaReplyToRedisReply()