Home
last modified time | relevance | path

Searched refs:flags (Results 1 – 25 of 55) sorted by relevance

123

/redis-3.2.3/src/
H A Dnotify.c42 int c, flags = 0; in keyspaceEventsStringToFlags() local
46 case 'A': flags |= NOTIFY_ALL; break; in keyspaceEventsStringToFlags()
47 case 'g': flags |= NOTIFY_GENERIC; break; in keyspaceEventsStringToFlags()
48 case '$': flags |= NOTIFY_STRING; break; in keyspaceEventsStringToFlags()
49 case 'l': flags |= NOTIFY_LIST; break; in keyspaceEventsStringToFlags()
50 case 's': flags |= NOTIFY_SET; break; in keyspaceEventsStringToFlags()
51 case 'h': flags |= NOTIFY_HASH; break; in keyspaceEventsStringToFlags()
52 case 'z': flags |= NOTIFY_ZSET; break; in keyspaceEventsStringToFlags()
60 return flags; in keyspaceEventsStringToFlags()
67 sds keyspaceEventsFlagsToString(int flags) { in keyspaceEventsFlagsToString() argument
[all …]
H A Dsds.h87 unsigned char flags = s[-1]; in sdslen() local
88 switch(flags&SDS_TYPE_MASK) { in sdslen()
104 unsigned char flags = s[-1]; in sdsavail() local
105 switch(flags&SDS_TYPE_MASK) { in sdsavail()
130 unsigned char flags = s[-1]; in sdssetlen() local
131 switch(flags&SDS_TYPE_MASK) { in sdssetlen()
154 unsigned char flags = s[-1]; in sdsinclen() local
155 switch(flags&SDS_TYPE_MASK) { in sdsinclen()
180 unsigned char flags = s[-1]; in sdsalloc() local
181 switch(flags&SDS_TYPE_MASK) { in sdsalloc()
[all …]
H A Dsentinel.c1183 ri->flags = flags; in createSentinelRedisInstance()
1367 ri->flags |= flags; in sentinelAddFlagsToDictOfRedisInstances()
1381 ri->flags &= ~flags; in sentinelDelFlagsToDictOfRedisInstances()
2660 if (ri->flags & SRI_S_DOWN) flags = sdscat(flags,"s_down,"); in addReplySentinelRedisInstance()
2661 if (ri->flags & SRI_O_DOWN) flags = sdscat(flags,"o_down,"); in addReplySentinelRedisInstance()
2662 if (ri->flags & SRI_MASTER) flags = sdscat(flags,"master,"); in addReplySentinelRedisInstance()
2663 if (ri->flags & SRI_SLAVE) flags = sdscat(flags,"slave,"); in addReplySentinelRedisInstance()
2664 if (ri->flags & SRI_SENTINEL) flags = sdscat(flags,"sentinel,"); in addReplySentinelRedisInstance()
2666 if (ri->flags & SRI_MASTER_DOWN) flags = sdscat(flags,"master_down,"); in addReplySentinelRedisInstance()
2669 if (ri->flags & SRI_PROMOTED) flags = sdscat(flags,"promoted,"); in addReplySentinelRedisInstance()
[all …]
H A Dblocked.c101 c->flags |= CLIENT_BLOCKED; in blockClient()
118 c->flags &= ~CLIENT_UNBLOCKED; in processUnblockedClients()
124 if (!(c->flags & CLIENT_BLOCKED)) { in processUnblockedClients()
144 c->flags &= ~CLIENT_BLOCKED; in unblockClient()
149 if (!(c->flags & CLIENT_UNBLOCKED)) { in unblockClient()
150 c->flags |= CLIENT_UNBLOCKED; in unblockClient()
182 if (c->flags & CLIENT_BLOCKED) { in disconnectAllBlockedClients()
187 c->flags |= CLIENT_CLOSE_AFTER_REPLY; in disconnectAllBlockedClients()
H A Dnetworking.c99 c->flags = 0; in createClient()
165 if ((c->flags & CLIENT_MASTER) && in prepareClientToWrite()
683 c->flags |= flags; in acceptCommonHandler()
807 if ((c->flags & CLIENT_SLAVE) && !(c->flags & CLIENT_MONITOR)) { in freeClient()
841 if (c->flags & CLIENT_SLAVE) { in freeClient()
884 if (c->flags & CLIENT_CLOSE_ASAP || c->flags & CLIENT_LUA) return; in freeClientAsync()
885 c->flags |= CLIENT_CLOSE_ASAP; in freeClientAsync()
1424 p = flags; in catClientInfoString()
1440 if (p == flags) *p++ = 'N'; in catClientInfoString()
1456 flags, in catClientInfoString()
[all …]
H A Dcluster.h60 #define nodeIsMaster(n) ((n)->flags & CLUSTER_NODE_MASTER)
61 #define nodeIsSlave(n) ((n)->flags & CLUSTER_NODE_SLAVE)
62 #define nodeInHandshake(n) ((n)->flags & CLUSTER_NODE_HANDSHAKE)
63 #define nodeHasAddr(n) (!((n)->flags & CLUSTER_NODE_NOADDR))
64 #define nodeWithoutAddr(n) ((n)->flags & CLUSTER_NODE_NOADDR)
65 #define nodeTimedOut(n) ((n)->flags & CLUSTER_NODE_PFAIL)
66 #define nodeFailed(n) ((n)->flags & CLUSTER_NODE_FAIL)
85 int flags; /* CLUSTER_NODE_... */ member
175 uint16_t flags; /* node->flags copy */ member
242 uint16_t flags; /* Sender node flags */ member
H A Dmulti.c82 if (c->flags & CLIENT_MULTI) in flagTransaction()
83 c->flags |= CLIENT_DIRTY_EXEC; in flagTransaction()
87 if (c->flags & CLIENT_MULTI) { in multiCommand()
91 c->flags |= CLIENT_MULTI; in multiCommand()
96 if (!(c->flags & CLIENT_MULTI)) { in discardCommand()
121 if (!(c->flags & CLIENT_MULTI)) { in execCommand()
132 if (c->flags & (CLIENT_DIRTY_CAS|CLIENT_DIRTY_EXEC)) { in execCommand()
276 c->flags |= CLIENT_DIRTY_CAS; in touchWatchedKey()
301 c->flags |= CLIENT_DIRTY_CAS; in touchWatchedKeysOnFlush()
310 if (c->flags & CLIENT_MULTI) { in watchCommand()
[all …]
H A Dserver.c2122 int flags) in propagate() argument
2126 if (flags & PROPAGATE_REPL) in propagate()
2162 if (flags & PROPAGATE_REPL) c->flags |= CLIENT_FORCE_REPL; in forceCommandPropagation()
2163 if (flags & PROPAGATE_AOF) c->flags |= CLIENT_FORCE_AOF; in forceCommandPropagation()
2220 void call(client *c, int flags) { in call() argument
2269 if (flags & CMD_CALL_STATS) { in call()
2308 c->flags |= client_old_flags & in call()
2383 !(c->flags & CLIENT_LUA && in processCommand()
2461 c->cmd->flags & CMD_WRITE) in processCommand()
2513 if (c->flags & CLIENT_MULTI && in processCommand()
[all …]
H A Danet.c62 int flags; in anetSetBlock() local
67 if ((flags = fcntl(fd, F_GETFL)) == -1) { in anetSetBlock()
73 flags |= O_NONBLOCK; in anetSetBlock()
75 flags &= ~O_NONBLOCK; in anetSetBlock()
77 if (fcntl(fd, F_SETFL, flags) == -1) { in anetSetBlock()
204 int flags) in anetGenericResolve() argument
210 if (flags & ANET_IP_ONLY) hints.ai_flags = AI_NUMERICHOST; in anetGenericResolve()
269 char *source_addr, int flags) in anetTcpGenericConnect() argument
372 int anetUnixGenericConnect(char *err, char *path, int flags) in anetUnixGenericConnect() argument
382 if (flags & ANET_CONNECT_NONBLOCK) { in anetUnixGenericConnect()
[all …]
H A Dt_string.c80 if ((flags & OBJ_SET_NX && lookupKeyWrite(c->db,key) != NULL) || in setGenericCommand()
81 (flags & OBJ_SET_XX && lookupKeyWrite(c->db,key) == NULL)) in setGenericCommand()
100 int flags = OBJ_SET_NO_FLAGS; in setCommand() local
108 !(flags & OBJ_SET_XX)) in setCommand()
110 flags |= OBJ_SET_NX; in setCommand()
113 !(flags & OBJ_SET_NX)) in setCommand()
115 flags |= OBJ_SET_XX; in setCommand()
118 !(flags & OBJ_SET_PX) && next) in setCommand()
120 flags |= OBJ_SET_EX; in setCommand()
126 !(flags & OBJ_SET_EX) && next) in setCommand()
[all …]
H A Dsparkline.c97 sds sparklineRenderRange(sds output, struct sequence *seq, int rows, int offset, int len, int flags… in sparklineRenderRange() argument
104 int opt_fill = flags & SPARKLINE_FILL; in sparklineRenderRange()
105 int opt_log = flags & SPARKLINE_LOG_SCALE; in sparklineRenderRange()
165 sds sparklineRender(sds output, struct sequence *seq, int columns, int rows, int flags) { in sparklineRender() argument
172 output = sparklineRenderRange(output, seq, rows, j, sublen, flags); in sparklineRender()
H A Dcluster.c70 void clusterDoBeforeSleep(int flags);
662 node->flags = flags; in createClusterNode()
1299 uint16_t flags = ntohs(g->flags); in clusterProcessGossipSection() local
1559 uint16_t flags = ntohs(hdr->flags); in clusterProcessPacket() local
1716 link->node->flags |= flags&(CLUSTER_NODE_MASTER|CLUSTER_NODE_SLAVE); in clusterProcessPacket()
2142 hdr->flags = htons(myself->flags); in clusterBuildMessageHdr()
2277 gossip->flags = htons(this->flags); in clusterSendPing()
3191 if (node->flags & in clusterCron()
3678 if (flags == 0) { in representClusterNodeFlags()
4920 c->flags |= CLIENT_ASKING; in askingCommand()
[all …]
H A Dae.c349 int aeProcessEvents(aeEventLoop *eventLoop, int flags) in aeProcessEvents() argument
354 if (!(flags & AE_TIME_EVENTS) && !(flags & AE_FILE_EVENTS)) return 0; in aeProcessEvents()
361 ((flags & AE_TIME_EVENTS) && !(flags & AE_DONT_WAIT))) { in aeProcessEvents()
366 if (flags & AE_TIME_EVENTS && !(flags & AE_DONT_WAIT)) in aeProcessEvents()
391 if (flags & AE_DONT_WAIT) { in aeProcessEvents()
422 if (flags & AE_TIME_EVENTS) in aeProcessEvents()
H A Dsparkline.h53 sds sparklineRenderRange(sds output, struct sequence *seq, int rows, int offset, int len, int flags…
54 sds sparklineRender(sds output, struct sequence *seq, int columns, int rows, int flags);
H A Dreplication.c278 if (c->flags & CLIENT_LUA) { in replicationFeedMonitors()
280 } else if (c->flags & CLIENT_UNIX_SOCKET) { in replicationFeedMonitors()
400 if (!(slave->flags & CLIENT_PRE_PSYNC)) { in replicationSetupSlaveForFullResync()
458 c->flags |= CLIENT_SLAVE; in masterTryPartialResynchronization()
533 slave->flags &= ~CLIENT_SLAVE; in startBgsaveForReplication()
566 if (c->flags & CLIENT_SLAVE) return; in syncCommand()
613 c->flags |= CLIENT_PRE_PSYNC; in syncCommand()
625 c->flags |= CLIENT_SLAVE; in syncCommand()
970 server.master->flags |= CLIENT_MASTER; in replicationCreateMasterClient()
1185 if (flags & SYNC_CMD_WRITE) { in sendSynchronousCommand()
[all …]
H A Dscripting.c469 if (cmd->flags & CMD_NOSCRIPT) { in luaRedisGenericCommand()
477 if (cmd->flags & CMD_WRITE) { in luaRedisGenericCommand()
502 (cmd->flags & CMD_DENYOOM)) in luaRedisGenericCommand()
521 c->flags |= server.lua_caller->flags & (CLIENT_READONLY|CLIENT_ASKING); in luaRedisGenericCommand()
750 int flags; in luaRedisSetReplCommand() local
760 flags = lua_tonumber(lua,-1); in luaRedisSetReplCommand()
765 server.lua_repl = flags; in luaRedisSetReplCommand()
1401 if (!(c->flags & CLIENT_LUA_DEBUG)) in evalCommand()
1416 if (!(c->flags & CLIENT_LUA_DEBUG)) in evalShaCommand()
1516 c->flags |= CLIENT_LUA_DEBUG; in ldbEnable()
[all …]
/redis-3.2.3/deps/hiredis/
H A Dsds.h87 unsigned char flags = s[-1]; in sdslen() local
88 switch(flags&SDS_TYPE_MASK) { in sdslen()
104 unsigned char flags = s[-1]; in sdsavail() local
105 switch(flags&SDS_TYPE_MASK) { in sdsavail()
130 unsigned char flags = s[-1]; in sdssetlen() local
131 switch(flags&SDS_TYPE_MASK) { in sdssetlen()
154 unsigned char flags = s[-1]; in sdsinclen() local
155 switch(flags&SDS_TYPE_MASK) { in sdsinclen()
180 unsigned char flags = s[-1]; in sdsalloc() local
181 switch(flags&SDS_TYPE_MASK) { in sdsalloc()
[all …]
H A Dasync.c117 c->flags &= ~REDIS_CONNECTED; in redisAsyncInitialize()
257 c->flags |= REDIS_IN_CALLBACK; in __redisRunCallback()
259 c->flags &= ~REDIS_IN_CALLBACK; in __redisRunCallback()
297 if (c->flags & REDIS_FREEING) { in __redisAsyncFree()
314 c->flags |= REDIS_FREEING; in redisAsyncFree()
315 if (!(c->flags & REDIS_IN_CALLBACK)) in redisAsyncFree()
348 c->flags |= REDIS_DISCONNECTING; in redisAsyncDisconnect()
451 assert((c->flags & REDIS_SUBSCRIBED || c->flags & REDIS_MONITORING)); in redisProcessCallbacks()
496 c->flags |= REDIS_CONNECTED; in __redisAsyncHandleConnect()
596 c->flags |= REDIS_SUBSCRIBED; in __redisAsyncCommand()
[all …]
H A Dnet.c100 int flags; in redisSetBlocking() local
105 if ((flags = fcntl(c->fd, F_GETFL)) == -1) { in redisSetBlocking()
112 flags &= ~O_NONBLOCK; in redisSetBlocking()
114 flags |= O_NONBLOCK; in redisSetBlocking()
116 if (fcntl(c->fd, F_SETFL, flags) == -1) { in redisSetBlocking()
262 int blocking = (c->flags & REDIS_BLOCK); in _redisContextConnectTcp()
327 c->flags |= REDIS_CONNECTED; in _redisContextConnectTcp()
357 int blocking = (c->flags & REDIS_BLOCK); in redisContextConnectUnix()
380 c->flags |= REDIS_CONNECTED; in redisContextConnectUnix()
H A Dhiredis.c1030 c->flags |= REDIS_BLOCK; in redisConnect()
1042 c->flags |= REDIS_BLOCK; in redisConnectWithTimeout()
1054 c->flags &= ~REDIS_BLOCK; in redisConnectNonBlock()
1062 c->flags &= ~REDIS_BLOCK; in redisConnectBindNonBlock()
1074 c->flags |= REDIS_BLOCK; in redisConnectUnix()
1086 c->flags |= REDIS_BLOCK; in redisConnectUnixWithTimeout()
1098 c->flags &= ~REDIS_BLOCK; in redisConnectUnixNonBlock()
1111 c->flags |= REDIS_BLOCK | REDIS_CONNECTED; in redisConnectFd()
1117 if (c->flags & REDIS_BLOCK) in redisSetTimeout()
1219 if (aux == NULL && c->flags & REDIS_BLOCK) { in redisGetReply()
[all …]
/redis-3.2.3/deps/jemalloc/include/jemalloc/
H A Djemalloc_protos.h.in29 void JEMALLOC_NOTHROW *@je_@mallocx(size_t size, int flags)
33 int flags) JEMALLOC_ALLOC_SIZE(2);
35 size_t extra, int flags);
37 int flags) JEMALLOC_ATTR(pure);
38 JEMALLOC_EXPORT void JEMALLOC_NOTHROW @je_@dallocx(void *ptr, int flags);
40 int flags);
41 JEMALLOC_EXPORT size_t JEMALLOC_NOTHROW @je_@nallocx(size_t size, int flags)
/redis-3.2.3/deps/jemalloc/src/
H A Djemalloc.c1927 *zero = MALLOCX_ZERO_GET(flags); in imallocx_flags_decode_hard()
1950 if (likely(flags == 0)) { in imallocx_flags_decode()
2036 if (likely(flags == 0)) { in imallocx_no_prof()
2053 je_mallocx(size_t size, int flags) in JEMALLOC_ATTR()
2163 bool zero = flags & MALLOCX_ZERO; in je_rallocx()
2297 bool zero = flags & MALLOCX_ZERO; in je_xallocx()
2360 je_dallocx(void *ptr, int flags) in je_dallocx() argument
2382 inallocx(size_t size, int flags) in inallocx() argument
2403 usize = inallocx(size, flags); in je_sdallocx()
2421 je_nallocx(size_t size, int flags) in JEMALLOC_ATTR()
[all …]
/redis-3.2.3/deps/jemalloc/include/jemalloc/internal/
H A Darena.h536 size_t size, size_t flags);
540 size_t flags);
542 size_t size, size_t flags);
796 size_t flags) in arena_mapbits_unallocated_set() argument
801 assert((flags & CHUNK_MAP_FLAGS_MASK) == flags); in arena_mapbits_unallocated_set()
802 assert((flags & CHUNK_MAP_DECOMMITTED) == 0 || (flags & in arena_mapbits_unallocated_set()
826 assert((flags & CHUNK_MAP_UNZEROED) == flags); in arena_mapbits_internal_set()
832 size_t flags) in arena_mapbits_large_set() argument
837 assert((flags & CHUNK_MAP_FLAGS_MASK) == flags); in arena_mapbits_large_set()
838 assert((flags & CHUNK_MAP_DECOMMITTED) == 0 || (flags & in arena_mapbits_large_set()
[all …]
/redis-3.2.3/deps/jemalloc/bin/
H A Djemalloc-config.in19 --cflags : Print compiler flags used to build jemalloc.
20 --cppflags : Print preprocessor flags used to build jemalloc.
21 --ldflags : Print library flags used to build jemalloc.
/redis-3.2.3/tests/sentinel/tests/
H A D07-down-conditions.tcl7 [dict get [S 4 sentinel master mymaster] flags] eq "master"
16 [dict get [S 4 sentinel master mymaster] flags]]

123