Home
last modified time | relevance | path

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

123

/redis-3.2.3/src/
H A Dserver.h565 typedef struct client { struct
616 } client; argument
983 client *client; member
1094 void freeClient(client *c);
1118 void copyClientOutputBuffer(client *dst, client *src);
1122 char *getClientPeerId(client *client);
1123 sds catClientInfoString(sds s, client *client);
1483 void setCommand(client *c);
1487 void getCommand(client *c);
1488 void delCommand(client *c);
[all …]
H A Dnetworking.c65 client *c = zmalloc(sizeof(client)); in createClient()
601 void copyClientOutputBuffer(client *dst, client *src) { in copyClientOutputBuffer()
617 client *c; in acceptCommonHandler()
1308 client *c = (client*) privdata; in readQueryFromClient()
1366 client *c; in getClientsMaxBuffers()
1393 void genClientPeerId(client *client, char *peerid, in genClientPeerId() argument
1420 sds catClientInfoString(sds s, client *client) { in catClientInfoString() argument
1453 client->name ? (char*)client->name->ptr : "", in catClientInfoString()
1467 client->lastcmd ? client->lastcmd->name : "NULL"); in catClientInfoString()
1473 client *client; in getAllClientsInfoString() local
[all …]
H A Dpubsub.c46 return (pa->client == pb->client) && in listMatchPubsubPattern()
51 int clientSubscriptionsCount(client *c) { in clientSubscriptionsCount()
137 pat->client = c; in pubsubSubscribePattern()
159 pat.client = c; in pubsubUnsubscribePattern()
240 client *c = ln->value; in pubsubPublishMessage()
277 void subscribeCommand(client *c) { in subscribeCommand()
285 void unsubscribeCommand(client *c) { in unsubscribeCommand()
297 void psubscribeCommand(client *c) { in psubscribeCommand()
305 void punsubscribeCommand(client *c) { in punsubscribeCommand()
317 void publishCommand(client *c) { in publishCommand()
[all …]
H A Dt_string.c96 void setCommand(client *c) { in setCommand()
142 void setnxCommand(client *c) { in setnxCommand()
147 void setexCommand(client *c) { in setexCommand()
152 void psetexCommand(client *c) { in psetexCommand()
172 void getCommand(client *c) { in getCommand()
176 void getsetCommand(client *c) { in getsetCommand()
285 void mgetCommand(client *c) { in mgetCommand()
333 void msetCommand(client *c) { in msetCommand()
337 void msetnxCommand(client *c) { in msetnxCommand()
379 void incrCommand(client *c) { in incrCommand()
[all …]
H A Dmulti.c35 void initClientMultiState(client *c) { in initClientMultiState()
41 void freeClientMultiState(client *c) { in freeClientMultiState()
56 void queueMultiCommand(client *c) { in queueMultiCommand()
72 void discardTransaction(client *c) { in discardTransaction()
81 void flagTransaction(client *c) { in flagTransaction()
86 void multiCommand(client *c) { in multiCommand()
95 void discardCommand(client *c) { in discardCommand()
114 void execCommand(client *c) { in execCommand()
233 void unwatchAllKeys(client *c) { in unwatchAllKeys()
307 void watchCommand(client *c) { in watchCommand()
[all …]
H A Dblocked.c76 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit) { in getTimeoutFromObjectOrReply()
100 void blockClient(client *c, int btype) { in blockClient()
111 client *c; in processUnblockedClients()
134 void unblockClient(client *c) { in unblockClient()
157 void replyToBlockedClientTimedOut(client *c) { in replyToBlockedClientTimedOut()
180 client *c = listNodeValue(ln); in disconnectAllBlockedClients()
H A Dt_list.c227 void lpushCommand(client *c) { in lpushCommand()
231 void rpushCommand(client *c) { in rpushCommand()
278 void lpushxCommand(client *c) { in lpushxCommand()
283 void rpushxCommand(client *c) { in rpushxCommand()
299 void llenCommand(client *c) { in llenCommand()
305 void lindexCommand(client *c) { in lindexCommand()
332 void lsetCommand(client *c) { in lsetCommand()
381 void lpopCommand(client *c) { in lpopCommand()
385 void rpopCommand(client *c) { in rpopCommand()
435 void ltrimCommand(client *c) { in ltrimCommand()
[all …]
H A Ddb.c317 void flushdbCommand(client *c) { in flushdbCommand()
344 void delCommand(client *c) { in delCommand()
362 void existsCommand(client *c) { in existsCommand()
373 void selectCommand(client *c) { in selectCommand()
403 void keysCommand(client *c) { in keysCommand()
669 void scanCommand(client *c) { in scanCommand()
683 void typeCommand(client *c) { in typeCommand()
781 void moveCommand(client *c) { in moveCommand()
1027 void ttlCommand(client *c) { in ttlCommand()
1031 void pttlCommand(client *c) { in pttlCommand()
[all …]
H A Dt_hash.c486 void hsetCommand(client *c) { in hsetCommand()
500 void hsetnxCommand(client *c) { in hsetnxCommand()
517 void hmsetCommand(client *c) { in hmsetCommand()
538 void hincrbyCommand(client *c) { in hincrbyCommand()
647 void hgetCommand(client *c) { in hgetCommand()
656 void hmgetCommand(client *c) { in hmgetCommand()
674 void hdelCommand(client *c) { in hdelCommand()
702 void hlenCommand(client *c) { in hlenCommand()
774 void hkeysCommand(client *c) { in hkeysCommand()
778 void hvalsCommand(client *c) { in hvalsCommand()
[all …]
H A Dreplication.c43 void putSlaveOnline(client *slave);
564 void syncCommand(client *c) { in syncCommand()
635 client *slave; in syncCommand()
799 client *slave = privdata; in sendBulkToSlave()
1789 client); in slaveofCommand()
1790 sdsfree(client); in slaveofCommand()
1811 sdsfree(client); in slaveofCommand()
1819 void roleCommand(client *c) { in roleCommand()
1876 client *c = server.master; in replicationSendAck()
2137 void waitCommand(client *c) { in waitCommand()
[all …]
H A Dt_set.c272 void saddCommand(client *c) { in saddCommand()
299 void sremCommand(client *c) { in sremCommand()
327 void smoveCommand(client *c) { in smoveCommand()
381 void sismemberCommand(client *c) { in sismemberCommand()
394 void scardCommand(client *c) { in scardCommand()
562 void spopCommand(client *c) { in spopCommand()
927 void sinterCommand(client *c) { in sinterCommand()
1098 void sunionCommand(client *c) { in sunionCommand()
1106 void sdiffCommand(client *c) { in sdiffCommand()
1110 void sdiffstoreCommand(client *c) { in sdiffstoreCommand()
[all …]
H A Dredis-benchmark.c98 } *client; typedef
102 static void createMissingClients(client c);
125 static void freeClient(client c) { in freeClient()
149 static void resetClient(client c) { in resetClient()
157 static void randomizeClientKey(client c) { in randomizeClientKey()
173 static void clientDone(client c) { in clientDone()
190 client c = privdata; in readHandler()
259 client c = privdata; in writeHandler()
316 static client createClient(char *cmd, size_t len, client from) { in createClient()
462 client c; in benchmark()
[all …]
H A Dgeo.c93 int extractLongLatOrReply(client *c, robj **argv, double *xy) { in extractLongLatOrReply()
127 double extractUnitOrReply(client *c, robj *unit) { in extractUnitOrReply()
152 double extractDistanceOrReply(client *c, robj **argv, in extractDistanceOrReply()
179 void addReplyDoubleDistance(client *c, double d) { in addReplyDoubleDistance()
384 void geoaddCommand(client *c) { in geoaddCommand()
440 void georadiusGeneric(client *c, int type) { in georadiusGeneric()
651 void georadiusCommand(client *c) { in georadiusCommand()
656 void georadiusByMemberCommand(client *c) { in georadiusByMemberCommand()
664 void geohashCommand(client *c) { in geohashCommand()
719 void geoposCommand(client *c) { in geoposCommand()
[all …]
/redis-3.2.3/tests/unit/
H A Dintrospection.tcl3 r client list
24 r client getname
28 r client list
32 catch {r client setname "foo bar"} e
37 assert_equal [r client setname myname] {OK}
38 r client list
42 assert_equal [r client setname someothername] {OK}
43 r client list
48 $rd client setname foobar
50 assert_match {*foobar*} [r client list]
[all …]
H A Ddump.tcl59 set first [srv 0 client]
78 set first [srv 0 client]
97 set first [srv 0 client]
116 set first [srv 0 client]
138 set first [srv 0 client]
158 set first [srv 0 client]
183 set first [srv 0 client]
203 set first [srv 0 client]
222 set first [srv 0 client]
250 set first [srv 0 client]
[all …]
H A Dpubsub.tcl2 proc __consume_subscribe_messages {client type channels} {
7 set msg [$client read]
30 proc subscribe {client channels} {
31 $client subscribe {*}$channels
32 __consume_subscribe_messages $client subscribe $channels
35 proc unsubscribe {client {channels {}}} {
36 $client unsubscribe {*}$channels
40 proc psubscribe {client channels} {
41 $client psubscribe {*}$channels
45 proc punsubscribe {client {channels {}}} {
[all …]
H A Dobuf-limits.tcl13 set clients [split [r client list] "\r\n"]
35 set clients [split [r client list] "\r\n"]
61 set clients [split [r client list] "\r\n"]
/redis-3.2.3/tests/integration/
H A Daof.tcl58 assert {[$client get foo] eq "5"}
62 $client incr foo
75 assert {[$client get foo] eq "6"}
175 [catch {$client ping} e] == 0
180 assert_equal "" [$client get bar]
199 [catch {$client ping} e] == 0
203 assert_equal 1 [$client scard set]
223 [catch {$client ping} e] == 0
227 assert_equal 1 [$client scard set]
246 [catch {$client ping} e] == 0
[all …]
H A Daof-race.tcl16 set client [redis [srv host] [srv port]]
21 $client bgrewriteaof
27 assert_equal 20000 [$client get foo]
32 set client [redis [srv host] [srv port]]
33 assert_equal 20000 [$client get foo]
H A Dreplication-4.tcl13 set master [srv -1 client]
16 set slave [srv 0 client]
60 set master [srv -1 client]
63 set slave [srv 0 client]
102 set master [srv -1 client]
105 set slave [srv 0 client]
H A Dreplication.tcl9 set slave [srv 0 client]
14 set master [srv 0 client]
55 set A [srv 0 client]
59 set B [srv 0 client]
188 set master [srv 0 client]
199 lappend slaves [srv 0 client]
201 lappend slaves [srv 0 client]
203 lappend slaves [srv 0 client]
H A Dreplication-psync.tcl24 set master [srv -1 client]
27 set slave [srv 0 client]
69 $slave client kill $master_host:$master_port
73 $slave client kill $master_host:$master_port
/redis-3.2.3/utils/
H A Dgenerate-command-help.rb56 client = Net::HTTP.new url.host, url.port
57 client.use_ssl = true
58 response = client.get url.path
/redis-3.2.3/tests/
H A Dtest_helper.tcl131 set client [redis $host $port]
132 dict set srv "client" $client
136 $client select 9
151 set client [redis [srv $level "host"] [srv $level "port"] 1]
154 $client select 9
155 $client read
156 return $client
194 --client $port --port $start_port &]
444 } elseif {$opt eq {--client}} {
/redis-3.2.3/
H A Dredis.conf1027 client-output-buffer-limit normal 0 0 0
1028 client-output-buffer-limit slave 256mb 64mb 60
1029 client-output-buffer-limit pubsub 32mb 8mb 60

123