| /f-stack/app/redis-5.0.5/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.c | 153 if (mask & AE_WRITABLE) fe->wfileProc = proc; in aeCreateFileEvent()
168 if (mask & AE_WRITABLE) mask |= AE_BARRIER; in aeDeleteFileEvent()
456 if (fe->mask & mask & AE_WRITABLE) { in aeProcessEvents()
491 if (mask & AE_WRITABLE) pfd.events |= POLLOUT; in aeWait()
495 if (pfd.revents & POLLOUT) retmask |= AE_WRITABLE; in aeWait()
496 if (pfd.revents & POLLERR) retmask |= AE_WRITABLE; in aeWait()
497 if (pfd.revents & POLLHUP) retmask |= AE_WRITABLE; in aeWait()
|
| H A D | ae_ff_kqueue.c | 85 if (mask & AE_WRITABLE) { in aeApiAddEvent()
100 if (mask & AE_WRITABLE) { in aeApiDelEvent()
130 if (e->filter == EVFILT_WRITE) 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_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 /* Fire when descriptor is writable. */ macro
|
| H A D | replication.c | 861 if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, in putSlaveOnline()
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()
1639 aeDeleteFileEvent(server.el,fd,AE_WRITABLE); 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()
2267 if (aeCreateFileEvent(server.el, newfd, AE_WRITABLE, in replicationResurrectCachedMaster()
|
| H A D | networking.c | 824 aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in unlinkClient()
1060 if (handler_installed) aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in writeToClient()
1103 int ae_flags = AE_WRITABLE; in handleClientsWithPendingWrites()
1164 aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in protectClient()
1673 if (emask & AE_WRITABLE) *p++ = 'w'; in catClientInfoString()
2155 if (events & AE_WRITABLE && in flushSlavesOutputBuffers()
|
| H A D | aof.c | 109 AE_WRITABLE); in aofChildWriteDiffData()
167 AE_WRITABLE, aofChildWriteDiffData, NULL); in aofRewriteBufferAppend()
1534 aeDeleteFileEvent(server.el,server.aof_pipe_write_data_to_child,AE_WRITABLE); in aofClosePipes()
|
| H A D | cluster.c | 604 aeDeleteFileEvent(server.el, link->fd, AE_READABLE|AE_WRITABLE); in freeClusterLink()
2135 aeDeleteFileEvent(server.el, link->fd, AE_WRITABLE); in clusterWriteHandler()
2211 aeCreateFileEvent(server.el,link->fd,AE_WRITABLE|AE_BARRIER, in clusterSendMessage()
5003 if ((aeWait(fd,AE_WRITABLE,timeout) & AE_WRITABLE) == 0) { in migrateGetSocket()
|
| H A D | sentinel.c | 315 aeCreateFileEvent(loop,e->fd,AE_WRITABLE,redisAeWriteEvent,e); in redisAeAddWrite()
324 aeDeleteFileEvent(loop,e->fd,AE_WRITABLE); in redisAeDelWrite()
|
| H A D | redis-cli.c | 6070 if (!eof || obuf_len != 0) mask |= AE_WRITABLE; in pipeMode()
6119 if (mask & AE_WRITABLE) { in pipeMode()
|
| /f-stack/app/redis-5.0.5/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()
|