Lines Matching refs:mask
82 eventLoop->events[i].mask = AE_NONE; in aeCreateEventLoop()
120 eventLoop->events[i].mask = AE_NONE; in aeResizeSetSize()
135 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask, in aeCreateFileEvent() argument
144 if (aeApiAddEvent(eventLoop, fd, mask) == -1) in aeCreateFileEvent()
146 fe->mask |= mask; in aeCreateFileEvent()
147 if (mask & AE_READABLE) fe->rfileProc = proc; in aeCreateFileEvent()
148 if (mask & AE_WRITABLE) fe->wfileProc = proc; in aeCreateFileEvent()
155 void aeDeleteFileEvent(aeEventLoop *eventLoop, int fd, int mask) in aeDeleteFileEvent() argument
159 if (fe->mask == AE_NONE) return; in aeDeleteFileEvent()
161 aeApiDelEvent(eventLoop, fd, mask); in aeDeleteFileEvent()
162 fe->mask = fe->mask & (~mask); in aeDeleteFileEvent()
163 if (fd == eventLoop->maxfd && fe->mask == AE_NONE) { in aeDeleteFileEvent()
168 if (eventLoop->events[j].mask != AE_NONE) break; in aeDeleteFileEvent()
177 return fe->mask; in aeGetFileEvents()
403 int mask = eventLoop->fired[j].mask; in aeProcessEvents() local
410 if (fe->mask & mask & AE_READABLE) { in aeProcessEvents()
412 fe->rfileProc(eventLoop,fd,fe->clientData,mask); in aeProcessEvents()
414 if (fe->mask & mask & AE_WRITABLE) { in aeProcessEvents()
416 fe->wfileProc(eventLoop,fd,fe->clientData,mask); in aeProcessEvents()
430 int aeWait(int fd, int mask, long long milliseconds) { in aeWait() argument
436 if (mask & AE_READABLE) pfd.events |= POLLIN; in aeWait()
437 if (mask & AE_WRITABLE) pfd.events |= POLLOUT; in aeWait()