Searched refs:clients (Results 1 – 15 of 15) sorted by relevance
| /redis-3.2.3/src/ |
| H A D | multi.c | 203 list *clients = NULL; in watchForKey() local
217 if (!clients) { in watchForKey()
218 clients = listCreate(); in watchForKey()
222 listAddNodeTail(clients,c); in watchForKey()
240 list *clients; in unwatchAllKeys() local
248 listDelNode(clients,listSearchKey(clients,c)); in unwatchAllKeys()
250 if (listLength(clients) == 0) in unwatchAllKeys()
262 list *clients; in touchWatchedKey() local
268 if (!clients) return; in touchWatchedKey()
272 listRewind(clients,&li); in touchWatchedKey()
[all …]
|
| H A D | pubsub.c | 60 list *clients = NULL; in pubsubSubscribeChannel() local
70 clients = listCreate(); in pubsubSubscribeChannel()
71 dictAdd(server.pubsub_channels,channel,clients); in pubsubSubscribeChannel()
74 clients = dictGetVal(de); in pubsubSubscribeChannel()
76 listAddNodeTail(clients,c); in pubsubSubscribeChannel()
90 list *clients; in pubsubUnsubscribeChannel() local
102 clients = dictGetVal(de); in pubsubUnsubscribeChannel()
103 ln = listSearchKey(clients,c); in pubsubUnsubscribeChannel()
105 listDelNode(clients,ln); in pubsubUnsubscribeChannel()
106 if (listLength(clients) == 0) { in pubsubUnsubscribeChannel()
|
| H A D | redis-benchmark.c | 73 list *clients; member
134 ln = listSearchKey(config.clients,c); in freeClient()
136 listDelNode(config.clients,ln); in freeClient()
140 listNode *ln = config.clients->head, *next; in freeAllClients()
408 listAddNodeTail(config.clients,c); in createClient()
675 config.clients = listCreate(); in main()
|
| H A D | blocked.c | 178 listRewind(server.clients,&li); in disconnectAllBlockedClients()
|
| H A D | networking.c | 128 if (fd != -1) listAddNodeTail(server.clients,c); in createClient()
629 if (listLength(server.clients) > server.maxclients) { in acceptCommonHandler()
757 ln = listSearchKey(server.clients,c); in unlinkClient()
759 listDelNode(server.clients,ln); in unlinkClient()
1371 listRewind(server.clients,&li); in getClientsMaxBuffers()
1474 sds o = sdsnewlen(NULL,200*listLength(server.clients)); in getAllClientsInfoString()
1476 listRewind(server.clients,&li); in getAllClientsInfoString()
1565 listRewind(server.clients,&li); in clientCommand()
1894 listRewind(server.clients,&li); in clientsArePaused()
|
| H A D | debug.c | 978 sds infostring, clients; in sigsegvHandler() local
1008 clients = getAllClientsInfoString(); in sigsegvHandler()
1009 serverLogRaw(LL_WARNING|LL_RAW, clients); in sigsegvHandler()
1011 sdsfree(clients); in sigsegvHandler()
|
| H A D | t_list.c | 818 list *clients = dictGetVal(de); in handleClientsBlockedOnLists() local
819 int numclients = listLength(clients); in handleClientsBlockedOnLists()
822 listNode *clientnode = listFirst(clients); in handleClientsBlockedOnLists()
|
| H A D | Makefile | 224 @(set -e; cd ..; ./runtest --clients 1)
|
| H A D | server.c | 988 int numclients = listLength(server.clients); in clientsCron()
999 while(listLength(server.clients) && iterations--) { in clientsCron()
1006 listRotate(server.clients); in clientsCron()
1007 head = listFirst(server.clients); in clientsCron()
1159 listLength(server.clients)-listLength(server.slaves), in serverCron()
1865 server.clients = listCreate(); in initServer()
2921 listLength(server.clients)-listLength(server.slaves), in genRedisInfoString()
|
| H A D | server.h | 736 list *clients; /* List of active clients */ member
|
| H A D | replication.c | 1958 listAddNodeTail(server.clients,server.master); in replicationResurrectCachedMaster()
|
| /redis-3.2.3/tests/unit/ |
| H A D | obuf-limits.tcl | 13 set clients [split [r client list] "\r\n"]
14 set c [split [lindex $clients 1] " "]
35 set clients [split [r client list] "\r\n"]
36 set c [split [lindex $clients 1] " "]
61 set clients [split [r client list] "\r\n"]
62 set c [split [lindex $clients 1] " "]
|
| /redis-3.2.3/tests/integration/ |
| H A D | replication-4.tcl | 28 test {Test replication with parallel clients writing in differnet DBs} {
|
| /redis-3.2.3/deps/lua/ |
| H A D | INSTALL | 64 it will be used by any Lua clients that you build, to ensure consistency.
|
| /redis-3.2.3/tests/ |
| H A D | test_helper.tcl | 448 } elseif {$opt eq {--clients}} {
|