Method read_thread

src/board_controller/openbci/galea.cpp:359–544

}

void Galea::read_thread ()
{
    int res;
    unsigned char b[Galea::max_transaction_size];
    DataBuffer time_buffer (1, 11);
    double latest_times[10];
    for (int i = 0; i < Galea::max_transaction_size; i++)
    {
        b[i] = 0;
    }

    int num_exg_rows = board_descr["default"]["num_rows"];
    int num_aux_rows = board_descr["auxiliary"]["num_rows"];
    double *exg_package = new double[num_exg_rows];
    double *aux_package = new double[num_aux_rows];
    for (int i = 0; i < num_exg_rows; i++)
    {
        exg_package[i] = 0.0;
    }
    for (int i = 0; i < num_aux_rows; i++)
    {
        aux_package[i] = 0.0;
    }

    while (keep_alive)
    {
        res = socket->recv (b, Galea::max_transaction_size);
        if (res == -1)
        {
#ifdef _WIN32
            safe_logger (spdlog::level::err, "WSAGetLastError is {}", WSAGetLastError ());
#else
            safe_logger (spdlog::level::err, "errno {} message {}", errno, strerror (errno));
#endif
            continue;
        }
        if (res % Galea::package_size != 0)
        {
            if (res > 0)
            {
                // more likely its a string received, try to print it
                b[res] = '\0';
                safe_logger (spdlog::level::warn, "Received: {}", b);
            }
            continue;
        }
        else
        {
            int num_packages = res / Galea::package_size;
            int offset_last_package = Galea::package_size * (num_packages - 1);
            // calc delta between PC timestamp and device timestamp in last 10 packages,
            // use this delta later on to assign timestamps
            double pc_timestamp = get_timestamp ();
            unsigned long long timestamp_last_package = 0.0;
            memcpy (&timestamp_last_package, b + 88 + offset_last_package,
                sizeof (unsigned long long)); // microseconds
            double timestamp_last_package_converted =
                static_cast<double> (timestamp_last_package) / 1000000.0; // convert to seconds