| /redis-3.2.3/src/ |
| H A D | ae_select.c | 65 if (mask & AE_READABLE) FD_SET(fd,&state->rfds); in aeApiAddEvent()
73 if (mask & AE_READABLE) FD_CLR(fd,&state->rfds); in aeApiDelEvent()
92 if (fe->mask & AE_READABLE && FD_ISSET(j,&state->_rfds)) in aeApiPoll()
93 mask |= AE_READABLE; in aeApiPoll()
|
| H A D | ae_epoll.c | 83 if (mask & AE_READABLE) ee.events |= EPOLLIN; in aeApiAddEvent()
96 if (mask & AE_READABLE) ee.events |= EPOLLIN; in aeApiDelEvent()
122 if (e->events & EPOLLIN) mask |= AE_READABLE; in aeApiPoll()
|
| H A D | ae_kqueue.c | 79 if (mask & AE_READABLE) { in aeApiAddEvent()
94 if (mask & AE_READABLE) { in aeApiDelEvent()
127 if (e->filter == EVFILT_READ) mask |= AE_READABLE; in aeApiPoll()
|
| H A D | ae.c | 147 if (mask & AE_READABLE) fe->rfileProc = proc; in aeCreateFileEvent()
410 if (fe->mask & mask & AE_READABLE) { in aeProcessEvents()
436 if (mask & AE_READABLE) pfd.events |= POLLIN; in aeWait()
440 if (pfd.revents & POLLIN) retmask |= AE_READABLE; in aeWait()
|
| H A D | ae_evport.c | 127 if (mask & AE_READABLE) in aeApiAssociate()
300 mask |= AE_READABLE; in aeApiPoll()
|
| H A D | syncio.c | 110 aeWait(fd,AE_READABLE,wait); in syncRead()
|
| H A D | ae.h | 42 #define AE_READABLE 1 macro
|
| H A D | replication.c | 1135 aeDeleteFileEvent(server.el,server.repl_transfer_s,AE_READABLE); in readSyncBulkPayload()
1309 aeDeleteFileEvent(server.el,fd,AE_READABLE); in slaveTryPartialResynchronization()
1324 aeDeleteFileEvent(server.el,fd,AE_READABLE); in slaveTryPartialResynchronization()
1623 if (aeCreateFileEvent(server.el,fd, AE_READABLE,readSyncBulkPayload,NULL) in syncWithMaster()
1642 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in syncWithMaster()
1665 if (aeCreateFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE,syncWithMaster,NULL) == in connectWithMaster()
1686 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in undoConnectWithMaster()
1959 if (aeCreateFileEvent(server.el, newfd, AE_READABLE, in replicationResurrectCachedMaster()
|
| H A D | redis-benchmark.c | 128 aeDeleteFileEvent(config.el,c->context->fd,AE_READABLE); in freeClient()
151 aeDeleteFileEvent(config.el,c->context->fd,AE_READABLE); in resetClient()
290 aeCreateFileEvent(config.el,c->context->fd,AE_READABLE,readHandler,c); in writeHandler()
|
| H A D | aof.c | 1119 if (aeWait(server.aof_pipe_read_data_from_parent, AE_READABLE, 1) <= 0) in rewriteAppendOnlyFile()
1200 aeDeleteFileEvent(server.el,server.aof_pipe_read_ack_from_child,AE_READABLE); in aofChildPipeReadable()
1218 …if (aeCreateFileEvent(server.el, fds[2], AE_READABLE, aofChildPipeReadable, NULL) == AE_ERR) goto … in aofCreatePipes()
1237 aeDeleteFileEvent(server.el,server.aof_pipe_read_ack_from_child,AE_READABLE); in aofClosePipes()
|
| H A D | networking.c | 76 if (aeCreateFileEvent(server.el,fd,AE_READABLE, in createClient()
762 aeDeleteFileEvent(server.el,c->fd,AE_READABLE); in unlinkClient()
1445 if (emask & AE_READABLE) *p++ = 'r'; in catClientInfoString()
|
| H A D | scripting.c | 1196 aeDeleteFileEvent(server.el, server.lua_caller->fd, AE_READABLE); in luaMaskCountHook()
1327 aeCreateFileEvent(server.el,c->fd,AE_READABLE, in evalGenericCommand()
|
| H A D | cluster.c | 462 if (aeCreateFileEvent(server.el, server.cfd[j], AE_READABLE, in clusterInit()
563 aeDeleteFileEvent(server.el, link->fd, AE_READABLE); in freeClusterLink()
607 aeCreateFileEvent(server.el,cfd,AE_READABLE,clusterReadHandler,link); in clusterAcceptHandler()
3120 aeCreateFileEvent(server.el,link->fd,AE_READABLE, in clusterCron()
|
| H A D | redis-cli.c | 1792 int mask = AE_READABLE; in pipeMode()
1798 if (mask & AE_READABLE) { in pipeMode()
|
| H A D | server.c | 1954 if (aeCreateFileEvent(server.el, server.ipfd[j], AE_READABLE, in initServer()
1961 if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE, in initServer()
|
| H A D | sentinel.c | 290 aeCreateFileEvent(loop,e->fd,AE_READABLE,redisAeReadEvent,e); in redisAeAddRead()
299 aeDeleteFileEvent(loop,e->fd,AE_READABLE); in redisAeDelRead()
|
| /redis-3.2.3/deps/hiredis/adapters/ |
| H A D | ae.h | 64 aeCreateFileEvent(loop,e->fd,AE_READABLE,redisAeReadEvent,e); in redisAeAddRead()
73 aeDeleteFileEvent(loop,e->fd,AE_READABLE); in redisAeDelRead()
|