Lines Matching refs:event_mask
190 void EpollServer::RegisterFD(int fd, CB* cb, int event_mask) {
192 VLOG(3) << "RegisterFD fd=" << fd << " event_mask=" << event_mask;
204 ModFD(fd, event_mask);
207 AddFD(fd, event_mask);
210 fd_i->event_mask = event_mask;
213 AddFD(fd, event_mask);
214 cb_map_.insert(CBAndEventMask(cb, event_mask, fd));
221 cb->OnRegistration(this, fd, event_mask);
299 fd_i->event_mask = 0;
304 void EpollServer::ModifyCallback(int fd, int event_mask) {
305 ModifyFD(fd, ~0, event_mask);
324 void EpollServer::HandleEvent(int fd, int event_mask) {
326 event_recorder_.RecordEpollEvent(fd, event_mask);
336 fd_i->events_asserted = event_mask;
506 std::string EpollServer::EventMaskToString(int event_mask) {
508 if (event_mask & EPOLLIN) s += "EPOLLIN ";
509 if (event_mask & EPOLLPRI) s += "EPOLLPRI ";
510 if (event_mask & EPOLLOUT) s += "EPOLLOUT ";
511 if (event_mask & EPOLLRDNORM) s += "EPOLLRDNORM ";
512 if (event_mask & EPOLLRDBAND) s += "EPOLLRDBAND ";
513 if (event_mask & EPOLLWRNORM) s += "EPOLLWRNORM ";
514 if (event_mask & EPOLLWRBAND) s += "EPOLLWRBAND ";
515 if (event_mask & EPOLLMSG) s += "EPOLLMSG ";
516 if (event_mask & EPOLLERR) s += "EPOLLERR ";
517 if (event_mask & EPOLLHUP) s += "EPOLLHUP ";
518 if (event_mask & EPOLLONESHOT) s += "EPOLLONESHOT ";
519 if (event_mask & EPOLLET) s += "EPOLLET ";
544 LOG(ERROR) << "fd: " << it->fd << " with mask " << it->event_mask
571 void EpollServer::AddFD(int fd, int event_mask) const {
574 ee.events = event_mask | EPOLLERR | EPOLLHUP;
589 void EpollServer::ModFD(int fd, int event_mask) const {
592 ee.events = event_mask | EPOLLERR | EPOLLHUP;
617 int & event_mask = fd_i->event_mask;
619 << " event_mask before: " << EventMaskToString(event_mask);
620 event_mask &= ~remove_event;
621 event_mask |= add_event;
623 VLOG(3) << " event_mask after: " << EventMaskToString(event_mask);
625 ModFD(fd, event_mask);
627 fd_i->cb->OnModification(fd, event_mask);
671 int event_mask = events[i].events;
673 HandleEvent(fd, event_mask);
