| /dports/devel/aws-c-io/aws-c-io-0.10.12/tests/vcc/ |
| H A D | new_destroy.c | 112 struct epoll_loop *epoll_loop = aws_mem_calloc(alloc, 1, sizeof(struct epoll_loop)); in aws_event_loop_new_default_with_options() local
113 if (!epoll_loop) { in aws_event_loop_new_default_with_options()
193 epoll_loop->task_pre_queue_mutex.protected_obj = &epoll_loop->task_pre_queue; in aws_event_loop_new_default_with_options()
194 epoll_loop->task_pre_queue_mutex.\owns = {&epoll_loop->task_pre_queue}; in aws_event_loop_new_default_with_options()
217 _(wrap(epoll_loop::queue)) in aws_event_loop_new_default_with_options()
219 _(wrap(epoll_loop)) in aws_event_loop_new_default_with_options()
261 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_destroy() local
269 _(unwrap(epoll_loop)) in s_destroy()
282 aws_atomic_store_ptr(&epoll_loop->running_thread_id, &epoll_loop->thread_joined_to); in s_destroy()
320 epoll_loop::queue, in s_destroy()
[all …]
|
| H A D | lifecycle.c | 24 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_stop_task() local
27 _(unwrap &epoll_loop->stop_task_ptr) in s_stop_task()
29 _(wrap &epoll_loop->stop_task_ptr) in s_stop_task()
34 _(unwrap epoll_loop::status) in s_stop_task()
36 _(wrap epoll_loop::status) in s_stop_task()
45 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_stop() local
48 _(unwrap &epoll_loop->stop_task_ptr) in s_stop()
50 …aws_atomic_compare_exchange_ptr(&epoll_loop->stop_task_ptr, &expected_ptr, &epoll_loop->stop_task); in s_stop()
51 _(wrap &epoll_loop->stop_task_ptr) in s_stop()
80 struct epoll_loop *epoll_loop = _(by_claim c_event_loop) event_loop->impl_data; in s_wait_for_stop_completion() local
[all …]
|
| H A D | main_loop.c | 32 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_on_tasks_to_schedule() local
34 epoll_loop->should_process_task_pre_queue = true; in s_on_tasks_to_schedule()
41 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_main_loop() local
46 _(unwrap &epoll_loop->running_thread_id) in s_main_loop()
47 aws_atomic_store_ptr(&epoll_loop->running_thread_id, &epoll_loop->thread_created_on.thread_id); in s_main_loop()
48 _(wrap &epoll_loop->running_thread_id) in s_main_loop()
78 while (epoll_loop->should_continue) in s_main_loop()
81 _(invariant \wrapped(&epoll_loop->scheduler)) in s_main_loop()
82 _(writes &epoll_loop->scheduler) in s_main_loop()
172 _(unwrap &epoll_loop->running_thread_id) in s_main_loop()
[all …]
|
| H A D | process_task_pre_queue.c | 29 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_process_task_pre_queue() local
30 _(assert \inv(epoll_loop)) in s_process_task_pre_queue()
32 if (!epoll_loop->should_process_task_pre_queue) { in s_process_task_pre_queue()
37 epoll_loop->should_process_task_pre_queue = false; in s_process_task_pre_queue()
47 aws_mutex_lock(&epoll_loop->task_pre_queue_mutex _(ghost c_mutex)); in s_process_task_pre_queue()
52 _(invariant \thread_local(&epoll_loop->read_task_handle)) in s_process_task_pre_queue()
53 _(invariant (&epoll_loop->read_task_handle)->\closed) in s_process_task_pre_queue()
54 _(invariant \inv(&epoll_loop->read_task_handle)) in s_process_task_pre_queue()
55 _(invariant \wrapped(&epoll_loop->scheduler)) in s_process_task_pre_queue()
67 _(invariant \wrapped(&epoll_loop->scheduler)) in s_process_task_pre_queue()
[all …]
|
| H A D | schedule.c | 41 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_schedule_task_common() local
42 _(assert \inv(epoll_loop)) in s_schedule_task_common()
43 _(assert epoll_loop->\closed) in s_schedule_task_common()
44 _(assert epoll_loop->write_task_handle.\closed) in s_schedule_task_common()
45 _(assert \inv(&epoll_loop->write_task_handle)) in s_schedule_task_common()
46 _(assert valid_fd(epoll_loop->write_task_handle.data.fd)) in s_schedule_task_common()
58 aws_task_scheduler_schedule_now(&epoll_loop->scheduler, task); in s_schedule_task_common()
74 aws_mutex_lock(&epoll_loop->task_pre_queue_mutex _(ghost c_mutex)); in s_schedule_task_common()
75 _(assert epoll_loop->task_pre_queue.\owner == \me) in s_schedule_task_common()
79 bool is_first_task = aws_linked_list_empty(&epoll_loop->task_pre_queue); in s_schedule_task_common()
[all …]
|
| H A D | is_on_callers_thread.c | 23 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_is_on_callers_thread() local
24 _(assert \always_by_claim(c_event_loop, epoll_loop)) in s_is_on_callers_thread()
25 _(assert \inv(epoll_loop)) in s_is_on_callers_thread()
27 aws_thread_id_t *thread_id = aws_atomic_load_ptr(&epoll_loop->running_thread_id); in s_is_on_callers_thread()
|
| H A D | cancel_task.c | 21 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_cancel_task() local
22 aws_task_scheduler_cancel_task(&epoll_loop->scheduler, task); in s_cancel_task()
|
| H A D | subscribe.c | 38 struct epoll_loop *epoll_loop = (struct epoll_loop *)event_loop->impl_data; in s_subscribe_to_io_events() local
69 …if (epoll_ctl(_(by_claim c_event_loop) epoll_loop->epoll_fd, EPOLL_CTL_ADD, handle->data.fd, &epol… in s_subscribe_to_io_events()
|
| H A D | unsubscribe.c | 36 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_unsubscribe_from_io_events() local
45 …if (AWS_UNLIKELY(epoll_ctl(epoll_loop->epoll_fd, EPOLL_CTL_DEL, handle->data.fd, &dummy_event /*ig… in s_unsubscribe_from_io_events()
|
| H A D | preamble.h | 197 struct epoll_loop;
452 _(invariant \mine((struct epoll_loop *)impl_data))
531 struct epoll_loop { struct
611 _(def struct epoll_loop *epoll_loop_of(struct aws_event_loop *event_loop) {
612 return (struct epoll_loop *)event_loop->impl_data;
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/source/linux/ |
| H A D | epoll_event_loop.c | 130 struct epoll_loop *epoll_loop = aws_mem_calloc(alloc, 1, sizeof(struct epoll_loop)); in aws_event_loop_new_default_with_options() local
234 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_destroy() local
269 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_run() local
289 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_stop_task() local
302 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_stop() local
319 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_wait_for_stop_completion() local
326 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_schedule_task_common() local
383 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_cancel_task() local
401 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_subscribe_to_io_events() local
451 struct epoll_loop *epoll_loop = event_loop->impl_data; in s_unsubscribe_from_io_events() local
[all …]
|
| /dports/security/nmap/nmap-7.91/nsock/src/ |
| H A D | engine_epoll.c | 91 static int epoll_loop(struct npool *nsp, int msec_timeout);
103 epoll_loop,
243 int epoll_loop(struct npool *nsp, int msec_timeout) { in epoll_loop() function
|
| /dports/security/ncrack/ncrack-0.7/nsock/src/ |
| H A D | engine_epoll.c | 91 static int epoll_loop(struct npool *nsp, int msec_timeout);
103 epoll_loop,
243 int epoll_loop(struct npool *nsp, int msec_timeout) { in epoll_loop() function
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/docs/ |
| H A D | epoll_event_loop_proof.md | 95 - In `s_destroy`, we (re-)take the `epoll_loop` pointer after stop and wait
|
| /dports/net/scamper/scamper-cvs-20211026/utils/sc_remoted/ |
| H A D | sc_remoted.c | 2431 static int epoll_loop(void) in epoll_loop() function
2924 return epoll_loop(); in main()
|