Home
last modified time | relevance | path

Searched refs:ev (Results 1 – 25 of 36) sorted by relevance

12

/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dfdevent.c19 ev = calloc(1, sizeof(*ev)); in fdevent_init()
97 if (ev->free) ev->free(ev); in fdevent_free()
100 if (ev->fdarray[i]) free(ev->fdarray[i]); in fdevent_free()
110 if (ev->reset) return ev->reset(ev); in fdevent_reset()
172 if (ev->event_del) fde = ev->event_del(ev, fde, fd); in fdevent_event_del()
185 if (ev->event_set) fde = ev->event_set(ev, fde, fd, events); in fdevent_event_set()
197 return ev->poll(ev, timeout_ms); in fdevent_poll()
205 return ev->event_get_revent(ev, ndx); in fdevent_event_get_revent()
213 return ev->event_get_fd(ev, ndx); in fdevent_event_get_fd()
250 if ((ev) && (ev->fcntl_set)) return ev->fcntl_set(ev, fd); in fdevent_fcntl_set()
[all …]
H A Dfdevent_poll.c25 if (ev->unused.ptr) free(ev->unused.ptr); in fdevent_poll_free()
46 ev->unused.ptr = malloc(sizeof(*(ev->unused.ptr)) * ev->unused.size); in fdevent_poll_event_del()
49 ev->unused.ptr = realloc(ev->unused.ptr, sizeof(*(ev->unused.ptr)) * ev->unused.size); in fdevent_poll_event_del()
52 ev->unused.ptr[ev->unused.used++] = k; in fdevent_poll_event_del()
70 for (j = ev->used - 1; j + 1 > 0 && ev->pollfds[j].fd == -1; j--) ev->used--;
95 int k = ev->unused.ptr[--ev->unused.used]; in fdevent_poll_event_set()
104 ev->pollfds = malloc(sizeof(*ev->pollfds) * ev->size); in fdevent_poll_event_set()
105 } else if (ev->size == ev->used) { in fdevent_poll_event_set()
107 ev->pollfds = realloc(ev->pollfds, sizeof(*ev->pollfds) * ev->size); in fdevent_poll_event_set()
110 ev->pollfds[ev->used].fd = fd; in fdevent_poll_event_set()
[all …]
H A Dfdevent_select.c19 FD_ZERO(&(ev->select_set_read)); in fdevent_select_reset()
20 FD_ZERO(&(ev->select_set_write)); in fdevent_select_reset()
22 ev->select_max_fd = -1; in fdevent_select_reset()
55 if (fd > ev->select_max_fd) ev->select_max_fd = fd; in fdevent_select_event_set()
66 ev->select_read = ev->select_set_read; in fdevent_select_poll()
67 ev->select_write = ev->select_set_write; in fdevent_select_poll()
68 ev->select_error = ev->select_set_error; in fdevent_select_poll()
70 …return select(ev->select_max_fd + 1, &(ev->select_read), &(ev->select_write), &(ev->select_error),… in fdevent_select_poll()
90 UNUSED(ev); in fdevent_select_event_get_fd()
112 ev->x = fdevent_select_##x; in fdevent_select_init()
[all …]
H A Dfdevent_libmtcp.c22 mtcp_close(ev->srv->mctx, ev->epoll_fd); in fdevent_libmtcp_epoll_free()
23 free(ev->_epoll_events); in fdevent_libmtcp_epoll_free()
38 if (0 != mtcp_epoll_ctl(ev->srv->mctx, ev->epoll_fd, MOS_EPOLL_CTL_DEL, fd, NULL/*&ep*/)) { in fdevent_libmtcp_epoll_event_del()
92 return mtcp_epoll_wait(ev->srv->mctx, ev->epoll_fd, ev->_epoll_events, in fdevent_libmtcp_epoll_poll()
93 ev->maxfds, timeout_ms); in fdevent_libmtcp_epoll_poll()
101 e = ev->_epoll_events[ndx].events; in fdevent_libmtcp_epoll_event_get_revent()
122 UNUSED(ev); in fdevent_libmtcp_epoll_event_next_fdndx()
147 if (-1 == (ev->epoll_fd = mtcp_epoll_create(ev->srv->mctx, ev->srv->max_conns * 3))) { in fdevent_libmtcp_epoll_init()
154 ev->_epoll_events = calloc(ev->srv->max_conns * 3, in fdevent_libmtcp_epoll_init()
156 if (NULL == ev->_epoll_events) { in fdevent_libmtcp_epoll_init()
[all …]
H A Dfdevent_solaris_devpoll.c20 free(ev->devpollfds); in fdevent_solaris_devpoll_free()
21 close(ev->devpoll_fd); in fdevent_solaris_devpoll_free()
74 dopoll.dp_nfds = ev->maxfds - 1; in fdevent_solaris_devpoll_poll()
75 dopoll.dp_fds = ev->devpollfds; in fdevent_solaris_devpoll_poll()
101 return ev->devpollfds[ndx].fd; in fdevent_solaris_devpoll_event_get_fd()
107 UNUSED(ev); in fdevent_solaris_devpoll_event_next_fdndx()
128 close(ev->devpoll_fd); in fdevent_solaris_devpoll_reset()
150 ev->devpollfds = malloc(sizeof(*ev->devpollfds) * ev->maxfds); in fdevent_solaris_devpoll_init()
160 close(ev->devpoll_fd); in fdevent_solaris_devpoll_init()
162 ev->devpoll_fd = -1; in fdevent_solaris_devpoll_init()
[all …]
H A Dfdevent_linux_sysepoll.c20 close(ev->epoll_fd); in fdevent_linux_sysepoll_free()
21 free(ev->epoll_events); in fdevent_linux_sysepoll_free()
86 return epoll_wait(ev->epoll_fd, ev->epoll_events, ev->maxfds, timeout_ms); in fdevent_linux_sysepoll_poll()
92 e = ev->epoll_events[ndx].events; in fdevent_linux_sysepoll_event_get_revent()
108 return ev->epoll_events[ndx].data.fd; in fdevent_linux_sysepoll_event_get_fd()
114 UNUSED(ev); in fdevent_linux_sysepoll_event_next_fdndx()
124 ev->x = fdevent_linux_sysepoll_##x; in fdevent_linux_sysepoll_init()
136 if (-1 == (ev->epoll_fd = epoll_create(ev->maxfds))) { in fdevent_linux_sysepoll_init()
147 close(ev->epoll_fd); in fdevent_linux_sysepoll_init()
152 ev->epoll_events = malloc(ev->maxfds * sizeof(*ev->epoll_events)); in fdevent_linux_sysepoll_init()
[all …]
H A Dfdevent_solaris_port.c62 e = ev->port_events[ndx].portev_events; in fdevent_solaris_port_event_get_revent()
80 UNUSED(ev); in fdevent_solaris_port_event_next_fdndx()
88 close(ev->port_fd); in fdevent_solaris_port_free()
89 free(ev->port_events); in fdevent_solaris_port_free()
105 if ((ret = port_getn(ev->port_fd, ev->port_events, 0, &wait_for_events, &timeout)) < 0) return ret; in fdevent_solaris_port_poll()
113 if ((ret = port_getn(ev->port_fd, ev->port_events, ev->maxfds, &available_events, &timeout)) < 0) { in fdevent_solaris_port_poll()
122 if ((ret = port_associate(ev->port_fd, PORT_SOURCE_FD, ev->port_events[i].portev_object, in fdevent_solaris_port_poll()
137 ev->type = FDEVENT_HANDLER_SOLARIS_PORT; in fdevent_solaris_port_init()
139 ev->x = fdevent_solaris_port_##x; in fdevent_solaris_port_init()
158 ev->port_events = malloc(ev->maxfds * sizeof(*ev->port_events)); in fdevent_solaris_port_init()
[all …]
H A Dfdevent_freebsd_kqueue.c20 close(ev->kq_fd); in fdevent_freebsd_kqueue_free()
21 free(ev->kq_results); in fdevent_freebsd_kqueue_free()
48 ret = kevent(ev->kq_fd, in fdevent_freebsd_kqueue_event_del()
95 ret = kevent(ev->kq_fd, in fdevent_freebsd_kqueue_event_set()
119 ev->kq_results, ev->maxfds, in fdevent_freebsd_kqueue_poll()
166 UNUSED(ev); in fdevent_freebsd_kqueue_event_next_fdndx()
199 ev->kq_fd = -1; in fdevent_freebsd_kqueue_init()
201 ev->kq_results = calloc(ev->maxfds, sizeof(*ev->kq_results)); in fdevent_freebsd_kqueue_init()
212 close(ev->kq_fd); in fdevent_freebsd_kqueue_init()
213 ev->kq_fd = -1; in fdevent_freebsd_kqueue_init()
[all …]
H A Dfdevent_libev.c12 fdevents *ev = w->data; in io_watcher_cb() local
13 fdnode *fdn = ev->fdarray[w->fd]; in io_watcher_cb()
38 UNUSED(ev); in fdevent_libev_free()
47 fdn = ev->fdarray[fd]; in fdevent_libev_event_del()
73 watcher->data = ev; in fdevent_libev_event_set()
108 UNUSED(ev); in fdevent_libev_event_get_revent()
115 UNUSED(ev); in fdevent_libev_event_get_fd()
122 UNUSED(ev); in fdevent_libev_event_next_fdndx()
129 UNUSED(ev); in fdevent_libev_reset()
139 ev->x = fdevent_libev_##x; in fdevent_libev_init()
[all …]
H A Dfdevent.h167 int (*reset)(struct fdevents *ev);
168 void (*free)(struct fdevents *ev);
184 void fdevent_free(fdevents *ev);
198 int fdevent_unregister(fdevents *ev, int fd);
200 int fdevent_fcntl_set(fdevents *ev, int fd);
202 int fdevent_select_init(fdevents *ev);
203 int fdevent_poll_init(fdevents *ev);
204 int fdevent_linux_sysepoll_init(fdevents *ev);
206 int fdevent_solaris_port_init(fdevents *ev);
208 int fdevent_libev_init(fdevents *ev);
[all …]
H A Dserver.c327 fdevent_unregister(srv->ev, srv->fd); in server_free()
329 fdevent_free(srv->ev); in server_free()
478 if (-1 == fdevent_fcntl_set(srv->ev, srv_socket->fd)) { in initialize_fd_framework()
882 fdevent_unregister(srv->ev, srv_socket->fd); in start_server()
938 if ((n = fdevent_poll(srv->ev, -1/*1000*/)) > 0) { in start_server()
960 handler = fdevent_get_handler(srv->ev, fd); in start_server()
961 context = fdevent_get_context(srv->ev, fd); in start_server()
2118 fdevent_unregister(srv->ev, srv_socket->fd); in main()
2170 if ((n = fdevent_poll(srv->ev, 1000)) > 0) { in main()
2192 handler = fdevent_get_handler(srv->ev, fd); in main()
[all …]
H A Dmod_cgi.c539 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in cgi_connection_close()
540 fdevent_unregister(srv->ev, hctx->fd); in cgi_connection_close()
1176 fdevent_register(srv->ev, hctx->fd, cgi_handle_fdevent, hctx); in cgi_create_env()
1177 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_IN); in cgi_create_env()
1179 if (-1 == fdevent_fcntl_set(srv->ev, hctx->fd)) { in cgi_create_env()
1182 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in cgi_create_env()
1183 fdevent_unregister(srv->ev, hctx->fd); in cgi_create_env()
1384 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in SUBREQUEST_FUNC()
1385 fdevent_unregister(srv->ev, hctx->fd); in SUBREQUEST_FUNC()
1416 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in SUBREQUEST_FUNC()
[all …]
H A Dmod_proxy.c345 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in proxy_connection_close()
346 fdevent_unregister(srv->ev, hctx->fd); in proxy_connection_close()
791 fdevent_register(srv->ev, hctx->fd, proxy_handle_fdevent, hctx); in proxy_write_request()
793 if (-1 == fdevent_fcntl_set(srv->ev, hctx->fd)) { in proxy_write_request()
805 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_OUT); in proxy_write_request()
845 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in proxy_write_request()
846 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_IN); in proxy_write_request()
848 fdevent_event_set(srv->ev, &(hctx->fde_ndx), hctx->fd, FDEVENT_OUT); in proxy_write_request()
1007 fdevent_event_del(srv->ev, &(hctx->fde_ndx), hctx->fd); in proxy_handle_fdevent()
H A Dnetwork.c539 fdevent_event_del(srv->ev, &(srv_socket->fde_ndx), srv_socket->fd);
540 fdevent_unregister(srv->ev, srv_socket->fd);
565 fdevent_event_del(srv->ev, &(srv_socket->fde_ndx), srv_socket->fd);
566 fdevent_unregister(srv->ev, srv_socket->fd);
981 if (-1 == fdevent_reset(srv->ev)) {
989 fdevent_register(srv->ev, srv_socket->fd, network_server_handle_fdevent, srv_socket);
990 fdevent_event_set(srv->ev, &(srv_socket->fde_ndx), srv_socket->fd, FDEVENT_IN);
/mOS-networking-stack/core/src/
H A Devent_callback.c33 const event_t ev = 1L << idx; if (!((map) & (ev))) continue;
164 if (events & ev) { in RegCbWCpy()
167 if (!(ev & overlap)) in RegCbWCpy()
178 new_evt->map |= ev; in RegCbWCpy()
191 if (events & ev) { in RegCbWCpy()
238 if (events & ev) { in RegCbWoCpy()
258 if (events & ev) { in RegCbWoCpy()
319 evt->map &= ~ev; in UnregCb()
327 evt->map &= ~ev; in UnregCb()
346 if (ev & events) { in FindReusableEvT()
[all …]
H A Dscalable_event.c35 #define NEWID(id, ev, cb) (id ^ hash64(ev, cb)) argument
76 de->ev = ev; in dforest_store()
106 if (p->ev == ev) in dforest_search()
160 if (walk->ev == ev) { in tree_search()
251 instance.ev = ev; in hash64()
294 ntn->ev = w->ev; in create_spine()
305 ntn->ev = w->ev; in create_spine()
456 if (sptr && w2->ev == next_sptr->ev) { in RegCb()
492 if (sptr && w->ev == sptr->ev) { in RegCb()
506 ntn->ev = w->ev; in RegCb()
[all …]
H A Deventpoll.c473 events[cnt++] = eq->events[eq->start].ev; in mtcp_epoll_wait()
479 EventToString(eq->events[eq->start].ev.events), in mtcp_epoll_wait()
485 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()
511 events[cnt++] = eq->events[eq->start].ev; in mtcp_epoll_wait()
517 EventToString(eq->events[eq->start].ev.events), in mtcp_epoll_wait()
523 EventToString(eq->events[eq->start].ev.events)); 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()
587 eq->events[index].ev.data = socket->ep_data; in AddEpollEvent()
[all …]
/mOS-networking-stack/core/test/scalable_event/
H A Dtest.c24 ModCb(kvs_t *store, stree_t **pstree, event_t ev, callback_t cb);
46 cb(mctx_t mctx, int sock, int side, event_t ev, filter_arg_t *arg) in cb() argument
138 event_t ev; in main() local
169 ev = mtcp_define_event(BEV4, ft_prob, NULL); in main()
173 for (ev = g_first_ev; g_depth != 1 && ev != MOS_NULL_EVENT; ev++) { in main()
176 nev = mtcp_define_event(ev, ft_prob, NULL); in main()
178 nev = mtcp_define_event(ev, ft_prob, NULL); in main()
187 if (ev == MOS_NULL_EVENT) { in main()
210 for (ev = g_first_ev; ev != g_last_ev; ev++) in main()
211 ModCb(mtcp.ev_store, &stree[3], ev, cb); in main()
[all …]
/mOS-networking-stack/samples/epserver/
H A Depserver-mp.c152 struct mtcp_epoll_event ev; in SendUntilAvailable() local
158 ev.events = MOS_EPOLLIN; in SendUntilAvailable()
159 ev.data.sock = sockid; in SendUntilAvailable()
175 struct mtcp_epoll_event ev; in HandleReadEvent() local
261 ev.data.sock = sockid; in HandleReadEvent()
274 struct mtcp_epoll_event ev; in AcceptConnection() local
288 ev.events = MOS_EPOLLIN; in AcceptConnection()
289 ev.data.sock = c; in AcceptConnection()
308 struct mtcp_epoll_event ev; in CreateListeningSocket() local
343 ev.events = MOS_EPOLLIN; in CreateListeningSocket()
[all …]
H A Depserver.c153 struct mtcp_epoll_event ev; in SendUntilAvailable() local
159 ev.events = MOS_EPOLLIN; in SendUntilAvailable()
160 ev.data.sock = sockid; in SendUntilAvailable()
176 struct mtcp_epoll_event ev; in HandleReadEvent() local
262 ev.data.sock = sockid; in HandleReadEvent()
275 struct mtcp_epoll_event ev; in AcceptConnection() local
289 ev.events = MOS_EPOLLIN; in AcceptConnection()
290 ev.data.sock = c; in AcceptConnection()
309 struct mtcp_epoll_event ev; in CreateListeningSocket() local
344 ev.events = MOS_EPOLLIN; in CreateListeningSocket()
[all …]
/mOS-networking-stack/samples/common/
H A Dapplib.c18 strevent(uint64_t ev) in strevent() argument
20 switch (ev) { in strevent()
48 strcbevent(uint64_t ev) in strcbevent() argument
50 switch (ev) { in strcbevent()
H A Dapplib.h39 strevent(uint64_t ev);
42 strcbevent(uint64_t ev);
/mOS-networking-stack/samples/epwget/
H A Depwget.c166 struct mtcp_epoll_event ev; in CreateConnection() local
205 ev.events = MOS_EPOLLOUT; in CreateConnection()
206 ev.data.sock = sockid; in CreateConnection()
207 mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_ADD, sockid, &ev); in CreateConnection()
232 struct mtcp_epoll_event ev; in SendHTTPRequest() local
269 ev.events = MOS_EPOLLIN; in SendHTTPRequest()
270 ev.data.sock = sockid; in SendHTTPRequest()
293 struct mtcp_epoll_event ev; in DownloadNext() local
326 ev.events = MOS_EPOLLOUT; in DownloadNext()
327 ev.data.sock = sockid; in DownloadNext()
[all …]
H A Depwget-mp.c165 struct mtcp_epoll_event ev; in CreateConnection() local
204 ev.events = MOS_EPOLLOUT; in CreateConnection()
205 ev.data.sock = sockid; in CreateConnection()
206 mtcp_epoll_ctl(mctx, ctx->ep, MOS_EPOLL_CTL_ADD, sockid, &ev); in CreateConnection()
231 struct mtcp_epoll_event ev; in SendHTTPRequest() local
268 ev.events = MOS_EPOLLIN; in SendHTTPRequest()
269 ev.data.sock = sockid; in SendHTTPRequest()
292 struct mtcp_epoll_event ev; in DownloadNext() local
325 ev.events = MOS_EPOLLOUT; in DownloadNext()
326 ev.data.sock = sockid; in DownloadNext()
[all …]
/mOS-networking-stack/core/src/include/
H A Deventpoll.h22 struct mtcp_epoll_event ev; member

12