Перехват соединений: XS_TAKEOVER — третий путь

Обзор

25.1 Введение

Границы трёх состояний нарисованы в главе 4: XS_OK возвращает соединение в keep-alive, XS_FALLBACK отдаёт статическому слою. Третье состояние XS_TAKEOVER значит «с этого момента соединение моё» — драйвер выходит из обработки событий, и дальнейший приём-передача, тайм-ауты и закрытие решает логика приложения. Типовые сцены: HTTP Upgrade к приватному протоколу, туннели-прокси, push-шлюзы с длинными межзапросными сеансами.

25.2 Семантика перехвата

• Точка перехвата: с момента возврата TAKEOVER из RequestProc соединение больше не потребляется HTTP-драйвером
• Таблица событий: после перехвата ставится своя обработка (заменять на нелегальное состояние нельзя)
• Контракт утилизации: объект соединения в конце всё равно Destroy-ит XServer — вы им управляете, но не владеете его деструкцией; терминал Close одновременно освобождает lease поколения, который держит соединение
• Байтовая синхронизация: потреблённые/записанные до перехвата байты по-прежнему сверяются драйвером — ползапроса HTTP + TAKEOVER отклоняется как несогласованное состояние

25.3 Модель pull на практике

В func_test есть реальный кейс перехвата-эха; паттерн (асинхронный pull-ввод-вывод):

typedef struct TakeoverCtx {
    XS_HostInfo*  pHost;      /* через потоки — по правилам владения */
    xnetstream*   tcp;        /* или tls: транспорт после перехвата */
} TakeoverCtx;

static XS_RequestResult RequestProc(XS_HttpReq* pReq)
{
    if ( !IsUpgradeTarget(pReq) ) return XS_FALLBACK;

    /* 1. сначала записать требуемые протоколом байты ответа (например 101 Switching Protocols) */
    /* 2. построить контекст перехвата */
    TakeoverCtx* pCtx = xrtCalloc(1, sizeof(TakeoverCtx));
    pCtx->tcp = pReq->tcp;

    /* 3. повесить асинхронное чтение: данные приходят в колбэк (кейс — отдельный поток + RecvAsync) */
    StartTakeoverLoop(pCtx);

    return XS_TAKEOVER;   /* соединение моё */
}

Что только что произошло: внутри цикла перехвата вы работаете с pCtx->tcp обычными потоковыми API xrt — ровно как в гл. 23. Разница лишь в «происхождении» потока: это было HTTP-соединение, а какой протокол оно говорит дальше — решаете вы.

25.4 Терминальное состояние и утилизация

• Вы обязаны в итоге Close: перехват — обещание; забытое соединение висит вечно (idle_timeout — подстраховка, а не проектный путь)
• Close идёт через семантику закрытия потоковых API; XServer в терминальном колбэке соединения делает Destroy и освобождает lease поколения — поэтому старое поколение может дождаться окончания всех перехваченных соединений до утилизации (reload_matrix проверил этот порядок)
• Контекст перехвата (pCtx) освобождается вместе с Close — тот же реестровый паттерн чистки, что у WS/TCP

25.5 Контракт

• Перехват: до возврата TAKEOVER дописаны байты ответа протокола; после перехвата драйвер соединение не потребляет.
• Терминал: финальный Close за приложением; Destroy и освобождение lease — за XServer на терминале.
• Контекст: жизнь контекста перехвата привязана к терминалу соединения — чистка реестровым паттерном.

Частые ошибки

Упражнения