Method queueAutomaticControl

Libraries/Http/HttpWebSocket.cpp:1250–1277

}

Result HttpWebSocketEndpoint::queueAutomaticControl(HttpWebSocketOpcode opcode, Span<const char> payload)
{
    SC_TRY_MSG(not hasPendingControlFrame(), "HttpWebSocketEndpoint pending control frame backpressure");

    HttpWebSocketFrameHeaderView header;
    header.opcode        = opcode;
    header.fin           = true;
    header.payloadLength = payload.sizeInBytes();
    SC_TRY(applyOutgoingMask(header, automaticMaskKeySet ? automaticMaskKey : nullptr));

    HttpWebSocketFrameWriter controlWriter;
    controlWriter.reset(endpointRole);

    Span<const char> encodedHeader;
    SC_TRY(controlWriter.beginFrame(header, automaticControlStorage, encodedHeader));
    SC_TRY_MSG(sizeof(automaticControlStorage) >= encodedHeader.sizeInBytes() + payload.sizeInBytes(),
               "HttpWebSocketEndpoint automatic control storage too small");
    if (payload.sizeInBytes() > 0)
    {
        Span<char> destinationPayload = {automaticControlStorage + encodedHeader.sizeInBytes(), payload.sizeInBytes()};
        ::memcpy(destinationPayload.data(), payload.data(), payload.sizeInBytes());
        SC_TRY(controlWriter.writePayload(destinationPayload));
    }
    SC_TRY(controlWriter.finishFrame());

    pendingControlFrame = {automaticControlStorage, encodedHeader.sizeInBytes() + payload.sizeInBytes()};
    return Result(true);
}

Result HttpWebSocketConnectionPump::attach(const HttpWebSocketTransportView& newTransport,
                                           HttpWebSocketEndpointRole         endpointRole)