| /redis-3.2.3/src/ |
| H A D | ae_epoll.c | 84 if (mask & AE_WRITABLE) ee.events |= EPOLLOUT; in aeApiAddEvent()
97 if (mask & AE_WRITABLE) ee.events |= EPOLLOUT; in aeApiDelEvent()
123 if (e->events & EPOLLOUT) mask |= AE_WRITABLE; in aeApiPoll()
124 if (e->events & EPOLLERR) mask |= AE_WRITABLE; in aeApiPoll()
125 if (e->events & EPOLLHUP) mask |= AE_WRITABLE; in aeApiPoll()
|
| H A D | ae_select.c | 66 if (mask & AE_WRITABLE) FD_SET(fd,&state->wfds); in aeApiAddEvent()
74 if (mask & AE_WRITABLE) FD_CLR(fd,&state->wfds); in aeApiDelEvent()
94 if (fe->mask & AE_WRITABLE && FD_ISSET(j,&state->_wfds)) in aeApiPoll()
95 mask |= AE_WRITABLE; in aeApiPoll()
|
| H A D | ae_kqueue.c | 83 if (mask & AE_WRITABLE) { in aeApiAddEvent()
98 if (mask & AE_WRITABLE) { in aeApiDelEvent()
128 if (e->filter == EVFILT_WRITE) mask |= AE_WRITABLE; in aeApiPoll()
|
| H A D | ae.c | 148 if (mask & AE_WRITABLE) fe->wfileProc = proc; in aeCreateFileEvent()
414 if (fe->mask & mask & AE_WRITABLE) { in aeProcessEvents()
437 if (mask & AE_WRITABLE) pfd.events |= POLLOUT; in aeWait()
441 if (pfd.revents & POLLOUT) retmask |= AE_WRITABLE; in aeWait()
442 if (pfd.revents & POLLERR) retmask |= AE_WRITABLE; in aeWait()
443 if (pfd.revents & POLLHUP) retmask |= AE_WRITABLE; in aeWait()
|
| H A D | ae_evport.c | 129 if (mask & AE_WRITABLE) in aeApiAssociate()
302 mask |= AE_WRITABLE; in aeApiPoll()
|
| H A D | redis-benchmark.c | 127 aeDeleteFileEvent(config.el,c->context->fd,AE_WRITABLE); in freeClient()
150 aeDeleteFileEvent(config.el,c->context->fd,AE_WRITABLE); in resetClient()
152 aeCreateFileEvent(config.el,c->context->fd,AE_WRITABLE,writeHandler,c); in resetClient()
289 aeDeleteFileEvent(config.el,c->context->fd,AE_WRITABLE); in writeHandler()
407 aeCreateFileEvent(config.el,c->context->fd,AE_WRITABLE,writeHandler,c); in createClient()
|
| H A D | syncio.c | 71 aeWait(fd,AE_WRITABLE,wait); in syncWrite()
|
| H A D | ae.h | 43 #define AE_WRITABLE 2 macro
|
| H A D | replication.c | 787 if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, in putSlaveOnline()
849 aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE); in sendBulkToSlave()
920 aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE); in updateSlavesWaitingBgsave()
921 … if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, sendBulkToSlave, slave) == AE_ERR) { in updateSlavesWaitingBgsave()
1416 aeDeleteFileEvent(server.el,fd,AE_WRITABLE); in syncWithMaster()
1642 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in syncWithMaster()
1665 if (aeCreateFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE,syncWithMaster,NULL) == in connectWithMaster()
1686 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in undoConnectWithMaster()
1968 if (aeCreateFileEvent(server.el, newfd, AE_WRITABLE, in replicationResurrectCachedMaster()
|
| H A D | networking.c | 763 aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in unlinkClient()
976 if (handler_installed) aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in writeToClient()
1015 aeCreateFileEvent(server.el, c->fd, AE_WRITABLE, in handleClientsWithPendingWrites()
1446 if (emask & AE_WRITABLE) *p++ = 'w'; in catClientInfoString()
1848 if (events & AE_WRITABLE && in flushSlavesOutputBuffers()
|
| H A D | aof.c | 109 AE_WRITABLE); in aofChildWriteDiffData()
166 AE_WRITABLE, aofChildWriteDiffData, NULL); in aofRewriteBufferAppend()
1238 aeDeleteFileEvent(server.el,server.aof_pipe_write_data_to_child,AE_WRITABLE); in aofClosePipes()
|
| H A D | cluster.c | 562 aeDeleteFileEvent(server.el, link->fd, AE_WRITABLE); in freeClusterLink()
2009 aeDeleteFileEvent(server.el, link->fd, AE_WRITABLE); in clusterWriteHandler()
2085 aeCreateFileEvent(server.el,link->fd,AE_WRITABLE, in clusterSendMessage()
4592 if ((aeWait(fd,AE_WRITABLE,timeout) & AE_WRITABLE) == 0) { in migrateGetSocket()
|
| H A D | redis-cli.c | 1794 if (!eof || obuf_len != 0) mask |= AE_WRITABLE; in pipeMode()
1843 if (mask & AE_WRITABLE) { in pipeMode()
|
| H A D | sentinel.c | 308 aeCreateFileEvent(loop,e->fd,AE_WRITABLE,redisAeWriteEvent,e); in redisAeAddWrite()
317 aeDeleteFileEvent(loop,e->fd,AE_WRITABLE); in redisAeDelWrite()
|
| /redis-3.2.3/deps/hiredis/adapters/ |
| H A D | ae.h | 82 aeCreateFileEvent(loop,e->fd,AE_WRITABLE,redisAeWriteEvent,e); in redisAeAddWrite()
91 aeDeleteFileEvent(loop,e->fd,AE_WRITABLE); in redisAeDelWrite()
|