| /f-stack/app/redis-5.0.5/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_ff_kqueue.c | 81 if (mask & AE_READABLE) { in aeApiAddEvent()
96 if (mask & AE_READABLE) { in aeApiDelEvent()
129 if (e->filter == EVFILT_READ) 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 | 152 if (mask & AE_READABLE) fe->rfileProc = proc; in aeCreateFileEvent()
450 if (!invert && fe->mask & mask & AE_READABLE) { in aeProcessEvents()
465 if (invert && fe->mask & mask & AE_READABLE) { in aeProcessEvents()
490 if (mask & AE_READABLE) pfd.events |= POLLIN; in aeWait()
494 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 /* Fire when descriptor is readable. */ macro
|
| H A D | replication.c | 1289 aeDeleteFileEvent(server.el,server.repl_transfer_s,AE_READABLE); in readSyncBulkPayload()
1477 aeDeleteFileEvent(server.el,fd,AE_READABLE); in slaveTryPartialResynchronization()
1492 aeDeleteFileEvent(server.el,fd,AE_READABLE); in slaveTryPartialResynchronization()
1854 if (aeCreateFileEvent(server.el,fd, AE_READABLE,readSyncBulkPayload,NULL) in syncWithMaster()
1873 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in syncWithMaster()
1897 if (aeCreateFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE,syncWithMaster,NULL) == in connectWithMaster()
1918 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in undoConnectWithMaster()
2258 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 | 1416 if (aeWait(server.aof_pipe_read_data_from_parent, AE_READABLE, 1) <= 0) in rewriteAppendOnlyFile()
1496 aeDeleteFileEvent(server.el,server.aof_pipe_read_ack_from_child,AE_READABLE); in aofChildPipeReadable()
1514 …if (aeCreateFileEvent(server.el, fds[2], AE_READABLE, aofChildPipeReadable, NULL) == AE_ERR) goto … in aofCreatePipes()
1533 aeDeleteFileEvent(server.el,server.aof_pipe_read_ack_from_child,AE_READABLE); in aofClosePipes()
|
| H A D | networking.c | 98 if (aeCreateFileEvent(server.el,fd,AE_READABLE, in createClient()
823 aeDeleteFileEvent(server.el,c->fd,AE_READABLE); in unlinkClient()
1163 aeDeleteFileEvent(server.el,c->fd,AE_READABLE); in protectClient()
1171 aeCreateFileEvent(server.el,c->fd,AE_READABLE,readQueryFromClient,c); in unprotectClient()
1672 if (emask & AE_READABLE) *p++ = 'r'; in catClientInfoString()
|
| H A D | cluster.c | 496 if (aeCreateFileEvent(server.el, server.cfd[j], AE_READABLE, in clusterInit()
604 aeDeleteFileEvent(server.el, link->fd, AE_READABLE|AE_WRITABLE); in freeClusterLink()
648 aeCreateFileEvent(server.el,cfd,AE_READABLE,clusterReadHandler,link); in clusterAcceptHandler()
3406 aeCreateFileEvent(server.el,link->fd,AE_READABLE, in clusterCron()
|
| H A D | server.c | 2141 if (aeCreateFileEvent(server.el, server.ipfd[j], AE_READABLE, in initServer()
2148 if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE, in initServer()
2154 if (aeCreateFileEvent(server.el, server.module_blocked_pipe[0], AE_READABLE, in initServer()
|
| H A D | sentinel.c | 297 aeCreateFileEvent(loop,e->fd,AE_READABLE,redisAeReadEvent,e); in redisAeAddRead()
306 aeDeleteFileEvent(loop,e->fd,AE_READABLE); in redisAeDelRead()
|
| H A D | redis-cli.c | 6068 int mask = AE_READABLE; in pipeMode()
6074 if (mask & AE_READABLE) { in pipeMode()
|
| /f-stack/app/redis-5.0.5/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()
|