Home
last modified time | relevance | path

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

12345678

/f-stack/app/nginx-1.16.1/src/event/
H A Dngx_event_timer.h36 ngx_event_ident(ev->data), ev->timer.key); in ngx_event_del_timer()
41 ev->timer.left = NULL; in ngx_event_del_timer()
42 ev->timer.right = NULL; in ngx_event_del_timer()
43 ev->timer.parent = NULL; in ngx_event_del_timer()
46 ev->timer_set = 0; in ngx_event_del_timer()
58 if (ev->timer_set) { in ngx_event_add_timer()
71 ngx_event_ident(ev->data), ev->timer.key, key); in ngx_event_add_timer()
75 ngx_del_timer(ev); in ngx_event_add_timer()
78 ev->timer.key = key; in ngx_event_add_timer()
82 ngx_event_ident(ev->data), timer, ev->timer.key); in ngx_event_add_timer()
[all …]
H A Dngx_event_posted.h17 #define ngx_post_event(ev, q) \ argument
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) \ argument
33 (ev)->posted = 0; \
34 ngx_queue_remove(&(ev)->queue); \
[all …]
H A Dngx_event_timer.c56 ngx_event_t *ev; in ngx_event_expire_timers() local
78 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0, in ngx_event_expire_timers()
80 ngx_event_ident(ev->data), ev->timer.key); in ngx_event_expire_timers()
85 ev->timer.left = NULL; in ngx_event_expire_timers()
86 ev->timer.right = NULL; in ngx_event_expire_timers()
87 ev->timer.parent = NULL; in ngx_event_expire_timers()
90 ev->timer_set = 0; in ngx_event_expire_timers()
92 ev->timedout = 1; in ngx_event_expire_timers()
94 ev->handler(ev); in ngx_event_expire_timers()
102 ngx_event_t *ev; in ngx_event_no_timers_left() local
[all …]
/f-stack/dpdk/drivers/event/octeontx2/
H A Dotx2_worker.c10 const uint32_t tag = (uint32_t)ev->event; in otx2_ssogws_new_event()
11 const uint8_t new_tt = ev->sched_type; in otx2_ssogws_new_event()
12 const uint64_t event_ptr = ev->u64; in otx2_ssogws_new_event()
13 const uint16_t grp = ev->queue_id; in otx2_ssogws_new_event()
64 const uint8_t grp = ev->queue_id; in otx2_ssogws_forward_event()
68 otx2_ssogws_fwd_swtag(ws, ev); in otx2_ssogws_forward_event()
198 struct rte_event ev[], \
216 switch (ev->op) { in otx2_ssogws_enq()
315 struct rte_event ev; in ssogws_flush_events() local
335 if (fn != NULL && ev.u64 != 0) in ssogws_flush_events()
[all …]
H A Dotx2_worker_dual.c10 const struct rte_event *ev) in otx2_ssogws_dual_new_event() argument
13 const uint8_t new_tt = ev->sched_type; in otx2_ssogws_dual_new_event()
14 const uint64_t event_ptr = ev->u64; in otx2_ssogws_dual_new_event()
15 const uint16_t grp = ev->queue_id; in otx2_ssogws_dual_new_event()
27 const struct rte_event *ev) in otx2_ssogws_dual_fwd_swtag() argument
66 const uint8_t grp = ev->queue_id; in otx2_ssogws_dual_forward_event()
88 switch (ev->op) { in otx2_ssogws_dual_enq()
202 ev, flags, \
213 struct rte_event ev[], \
262 struct rte_event *ev, \
[all …]
H A Dotx2_evdev_selftest.c265 ev->mbuf = m; in update_event_and_validation_attr()
295 struct rte_event ev; in check_excess_events() local
371 struct rte_event ev; in consume_events() local
886 ev.flow_id = 0x2; in worker_flow_based_pipeline()
1204 ev.sched_type = in worker_flow_based_pipeline_max_stages_rand_sched_type()
1280 ev.queue_id++; in worker_queue_based_pipeline_max_stages_rand_sched_type()
1281 ev.sched_type = in worker_queue_based_pipeline_max_stages_rand_sched_type()
1324 ev.queue_id++; in worker_mixed_pipeline_max_stages_rand_sched_type()
1326 ev.sched_type = in worker_mixed_pipeline_max_stages_rand_sched_type()
1367 ev.queue_id = 0; in worker_ordered_flow_producer()
[all …]
/f-stack/dpdk/app/test-eventdev/
H A Dtest_pipeline_queue.c35 ev.queue_id++; in pipeline_queue_worker_single_stage_tx()
58 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_queue_worker_single_stage_fwd()
89 ev[i].queue_id++; in pipeline_queue_worker_single_stage_burst_tx()
118 ev[i].queue_id = tx_queue[ev[i].mbuf->port]; in pipeline_queue_worker_single_stage_burst_fwd()
147 if (ev.queue_id == tx_queue[ev.mbuf->port]) { in pipeline_queue_worker_multi_stage_tx()
153 ev.queue_id++; in pipeline_queue_worker_multi_stage_tx()
180 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_queue_worker_multi_stage_fwd()
185 ev.queue_id++; in pipeline_queue_worker_multi_stage_fwd()
214 if (ev[i].queue_id == tx_queue[ev[i].mbuf->port]) { in pipeline_queue_worker_multi_stage_burst_tx()
221 ev[i].queue_id++; in pipeline_queue_worker_multi_stage_burst_tx()
[all …]
H A Dtest_pipeline_atq.c52 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_atq_worker_single_stage_fwd()
76 rte_prefetch0(ev[i + 1].mbuf); in pipeline_atq_worker_single_stage_burst_tx()
105 ev[i].queue_id = tx_queue[ev[i].mbuf->port]; in pipeline_atq_worker_single_stage_burst_fwd()
137 ev.sub_event_type++; in pipeline_atq_worker_multi_stage_tx()
162 ev.queue_id = tx_queue[ev.mbuf->port]; in pipeline_atq_worker_multi_stage_fwd()
166 ev.sub_event_type++; in pipeline_atq_worker_multi_stage_fwd()
201 ev[i].sub_event_type++; in pipeline_atq_worker_multi_stage_burst_tx()
232 ev[i].queue_id = tx_queue[ev[i].mbuf->port]; in pipeline_atq_worker_multi_stage_burst_fwd()
233 pipeline_fwd_event(&ev[i], in pipeline_atq_worker_multi_stage_burst_fwd()
236 ev[i].sub_event_type++; in pipeline_atq_worker_multi_stage_burst_fwd()
[all …]
H A Dtest_order_atq.c16 ev->op = RTE_EVENT_OP_FORWARD; in order_atq_process_stage_0()
17 ev->sched_type = RTE_SCHED_TYPE_ATOMIC; in order_atq_process_stage_0()
18 ev->event_type = RTE_EVENT_TYPE_CPU; in order_atq_process_stage_0()
25 struct rte_event ev; in order_atq_worker() local
29 &ev, 1, 0); in order_atq_worker()
41 order_atq_process_stage_0(&ev); in order_atq_worker()
49 order_process_stage_invalid(t, &ev); in order_atq_worker()
59 struct rte_event ev[BURST_SIZE]; in order_atq_worker_burst() local
78 order_atq_process_stage_0(&ev[i]); in order_atq_worker_burst()
82 ev[i].op = RTE_EVENT_OP_RELEASE; in order_atq_worker_burst()
[all …]
H A Dtest_order_queue.c15 ev->queue_id = 1; /* q1 atomic queue */ in order_queue_process_stage_0()
16 ev->op = RTE_EVENT_OP_FORWARD; in order_queue_process_stage_0()
17 ev->sched_type = RTE_SCHED_TYPE_ATOMIC; in order_queue_process_stage_0()
18 ev->event_type = RTE_EVENT_TYPE_CPU; in order_queue_process_stage_0()
25 struct rte_event ev; in order_queue_worker() local
29 &ev, 1, 0); in order_queue_worker()
38 order_flow_id_copy_from_mbuf(t, &ev); in order_queue_worker()
41 order_queue_process_stage_0(&ev); in order_queue_worker()
59 struct rte_event ev[BURST_SIZE]; in order_queue_worker_burst() local
83 ev[i].op = RTE_EVENT_OP_RELEASE; in order_queue_worker_burst()
[all …]
H A Dtest_perf_atq.c31 ev->sub_event_type++; in atq_fwd_event()
32 ev->sched_type = sched_type_list[ev->sub_event_type % nb_stages]; in atq_fwd_event()
33 ev->op = RTE_EVENT_OP_FORWARD; in atq_fwd_event()
34 ev->event_type = RTE_EVENT_TYPE_CPU; in atq_fwd_event()
41 struct rte_event ev; in perf_atq_worker() local
53 atq_mark_fwd_latency(&ev); in perf_atq_worker()
59 &ev, w, bufs, sz, cnt); in perf_atq_worker()
95 atq_mark_fwd_latency(&ev[i]); in perf_atq_worker_burst()
105 &ev[i], w, bufs, sz, cnt); in perf_atq_worker_burst()
107 ev[i].op = RTE_EVENT_OP_RELEASE; in perf_atq_worker_burst()
[all …]
H A Dtest_perf_queue.c33 ev->queue_id++; in fwd_event()
34 ev->sched_type = sched_type_list[ev->queue_id % nb_stages]; in fwd_event()
35 ev->op = RTE_EVENT_OP_FORWARD; in fwd_event()
36 ev->event_type = RTE_EVENT_TYPE_CPU; in fwd_event()
43 struct rte_event ev; in perf_queue_worker() local
54 mark_fwd_latency(&ev, nb_stages); in perf_queue_worker()
60 &ev, w, bufs, sz, cnt); in perf_queue_worker()
63 &ev, w, bufs, sz, cnt); in perf_queue_worker()
106 &ev[i], w, bufs, sz, cnt); in perf_queue_worker_burst()
108 ev[i].op = RTE_EVENT_OP_RELEASE; in perf_queue_worker_burst()
[all …]
/f-stack/app/nginx-1.16.1/src/event/modules/
H A Dngx_kqueue_module.c302 ev->active = 1; in ngx_kqueue_add_event()
303 ev->disabled = 0; in ngx_kqueue_add_event()
333 c = ev->data; in ngx_kqueue_add_event()
355 ev->active = 0; in ngx_kqueue_del_event()
356 ev->disabled = 0; in ngx_kqueue_del_event()
410 c = ev->data; in ngx_kqueue_set_event()
438 kev->udata = NGX_KQUEUE_UDATA_T ((uintptr_t) ev | ev->instance); in ngx_kqueue_set_event()
628 ev = (ngx_event_t *) ((uintptr_t) ev & (uintptr_t) ~1); in ngx_kqueue_process_events()
630 if (ev->closed || ev->instance != instance) { in ngx_kqueue_process_events()
642 if (ev->log && (ev->log->log_level & NGX_LOG_DEBUG_CONNECTION)) { in ngx_kqueue_process_events()
[all …]
H A Dngx_poll_module.c119 c = ev->data; in ngx_poll_add_event()
121 ev->active = 1; in ngx_poll_add_event()
150 ev->index = nevents; in ngx_poll_add_event()
158 ev->index = e->index; in ngx_poll_add_event()
171 c = ev->data; in ngx_poll_del_event()
173 ev->active = 0; in ngx_poll_del_event()
244 ngx_event_t *ev; in ngx_poll_process_events() local
371 ev = c->read; in ngx_poll_process_events()
372 ev->ready = 1; in ngx_poll_process_events()
383 ev = c->write; in ngx_poll_process_events()
[all …]
H A Dngx_win32_select_module.c132 c = ev->data; in ngx_select_add_event()
170 ev->active = 1; in ngx_select_add_event()
173 ev->index = nevents; in ngx_select_add_event()
186 c = ev->data; in ngx_select_del_event()
188 ev->active = 0; in ngx_select_del_event()
225 ngx_event_t *ev; in ngx_select_process_events() local
234 c = ev->data; in ngx_select_process_events()
306 ev = event_index[i]; in ngx_select_process_events()
307 c = ev->data; in ngx_select_process_events()
310 if (ev->write) { in ngx_select_process_events()
[all …]
H A Dngx_win32_poll_module.c138 c = ev->data; in ngx_poll_add_event()
140 ev->active = 1; in ngx_poll_add_event()
172 ev->index = nevents; in ngx_poll_add_event()
180 ev->index = e->index; in ngx_poll_add_event()
193 c = ev->data; in ngx_poll_del_event()
195 ev->active = 0; in ngx_poll_del_event()
267 ngx_event_t *ev; in ngx_poll_process_events() local
381 ev = c->read; in ngx_poll_process_events()
382 ev->ready = 1; in ngx_poll_process_events()
393 ev = c->write; in ngx_poll_process_events()
[all …]
H A Dngx_select_module.c131 c = ev->data; in ngx_select_add_event()
162 ev->active = 1; in ngx_select_add_event()
165 ev->index = nevents; in ngx_select_add_event()
178 c = ev->data; in ngx_select_del_event()
180 ev->active = 0; in ngx_select_del_event()
219 ngx_event_t *ev; in ngx_select_process_events() local
240 c = ev->data; in ngx_select_process_events()
318 ev = event_index[i]; in ngx_select_process_events()
319 c = ev->data; in ngx_select_process_events()
322 if (ev->write) { in ngx_select_process_events()
[all …]
/f-stack/dpdk/drivers/event/octeontx/
H A Dssovf_evdev_selftest.c286 ev->mbuf = m; in update_event_and_validation_attr()
316 struct rte_event ev; in check_excess_events() local
392 struct rte_event ev; in consume_events() local
902 ev.flow_id = 0x2; in worker_flow_based_pipeline()
1217 ev.sched_type = in worker_flow_based_pipeline_max_stages_rand_sched_type()
1291 ev.queue_id++; in worker_queue_based_pipeline_max_stages_rand_sched_type()
1292 ev.sched_type = in worker_queue_based_pipeline_max_stages_rand_sched_type()
1333 ev.queue_id++; in worker_mixed_pipeline_max_stages_rand_sched_type()
1335 ev.sched_type = in worker_mixed_pipeline_max_stages_rand_sched_type()
1375 ev.queue_id = 0; in worker_ordered_flow_producer()
[all …]
H A Dssovf_worker.c10 const uint64_t event_ptr = ev->u64; in ssows_new_event()
13 const uint8_t grp = ev->queue_id; in ssows_new_event()
157 switch (ev->op) { in ssows_enq()
160 ssows_new_event(ws, ev); in ssows_enq()
210 struct rte_event ev; in ssows_flush_events() local
244 ev.u64 = get_work1; in ssows_flush_events()
247 fn(arg, ev); in ssows_flush_events()
286 switch (ev->sched_type) { in __sso_event_tx_adapter_enqueue()
293 ssows_swtag_full(ws, ev->u64, ev->event, SSO_SYNC_ATOMIC, in __sso_event_tx_adapter_enqueue()
294 ev->queue_id); in __sso_event_tx_adapter_enqueue()
[all …]
/f-stack/dpdk/examples/eventdev_pipeline/
H A Dpipeline_worker_tx.c14 ev->sched_type = sched; in worker_fwd_event()
19 struct rte_event *ev) in worker_event_enqueue() argument
41 exchange_mac(ev->mbuf); in worker_tx_pkt()
56 struct rte_event ev; in worker_do_tx_single() local
72 ev.queue_id++; in worker_do_tx_single()
92 struct rte_event ev; in worker_do_tx_single_atq() local
150 ev[i].queue_id++; in worker_do_tx_single_burst()
243 cdata.next_qid[ev.queue_id] : ev.queue_id; in worker_do_tx()
245 ev.queue_id = cdata.next_qid[ev.queue_id]; in worker_do_tx()
341 ev[i].queue_id; in worker_do_tx_burst()
[all …]
/f-stack/app/nginx-1.16.1/src/os/unix/
H A Dngx_file_aio_read.c35 ngx_event_t *ev);
78 ev = &aio->event; in ngx_file_aio_read()
80 if (!ev->ready) { in ngx_file_aio_read()
90 if (ev->complete) { in ngx_file_aio_read()
140 ev->active = 1; in ngx_file_aio_read()
141 ev->ready = 0; in ngx_file_aio_read()
142 ev->complete = 0; in ngx_file_aio_read()
184 ev->ready = 1; in ngx_file_aio_result()
193 ev->ready = 1; in ngx_file_aio_result()
194 ev->active = 0; in ngx_file_aio_result()
[all …]
H A Dngx_linux_aio_read.c55 ngx_event_t *ev; in ngx_file_aio_read() local
67 ev = &aio->event; in ngx_file_aio_read()
69 if (!ev->ready) { in ngx_file_aio_read()
79 if (ev->complete) { in ngx_file_aio_read()
80 ev->active = 0; in ngx_file_aio_read()
81 ev->complete = 0; in ngx_file_aio_read()
112 ev->active = 1; in ngx_file_aio_read()
113 ev->ready = 0; in ngx_file_aio_read()
114 ev->complete = 0; in ngx_file_aio_read()
142 aio = ev->data; in ngx_file_aio_event_handler()
[all …]
/f-stack/dpdk/app/test/
H A Dtest_event_timer_adapter.c390 struct rte_event ev; in test_timer_state() local
392 .ev.op = RTE_EVENT_OP_NEW, in test_timer_state()
393 .ev.queue_id = 0, in test_timer_state()
449 .ev.op = RTE_EVENT_OP_NEW, in _arm_timers()
450 .ev.queue_id = 0, in _arm_timers()
481 struct rte_event ev; in _wait_timer_triggers() local
551 .ev.queue_id = 0, in _arm_timers_burst()
620 .ev.queue_id = 0, in test_timer_cancel()
662 .ev.queue_id = 0, in _cancel_producer()
701 .ev.queue_id = 0, in _cancel_producer_burst()
[all …]
/f-stack/dpdk/drivers/event/dlb/
H A Ddlb_selftest.c223 ev.queue_id = 0; in test_stop_flush()
235 ev.queue_id = 1; in test_stop_flush()
868 ev.queue_id = 0; in test_load_balanced_traffic()
869 ev.priority = 0; in test_load_balanced_traffic()
870 ev.u64 = 0; in test_load_balanced_traffic()
995 ev.queue_id = 0; in test_directed_traffic()
996 ev.priority = 0; in test_directed_traffic()
997 ev.u64 = 0; in test_directed_traffic()
1157 ev.u64 = 0; in test_deferred_sched()
1302 ev.u64 = 0; in test_delayed_pop()
[all …]
/f-stack/dpdk/examples/performance-thread/common/
H A Dlthread_diag.h43 #define DIAG_CREATE_EVENT(obj, ev) do { \ argument
45 if ((BIT(ev) & diag_mask) && (ev < LT_DIAG_EVENT_MAX)) { \
48 (ev), \
50 diag_event_text[(ev)], \
68 #define DIAG_EVENT(obj, ev, p1, p2) do { \ argument
70 if ((BIT(ev) & diag_mask) && (ev < LT_DIAG_EVENT_MAX)) { \
73 ev, \
75 diag_event_text[(ev)], \
95 #define DIAG_CREATE_EVENT(obj, ev) argument
96 #define DIAG_EVENT(obj, ev, p1, p) argument

12345678