Lines Matching refs:el
76 if (aeCreateFileEvent(server.el,fd,AE_READABLE, in createClient()
686 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptTcpHandler() argument
689 UNUSED(el); in acceptTcpHandler()
706 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptUnixHandler() argument
708 UNUSED(el); in acceptUnixHandler()
762 aeDeleteFileEvent(server.el,c->fd,AE_READABLE); in unlinkClient()
763 aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in unlinkClient()
976 if (handler_installed) aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in writeToClient()
988 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask) { in sendReplyToClient() argument
989 UNUSED(el); in sendReplyToClient()
1015 aeCreateFileEvent(server.el, c->fd, AE_WRITABLE, in handleClientsWithPendingWrites()
1307 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask) { in readQueryFromClient() argument
1311 UNUSED(el); in readQueryFromClient()
1443 emask = client->fd == -1 ? 0 : aeGetFileEvents(server.el,client->fd); in catClientInfoString()
1847 events = aeGetFileEvents(server.el,slave->fd); in flushSlavesOutputBuffers()
1925 events += aeProcessEvents(server.el, AE_FILE_EVENTS|AE_DONT_WAIT); in processEventsWhileBlocked()