Method beginFrame

Libraries/Http/HttpWebSocket.cpp:839–907

    }
}

void HttpWebSocketFrameReader::reset(HttpWebSocketEndpointRole role)
{
    endpointRole = role;
    currentFrame = {};

    state = State::HeaderByte0;

    fragmentedMessageInProgress = false;

    headerByte0 = 0;

    extendedLengthBytesExpected = 0;
    extendedLengthBytesRead     = 0;
    maskBytesRead               = 0;

    extendedLengthAccumulator = 0;
    payloadBytesRemaining     = 0;
    payloadBytesConsumed      = 0;
}

Result HttpWebSocketFrameReader::parse(Span<char> data, size_t& consumedBytes)
{
    consumedBytes = 0;
    while (consumedBytes < data.sizeInBytes())
    {
        const uint8_t current = static_cast<uint8_t>(data[consumedBytes]);
        switch (state)
        {
        case State::HeaderByte0:
            headerByte0 = current;
            consumedBytes++;
            state = State::HeaderByte1;
            break;

        case State::HeaderByte1: {
            const uint8_t opcodeValue = headerByte0 & 0x0F;
            SC_TRY_MSG((headerByte0 & 0x70) == 0, "HttpWebSocketFrameReader RSV bits are not supported");
            currentFrame        = {};
            currentFrame.fin    = (headerByte0 & 0x80) != 0;
            currentFrame.opcode = static_cast<HttpWebSocketOpcode>(opcodeValue);
            SC_TRY_MSG(scHttpWebSocketIsSupportedOpcode(currentFrame.opcode),
                       "HttpWebSocketFrameReader unsupported opcode");

            currentFrame.masked              = (current & 0x80) != 0;
            const uint8_t payloadLengthField = current & 0x7F;

            extendedLengthAccumulator = 0;
            extendedLengthBytesRead   = 0;
            maskBytesRead             = 0;

            consumedBytes++;

            if (payloadLengthField < 126)
            {
                currentFrame.payloadLength = payloadLengthField;
                if (currentFrame.masked)
                {