| /redis-3.2.3/src/ |
| H A D | blocked.c | 110 listNode *ln; in processUnblockedClients() local
114 ln = listFirst(server.unblocked_clients); in processUnblockedClients()
115 serverAssert(ln != NULL); in processUnblockedClients()
116 c = ln->value; in processUnblockedClients()
117 listDelNode(server.unblocked_clients,ln); in processUnblockedClients()
175 listNode *ln; in disconnectAllBlockedClients() local
179 while((ln = listNext(&li))) { in disconnectAllBlockedClients()
180 client *c = listNodeValue(ln); in disconnectAllBlockedClients()
|
| H A D | pubsub.c | 91 listNode *ln; in pubsubUnsubscribeChannel() local
103 ln = listSearchKey(clients,c); in pubsubUnsubscribeChannel()
105 listDelNode(clients,ln); in pubsubUnsubscribeChannel()
151 listNode *ln; in pubsubUnsubscribePattern() local
158 listDelNode(c->pubsub_patterns,ln); in pubsubUnsubscribePattern()
203 listNode *ln; in pubsubUnsubscribeAllPatterns() local
208 while ((ln = listNext(&li)) != NULL) { in pubsubUnsubscribeAllPatterns()
209 robj *pattern = ln->value; in pubsubUnsubscribeAllPatterns()
228 listNode *ln; in pubsubPublishMessage() local
235 listNode *ln; in pubsubPublishMessage() local
[all …]
|
| H A D | multi.c | 205 listNode *ln; in watchForKey() local
210 while((ln = listNext(&li))) { in watchForKey()
211 wk = listNodeValue(ln); in watchForKey()
235 listNode *ln; in unwatchAllKeys() local
239 while((ln = listNext(&li))) { in unwatchAllKeys()
245 wk = listNodeValue(ln); in unwatchAllKeys()
264 listNode *ln; in touchWatchedKey() local
273 while((ln = listNext(&li))) { in touchWatchedKey()
274 client *c = listNodeValue(ln); in touchWatchedKey()
286 listNode *ln; in touchWatchedKeysOnFlush() local
[all …]
|
| H A D | networking.c | 197 listNode *ln; in dupLastObjectIfNeeded() local
199 ln = listLast(reply); in dupLastObjectIfNeeded()
200 cur = listNodeValue(ln); in dupLastObjectIfNeeded()
747 listNode *ln; in unlinkClient() local
787 listNode *ln; in freeClient() local
1000 listNode *ln; in handleClientsWithPendingWrites() local
1367 listNode *ln; in getClientsMaxBuffers() local
1471 listNode *ln; in getAllClientsInfoString() local
1486 listNode *ln; in clientCommand() local
1834 listNode *ln; in flushSlavesOutputBuffers() local
[all …]
|
| H A D | replication.c | 174 listNode *ln; in replicationFeedSlaves() local
269 listNode *ln; in replicationFeedMonitors() local
513 listNode *ln; in startBgsaveForReplication() local
636 listNode *ln; in syncCommand() local
869 listNode *ln; in updateSlavesWaitingBgsave() local
1822 listNode *ln; in roleCommand() local
1983 listNode *ln; in refreshGoodSlavesCount() local
2122 listNode *ln; in replicationCountAcksByOffset() local
2185 listNode *ln; in processClientsWaitingReplicas() local
2286 listNode *ln; in replicationCron() local
[all …]
|
| H A D | sort.c | 401 zskiplistNode *ln; in sortCommand() local
409 ln = zsl->tail; in sortCommand()
413 ln = zsl->header->level[0].forward; in sortCommand()
415 ln = zslGetElementByRank(zsl,start+1); in sortCommand()
420 ele = ln->obj; in sortCommand()
425 ln = desc ? ln->backward : ln->level[0].forward; in sortCommand()
510 listNode *ln; in sortCommand() local
515 while((ln = listNext(&li))) { in sortCommand()
516 redisSortOperation *sop = ln->value; in sortCommand()
538 listNode *ln; in sortCommand() local
[all …]
|
| H A D | bio.c | 167 listNode *ln; in bioProcessBackgroundJobs() local
175 ln = listFirst(bio_jobs[type]); in bioProcessBackgroundJobs()
176 job = ln->value; in bioProcessBackgroundJobs()
194 listDelNode(bio_jobs[type],ln); in bioProcessBackgroundJobs()
|
| H A D | t_zset.c | 2277 ln = reverse ? ln->backward : ln->level[0].forward; in zrangeGenericCommand()
2426 if (ln == NULL) { in genericZrangebyscoreCommand()
2440 ln = ln->backward; in genericZrangebyscoreCommand()
2442 ln = ln->level[0].forward; in genericZrangebyscoreCommand()
2463 ln = ln->backward; in genericZrangebyscoreCommand()
2465 ln = ln->level[0].forward; in genericZrangebyscoreCommand()
2773 if (ln == NULL) { in genericZrangebylexCommand()
2788 ln = ln->backward; in genericZrangebylexCommand()
2790 ln = ln->level[0].forward; in genericZrangebylexCommand()
2807 ln = ln->backward; in genericZrangebylexCommand()
[all …]
|
| H A D | slowlog.c | 142 listNode *ln; in slowlogCommand() local
151 while(count-- && (ln = listNext(&li))) { in slowlogCommand()
154 se = ln->value; in slowlogCommand()
|
| H A D | aof.c | 80 listNode *ln; in aofRewriteBufferSize() local
85 while((ln = listNext(&li))) { in aofRewriteBufferSize()
86 aofrwblock *block = listNodeValue(ln); in aofRewriteBufferSize()
96 listNode *ln; in aofChildWriteDiffData() local
105 ln = listFirst(server.aof_rewrite_buf_blocks); in aofChildWriteDiffData()
106 block = ln ? ln->value : NULL; in aofChildWriteDiffData()
125 listNode *ln = listLast(server.aof_rewrite_buf_blocks); in aofRewriteBufferAppend() local
126 aofrwblock *block = ln ? ln->value : NULL; in aofRewriteBufferAppend()
174 listNode *ln; in aofRewriteBufferWrite() local
179 while((ln = listNext(&li))) { in aofRewriteBufferWrite()
[all …]
|
| H A D | redis-benchmark.c | 126 listNode *ln; in freeClient() local
134 ln = listSearchKey(config.clients,c); in freeClient()
135 assert(ln != NULL); in freeClient()
136 listDelNode(config.clients,ln); in freeClient()
140 listNode *ln = config.clients->head, *next; in freeAllClients() local
142 while(ln) { in freeAllClients()
143 next = ln->next; in freeAllClients()
144 freeClient(ln->value); in freeAllClients()
145 ln = next; in freeAllClients()
|
| H A D | geo.c | 264 zskiplistNode *ln; in geoGetPointsInRange() local
266 if ((ln = zslFirstInRange(zsl, &range)) == NULL) { in geoGetPointsInRange()
271 while (ln) { in geoGetPointsInRange()
272 robj *o = ln->obj; in geoGetPointsInRange()
274 if (!zslValueLteMax(ln->score, &range)) in geoGetPointsInRange()
280 if (geoAppendIfWithinRadius(ga,lon,lat,radius,ln->score,member) in geoGetPointsInRange()
282 ln = ln->level[0].forward; in geoGetPointsInRange()
|
| H A D | scripting.c | 1508 listNode *ln; in ldbFlushLog() local
1510 while((ln = listFirst(log)) != NULL) in ldbFlushLog()
1511 listDelNode(log,ln); in ldbFlushLog()
1566 listNode *ln = listFirst(ldb.logs); in ldbSendLogs() local
1568 sdsmapchars(ln->value,"\r\n"," ",2); in ldbSendLogs()
1569 proto = sdscatsds(proto,ln->value); in ldbSendLogs()
1571 listDelNode(ldb.logs,ln); in ldbSendLogs()
1681 if (ln) { in ldbRemoveChild()
1682 listDelNode(ldb.children,ln); in ldbRemoveChild()
1697 listNode *ln; in ldbKillForkedSessions() local
[all …]
|
| H A D | sentinel.c | 695 listNode *ln; in sentinelScheduleScriptExecution() local
700 sj = ln->value; in sentinelScheduleScriptExecution()
716 listNode *ln; in sentinelGetScriptListNodeByPid() local
724 return ln; in sentinelGetScriptListNodeByPid()
732 listNode *ln; in sentinelRunPendingScripts() local
740 (ln = listNext(&li)) != NULL) in sentinelRunPendingScripts()
802 listNode *ln; in sentinelCollectTerminatedScripts() local
810 if (ln == NULL) { in sentinelCollectTerminatedScripts()
814 sj = ln->value; in sentinelCollectTerminatedScripts()
843 listNode *ln; in sentinelKillTimedoutScripts() local
[all …]
|
| H A D | rdb.c | 1520 listNode *ln; in backgroundSaveDoneHandlerSocket() local
1524 while((ln = listNext(&li))) { in backgroundSaveDoneHandlerSocket()
1525 client *slave = ln->value; in backgroundSaveDoneHandlerSocket()
1583 listNode *ln; in rdbSaveToSlavesSockets() local
1608 while((ln = listNext(&li))) { in rdbSaveToSlavesSockets()
1609 client *slave = ln->value; in rdbSaveToSlavesSockets()
1704 while((ln = listNext(&li))) { in rdbSaveToSlavesSockets()
1705 client *slave = ln->value; in rdbSaveToSlavesSockets()
|
| H A D | config.c | 1411 listNode *ln = listFirst(l); local
1412 int linenum = (long) ln->value;
1416 listDelNode(l,ln);
1692 listNode *ln = listFirst(l); local
1693 int linenum = (long) ln->value;
1697 listDelNode(l,ln);
|
| H A D | cluster.c | 694 listNode *ln; in clusterNodeAddFailureReport() local
701 while ((ln = listNext(&li)) != NULL) { in clusterNodeAddFailureReport()
702 fr = ln->value; in clusterNodeAddFailureReport()
724 listNode *ln; in clusterNodeCleanupFailureReports() local
732 while ((ln = listNext(&li)) != NULL) { in clusterNodeCleanupFailureReports()
733 fr = ln->value; in clusterNodeCleanupFailureReports()
734 if (now - fr->time > maxtime) listDelNode(l,ln); in clusterNodeCleanupFailureReports()
751 listNode *ln; in clusterNodeDelFailureReport() local
757 while ((ln = listNext(&li)) != NULL) { in clusterNodeDelFailureReport()
758 fr = ln->value; in clusterNodeDelFailureReport()
[all …]
|
| H A D | t_list.c | 801 listNode *ln = listFirst(l); in handleClientsBlockedOnLists() local
802 readyList *rl = ln->value; in handleClientsBlockedOnLists()
864 listDelNode(l,ln); in handleClientsBlockedOnLists()
|
| H A D | Makefile | 262 @ln -sf $(REDIS_SERVER_NAME) $(INSTALL_BIN)/$(REDIS_SENTINEL_NAME)
|
| H A D | server.c | 3189 listNode *ln; in genRedisInfoString() local
3193 while((ln = listNext(&li))) { in genRedisInfoString()
3194 client *slave = listNodeValue(ln); in genRedisInfoString()
3458 listNode *ln; in freeMemoryIfNeeded() local
3461 while((ln = listNext(&li))) { in freeMemoryIfNeeded()
3462 client *slave = listNodeValue(ln); in freeMemoryIfNeeded()
|
| /redis-3.2.3/deps/hiredis/ |
| H A D | Makefile | 141 cd $(INSTALL_LIBRARY_PATH) && ln -sf $(DYLIB_MINOR_NAME) $(DYLIB_MAJOR_NAME)
142 cd $(INSTALL_LIBRARY_PATH) && ln -sf $(DYLIB_MAJOR_NAME) $(DYLIBNAME)
|
| /redis-3.2.3/deps/jemalloc/ |
| H A D | Makefile.in | 252 ln -sf $(<F) $@
301 ln -sf $(LIBJEMALLOC).$(SOREV) $(LIBDIR)/$(LIBJEMALLOC).$(SO)
|
| H A D | configure | 8583 if ln -s conf$$.file conf$$ 2>/dev/null; then
8589 ln -s conf$$.file conf$$.dir 2>/dev/null && test ! -f conf$$.exe ||
8591 elif ln conf$$.file conf$$ 2>/dev/null; then
8592 as_ln_s=ln
|