Home
last modified time | relevance | path

Searched refs:state (Results 1 – 25 of 27) sorted by relevance

12

/redis-3.2.3/src/
H A Dae_evport.c78 if (!state) return -1; in aeApiCreate()
80 state->portfd = port_create(); in aeApiCreate()
81 if (state->portfd == -1) { in aeApiCreate()
82 zfree(state); in aeApiCreate()
86 state->npending = 0; in aeApiCreate()
93 eventLoop->apidata = state; in aeApiCreate()
105 close(state->portfd); in aeApiFree()
106 zfree(state); in aeApiFree()
261 state->pending_fds[i], state->pending_masks[i]) != 0) { in aeApiPoll()
270 state->npending = 0; in aeApiPoll()
[all …]
H A Dae_kqueue.c44 if (!state) return -1; in aeApiCreate()
46 if (!state->events) { in aeApiCreate()
47 zfree(state); in aeApiCreate()
50 state->kqfd = kqueue(); in aeApiCreate()
53 zfree(state); in aeApiCreate()
63 state->events = zrealloc(state->events, sizeof(struct kevent)*setsize); in aeApiResize()
70 close(state->kqfd); in aeApiFree()
71 zfree(state->events); in aeApiFree()
72 zfree(state); in aeApiFree()
112 retval = kevent(state->kqfd, NULL, 0, state->events, eventLoop->setsize, in aeApiPoll()
[all …]
H A Dae_epoll.c42 if (!state) return -1; in aeApiCreate()
44 if (!state->events) { in aeApiCreate()
45 zfree(state); in aeApiCreate()
49 if (state->epfd == -1) { in aeApiCreate()
50 zfree(state->events); in aeApiCreate()
51 zfree(state); in aeApiCreate()
61 state->events = zrealloc(state->events, sizeof(struct epoll_event)*setsize); in aeApiResize()
68 close(state->epfd); in aeApiFree()
69 zfree(state->events); in aeApiFree()
70 zfree(state); in aeApiFree()
[all …]
H A Dae_select.c43 aeApiState *state = zmalloc(sizeof(aeApiState)); in aeApiCreate() local
45 if (!state) return -1; in aeApiCreate()
46 FD_ZERO(&state->rfds); in aeApiCreate()
47 FD_ZERO(&state->wfds); in aeApiCreate()
48 eventLoop->apidata = state; in aeApiCreate()
63 aeApiState *state = eventLoop->apidata; in aeApiAddEvent() local
71 aeApiState *state = eventLoop->apidata; in aeApiDelEvent() local
78 aeApiState *state = eventLoop->apidata; in aeApiPoll() local
81 memcpy(&state->_rfds,&state->rfds,sizeof(fd_set)); in aeApiPoll()
82 memcpy(&state->_wfds,&state->wfds,sizeof(fd_set)); in aeApiPoll()
[all …]
H A Dconfig.c1294 state->lines = zrealloc(state->lines, sizeof(char*) * (state->numlines+1));
1295 state->lines[state->numlines++] = line;
1326 struct rewriteConfigState *state = zmalloc(sizeof(*state)); local
1334 state->numlines = 0;
1335 state->lines = NULL;
1336 state->has_tail = 0;
1378 return state;
1422 if (!state->has_tail) {
1425 state->has_tail = 1;
1662 sdsfreesplitres(state->lines,state->numlines);
[all …]
H A Dsha1.c75 a = state[0]; in SHA1Transform()
76 b = state[1]; in SHA1Transform()
77 c = state[2]; in SHA1Transform()
78 d = state[3]; in SHA1Transform()
79 e = state[4]; in SHA1Transform()
102 state[0] += a; in SHA1Transform()
103 state[1] += b; in SHA1Transform()
104 state[2] += c; in SHA1Transform()
105 state[3] += d; in SHA1Transform()
106 state[4] += e; in SHA1Transform()
[all …]
H A Drio.c195 if (r->io.fdset.state[j] != 0) { in rioFdsetWrite()
219 r->io.fdset.state[j] = errno; in rioFdsetWrite()
220 if (r->io.fdset.state[j] == 0) r->io.fdset.state[j] = EIO; in rioFdsetWrite()
271 r->io.fdset.state = zmalloc(sizeof(int)*numfds); in rioInitWithFdset()
273 for (j = 0; j < numfds; j++) r->io.fdset.state[j] = 0; in rioInitWithFdset()
282 zfree(r->io.fdset.state); in rioFreeFdset()
H A Dsha1.h11 uint32_t state[5]; member
16 void SHA1Transform(uint32_t state[5], const unsigned char buffer[64]);
H A Dcluster.h111 int state; /* CLUSTER_OK, CLUSTER_FAIL, ... */ member
243 unsigned char state; /* Cluster state from the POV of the sender */ member
H A Dsentinel.c923 state, from->ip, fromport, to->ip, toport, NULL); in sentinelCallClientReconfScript()
1705 rewriteConfigRewriteLine(state,"sentinel",line,1); in rewriteConfigSentinelOption()
1719 rewriteConfigRewriteLine(state,"sentinel",line,1); in rewriteConfigSentinelOption()
1726 rewriteConfigRewriteLine(state,"sentinel",line,1); in rewriteConfigSentinelOption()
1773 rewriteConfigRewriteLine(state,"sentinel",line,1); in rewriteConfigSentinelOption()
1779 rewriteConfigRewriteLine(state,"sentinel",line,1); in rewriteConfigSentinelOption()
1819 rewriteConfigRewriteLine(state,"sentinel",line,1); in rewriteConfigSentinelOption()
1825 rewriteConfigRewriteLine(state,"sentinel",line,1); in rewriteConfigSentinelOption()
1832 rewriteConfigRewriteLine(state,"sentinel",line,1); in rewriteConfigSentinelOption()
2622 const char *sentinelFailoverStateStr(int state) { in sentinelFailoverStateStr() argument
[all …]
H A Drio.h79 int *state; /* Error state of each fd. 0 (if ok) or errno. */ member
H A Dcluster.c404 server.cluster->state = CLUSTER_FAIL; in clusterInit()
2143 hdr->state = server.cluster->state; in clusterBuildMessageHdr()
2905 if (server.cluster->state != CLUSTER_OK) return; in clusterHandleSlaveMigration()
3298 if (update_state || server.cluster->state == CLUSTER_FAIL) in clusterCron()
3486 server.cluster->state == CLUSTER_FAIL && in clusterUpdateState()
3540 if (new_state != server.cluster->state) { in clusterUpdateState()
3562 server.cluster->state = new_state; in clusterUpdateState()
4116 , statestr[server.cluster->state], in clusterCommand()
5084 if (server.cluster->state != CLUSTER_OK) { in getNodeByQuery()
5185 if (server.cluster->state == CLUSTER_FAIL) { in clusterRedirectBlockedClientIfNeeded()
H A Dserver.c3195 char *state = NULL; in genRedisInfoString() local
3208 state = "wait_bgsave"; in genRedisInfoString()
3211 state = "send_bulk"; in genRedisInfoString()
3214 state = "online"; in genRedisInfoString()
3217 if (state == NULL) continue; in genRedisInfoString()
3224 slaveid,slaveip,slave->slave_listening_port,state, in genRedisInfoString()
H A Drdb.c1672 *ids++ = slave_sockets.io.fdset.state[j]; in rdbSaveToSlavesSockets()
/redis-3.2.3/deps/jemalloc/include/jemalloc/internal/
H A Dprng.h28 #define prng32(r, lg_range, state, a, c) do { \ argument
32 r = (state * (a)) + (c); \
33 state = r; \
38 #define prng64(r, lg_range, state, a, c) do { \ argument
42 r = (state * (a)) + (c); \
43 state = r; \
H A Dtsd.h561 tsd_state_t state; member
616 if (unlikely(tsd->state != tsd_state_nominal)) { in tsd_fetch()
617 if (tsd->state == tsd_state_uninitialized) { in tsd_fetch()
618 tsd->state = tsd_state_nominal; in tsd_fetch()
621 } else if (tsd->state == tsd_state_purgatory) { in tsd_fetch()
622 tsd->state = tsd_state_reincarnated; in tsd_fetch()
625 assert(tsd->state == tsd_state_reincarnated); in tsd_fetch()
635 return (tsd->state == tsd_state_nominal); in tsd_nominal()
657 assert(tsd->state == tsd_state_nominal); \
H A Dprof.h130 prof_tctx_state_t state; member
H A Djemalloc_internal_defs.h.in135 * when the cache is in the steady state.
/redis-3.2.3/deps/jemalloc/src/
H A Dtsd.c75 switch (tsd->state) { in tsd_cleanup()
84 tsd->state = tsd_state_purgatory; in tsd_cleanup()
101 tsd->state = tsd_state_purgatory; in tsd_cleanup()
H A Dprof.c655 switch (tctx->state) { in prof_tctx_destroy()
685 tctx->state = prof_tctx_state_purgatory; in prof_tctx_destroy()
806 ret.p->state = prof_tctx_state_initializing; in prof_lookup()
817 ret.p->state = prof_tctx_state_nominal; in prof_lookup()
1041 switch (tctx->state) { in prof_tctx_merge_tdata()
1046 tctx->state = prof_tctx_state_dumping; in prof_tctx_merge_tdata()
1084 switch (tctx->state) { in prof_tctx_merge_iter()
1105 switch (tctx->state) { in prof_tctx_dump_iter()
1131 switch (tctx->state) { in prof_tctx_finish_iter()
1136 tctx->state = prof_tctx_state_nominal; in prof_tctx_finish_iter()
/redis-3.2.3/tests/cluster/
H A Dcluster.tcl66 proc assert_cluster_state {state} { argument
70 [CI $id cluster_state] eq $state
/redis-3.2.3/tests/integration/
H A Dreplication.tcl177 test {ROLE in slave reports slave in connected state} {
/redis-3.2.3/deps/hiredis/
H A DREADME.md27 upgrading is that hiredis >= 0.9.0 uses a `redisContext*` to keep state, in contrast to
41 context is where Hiredis holds state for a connection. The `redisContext`
43 an error state. The field `errstr` will contain a string with a description of
332 buffer with unparsed data and state for the protocol parser.
/redis-3.2.3/tests/unit/
H A Dmulti.tcl77 test {If EXEC aborts, the client MULTI state is cleared} {
/redis-3.2.3/
H A D00-RELEASENOTES59 3. Redis Sentinel now checks slaves INFO state more often when disconnected.
140 Sentinel: check Slave INFO state more often when disconnected.
160 redis-cli: check SELECT reply type just in state updated.
1520 | Remove Lua state reference from buffers in lua_cmsgpack.

12