Searched refs:KQ_EVENT_READ (Results 1 – 6 of 6) sorted by relevance
45 #define KQ_EVENT_READ 1 macro123 void EnableInput() { _events |= KQ_EVENT_READ; }; in EnableInput()127 void DisableInput() { _events &= ~KQ_EVENT_READ; }; in DisableInput()191 if (event & KQ_EVENT_READ) { in AttachEvents()199 if (event & KQ_EVENT_READ) { in DetachEvents()
200 if (old_events & KQ_EVENT_READ) { in KqueueCtrlAdd()220 if (events & KQ_EVENT_READ) { in KqueueCtrlAdd()261 new_events = new_events & ~KQ_EVENT_READ; in KqueueCtrlDelRef()282 if (old_events & KQ_EVENT_READ) { in KqueueCtrlDelRef()299 if (new_events & KQ_EVENT_READ) { in KqueueCtrlDelRef()389 revents |= KQ_EVENT_READ; in KqueueRcvEventList()398 KqueueCtrlDel(osfd, (revents & (KQ_EVENT_READ | KQ_EVENT_WRITE))); in KqueueRcvEventList()409 if (revents & KQ_EVENT_READ) in KqueueRcvEventList()
110 frame->KqueueCtrlAdd(osfd, KQ_EVENT_READ); in CreateSocket()121 frame->KqueueCtrlDel(osfd, KQ_EVENT_READ); in CloseSocket()214 conn->GetNtfyObj()->SetRcvEvents(KQ_EVENT_READ); in InputNotify()
55 if (how & KQ_EVENT_READ) in mt_multi_netfd_poll()374 mt_multi_netfd_poll(wait_list, KQ_EVENT_READ, end_ms - curr_ms); in mt_multi_recvfrom()
1419 if (events & KQ_EVENT_READ) in WaitEvents()
1101 rc = MtFrame::Instance()->KqueueCtrlAdd(_fd, KQ_EVENT_READ); in SendData()