Method read_thread

src/board_controller/neuromd/callibri.cpp:207–248

void Callibri::read_thread ()
{
    int num_rows = board_descr["default"]["num_rows"];
    double *package = new double[num_rows];
    for (int i = 0; i < num_rows; i++)
    {
        package[i] = 0.0;
    }

    while (keep_alive)
    {
        size_t length = 0;

        do
        {
            AnyChannel_get_total_length ((AnyChannel *)signal_channel, &length);
        } while ((keep_alive) && (length < (counter + 1)));

        // check that inner loop ended not because of stop_stream invocation
        if (!keep_alive)
        {
            break;
        }

        double timestamp = get_timestamp ();
        size_t stub = 0;
        double data = 0;
        int sdk_ec = SDK_NO_ERROR;
        sdk_ec =
            DoubleChannel_read_data ((DoubleChannel *)signal_channel, counter, 1, &data, 1, &stub);
        if (sdk_ec != SDK_NO_ERROR)
        {
            continue;
        }
        counter++;

        package[board_descr["default"]["package_num_channel"].get<int> ()] = (double)counter;
        package[1] = data * 1e6; // hardcode channel num here because there are 3 different types
        package[board_descr["default"]["timestamp_channel"].get<int> ()] = timestamp;
        push_package (package);
    }
}

void Callibri::free_channels ()
{