| /dports/databases/redis5/redis-5.0.14/src/ |
| H A D | pubsub.c | 52 return dictSize(c->pubsub_channels)+ in clientSubscriptionsCount()
68 de = dictFind(server.pubsub_channels,channel); in pubsubSubscribeChannel()
71 dictAdd(server.pubsub_channels,channel,clients); in pubsubSubscribeChannel()
97 if (dictDelete(c->pubsub_channels,channel) == DICT_OK) { in pubsubUnsubscribeChannel()
100 de = dictFind(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
110 dictDelete(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
118 addReplyLongLong(c,dictSize(c->pubsub_channels)+ in pubsubUnsubscribeChannel()
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()
[all …]
|
| H A D | networking.c | 153 c->pubsub_channels = dictCreate(&objectKeyPointerValueDictType,NULL); in createClient()
895 dictRelease(c->pubsub_channels); in freeClient()
1689 (int) dictSize(client->pubsub_channels), in catClientInfoString()
|
| H A D | server.h | 774 dict *pubsub_channels; /* channels a client is interested in (SUBSCRIBE) */ member
1241 dict *pubsub_channels; /* Map channels to list of subscribed clients */ member
|
| /dports/databases/redis-devel/redis-0e5b813/src/ |
| H A D | pubsub.c | 130 return dictSize(c->pubsub_channels)+ in clientSubscriptionsCount()
142 if (dictAdd(c->pubsub_channels,channel,NULL) == DICT_OK) { in pubsubSubscribeChannel()
146 de = dictFind(server.pubsub_channels,channel); in pubsubSubscribeChannel()
149 dictAdd(server.pubsub_channels,channel,clients); in pubsubSubscribeChannel()
172 if (dictDelete(c->pubsub_channels,channel) == DICT_OK) { in pubsubUnsubscribeChannel()
175 de = dictFind(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
185 dictDelete(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
255 if (dictSize(c->pubsub_channels) > 0) { in pubsubUnsubscribeAllChannels()
256 dictIterator *di = dictGetSafeIterator(c->pubsub_channels); in pubsubUnsubscribeAllChannels()
297 de = dictFind(server.pubsub_channels,channel); in pubsubPublishMessage()
[all …]
|
| H A D | networking.c | 189 c->pubsub_channels = dictCreate(&objectKeyPointerValueDictType); in createClient()
1407 dictRelease(c->pubsub_channels); in freeClient()
2469 (int) dictSize(client->pubsub_channels), in catClientInfoString()
3354 mem += dictSize(c->pubsub_channels) * sizeof(dictEntry) + in getClientMemoryUsage()
3355 dictSlots(c->pubsub_channels) * sizeof(dictEntry*); in getClientMemoryUsage()
|
| H A D | server.h | 1045 dict *pubsub_channels; /* channels a client is interested in (SUBSCRIBE) */ member
1693 dict *pubsub_channels; /* Map channels to list of subscribed clients */ member
|
| /dports/databases/redis6/redis-6.0.16/src/ |
| H A D | pubsub.c | 143 return dictSize(c->pubsub_channels)+ in clientSubscriptionsCount()
155 if (dictAdd(c->pubsub_channels,channel,NULL) == DICT_OK) { in pubsubSubscribeChannel()
159 de = dictFind(server.pubsub_channels,channel); in pubsubSubscribeChannel()
162 dictAdd(server.pubsub_channels,channel,clients); in pubsubSubscribeChannel()
185 if (dictDelete(c->pubsub_channels,channel) == DICT_OK) { in pubsubUnsubscribeChannel()
188 de = dictFind(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
198 dictDelete(server.pubsub_channels,channel); in pubsubUnsubscribeChannel()
277 dictIterator *di = dictGetSafeIterator(c->pubsub_channels); in pubsubUnsubscribeAllChannels()
318 de = dictFind(server.pubsub_channels,channel); in pubsubPublishMessage()
424 dictIterator *di = dictGetIterator(server.pubsub_channels); in pubsubCommand()
[all …]
|
| H A D | networking.c | 177 c->pubsub_channels = dictCreate(&objectKeyPointerValueDictType,NULL); in createClient()
1271 dictRelease(c->pubsub_channels); in freeClient()
2218 (int) dictSize(client->pubsub_channels), in catClientInfoString()
|
| H A D | server.h | 852 dict *pubsub_channels; /* channels a client is interested in (SUBSCRIBE) */ member
1413 dict *pubsub_channels; /* Map channels to list of subscribed clients */ member
|
| /dports/databases/py-aioredis/aioredis-1.3.1/tests/ |
| H A D | pubsub_commands_test.py | 10 ch = conn.pubsub_channels[channel]
138 res = await redis.pubsub_channels()
141 res = await redis.pubsub_channels('chan:*')
147 res = await redis.pubsub_channels()
150 res = await redis.pubsub_channels('ch*')
156 res = await redis.pubsub_channels()
|
| H A D | connection_test.py | 340 assert b'chan:1' in sub.pubsub_channels
341 chan = sub.pubsub_channels[b'chan:1']
372 ch = sub.pubsub_channels['chan:1']
376 assert ch is sub.pubsub_channels['chan:1']
379 assert ch is sub.pubsub_channels['chan:1']
|
| /dports/databases/py-aioredis/aioredis-1.3.1/examples/ |
| H A D | pool_pubsub.py | 24 channel = conn.pubsub_channels['channel:1']
32 channel = conn.pubsub_channels['channel:1']
|
| H A D | pubsub2.py | 37 channels = await pub.pubsub_channels('channel:*')
|
| /dports/databases/py-aioredis/aioredis-1.3.1/aioredis/commands/ |
| H A D | pubsub.py | 65 def pubsub_channels(self, pattern=None): member in PubSubCommandsMixin
87 return self._pool_or_conn.pubsub_channels
|
| /dports/sysutils/ganglia-monitor-core/ganglia-3.7.2/gmond/python_modules/conf.d/ |
| H A D | redis.pyconf.disabled | 45 name = "pubsub_channels"
|
| /dports/databases/py-aioredis/aioredis-1.3.1/aioredis/ |
| H A D | abc.py | 61 def pubsub_channels(self): member in AbcConnection
|
| H A D | pool.py | 302 def pubsub_channels(self): member in ConnectionsPool
304 return self._pubsub_conn.pubsub_channels
|
| H A D | connection.py | 537 def pubsub_channels(self): member in RedisConnection
|
| /dports/databases/credis/credis-0.2.3/ |
| H A D | credis.h | 129 long pubsub_channels; member
|
| H A D | credis-test.c | 137 printf("> pubsub_channels: %ld\n", info.pubsub_channels); in main()
|
| /dports/databases/p5-RedisDB/RedisDB-2.53/t/ |
| H A D | subscribe.t | 133 eq_or_diff $pub->pubsub_channels, ['baz'], "Only baz channel is active";
|
| /dports/databases/py-redis2/redis-py-2.10.6/tests/ |
| H A D | test_pubsub.py | 410 channels = sorted(r.pubsub_channels())
|
| /dports/databases/py-redis/redis-3.5.3/tests/ |
| H A D | test_pubsub.py | 478 channels = sorted(r.pubsub_channels())
|
| /dports/devel/py-jedi/jedi-0.18.0/jedi/third_party/typeshed/third_party/2and3/redis/ |
| H A D | client.pyi | 280 def pubsub_channels(self, pattern: Text = ...) -> List[Text]: ...
|
| /dports/devel/p5-Test-Mock-Redis/Test-Mock-Redis-0.22/lib/Test/Mock/ |
| H A D | Redis.pm | 967 pubsub_channels => '0',
|