Method start_stream

src/board_controller/playback_file_board.cpp:121–178

}

int PlaybackFileBoard::start_stream (int buffer_size, const char *streamer_params)
{
    safe_logger (spdlog::level::trace, "start stream");
    if (keep_alive)
    {
        safe_logger (spdlog::level::err, "Streaming thread already running");
        return (int)BrainFlowExitCodes::STREAM_ALREADY_RUN_ERROR;
    }

    int res = prepare_for_acquisition (buffer_size, streamer_params);
    if (res != (int)BrainFlowExitCodes::STATUS_OK)
    {
        return res;
    }
    if (!params.file.empty ())
    {
        res = validate_file_access (params.file);
        if (res != (int)BrainFlowExitCodes::STATUS_OK)
        {
            return res;
        }
    }
    if (!params.file_aux.empty ())
    {
        res = validate_file_access (params.file_aux);
        if (res != (int)BrainFlowExitCodes::STATUS_OK)
        {
            return res;
        }
    }
    if (!params.file_anc.empty ())
    {
        res = validate_file_access (params.file_anc);
        if (res != (int)BrainFlowExitCodes::STATUS_OK)
        {
            return res;
        }
    }

    keep_alive = true;
    if (!params.file.empty ())
    {
        streaming_threads.push_back (std::thread (
            [this] { this->read_thread ((int)BrainFlowPresets::DEFAULT_PRESET, params.file); }));
    }
    if (!params.file_aux.empty ())
    {
        streaming_threads.push_back (std::thread ([this]
            { this->read_thread ((int)BrainFlowPresets::AUXILIARY_PRESET, params.file_aux); }));
    }
    if (!params.file_anc.empty ())
    {
        streaming_threads.push_back (std::thread ([this]
            { this->read_thread ((int)BrainFlowPresets::ANCILLARY_PRESET, params.file_anc); }));
    }

    return (int)BrainFlowExitCodes::STATUS_OK;
}