Skip to content

NET_TCP.md

Latest commit

 

History

History
105 lines (77 loc) · 3.2 KB

NET_TCP.md

File metadata and controls

105 lines (77 loc) · 3.2 KB
Raw

TCP (транспорт + async API)

IPv4, потоковые сокеты. Без TLS и без отдельного DNS-модуля: имя хоста в endpoint разрешается через getaddrinfo в posix_socket_backend / win_socket_backend.

Типы

Класс Файл Назначение
endpoint endpoint.hpp host + port
tcp_socket tcp_socket.hpp connect, read, write
tcp_acceptor tcp_acceptor.hpp bind, listen, accept

async_connect

См. diagrams/tcp_async_connect.puml.

@startuml tcp_read_write
skinparam sequenceMessageAlign center

participant App
participant Sock as "tcp_socket"
participant Loop as "event_loop"

== write_all ==
App -> Sock : async_write_all(loop, data, on_done, on_err)
alt try_send сразу всё
  Sock -> App : on_done
else EAGAIN
  Sock -> Loop : register writable
  Loop -> Sock : try_write loop
  Sock -> App : on_done
end

== read_some ==
App -> Sock : async_read_some(loop, buf, on_data, on_eof, on_err)
alt данные в буфере / try_recv
  Sock -> App : on_data(n) или on_eof
else EAGAIN
  Sock -> Loop : register readable
end
@enduml

Lifetime и io_handle()

Критично для цепочек колбэков: tcp_socket move в лямбду до старта async может закрыть fd.

Паттерн:

auto io = server_sock.io_handle();
server_sock.async_read_some(loop, buf,
    [io, &loop](std::size_t n) {
        tcp_socket{io}.async_write_all(loop, ...);
    }, ...);

Подробнее: LIFECYCLE.md.

tcp_acceptor

  • open(endpoint) — bind + listen, порт 0 → get_local_port.
  • async_accept(loop, on_socket, on_error) — неблокирующий accept или ожидание readable.
  • cancel_accept(loop) — снять ожидание + ошибка «отменена».

Coroutine-обёртки

Callback Awaitable
async_connect connect_async
async_write_all write_all_async
async_read_some read_some_async
read_exact (цикл) read_exact_async
async_accept accept_async

Хелперы: coro_tcp.hpp, tcp_coro.hpp — см. COROUTINES.md.

Отмена

socket.cancel_io(loop);   // connect / read / write
acceptor.cancel_accept(loop);

С cancellation_token в awaitables — token->on_cancel вызывает то же. См. CANCELLATION_AND_TIMEOUT.md.

Опции сокета (medium)

net::medium::socket_options + apply_socket_options — TCP_NODELAY, буферы, keepalive, linger.
Simple/Medium оборачивают full API — API_LAYERS.md.

Примеры

Пример API
examples/tcp_echo/server.cpp callback
examples/tcp_echo/client.cpp callback
examples/tcp_echo/server_coro.cpp tcp_echo_server_loop
examples/tcp_echo/client_coro.cpp awaitables

Тесты

  • Unit: tests/unit/net/tcp_socket_*, фейки.
  • Integration: tests/integration/tcp_echo_tests.cpp, tcp_echo_coro_tests.cpp.