Home
last modified time | relevance | path

Searched refs:pfd (Results 1 – 2 of 2) sorted by relevance

/redis-3.2.3/src/
H A Dae_evport.c154 int fullmask, pfd; in aeApiAddEvent() local
165 pfd = aeApiLookupPending(state, fd); in aeApiAddEvent()
167 if (pfd != -1) { in aeApiAddEvent()
176 state->pending_masks[pfd] |= fullmask; in aeApiAddEvent()
185 int fullmask, pfd; in aeApiDelEvent() local
190 pfd = aeApiLookupPending(state, fd); in aeApiDelEvent()
192 if (pfd != -1) { in aeApiDelEvent()
201 state->pending_masks[pfd] &= ~mask; in aeApiDelEvent()
203 if (state->pending_masks[pfd] == AE_NONE) in aeApiDelEvent()
204 state->pending_fds[pfd] = -1; in aeApiDelEvent()
H A Dae.c431 struct pollfd pfd; in aeWait() local
434 memset(&pfd, 0, sizeof(pfd)); in aeWait()
435 pfd.fd = fd; in aeWait()
436 if (mask & AE_READABLE) pfd.events |= POLLIN; in aeWait()
437 if (mask & AE_WRITABLE) pfd.events |= POLLOUT; in aeWait()
439 if ((retval = poll(&pfd, 1, milliseconds))== 1) { in aeWait()
440 if (pfd.revents & POLLIN) retmask |= AE_READABLE; 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()