| /redis-3.2.3/src/ |
| H A D | ae_epoll.c | 36 struct epoll_event *events; member
44 if (!state->events) { in aeApiCreate()
50 zfree(state->events); in aeApiCreate()
61 state->events = zrealloc(state->events, sizeof(struct epoll_event)*setsize); in aeApiResize()
69 zfree(state->events); in aeApiFree()
81 ee.events = 0; in aeApiAddEvent()
83 if (mask & AE_READABLE) ee.events |= EPOLLIN; in aeApiAddEvent()
84 if (mask & AE_WRITABLE) ee.events |= EPOLLOUT; in aeApiAddEvent()
95 ee.events = 0; in aeApiDelEvent()
96 if (mask & AE_READABLE) ee.events |= EPOLLIN; in aeApiDelEvent()
[all …]
|
| H A D | ae_kqueue.c | 38 struct kevent *events; member
45 state->events = zmalloc(sizeof(struct kevent)*eventLoop->setsize); in aeApiCreate()
46 if (!state->events) { in aeApiCreate()
52 zfree(state->events); in aeApiCreate()
63 state->events = zrealloc(state->events, sizeof(struct kevent)*setsize); in aeApiResize()
71 zfree(state->events); in aeApiFree()
112 retval = kevent(state->kqfd, NULL, 0, state->events, eventLoop->setsize, in aeApiPoll()
115 retval = kevent(state->kqfd, NULL, 0, state->events, eventLoop->setsize, in aeApiPoll()
125 struct kevent *e = state->events+j; in aeApiPoll()
|
| H A D | ae.c | 68 eventLoop->events = zmalloc(sizeof(aeFileEvent)*setsize); in aeCreateEventLoop()
82 eventLoop->events[i].mask = AE_NONE; in aeCreateEventLoop()
87 zfree(eventLoop->events); in aeCreateEventLoop()
113 eventLoop->events = zrealloc(eventLoop->events,sizeof(aeFileEvent)*setsize); in aeResizeSetSize()
120 eventLoop->events[i].mask = AE_NONE; in aeResizeSetSize()
126 zfree(eventLoop->events); in aeDeleteEventLoop()
142 aeFileEvent *fe = &eventLoop->events[fd]; in aeCreateFileEvent()
158 aeFileEvent *fe = &eventLoop->events[fd]; in aeDeleteFileEvent()
175 aeFileEvent *fe = &eventLoop->events[fd]; in aeGetFileEvents()
436 if (mask & AE_READABLE) pfd.events |= POLLIN; in aeWait()
[all …]
|
| H A D | ae_evport.c | 124 int events = 0; in aeApiAssociate() local
128 events |= POLLIN; in aeApiAssociate()
130 events |= POLLOUT; in aeApiAssociate()
133 fprintf(stderr, "%s: port_associate(%d, 0x%x) = ", where, fd, events); in aeApiAssociate()
135 rv = port_associate(portfd, PORT_SOURCE_FD, fd, events, in aeApiAssociate()
164 fullmask = mask | eventLoop->events[fd].mask; in aeApiAddEvent()
217 fullmask = eventLoop->events[fd].mask; in aeApiDelEvent()
|
| H A D | networking.c | 1421 char flags[16], events[3], *p; in catClientInfoString() local
1444 p = events; in catClientInfoString()
1466 events, in catClientInfoString()
1839 int events; in flushSlavesOutputBuffers() local
1847 events = aeGetFileEvents(server.el,slave->fd); in flushSlavesOutputBuffers()
1848 if (events & AE_WRITABLE && in flushSlavesOutputBuffers()
1924 int events = 0; in processEventsWhileBlocked() local
1925 events += aeProcessEvents(server.el, AE_FILE_EVENTS|AE_DONT_WAIT); in processEventsWhileBlocked()
1926 events += handleClientsWithPendingWrites(); in processEventsWhileBlocked()
1927 if (!events) break; in processEventsWhileBlocked()
[all …]
|
| H A D | ae.h | 95 aeFileEvent *events; /* Registered events */ member
|
| H A D | ae_select.c | 89 aeFileEvent *fe = &eventLoop->events[j]; in aeApiPoll()
|
| /redis-3.2.3/deps/hiredis/adapters/ |
| H A D | libuv.h | 11 int events; member
23 if (events & UV_READABLE) { in redisLibuvPoll()
26 if (events & UV_WRITABLE) { in redisLibuvPoll()
35 p->events |= UV_READABLE; in redisLibuvAddRead()
37 uv_poll_start(&p->handle, p->events, redisLibuvPoll); in redisLibuvAddRead()
44 p->events &= ~UV_READABLE; in redisLibuvDelRead()
46 if (p->events) { in redisLibuvDelRead()
57 p->events |= UV_WRITABLE; in redisLibuvAddWrite()
59 uv_poll_start(&p->handle, p->events, redisLibuvPoll); in redisLibuvAddWrite()
66 p->events &= ~UV_WRITABLE; in redisLibuvDelWrite()
[all …]
|
| /redis-3.2.3/deps/lua/src/ |
| H A D | ltm.c | 50 const TValue *luaT_gettm (Table *events, TMS event, TString *ename) { in luaT_gettm() argument
51 const TValue *tm = luaH_getstr(events, ename); in luaT_gettm()
54 events->flags |= cast_byte(1u<<event); /* cache this fact */ in luaT_gettm()
|
| H A D | ltm.h | 49 LUAI_FUNC const TValue *luaT_gettm (Table *events, TMS event, TString *ename);
|
| /redis-3.2.3/tests/unit/ |
| H A D | latency-monitor.tcl | 6 test {Test latency events logging} {
46 test {LATENCY RESET is able to reset events} {
|
| /redis-3.2.3/tests/assets/ |
| H A D | default.conf | 3 notify-keyspace-events KEA
|
| /redis-3.2.3/ |
| H A D | redis.conf | 906 notify-keyspace-events ""
|
| /redis-3.2.3/deps/hiredis/ |
| H A D | net.c | 184 wfd[0].events = POLLOUT; in redisContextWaitReady()
|
| /redis-3.2.3/deps/jemalloc/ |
| H A D | ChangeLog | 72 allocation events against concurrent prof_active changes.
|