| /mOS-networking-stack/samples/lighttpd-1.4.32/src/ |
| H A D | fdevent.c | 17 fdevents *ev; in fdevent_init() local
92 fdevent_free(fdevents *ev) in fdevent_free()
108 fdevent_reset(fdevents *ev) in fdevent_reset()
149 fdevent_unregister(fdevents *ev, int fd) in fdevent_unregister()
194 fdevent_poll(fdevents *ev, int timeout_ms) in fdevent_poll()
201 fdevent_event_get_revent(fdevents *ev, size_t ndx) in fdevent_event_get_revent()
209 fdevent_event_get_fd(fdevents *ev, size_t ndx) in fdevent_event_get_fd()
217 fdevent_get_handler(fdevents *ev, int fd) in fdevent_get_handler()
226 fdevent_get_context(fdevents *ev, int fd) in fdevent_get_context()
235 fdevent_fcntl_set(fdevents *ev, int fd) in fdevent_fcntl_set()
[all …]
|
| H A D | fdevent_select.c | 18 static int fdevent_select_reset(fdevents *ev) { in fdevent_select_reset()
27 static int fdevent_select_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_select_event_del()
37 static int fdevent_select_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_select_event_set()
60 static int fdevent_select_poll(fdevents *ev, int timeout_ms) { in fdevent_select_poll()
73 static int fdevent_select_event_get_revent(fdevents *ev, size_t ndx) { in fdevent_select_event_get_revent()
89 static int fdevent_select_event_get_fd(fdevents *ev, size_t ndx) { in fdevent_select_event_get_fd()
95 static int fdevent_select_event_next_fdndx(fdevents *ev, int ndx) { in fdevent_select_event_next_fdndx()
109 int fdevent_select_init(fdevents *ev) { in fdevent_select_init()
128 int fdevent_select_init(fdevents *ev) { in fdevent_select_init()
|
| H A D | fdevent_solaris_devpoll.c | 19 static void fdevent_solaris_devpoll_free(fdevents *ev) { in fdevent_solaris_devpoll_free()
26 static int fdevent_solaris_devpoll_event_del(fdevents *ev, int fde_ndx, int fd) { 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()
69 static int fdevent_solaris_devpoll_poll(fdevents *ev, int timeout_ms) { in fdevent_solaris_devpoll_poll()
82 static int fdevent_solaris_devpoll_event_get_revent(fdevents *ev, size_t ndx) { in fdevent_solaris_devpoll_event_get_revent()
100 static int fdevent_solaris_devpoll_event_get_fd(fdevents *ev, size_t ndx) { in fdevent_solaris_devpoll_event_get_fd()
104 static int fdevent_solaris_devpoll_event_next_fdndx(fdevents *ev, int last_ndx) { in fdevent_solaris_devpoll_event_next_fdndx()
114 int fdevent_solaris_devpoll_reset(fdevents *ev) { in fdevent_solaris_devpoll_reset()
134 int fdevent_solaris_devpoll_init(fdevents *ev) { in fdevent_solaris_devpoll_init()
168 int fdevent_solaris_devpoll_init(fdevents *ev) { in fdevent_solaris_devpoll_init()
|
| H A D | fdevent_libmtcp.c | 20 fdevent_libmtcp_epoll_free(fdevents *ev) in fdevent_libmtcp_epoll_free()
27 fdevent_libmtcp_epoll_event_del(fdevents *ev, int fde_ndx, int fd) in fdevent_libmtcp_epoll_event_del()
52 fdevent_libmtcp_epoll_event_set(fdevents *ev, int fde_ndx, int fd, int events) in fdevent_libmtcp_epoll_event_set()
90 fdevent_libmtcp_epoll_poll(fdevents *ev, int timeout_ms) in fdevent_libmtcp_epoll_poll()
97 fdevent_libmtcp_epoll_event_get_revent(fdevents *ev, size_t ndx) in fdevent_libmtcp_epoll_event_get_revent()
112 fdevent_libmtcp_epoll_event_get_fd(fdevents *ev, size_t ndx) in fdevent_libmtcp_epoll_event_get_fd()
118 fdevent_libmtcp_epoll_event_next_fdndx(fdevents *ev, int ndx) in fdevent_libmtcp_epoll_event_next_fdndx()
130 fdevent_libmtcp_epoll_init(fdevents *ev) in fdevent_libmtcp_epoll_init()
167 fdevent_libmtcp_epoll_init(fdevents *ev) in fdevent_libmtcp_epoll_init()
|
| H A D | fdevent_poll.c | 23 static void fdevent_poll_free(fdevents *ev) { in fdevent_poll_free()
28 static int fdevent_poll_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_poll_event_del()
76 static int fdevent_poll_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_poll_event_set()
117 static int fdevent_poll_poll(fdevents *ev, int timeout_ms) { in fdevent_poll_poll()
124 static int fdevent_poll_event_get_revent(fdevents *ev, size_t ndx) { in fdevent_poll_event_get_revent()
156 static int fdevent_poll_event_get_fd(fdevents *ev, size_t ndx) { in fdevent_poll_event_get_fd()
160 static int fdevent_poll_event_next_fdndx(fdevents *ev, int ndx) { in fdevent_poll_event_next_fdndx()
171 int fdevent_poll_init(fdevents *ev) { in fdevent_poll_init()
193 int fdevent_poll_init(fdevents *ev) { in fdevent_poll_init()
|
| H A D | fdevent_linux_sysepoll.c | 19 static void fdevent_linux_sysepoll_free(fdevents *ev) { in fdevent_linux_sysepoll_free()
24 static int fdevent_linux_sysepoll_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_linux_sysepoll_event_del()
47 static int fdevent_linux_sysepoll_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_linux_sysepoll_event_set()
85 static int fdevent_linux_sysepoll_poll(fdevents *ev, int timeout_ms) { in fdevent_linux_sysepoll_poll()
89 static int fdevent_linux_sysepoll_event_get_revent(fdevents *ev, size_t ndx) { in fdevent_linux_sysepoll_event_get_revent()
102 static int fdevent_linux_sysepoll_event_get_fd(fdevents *ev, size_t ndx) { in fdevent_linux_sysepoll_event_get_fd()
111 static int fdevent_linux_sysepoll_event_next_fdndx(fdevents *ev, int ndx) { in fdevent_linux_sysepoll_event_next_fdndx()
121 int fdevent_linux_sysepoll_init(fdevents *ev) { in fdevent_linux_sysepoll_init()
158 int fdevent_linux_sysepoll_init(fdevents *ev) { in fdevent_linux_sysepoll_init()
|
| H A D | fdevent_libev.c | 12 fdevents *ev = w->data; in io_watcher_cb() local
37 static void fdevent_libev_free(fdevents *ev) { in fdevent_libev_free()
41 static int fdevent_libev_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_libev_event_del()
59 static int fdevent_libev_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_libev_event_set()
93 static int fdevent_libev_poll(fdevents *ev, int timeout_ms) { in fdevent_libev_poll()
107 static int fdevent_libev_event_get_revent(fdevents *ev, size_t ndx) { in fdevent_libev_event_get_revent()
114 static int fdevent_libev_event_get_fd(fdevents *ev, size_t ndx) { in fdevent_libev_event_get_fd()
121 static int fdevent_libev_event_next_fdndx(fdevents *ev, int ndx) { in fdevent_libev_event_next_fdndx()
128 static int fdevent_libev_reset(fdevents *ev) { in fdevent_libev_reset()
136 int fdevent_libev_init(fdevents *ev) { in fdevent_libev_init()
[all …]
|
| H A D | fdevent_freebsd_kqueue.c | 19 static void fdevent_freebsd_kqueue_free(fdevents *ev) { in fdevent_freebsd_kqueue_free()
24 static int fdevent_freebsd_kqueue_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_freebsd_kqueue_event_del()
63 static int fdevent_freebsd_kqueue_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_freebsd_kqueue_event_set()
110 static int fdevent_freebsd_kqueue_poll(fdevents *ev, int timeout_ms) { in fdevent_freebsd_kqueue_poll()
137 static int fdevent_freebsd_kqueue_event_get_revent(fdevents *ev, size_t ndx) { in fdevent_freebsd_kqueue_event_get_revent()
161 static int fdevent_freebsd_kqueue_event_get_fd(fdevents *ev, size_t ndx) { in fdevent_freebsd_kqueue_event_get_fd()
165 static int fdevent_freebsd_kqueue_event_next_fdndx(fdevents *ev, int ndx) { in fdevent_freebsd_kqueue_event_next_fdndx()
171 static int fdevent_freebsd_kqueue_reset(fdevents *ev) { in fdevent_freebsd_kqueue_reset()
183 int fdevent_freebsd_kqueue_init(fdevents *ev) { in fdevent_freebsd_kqueue_init()
218 int fdevent_freebsd_kqueue_init(fdevents *ev) { in fdevent_freebsd_kqueue_init()
|
| H A D | fdevent_solaris_port.c | 21 static int fdevent_solaris_port_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_solaris_port_event_del()
36 static int fdevent_solaris_port_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_solaris_port_event_set()
59 static int fdevent_solaris_port_event_get_revent(fdevents *ev, size_t ndx) { in fdevent_solaris_port_event_get_revent()
73 static int fdevent_solaris_port_event_get_fd(fdevents *ev, size_t ndx) { in fdevent_solaris_port_event_get_fd()
77 static int fdevent_solaris_port_event_next_fdndx(fdevents *ev, int ndx) { in fdevent_solaris_port_event_next_fdndx()
87 static void fdevent_solaris_port_free(fdevents *ev) { in fdevent_solaris_port_free()
93 static int fdevent_solaris_port_poll(fdevents *ev, int timeout_ms) { in fdevent_solaris_port_poll()
136 int fdevent_solaris_port_init(fdevents *ev) { in fdevent_solaris_port_init()
164 int fdevent_solaris_port_init(fdevents *ev) { in fdevent_solaris_port_init()
|
| H A D | base.h | 576 fdevents *ev, *ev_ins; member
|
| /mOS-networking-stack/core/src/ |
| H A D | scalable_event.c | 35 #define NEWID(id, ev, cb) (id ^ hash64(ev, cb)) argument
57 event_t ev; /* event id = key */ member
67 dforest_store(event_t ev, tree_node_t* ptr) in dforest_store()
94 dforest_search(event_t ev) in dforest_search()
154 tree_search(tree_node_t *root, event_t ev) in tree_search()
243 hash64(event_t ev, callback_t cb) in hash64()
247 event_t ev; in hash64() member
559 UnregCb(kvs_t *store, stree_t **pstree, event_t ev) in UnregCb()
825 tree_node_t *ev = NULL; in RaiseEv() local
828 event_t ev; in RaiseEv() member
[all …]
|
| H A D | event_callback.c | 31 #define EVENT_FOREACH_START(ev, idx, from, to, map) \ argument
34 #define EVENT_FOREACH_END(ev, map) \ argument
684 const uint64_t ev = (1L << ev_idx); in HandleCallback() local
|
| /mOS-networking-stack/samples/common/ |
| H A D | applib.c | 18 strevent(uint64_t ev) in strevent()
48 strcbevent(uint64_t ev) in strcbevent()
|
| /mOS-networking-stack/core/test/scalable_event/ |
| H A D | test.c | 46 cb(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in cb()
53 ft(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in ft()
88 ft_ac_match(mctx_t mctx, int sock, int side, uint64_t ev, filter_arg_t *arg) in ft_ac_match()
138 event_t ev; in main() local
|
| /mOS-networking-stack/samples/epserver/ |
| H A D | epserver-mp.c | 152 struct mtcp_epoll_event ev; in SendUntilAvailable() local
175 struct mtcp_epoll_event ev; in HandleReadEvent() local
274 struct mtcp_epoll_event ev; in AcceptConnection() local
308 struct mtcp_epoll_event ev; in CreateListeningSocket() local
|
| H A D | epserver.c | 153 struct mtcp_epoll_event ev; in SendUntilAvailable() local
176 struct mtcp_epoll_event ev; in HandleReadEvent() local
275 struct mtcp_epoll_event ev; in AcceptConnection() local
309 struct mtcp_epoll_event ev; in CreateListeningSocket() local
|
| /mOS-networking-stack/core/src/include/ |
| H A D | scalable_event.h | 45 event_t ev; // event id member
|
| H A D | eventpoll.h | 22 struct mtcp_epoll_event ev; member
|
| /mOS-networking-stack/samples/epwget/ |
| H A D | epwget-mp.c | 165 struct mtcp_epoll_event ev; in CreateConnection() local
231 struct mtcp_epoll_event ev; in SendHTTPRequest() local
292 struct mtcp_epoll_event ev; in DownloadNext() local
|
| H A D | epwget.c | 166 struct mtcp_epoll_event ev; in CreateConnection() local
232 struct mtcp_epoll_event ev; in SendHTTPRequest() local
293 struct mtcp_epoll_event ev; in DownloadNext() local
|