Method read_data

src/board_controller/aavaa/aavaa_v3.cpp:471–582

}

void AAVAAv3::read_data (
    simpleble_uuid_t service, simpleble_uuid_t characteristic, const uint8_t *data, size_t size)
{
    safe_logger (spdlog::level::trace, "received {} number of bytes", size);

    if (!is_streaming)
    {
        if (data[1] == 64)
        { // when the first byte is @
            std::string temp (reinterpret_cast<const char *> (data), size);
            device_status = temp.substr (1);
            safe_logger (spdlog::level::trace, "received a status string {} ", device_status);
        }
        else
        {
            safe_logger (spdlog::level::trace, "received a string with start byte {} {} {} {} {}",
                data[0], data[1], data[2], data[3], data[4]);
        }
        return;
    }

    int num_rows = board_descr["default"]["num_rows"];

    std::vector<int> eeg_channels = board_descr["default"]["eeg_channels"];

    if (size == 244)
    {
        data += 3;
        size -= 3;
        Incoming_BLE_Data_Buffer.insert (Incoming_BLE_Data_Buffer.end (), data, data + size);
    }
    else if (size > 1)
    {
        ++data;
        --size;
        Incoming_BLE_Data_Buffer.insert (Incoming_BLE_Data_Buffer.end (), data, data + size);
    }

    while ((int)Incoming_BLE_Data_Buffer.size () >= SIZE_OF_DATA_FRAME)
    {
        if (Incoming_BLE_Data_Buffer[0] != START_BYTE)
        {
            Incoming_BLE_Data_Buffer.pop_front (); // discard data, we have half a frame here
            continue;
        }

        uint8_t *data_frame = new uint8_t[SIZE_OF_DATA_FRAME];
        for (int i = 0; i < SIZE_OF_DATA_FRAME; ++i)
        {
            data_frame[i] = Incoming_BLE_Data_Buffer.front ();
            Incoming_BLE_Data_Buffer.pop_front ();
        }

        if (data_frame[SIZE_OF_DATA_FRAME - 1] != END_BYTE)
        {
            safe_logger (
                spdlog::level::warn, "Wrong End Byte: {}", data_frame[SIZE_OF_DATA_FRAME - 1]);
            continue;