Home
last modified time | relevance | path

Searched refs:KQ_EVENT_WRITE (Results 1 – 7 of 7) sorted by relevance

/f-stack/app/micro_thread/
H A Dkqueue_proxy.h46 #define KQ_EVENT_WRITE 2 macro
125 void EnableOutput() { _events |= KQ_EVENT_WRITE; }; in EnableOutput()
129 void DisableOutput() { _events &= ~KQ_EVENT_WRITE; }; in DisableOutput()
194 if (event & KQ_EVENT_WRITE){ in AttachEvents()
206 if (event & KQ_EVENT_WRITE){ in DetachEvents()
H A Dkqueue_proxy.cpp190 if (old_events & KQ_EVENT_WRITE) { in KqueueCtrlAdd()
210 if (events & KQ_EVENT_WRITE) { in KqueueCtrlAdd()
264 new_events = new_events & ~KQ_EVENT_WRITE; in KqueueCtrlDelRef()
274 if (old_events & KQ_EVENT_WRITE) { in KqueueCtrlDelRef()
291 if (new_events & KQ_EVENT_WRITE) { in KqueueCtrlDelRef()
392 revents |= KQ_EVENT_WRITE; in KqueueRcvEventList()
398 KqueueCtrlDel(osfd, (revents & (KQ_EVENT_READ | KQ_EVENT_WRITE))); in KqueueRcvEventList()
418 if (revents & KQ_EVENT_WRITE) in KqueueRcvEventList()
H A Dmt_notify.cpp64 proxy->SetRcvEvents(KQ_EVENT_WRITE); in NotifyWriteWait()
261 if (!frame->KqueueCtrlAdd(osfd, KQ_EVENT_WRITE)) in KqueueCtlAdd()
286 if (!frame->KqueueCtrlDel(osfd, KQ_EVENT_WRITE)) in KqueueCtlDel()
H A Dmt_concurrent.cpp64 if (how & KQ_EVENT_WRITE) in mt_multi_netfd_poll()
216 mt_multi_netfd_poll(wait_list, KQ_EVENT_WRITE, end_ms - curr_ms); in mt_multi_open()
298 mt_multi_netfd_poll(wait_list, KQ_EVENT_WRITE, end_ms - curr_ms); in mt_multi_sendto()
H A Dmt_notify.h191 if (!(events & KQ_EVENT_WRITE)) { in KqueueCtlAdd()
209 if (!(events & KQ_EVENT_WRITE)) { in KqueueCtlDel()
H A Dmt_net.cpp1106 rc = MtFrame::Instance()->KqueueCtrlDel(_fd, KQ_EVENT_WRITE); in SendData()
1436 if (!MtFrame::Instance()->KqueueCtrlDel(_fd, KQ_EVENT_WRITE)) in OutputNotify()
H A Dmicro_thread.cpp1423 if (events & KQ_EVENT_WRITE) in WaitEvents()