Home
last modified time | relevance | path

Searched refs:events (Results 1 – 25 of 38) sorted by relevance

12

/mOS-networking-stack/core/src/
H A Deventpoll.c290 events = event->events; in mtcp_epoll_ctl()
314 events = event->events; in mtcp_epoll_ctl()
469 if (!(event_socket->events & eq->events[eq->start].ev.events)) in mtcp_epoll_wait()
473 events[cnt++] = eq->events[eq->start].ev; in mtcp_epoll_wait()
479 EventToString(eq->events[eq->start].ev.events), in mtcp_epoll_wait()
488 event_socket->events &= (~eq->events[eq->start].ev.events); in mtcp_epoll_wait()
507 if (!(event_socket->events & eq->events[eq->start].ev.events)) in mtcp_epoll_wait()
511 events[cnt++] = eq->events[eq->start].ev; in mtcp_epoll_wait()
526 event_socket->events &= (~eq->events[eq->start].ev.events); in mtcp_epoll_wait()
586 eq->events[index].ev.events = event; in AddEpollEvent()
[all …]
H A Devent_callback.c164 if (events & ev) { in RegCbWCpy()
191 if (events & ev) { in RegCbWCpy()
231 ev_inc_ref = events; in RegCbWoCpy()
238 if (events & ev) { in RegCbWoCpy()
253 if (!events) in RegCbWoCpy()
258 if (events & ev) { in RegCbWoCpy()
322 if (!events) in UnregCb()
412 if ((events & evp->cb_map) != events) { in ModCb()
435 if ((events & (g_bev_map | g_ude_map)) != events) { in ModifyCallback()
610 if (!events) in HandleCallback()
[all …]
H A Dsocket.c87 if (socket->events) { in AllocateSocket()
104 if (socket->events) { in AllocateSocket()
123 socket->events = 0; in AllocateSocket()
164 socket->events = 0; in FreeSocket()
H A Dtcp_stream.c270 eq->events[index].ev.events = MOS_EPOLLIN; in RaiseReadEvent()
271 eq->events[index].ev.data.ptr = (void *)stream; in RaiseReadEvent()
921 socket->events, socket->events & MOS_EPOLLIN,
922 socket->events & MOS_EPOLLOUT, socket->events & MOS_EPOLLERR,
923 socket->events & MOS_EPOLLRDHUP, socket->events & MOS_EPOLLET);
H A Dtcp.c411 uint64_t events = 0; in ProcessInTCPPacket() local
445 events |= MOS_ON_PKT_IN; in ProcessInTCPPacket()
462 events = MOS_ON_ORPHAN; in ProcessInTCPPacket()
466 cur_stream->cb_events = events; in ProcessInTCPPacket()
494 pctx, events); in ProcessInTCPPacket()
H A Dscalable_event.c882 stree_t * const stree, event_t events) in HandleCb() argument
893 if (!((1L << i) & events)) in HandleCb()
929 if (!(events &= ~(1L << i))) { in HandleCb()
1025 socket_map_t socket, int side, struct pkt_ctx *pctx, event_t events) in HandleCallback() argument
1032 if (!events) in HandleCallback()
1034 assert(events); in HandleCallback()
1086 HandleCb(mctx, socket->id, side, stree, events); in HandleCallback()
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dfdevent_libmtcp.c59 ep.events = 0; in fdevent_libmtcp_epoll_event_set()
61 if (events & FDEVENT_IN) ep.events |= MOS_EPOLLIN; in fdevent_libmtcp_epoll_event_set()
62 if (events & FDEVENT_OUT) ep.events |= MOS_EPOLLOUT; in fdevent_libmtcp_epoll_event_set()
99 int events = 0, e; in fdevent_libmtcp_epoll_event_get_revent() local
101 e = ev->_epoll_events[ndx].events; in fdevent_libmtcp_epoll_event_get_revent()
102 if (e & MOS_EPOLLIN) events |= FDEVENT_IN; in fdevent_libmtcp_epoll_event_get_revent()
103 if (e & MOS_EPOLLOUT) events |= FDEVENT_OUT; in fdevent_libmtcp_epoll_event_get_revent()
104 if (e & MOS_EPOLLERR) events |= FDEVENT_ERR; in fdevent_libmtcp_epoll_event_get_revent()
105 if (e & MOS_EPOLLHUP) events |= FDEVENT_HUP; in fdevent_libmtcp_epoll_event_get_revent()
106 if (e & MOS_EPOLLPRI) events |= FDEVENT_PRI; in fdevent_libmtcp_epoll_event_get_revent()
[all …]
H A Dfdevent_linux_sysepoll.c55 ep.events = 0; in fdevent_linux_sysepoll_event_set()
57 if (events & FDEVENT_IN) ep.events |= EPOLLIN; in fdevent_linux_sysepoll_event_set()
58 if (events & FDEVENT_OUT) ep.events |= EPOLLOUT; in fdevent_linux_sysepoll_event_set()
90 int events = 0, e; in fdevent_linux_sysepoll_event_get_revent() local
92 e = ev->epoll_events[ndx].events; in fdevent_linux_sysepoll_event_get_revent()
93 if (e & EPOLLIN) events |= FDEVENT_IN; in fdevent_linux_sysepoll_event_get_revent()
94 if (e & EPOLLOUT) events |= FDEVENT_OUT; in fdevent_linux_sysepoll_event_get_revent()
95 if (e & EPOLLERR) events |= FDEVENT_ERR; in fdevent_linux_sysepoll_event_get_revent()
96 if (e & EPOLLHUP) events |= FDEVENT_HUP; in fdevent_linux_sysepoll_event_get_revent()
97 if (e & EPOLLPRI) events |= FDEVENT_PRI; in fdevent_linux_sysepoll_event_get_revent()
[all …]
H A Dfdevent_solaris_port.c36 static int fdevent_solaris_port_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_solaris_port_event_set() argument
39 if ((events & FDEVENT_IN) && (events & FDEVENT_OUT)) { in fdevent_solaris_port_event_set()
41 } else if (events & FDEVENT_IN) { in fdevent_solaris_port_event_set()
43 } else if (events & FDEVENT_OUT) { in fdevent_solaris_port_event_set()
60 int events = 0, e; in fdevent_solaris_port_event_get_revent() local
63 if (e & POLLIN) events |= FDEVENT_IN; in fdevent_solaris_port_event_get_revent()
64 if (e & POLLOUT) events |= FDEVENT_OUT; in fdevent_solaris_port_event_get_revent()
65 if (e & POLLERR) events |= FDEVENT_ERR; in fdevent_solaris_port_event_get_revent()
66 if (e & POLLHUP) events |= FDEVENT_HUP; in fdevent_solaris_port_event_get_revent()
67 if (e & POLLPRI) events |= FDEVENT_PRI; in fdevent_solaris_port_event_get_revent()
[all …]
H A Dfdevent_freebsd_kqueue.c32 oevents = ev->fdarray[fd]->events; in fdevent_freebsd_kqueue_event_del()
67 int oevents = ev->fdarray[fd]->events; in fdevent_freebsd_kqueue_event_set()
68 int addevents = events & ~oevents; in fdevent_freebsd_kqueue_event_set()
69 int delevents = ~events & oevents; in fdevent_freebsd_kqueue_event_set()
73 if (events == oevents) return fd; in fdevent_freebsd_kqueue_event_set()
138 int events = 0, e; in fdevent_freebsd_kqueue_event_get_revent() local
143 events |= FDEVENT_IN; in fdevent_freebsd_kqueue_event_get_revent()
145 events |= FDEVENT_OUT; in fdevent_freebsd_kqueue_event_get_revent()
151 events |= FDEVENT_HUP; in fdevent_freebsd_kqueue_event_get_revent()
155 events |= FDEVENT_ERR; in fdevent_freebsd_kqueue_event_get_revent()
[all …]
H A Dfdevent.c141 fdn->events = 0; in fdevent_register()
156 assert(fdn->events == 0); in fdevent_unregister()
173 ev->fdarray[fd]->events = 0; in fdevent_event_del()
181 fdevent_event_set(fdevents *ev, int *fde_ndx, int fd, int events) in fdevent_event_set() argument
185 if (ev->event_set) fde = ev->event_set(ev, fde, fd, events); in fdevent_event_set()
186 ev->fdarray[fd]->events = events; in fdevent_event_set()
H A Dfdevent_poll.c76 static int fdevent_poll_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_poll_event_set() argument
78 if (events & FDEVENT_IN) pevents |= POLLIN; in fdevent_poll_event_set()
79 if (events & FDEVENT_OUT) pevents |= POLLOUT; in fdevent_poll_event_set()
85 ev->pollfds[fde_ndx].events = pevents; in fdevent_poll_event_set()
98 ev->pollfds[k].events = pevents; in fdevent_poll_event_set()
111 ev->pollfds[ev->used].events = pevents; in fdevent_poll_event_set()
H A Dfdevent_solaris_devpoll.c32 pfd.events = POLLREMOVE; in fdevent_solaris_devpoll_event_del()
45 static int fdevent_solaris_devpoll_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_solaris_devpoll_event_set() argument
50 if (events & FDEVENT_IN) pevents |= POLLIN; in fdevent_solaris_devpoll_event_set()
51 if (events & FDEVENT_OUT) pevents |= POLLOUT; in fdevent_solaris_devpoll_event_set()
56 pfd.events = pevents; in fdevent_solaris_devpoll_event_set()
H A Dfdevent_libev.c59 static int fdevent_libev_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_libev_event_set() argument
65 if (events & FDEVENT_IN) ev_events |= EV_READ; in fdevent_libev_event_set()
66 if (events & FDEVENT_OUT) ev_events |= EV_WRITE; in fdevent_libev_event_set()
76 if ((watcher->events & (EV_READ | EV_WRITE)) != ev_events) { in fdevent_libev_event_set()
H A Dfdevent_select.c37 static int fdevent_select_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_select_event_set() argument
43 if (events & FDEVENT_IN) { in fdevent_select_event_set()
48 if (events & FDEVENT_OUT) { in fdevent_select_event_set()
H A Dfdevent.h96 int events; member
170 int (*event_set)(struct fdevents *ev, int fde_ndx, int fd, int events);
186 int fdevent_event_set(fdevents *ev, int *fde_ndx, int fd, int events); /* events can be FDEVENT_IN,…
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c158 ev.events = MOS_EPOLLIN; in SendUntilAvailable()
288 ev.events = MOS_EPOLLIN; in AcceptConnection()
343 ev.events = MOS_EPOLLIN; in CreateListeningSocket()
477 struct mtcp_epoll_event *events; in RunServer() local
482 events = (struct mtcp_epoll_event *) in RunServer()
484 if (!events) { in RunServer()
504 } else if (events[i].events & MOS_EPOLLERR) { in RunServer()
510 core, events[i].data.sock); in RunServer()
525 } else if (events[i].events & MOS_EPOLLIN) { in RunServer()
541 } else if (events[i].events & MOS_EPOLLOUT) { in RunServer()
[all …]
H A Depserver.c159 ev.events = MOS_EPOLLIN; in SendUntilAvailable()
289 ev.events = MOS_EPOLLIN; in AcceptConnection()
344 ev.events = MOS_EPOLLIN; in CreateListeningSocket()
478 struct mtcp_epoll_event *events; in RunServer() local
483 events = (struct mtcp_epoll_event *) in RunServer()
485 if (!events) { in RunServer()
505 } else if (events[i].events & MOS_EPOLLERR) { in RunServer()
511 core, events[i].data.sock); in RunServer()
526 } else if (events[i].events & MOS_EPOLLIN) { in RunServer()
542 } else if (events[i].events & MOS_EPOLLOUT) { in RunServer()
[all …]
/mOS-networking-stack/samples/epwget/
H A Depwget.c79 uint64_t events; member
108 struct mtcp_epoll_event *events; member
205 ev.events = MOS_EPOLLOUT; in CreateConnection()
269 ev.events = MOS_EPOLLIN; in SendHTTPRequest()
326 ev.events = MOS_EPOLLOUT; in DownloadNext()
507 total.events += st->events; in PrintStats()
641 if (!ctx->events) { in InitWget()
714 if (ctx->events[i].events & MOS_EPOLLERR) { in RunWget()
729 } else if (ctx->events[i].events & MOS_EPOLLIN) { in RunWget()
734 } else if (ctx->events[i].events == MOS_EPOLLOUT) { in RunWget()
[all …]
H A Depwget-mp.c78 uint64_t events; member
107 struct mtcp_epoll_event *events; member
204 ev.events = MOS_EPOLLOUT; in CreateConnection()
268 ev.events = MOS_EPOLLIN; in SendHTTPRequest()
325 ev.events = MOS_EPOLLOUT; in DownloadNext()
505 total.events += st->events; in PrintStats()
639 if (!ctx->events) { in InitWget()
712 if (ctx->events[i].events & MOS_EPOLLERR) { in RunWget()
727 } else if (ctx->events[i].events & MOS_EPOLLIN) { in RunWget()
732 } else if (ctx->events[i].events == MOS_EPOLLOUT) { in RunWget()
[all …]
/mOS-networking-stack/core/include/
H A Dmtcp_epoll.h68 uint64_t events; member
109 struct mtcp_epoll_event *events, int maxevents, int timeout);
/mOS-networking-stack/core/src/include/
H A Dmtcp_epoll.h68 uint64_t events; member
109 struct mtcp_epoll_event *events, int maxevents, int timeout);
H A Dtcp.h17 struct pkt_ctx *pctx, uint64_t events);
/mOS-networking-stack/samples/midstat/
H A Dmidstat.c71 cb_creation(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_creation() argument
95 cb_destroy(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_destroy() argument
108 cb_st_chg(mctx_t mctx, int sock, int side, uint64_t events, filter_arg_t *arg) in cb_st_chg() argument
156 uint64_t events, filter_arg_t *arg) in cb_printstat() argument
/mOS-networking-stack/samples/nat/
H A Dnat.c122 translate_addr(mctx_t mctx, int sock, int side, uint64_t events, in translate_addr() argument
158 release_port(mctx_t mctx, int sock, int side, uint64_t events, in release_port() argument

12