Home
last modified time | relevance | path

Searched refs:aeCreateFileEvent (Results 1 – 11 of 11) sorted by relevance

/redis-3.2.3/deps/hiredis/adapters/
H A Dae.h64 aeCreateFileEvent(loop,e->fd,AE_READABLE,redisAeReadEvent,e); in redisAeAddRead()
82 aeCreateFileEvent(loop,e->fd,AE_WRITABLE,redisAeWriteEvent,e); in redisAeAddWrite()
/redis-3.2.3/src/
H A Dae.h107 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask,
H A Dredis-benchmark.c152 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 Dreplication.c787 if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, in putSlaveOnline()
921 … if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, sendBulkToSlave, slave) == AE_ERR) { in updateSlavesWaitingBgsave()
1623 if (aeCreateFileEvent(server.el,fd, AE_READABLE,readSyncBulkPayload,NULL) in syncWithMaster()
1665 if (aeCreateFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE,syncWithMaster,NULL) == in connectWithMaster()
1959 if (aeCreateFileEvent(server.el, newfd, AE_READABLE, in replicationResurrectCachedMaster()
1968 if (aeCreateFileEvent(server.el, newfd, AE_WRITABLE, in replicationResurrectCachedMaster()
H A Dae.c135 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask, in aeCreateFileEvent() function
H A Daof.c165 aeCreateFileEvent(server.el, server.aof_pipe_write_data_to_child, in aofRewriteBufferAppend()
1218 …if (aeCreateFileEvent(server.el, fds[2], AE_READABLE, aofChildPipeReadable, NULL) == AE_ERR) goto … in aofCreatePipes()
H A Dnetworking.c76 if (aeCreateFileEvent(server.el,fd,AE_READABLE, in createClient()
1015 aeCreateFileEvent(server.el, c->fd, AE_WRITABLE, in handleClientsWithPendingWrites()
H A Dcluster.c462 if (aeCreateFileEvent(server.el, server.cfd[j], AE_READABLE, in clusterInit()
607 aeCreateFileEvent(server.el,cfd,AE_READABLE,clusterReadHandler,link); in clusterAcceptHandler()
2085 aeCreateFileEvent(server.el,link->fd,AE_WRITABLE, in clusterSendMessage()
3120 aeCreateFileEvent(server.el,link->fd,AE_READABLE, in clusterCron()
H A Dserver.c1954 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 Dsentinel.c290 aeCreateFileEvent(loop,e->fd,AE_READABLE,redisAeReadEvent,e); in redisAeAddRead()
308 aeCreateFileEvent(loop,e->fd,AE_WRITABLE,redisAeWriteEvent,e); in redisAeAddWrite()
H A Dscripting.c1327 aeCreateFileEvent(server.el,c->fd,AE_READABLE, in evalGenericCommand()