| /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()
82 aeCreateFileEvent(loop,e->fd,AE_WRITABLE,redisAeWriteEvent,e); in redisAeAddWrite()
|
| /f-stack/app/redis-5.0.5/src/ |
| H A D | ae.h | 115 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask,
|
| H A D | redis-benchmark.c | 152 aeCreateFileEvent(config.el,c->context->fd,AE_WRITABLE,writeHandler,c); in resetClient()
290 aeCreateFileEvent(config.el,c->context->fd,AE_READABLE,readHandler,c); in writeHandler()
407 aeCreateFileEvent(config.el,c->context->fd,AE_WRITABLE,writeHandler,c); in createClient()
|
| H A D | replication.c | 861 if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, in putSlaveOnline()
995 … if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, sendBulkToSlave, slave) == AE_ERR) { in updateSlavesWaitingBgsave()
1854 if (aeCreateFileEvent(server.el,fd, AE_READABLE,readSyncBulkPayload,NULL) in syncWithMaster()
1897 if (aeCreateFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE,syncWithMaster,NULL) == in connectWithMaster()
2258 if (aeCreateFileEvent(server.el, newfd, AE_READABLE, in replicationResurrectCachedMaster()
2267 if (aeCreateFileEvent(server.el, newfd, AE_WRITABLE, in replicationResurrectCachedMaster()
|
| H A D | ae.c | 140 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask, in aeCreateFileEvent() function
|
| H A D | networking.c | 98 if (aeCreateFileEvent(server.el,fd,AE_READABLE, in createClient()
1114 if (aeCreateFileEvent(server.el, c->fd, ae_flags, in handleClientsWithPendingWrites()
1171 aeCreateFileEvent(server.el,c->fd,AE_READABLE,readQueryFromClient,c); in unprotectClient()
|
| H A D | aof.c | 166 aeCreateFileEvent(server.el, server.aof_pipe_write_data_to_child, in aofRewriteBufferAppend()
1514 …if (aeCreateFileEvent(server.el, fds[2], AE_READABLE, aofChildPipeReadable, NULL) == AE_ERR) goto … in aofCreatePipes()
|
| H A D | cluster.c | 496 if (aeCreateFileEvent(server.el, server.cfd[j], AE_READABLE, in clusterInit()
648 aeCreateFileEvent(server.el,cfd,AE_READABLE,clusterReadHandler,link); in clusterAcceptHandler()
2211 aeCreateFileEvent(server.el,link->fd,AE_WRITABLE|AE_BARRIER, in clusterSendMessage()
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()
315 aeCreateFileEvent(loop,e->fd,AE_WRITABLE,redisAeWriteEvent,e); in redisAeAddWrite()
|