| /f-stack/app/redis-5.0.5/src/ |
| H A D | sort.c | 85 decrRefCount(subst); in lookupKeyByPattern()
125 decrRefCount(keyobj); in lookupKeyByPattern()
126 if (fieldobj) decrRefCount(fieldobj); in lookupKeyByPattern()
130 decrRefCount(keyobj); in lookupKeyByPattern()
131 if (fieldlen) decrRefCount(fieldobj); in lookupKeyByPattern()
283 decrRefCount(sortval); in sortCommand()
487 decrRefCount(byval); in sortCommand()
525 decrRefCount(val); in sortCommand()
575 decrRefCount(sobj); in sortCommand()
581 decrRefCount(vector[j].obj); in sortCommand()
[all …]
|
| H A D | blocked.c | 311 if (dstkey) decrRefCount(dstkey); in handleClientsBlockedOnKeys()
312 decrRefCount(value); in handleClientsBlockedOnKeys()
368 decrRefCount(argv[0]); in handleClientsBlockedOnKeys()
369 decrRefCount(argv[1]); in handleClientsBlockedOnKeys()
462 decrRefCount(rl->key); in handleClientsBlockedOnKeys()
567 decrRefCount(c->bpop.target); in unblockClientWaitingData()
571 decrRefCount(c->bpop.xread_group); in unblockClientWaitingData()
572 decrRefCount(c->bpop.xread_consumer); in unblockClientWaitingData()
|
| H A D | notify.c | 123 decrRefCount(chanobj); in notifyKeyspaceEvent()
135 decrRefCount(chanobj); in notifyKeyspaceEvent()
137 decrRefCount(eventobj); in notifyKeyspaceEvent()
|
| H A D | redis-check-rdb.c | 270 decrRefCount(auxkey); in redis_check_rdb()
271 decrRefCount(auxval); in redis_check_rdb()
294 decrRefCount(key); in redis_check_rdb()
295 decrRefCount(val); in redis_check_rdb()
|
| H A D | lazyfree.c | 100 decrRefCount(o); in freeObjAsync()
130 decrRefCount(o); in lazyfreeFreeObjectFromBioThread()
|
| H A D | pubsub.c | 39 decrRefCount(pat->pattern); in freePubsubPattern()
122 decrRefCount(channel); /* it is finally safe to release it */ in pubsubUnsubscribeChannel()
172 decrRefCount(pattern); in pubsubUnsubscribePattern()
268 decrRefCount(channel); in pubsubPublishMessage()
|
| H A D | t_set.c | 492 decrRefCount(objele); in spopWithCountCommand()
535 decrRefCount(objele); in spopWithCountCommand()
547 decrRefCount(propargv[0]); in spopWithCountCommand()
589 decrRefCount(aux); in spopCommand()
593 decrRefCount(ele); in spopCommand()
731 decrRefCount(objele); in srandmemberWithCountCommand()
905 decrRefCount(dstset); in sinterGenericCommand()
1067 decrRefCount(dstset); in sunionDiffGenericCommand()
1079 decrRefCount(dstset); in sunionDiffGenericCommand()
|
| H A D | db.c | 262 decrRefCount(keyobj); in dbRandomKey()
322 decrRefCount(decoded); in dbUnshareStringValue()
533 decrRefCount(key); in randomkeyCommand()
556 decrRefCount(keyobj); in keysCommand()
765 decrRefCount(kobj); in scanGenericCommand()
777 decrRefCount(kobj); in scanGenericCommand()
792 decrRefCount(kobj); in scanGenericCommand()
890 decrRefCount(o); in renameGenericCommand()
1125 decrRefCount(argv[0]); in propagateExpire()
1126 decrRefCount(argv[1]); in propagateExpire()
[all …]
|
| H A D | t_list.c | 47 decrRefCount(value); in listTypePush()
153 decrRefCount(value); in listTypeInsert()
332 decrRefCount(value); in lindexCommand()
378 decrRefCount(value); in popGenericCommand()
587 decrRefCount(value); in rpoplpushCommand()
597 decrRefCount(touchedkey); in rpoplpushCommand()
710 decrRefCount(value); in blockingPopGenericCommand()
|
| H A D | t_stream.c | 818 decrRefCount(argv[0]); in streamPropagateXCLAIM()
819 decrRefCount(argv[3]); in streamPropagateXCLAIM()
820 decrRefCount(argv[4]); in streamPropagateXCLAIM()
821 decrRefCount(argv[6]); in streamPropagateXCLAIM()
822 decrRefCount(argv[7]); in streamPropagateXCLAIM()
823 decrRefCount(argv[8]); in streamPropagateXCLAIM()
824 decrRefCount(argv[9]); in streamPropagateXCLAIM()
845 decrRefCount(argv[0]); in streamPropagateGroupID()
846 decrRefCount(argv[1]); in streamPropagateGroupID()
847 decrRefCount(argv[4]); in streamPropagateGroupID()
[all …]
|
| H A D | multi.c | 50 decrRefCount(mc->argv[i]); in freeClientMultiState()
113 decrRefCount(multistring); in execCommandPropagateMulti()
286 decrRefCount(wk->key); in unwatchAllKeys()
|
| H A D | debug.c | 80 decrRefCount(o); in xorStringObjectDigest()
110 decrRefCount(o); in mixStringObjectDigest()
136 decrRefCount(eleobj); in xorObjectDigest()
294 decrRefCount(keyobj); in computeDatasetDigest()
493 decrRefCount(key); in debugCommand()
506 decrRefCount(key); in debugCommand()
1134 decrRefCount(decoded); in logCurrentClient()
1149 decrRefCount(key); in logCurrentClient()
|
| H A D | rdb.c | 518 decrRefCount(o); in rdbGenericLoadStringObject()
1364 decrRefCount(o); in rdbLoadCheckModuleValue()
1407 decrRefCount(dec); in rdbLoadObject()
1408 decrRefCount(ele); in rdbLoadObject()
1974 decrRefCount(auxkey); in rdbLoadRio()
1975 decrRefCount(auxval); in rdbLoadRio()
2003 decrRefCount(aux); in rdbLoadRio()
2017 decrRefCount(key); in rdbLoadRio()
2018 decrRefCount(val); in rdbLoadRio()
2031 decrRefCount(key); in rdbLoadRio()
|
| H A D | module.c | 530 decrRefCount(propargv[0]); in moduleHandlePropagationAfterCommandCallback()
941 decrRefCount(str); in RM_FreeString()
1551 decrRefCount(key->key); in RM_CloseKey()
1741 decrRefCount(o); in RM_StringTruncate()
1789 decrRefCount(ele); in RM_ListPop()
2348 decrRefCount(field); in RM_HashSet()
2729 decrRefCount(argv[j]); in moduleCreateArgvFromUserFormat()
3090 decrRefCount(o); in RM_ModuleTypeSetValue()
3451 decrRefCount(argv[j]); in RM_EmitAOF()
4992 decrRefCount(fctx->argv[pos]); in RM_CommandFilterArgReplace()
[all …]
|
| H A D | aof.c | 538 decrRefCount(o); in catAppendOnlyGenericCommand()
569 decrRefCount(seconds); in catAppendOnlyExpireAtCommand()
575 decrRefCount(argv[0]); in catAppendOnlyExpireAtCommand()
576 decrRefCount(argv[2]); in catAppendOnlyExpireAtCommand()
605 decrRefCount(tmpargv[0]); in feedAppendOnlyFile()
683 decrRefCount(c->argv[j]); in freeFakeClientArgv()
|
| H A D | slowlog.c | 105 decrRefCount(se->argv[j]); in slowlogFreeEntry()
|
| H A D | networking.c | 492 decrRefCount(o); in addReplyHumanLongDouble()
776 decrRefCount(c->argv[j]); in freeClientArgv()
940 if (c->name) decrRefCount(c->name); in freeClient()
1895 if (c->name) decrRefCount(c->name); in clientCommand()
1912 if (c->name) decrRefCount(c->name); in clientCommand()
1973 for (j = 0; j < c->argc; j++) decrRefCount(c->argv[j]); in rewriteClientCommandVector()
2015 if (oldval) decrRefCount(oldval); in rewriteClientCommandArgument()
|
| H A D | bitops.c | 642 decrRefCount(objects[i]); in bitopCommand()
748 decrRefCount(objects[j]); in bitopCommand()
759 decrRefCount(o); in bitopCommand()
|
| H A D | object.c | 353 void decrRefCount(robj *o) { in decrRefCount() function
376 decrRefCount(o); in decrRefCountVoid()
466 decrRefCount(o); in tryObjectEncoding()
486 decrRefCount(o); in tryObjectEncoding()
|
| H A D | geo.c | 430 if (argv[i]) decrRefCount(argv[i]); in geoaddCommand()
661 decrRefCount(zobj); in georadiusGeneric()
|
| H A D | expire.c | 67 decrRefCount(keyobj); in activeExpireCycleTryExpire()
|
| H A D | server.c | 503 decrRefCount(val); in dictObjectDestructor()
546 decrRefCount(o1); in dictEncObjKeyCompare()
547 decrRefCount(o2); in dictEncObjKeyCompare()
568 decrRefCount(o); in dictEncObjHash()
1388 decrRefCount(argv[0]); in beforeSleep()
1389 decrRefCount(argv[1]); in beforeSleep()
1390 decrRefCount(argv[2]); in beforeSleep()
2277 decrRefCount(op->argv[j]); in redisOpArrayFree()
|
| H A D | t_hash.c | 639 decrRefCount(aux); in hincrbyfloatCommand()
641 decrRefCount(newobj); in hincrbyfloatCommand()
|
| H A D | evict.c | 579 decrRefCount(keyobj); in freeMemoryIfNeeded()
|
| H A D | scripting.c | 433 decrRefCount(argv[j]); in luaRedisGenericCommand()
631 if (cached_objects[j]) decrRefCount(cached_objects[j]); in luaRedisGenericCommand()
635 decrRefCount(o); in luaRedisGenericCommand()
1423 decrRefCount(propargv[0]); in evalGenericCommand()
|