Method AsioTransport

src/ipc/asio_transport.cpp:58–91

} // namespace

AsioTransport::AsioTransport(const std::string& host,
                             const unsigned short port,
                             std::chrono::milliseconds timeout)
    : owned_ctx_{std::make_unique<asio::io_context>()}, ctx_{owned_ctx_.get()},
      socket_{*ctx_}, timeout_{timeout} {
    // NOTE: connect failure here must NOT throw -- it must leave the socket
    // closed and disconnected_ set, matching the old Qt-based TcpTransport,
    // which never checked its wait-for-connected result and let the app
    // self-quit on the first loop() tick via should_quit_on_disconnect.
    // Throwing here would escape MainWindow's ctor and crash the process
    // instead.
    asio::ip::tcp::resolver resolver{*ctx_};
    asio::error_code ec;
    const auto endpoints = resolver.resolve(host, std::to_string(port), ec);
    if (ec) {
        disconnected_ = true;
        return;
    }

    bool done = false;
    asio::error_code op_ec;
    asio::async_connect(socket_,
                        endpoints,
                        [&op_ec, &done](const asio::error_code& e,
                                        const asio::ip::tcp::endpoint&) {
                            op_ec = e;
                            done = true;
                        });
    if (run_until(*ctx_, socket_, done, timeout_) || op_ec) {
        disconnected_ = true;
        asio::error_code close_ec;
        socket_.close(close_ec);
    }
}

AsioTransport::AsioTransport(asio::io_context& ctx,
                             asio::ip::tcp::socket&& sock,