Lines Matching refs:el
861 if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, in putSlaveOnline()
872 void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) { in sendBulkToSlave() argument
874 UNUSED(el); in sendBulkToSlave()
923 aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE); in sendBulkToSlave()
994 aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE); in updateSlavesWaitingBgsave()
995 … if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, sendBulkToSlave, slave) == AE_ERR) { in updateSlavesWaitingBgsave()
1117 void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) { in readSyncBulkPayload() argument
1121 UNUSED(el); in readSyncBulkPayload()
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()
1608 void syncWithMaster(aeEventLoop *el, int fd, void *privdata, int mask) { in syncWithMaster() argument
1613 UNUSED(el); in syncWithMaster()
1639 aeDeleteFileEvent(server.el,fd,AE_WRITABLE); in syncWithMaster()
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()
2267 if (aeCreateFileEvent(server.el, newfd, AE_WRITABLE, in replicationResurrectCachedMaster()