Skip to content

NET_REACTOR.md

Latest commit

 

History

History
100 lines (74 loc) · 3.09 KB

NET_REACTOR.md

File metadata and controls

100 lines (74 loc) · 3.09 KB
Raw

Reactor и event_loop

rrmode::netlib::net::event_loop — единая точка ожидания готовности fd и доставки колбэков через execution::scheduler.

Архитектура

@startuml reactor_arch
skinparam componentStyle rectangle

component "event_loop" as loop
interface "reactor_backend" as rb
interface "timer_scheduler" as ts
component "epoll_reactor" as epoll
component "kqueue_reactor" as kq
component "poll_reactor" as poll
component "linux_timer_scheduler" as lt
component "kqueue_timer_scheduler" as kt
component "fallback_timer_scheduler" as ft

loop --> rb
loop --> ts
rb <|.. epoll : Linux
rb <|.. kq : macOS
rb <|.. poll : Windows / fallback
ts <|.. lt : Linux timerfd
ts <|.. kt : macOS EVFILT_TIMER
ts <|.. ft : run_once + steady_clock

@enduml

Фабрика: detail/make_default_reactor() в make_reactor.hpp.

ОС Reactor Таймеры run_after
Linux epoll_reactor timerfd + epoll (linux_timer_scheduler)
macOS kqueue_reactor EVFILT_TIMER в том же kqueue
Иное / Windows poll_reactor + winsock fallback_timer_scheduler

event_loop::uses_kernel_timers() — true, если таймеры в ядре (не опрос часов в run_once).

Цикл run_once

@startuml run_once
start
:if stopped → return 0;
:reactor.wait(timeout);
:для каждого (fd, events):
  вызвать зарегистрированный callback;
:timer_scheduler.tick (fallback);
:return число событий;
stop
@enduml

Типичное использование в приложении:

std::thread io{[&] {
  while (!stop) loop.run_once(10ms);
}};

Пример обёртки: examples/common/io_runner.hpp.

Регистрация fd

loop.register_fd(fd, detail::poll_event::readable, [](detail::poll_event ev) {
    // обработка; обычно unregister + sync recv/send
});
  • modify_fd — обновить интерес и колбэк (epoll MOD вместо повторного ADD).
  • unregister_fd — снять с reactor (обязательно при отмене I/O).

Правило: колбэк reactor должен быть коротким — тяжёлую работу переносить в scheduler.schedule.

Связь с tcp_socket / udp_socket

Сокеты не блокируют в reactor thread:

  1. try_recv / try_send / try_sendto → nullopt при EAGAIN.
  2. Регистрация readable / writable.
  3. При событии — повтор try_*, затем scheduler.schedule(user_callback).

Тестирование

  • Unit: fake_reactor + fake_socket_backend — без epoll.
  • Integration: реальный loopback + run_once в фоне.

См. TESTING.md.

Связанные документы