Searched refs:ev (Results 1 - 25 of 50) sorted by relevance

12

/tldk/app/nginx/src/event/
H A Dngx_event_posted.h17 #define ngx_post_event(ev, q) \
19 if (!(ev)->posted) { \
20 (ev)->posted = 1; \
21 ngx_queue_insert_tail(q, &(ev)->queue); \
23 ngx_log_debug1(NGX_LOG_DEBUG_CORE, (ev)->log, 0, "post event %p", ev);\
26 ngx_log_debug1(NGX_LOG_DEBUG_CORE, (ev)->log, 0, \
27 "update posted event %p", ev); \
31 #define ngx_delete_posted_event(ev) \
33 (ev)
[all...]
H A Dngx_event_timer.h32 ngx_event_del_timer(ngx_event_t *ev) argument
34 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
36 ngx_event_ident(ev->data), ev->timer.key);
38 ngx_rbtree_delete(&ngx_event_timer_rbtree, &ev->timer);
41 ev->timer.left = NULL;
42 ev->timer.right = NULL;
43 ev->timer.parent = NULL;
46 ev->timer_set = 0;
51 ngx_event_add_timer(ngx_event_t *ev, ngx_msec_ argument
[all...]
H A Dngx_event_posted.c21 ngx_event_t *ev; local
26 ev = ngx_queue_data(q, ngx_event_t, queue);
29 "posted event %p", ev);
31 ngx_delete_posted_event(ev);
33 ev->handler(ev);
H A Dngx_event_timer.c56 ngx_event_t *ev; local
76 ev = (ngx_event_t *) ((char *) node - offsetof(ngx_event_t, timer));
78 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
80 ngx_event_ident(ev->data), ev->timer.key);
82 ngx_rbtree_delete(&ngx_event_timer_rbtree, &ev->timer);
85 ev->timer.left = NULL;
86 ev->timer.right = NULL;
87 ev->timer.parent = NULL;
90 ev
102 ngx_event_t *ev; local
[all...]
H A Dngx_event_accept.c23 ngx_event_accept(ngx_event_t *ev) argument
39 if (ev->timedout) {
44 ev->timedout = 0;
50 ev->available = ecf->multi_accept;
53 lc = ev->data;
55 ev->ready = 0;
57 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
58 "accept on %V, ready: %d", &ls->addr_text, ev->available);
77 ngx_log_debug0(NGX_LOG_DEBUG_EVENT, ev->log, err,
92 ngx_log_error(level, ev
322 ngx_event_recvmsg(ngx_event_t *ev) argument
[all...]
H A Dngx_event.h178 ngx_int_t (*add)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags);
179 ngx_int_t (*del)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags);
181 ngx_int_t (*enable)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags);
182 ngx_int_t (*disable)(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags);
506 void ngx_event_accept(ngx_event_t *ev);
508 void ngx_event_recvmsg(ngx_event_t *ev);
520 void ngx_event_acceptex(ngx_event_t *ev);
/tldk/lib/libtle_l4p/
H A Dtle_event.h104 * @param ev
107 void tle_event_free(struct tle_event *ev);
110 tle_event_state(const struct tle_event *ev) argument
112 return ev->state;
117 * @param ev
121 tle_event_raise(struct tle_event *ev) argument
125 if (ev->state != TLE_SEV_DOWN)
128 q = ev->head;
132 if (ev->state == TLE_SEV_DOWN) {
133 ev
146 tle_event_down(struct tle_event *ev) argument
173 tle_event_active(struct tle_event *ev, enum tle_ev_state st) argument
200 tle_event_idle(struct tle_event *ev) argument
220 tle_evq_idle(struct tle_evq *evq, struct tle_event *ev[], uint32_t num) argument
258 struct tle_event *ev; local
[all...]
H A Devent.c88 tle_event_free(struct tle_event *ev) argument
92 if (ev == NULL) {
97 q = ev->head;
99 ev->data = NULL;
100 ev->state = TLE_SEV_IDLE;
101 TAILQ_INSERT_HEAD(&q->free, ev, ql);
H A Dudp_stream.h47 struct tle_event *ev; member in struct:tle_udp_stream::__anon544
59 struct tle_event *ev; member in struct:tle_udp_stream::__anon545
H A Dudp_stream.c265 s->rx.ev = prm->recv_ev;
267 s->tx.ev = prm->send_ev;
271 if (s->tx.ev != NULL)
272 tle_event_raise(s->tx.ev);
298 if (s->rx.ev != NULL) {
299 tle_event_idle(s->rx.ev);
300 s->rx.ev = NULL;
302 if (s->tx.ev != NULL) {
303 tle_event_idle(s->tx.ev);
304 s->tx.ev
[all...]
/tldk/app/nginx/src/os/unix/
H A Dngx_linux_aio_read.c17 static void ngx_file_aio_event_handler(ngx_event_t *ev);
55 ngx_event_t *ev; local
67 ev = &aio->event;
69 if (!ev->ready) {
77 ev->complete, offset, size, &file->name);
79 if (ev->complete) {
80 ev->active = 0;
81 ev->complete = 0;
98 aio->aiocb.aio_data = (uint64_t) (uintptr_t) ev;
107 ev
138 ngx_file_aio_event_handler(ngx_event_t *ev) argument
[all...]
H A Dngx_file_aio_read.c35 ngx_event_t *ev);
36 static void ngx_file_aio_event_handler(ngx_event_t *ev);
66 ngx_event_t *ev; local
78 ev = &aio->event;
80 if (!ev->ready) {
88 ev->complete, offset, size, &file->name);
90 if (ev->complete) {
91 ev->complete = 0;
113 aio->aiocb.aio_sigevent.sigev_value.sigval_ptr = ev;
115 ev
149 ngx_file_aio_result(ngx_file_t *file, ngx_event_aio_t *aio, ngx_event_t *ev) argument
204 ngx_file_aio_event_handler(ngx_event_t *ev) argument
[all...]
/tldk/app/nginx/src/event/modules/
H A Dngx_kqueue_module.c24 static ngx_int_t ngx_kqueue_add_event(ngx_event_t *ev, ngx_int_t event,
26 static ngx_int_t ngx_kqueue_del_event(ngx_event_t *ev, ngx_int_t event,
28 static ngx_int_t ngx_kqueue_set_event(ngx_event_t *ev, ngx_int_t filter,
283 ngx_kqueue_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
291 ev->active = 1;
292 ev->disabled = 0;
293 ev->oneshot = (flags & NGX_ONESHOT_EVENT) ? 1 : 0;
297 if (ev->index < nchanges
298 && ((uintptr_t) change_list[ev->index].udata & (uintptr_t) ~1)
299 == (uintptr_t) ev)
339 ngx_kqueue_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
393 ngx_kqueue_set_event(ngx_event_t *ev, ngx_int_t filter, ngx_uint_t flags) argument
505 ngx_event_t *ev; local
[all...]
H A Dngx_poll_module.c15 static ngx_int_t ngx_poll_add_event(ngx_event_t *ev, ngx_int_t event,
17 static ngx_int_t ngx_poll_del_event(ngx_event_t *ev, ngx_int_t event,
114 ngx_poll_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
119 c = ev->data;
121 ev->active = 1;
123 if (ev->index != NGX_INVALID_INDEX) {
124 ngx_log_error(NGX_LOG_ALERT, ev->log, 0,
125 "poll event fd:%d ev:%i is already set", c->fd, event);
142 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
143 "poll add event: fd:%d ev
166 ngx_poll_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
244 ngx_event_t *ev; local
[all...]
H A Dngx_win32_select_module.c15 static ngx_int_t ngx_select_add_event(ngx_event_t *ev, ngx_int_t event,
17 static ngx_int_t ngx_select_del_event(ngx_event_t *ev, ngx_int_t event,
127 ngx_select_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
131 c = ev->data;
133 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
134 "select add event fd:%d ev:%i", c->fd, event);
136 if (ev->index != NGX_INVALID_INDEX) {
137 ngx_log_error(NGX_LOG_ALERT, ev->log, 0,
138 "select event fd:%d ev:%i is already set", c->fd, event);
142 if ((event == NGX_READ_EVENT && ev
180 ngx_select_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
224 ngx_event_t *ev; local
[all...]
H A Dngx_select_module.c15 static ngx_int_t ngx_select_add_event(ngx_event_t *ev, ngx_int_t event,
17 static ngx_int_t ngx_select_del_event(ngx_event_t *ev, ngx_int_t event,
125 ngx_select_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
129 c = ev->data;
131 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
132 "select add event fd:%d ev:%i", c->fd, event);
134 if (ev->index != NGX_INVALID_INDEX) {
135 ngx_log_error(NGX_LOG_ALERT, ev->log, 0,
136 "select event fd:%d ev:%i is already set", c->fd, event);
140 if ((event == NGX_READ_EVENT && ev
171 ngx_select_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
217 ngx_event_t *ev; local
[all...]
H A Dngx_eventport_module.c139 static ngx_int_t ngx_eventport_add_event(ngx_event_t *ev, ngx_int_t event,
141 static ngx_int_t ngx_eventport_del_event(ngx_event_t *ev, ngx_int_t event,
312 ngx_eventport_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
318 c = ev->data;
341 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
342 "eventport add event: fd:%d ev:%04Xi", c->fd, events);
345 (void *) ((uintptr_t) ev | ev->instance))
348 ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_errno,
353 ev
361 ngx_eventport_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
444 ngx_event_t *ev, *rev, *wev; local
[all...]
H A Dngx_iocp_module.c17 static ngx_int_t ngx_iocp_add_event(ngx_event_t *ev, ngx_int_t event,
194 ngx_iocp_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t key) argument
198 c = (ngx_connection_t *) ev->data;
203 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0,
204 "iocp add: fd:%d k:%ui ov:%p", c->fd, key, &ev->ovlp);
243 ngx_event_t *ev; local
299 ev = ovlp->event;
301 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, err, "iocp event:%p", ev);
314 "iocp: aborted event %p", ev);
328 ev
[all...]
H A Dngx_devpoll_module.c40 static ngx_int_t ngx_devpoll_add_event(ngx_event_t *ev, ngx_int_t event,
42 static ngx_int_t ngx_devpoll_del_event(ngx_event_t *ev, ngx_int_t event,
44 static ngx_int_t ngx_devpoll_set_event(ngx_event_t *ev, ngx_int_t event,
218 ngx_devpoll_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
229 c = ev->data;
230 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
231 "devpoll add event: fd:%d ev:%04Xi", c->fd, event);
234 ev->active = 1;
236 return ngx_devpoll_set_event(ev, event, 0);
241 ngx_devpoll_del_event(ngx_event_t *ev, ngx_int_ argument
291 ngx_devpoll_set_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
[all...]
H A Dngx_epoll_module.c107 static void ngx_epoll_notify_handler(ngx_event_t *ev);
113 static ngx_int_t ngx_epoll_add_event(ngx_event_t *ev, ngx_int_t event,
115 static ngx_int_t ngx_epoll_del_event(ngx_event_t *ev, ngx_int_t event,
127 static void ngx_epoll_eventfd_handler(ngx_event_t *ev);
432 ngx_epoll_notify_handler(ngx_event_t *ev) argument
439 if (++ev->index == NGX_MAX_UINT32_VALUE) {
440 ev->index = 0;
446 ngx_log_debug3(NGX_LOG_DEBUG_EVENT, ev->log, 0,
450 ngx_log_error(NGX_LOG_ALERT, ev->log, err,
455 handler = ev
579 ngx_epoll_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
643 ngx_epoll_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
943 ngx_epoll_eventfd_handler(ngx_event_t *ev) argument
[all...]
/tldk/app/nginx/src/tldk/
H A Dtldk_event.c59 tldk_add_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
64 c = ev->data;
66 FE_TRACE("%s(ev=%p,event=%#lx,flags=%#lx): fd=%d;\n",
67 __func__, ev, event, flags, c->fd);
76 ts->rev = ev;
80 ts->wev = ev;
83 ev->active = 1;
88 tldk_del_event(ngx_event_t *ev, ngx_int_t event, ngx_uint_t flags) argument
93 c = ev->data;
95 FE_TRACE("%s(ev
120 post_event(ngx_event_t *ev, ngx_queue_t *q, ngx_uint_t flags, uint32_t type) argument
[all...]
/tldk/app/nginx/src/os/win32/
H A Dngx_event_log.c20 HANDLE ev; local
79 ev = RegisterEventSource(NULL, "nginx");
96 ReportEvent(ev, EVENTLOG_ERROR_TYPE, 0, 3299, NULL, 9, 0, msgarg, NULL);
98 DeregisterEventSource(ev);
H A Dngx_process_cycle.c65 u_long nev, ev, timeout; local
138 ev = WaitForMultipleObjects(nev, events, 0, timeout);
144 "master WaitForMultipleObjects: %ul", ev);
146 if (ev == WAIT_OBJECT_0) {
164 if (ev == WAIT_OBJECT_0 + 1) {
178 if (ev == WAIT_OBJECT_0 + 2) {
193 if (ev == WAIT_OBJECT_0 + 3) {
219 if (ev > WAIT_OBJECT_0 + 3 && ev < WAIT_OBJECT_0 + nev) {
223 live = ngx_reap_worker(cycle, events[ev]);
575 u_long nev, ev; local
860 u_long ev; local
920 u_long ev; local
1007 HANDLE ev; local
[all...]
/tldk/app/nginx/src/stream/
H A Dngx_stream_return_module.c24 static void ngx_stream_return_write_handler(ngx_event_t *ev);
134 ngx_stream_return_write_handler(ngx_event_t *ev) argument
140 c = ev->data;
143 if (ev->timedout) {
165 if (ngx_handle_write_event(ev, 0) != NGX_OK) {
170 ngx_add_timer(ev, 5000);
/tldk/app/nginx/src/http/
H A Dngx_http_copy_filter_module.c21 static void ngx_http_copy_aio_event_handler(ngx_event_t *ev);
24 static void ngx_http_copy_aio_sendfile_event_handler(ngx_event_t *ev);
30 static void ngx_http_copy_thread_event_handler(ngx_event_t *ev);
187 ngx_http_copy_aio_event_handler(ngx_event_t *ev) argument
193 aio = ev->data;
241 ngx_http_copy_aio_sendfile_event_handler(ngx_event_t *ev) argument
246 aio = ev->data;
251 ev->complete = 0;
310 ngx_http_copy_thread_event_handler(ngx_event_t *ev) argument
315 r = ev
[all...]

Completed in 12 milliseconds

12