Почему последовательная функция Matlab работает лучше, чем чистый C ++ с использованием функции «Windows.h» - PullRequest
0 голосов
/ 13 декабря 2018

У меня была функция Matlab, выполняющая последовательное чтение (фред) с устройства с последовательным интерфейсом, сеньор, с которого я получаю данные, отправляет 150 пакетов по 42 байта в секунду, это означает, что он фактически записывает 6300 байтов в секунду в последовательный порт.

Недавно я реализовал точно такой же код для чтения пакетов даты из порта, используя c++ и его ReadFile из обработчика порта.в matlab я использовал availableBytes witch представляет данные в буфере чтения, а в c ++ я читал cbInQue из обработчика порта, в matlab он всегда близок к нулю, но в написанном на c ++ коде он становится все больше и больше.

Я должен добавить сюда, чем я просто читаю данные, и нет никакой другой нагрузки на процессор, выполняющей чрезмерную работу в коде c ++.

Matlab Code - это именно так:

s                       = serial(COMPort,'BaudRate',115200,'DataBits',8);
s.InputBufferSize       = 1000*1000*100;
fopen(s);
fwrite(s,hex2dec('C4'));fwrite(s,hex2dec('C1'));fwrite(s,hex2dec('29'));
fwrite(s,hex2dec('CB'));fread(s,8);%flushinput(s)
i                       = 0; % Counter
j                       = 0;
lost                    = 0;
PacketSize              = 42;
clc;disp('Started Sampling');
while i < Samples
    j                   = j + 1;
    Header              = fread(s,1);
    if Header == hex2dec('CB')

        pack                    = fread(s, PacketSize);
        cks                     = convert2int16(pack(41:42)) ;
        cksc                    = sum(pack(1:40)) + hex2dec('CB');

        if(cks - cksc == 0)
            i                       = i + 1;
            a_x(i,1)                = convert2float32bin(pack(1:4));
            a_y(i,1)                = convert2float32bin(pack(5:8));
            a_z(i,1)                = convert2float32bin(pack(9:12));
            w1(i,1)                 = convert2float32bin(pack(13:16));
            w2(i,1)                 = convert2float32bin(pack(17:20));
            w3(i,1)                 = convert2float32bin(pack(21:24));
            m1(i,1)                 = convert2float32bin(pack(25:28));
            m2(i,1)                 = convert2float32bin(pack(29:32));
            m3(i,1)                 = convert2float32bin(pack(33:36));
            tspan(i,1)              = convert2int32(pack(37:40))/19660800;
                if(mod(i,Rate) == 0)
                    if( i < CalibrCount)
                        disp(['Calibratuing ... [', num2str(100*i/CalibrCount),'%]']);
                    else
                        disp(['Time: ', num2str((i - CalibrCount)/Rate),'sec/ [', num2str(100*(i - CalibrCount)/(SampleCount - CalibrCount)) ,'%] AwPacks: ', num2str(floor(s.BytesAvailable/PacketSize))]);
                    end
                end
        else
            lost = lost + 1;
            disp('Packet Lost !!!!!!');
            disp(['Lost Count: ', num2str(lost), ' LossRatio:[' , num2str(100*lost/i), '%]']);
        end
    end

и код c ++ выглядит примерно так:

    int i{0};
    while (true)
    {
        Sensor->read(&header, sizeof(ReadType));
        if (header == Header_CB)
        {
            int add{0};
            GX2->read(packet, sizeof(packet));

            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].accX);
            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].accY);
            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].accZ);
            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].gyrX);
            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].gyrY);
            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].gyrZ);
            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].magX);
            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].magY);
            Bytes2Float(&packet[3] + 4 * add++, &imuData[i].magZ);
            // Bytes2Float(packet + 3, accX);
            // Bytes2Float(packet + 11, accZ);

            printf("accX: %+1.4f \taccY: %+1.4f \taccZ: %+1.4f i:%d buff: %d\n", imuData[i].accX,imuData[i].accY,imuData[i].accZ, i, GX2->Get_cbInQue());
            //system("@cls||clear");
            i++;
        }

в классе класса Read Mthod of Serialport выглядит так:

int SerialPort::read(void *buffer, unsigned int buf_size)
{
    DWORD bytesRead;
    unsigned int toRead = 0;

    ClearCommError(this->handler, &this->errors, &this->status);

    if (this->status.cbInQue > 0)
    {
        if (this->status.cbInQue > buf_size)
        {
            toRead = buf_size;
        }
        else
            toRead = this->status.cbInQue;
    }

    memset(buffer, 0, buf_size);

    if (ReadFile(this->handler, buffer, toRead, &bytesRead, NULL))
        return bytesRead;

    return 0;
}

просто упомянуть: Я удалил все ByeToFloat вызовы из кода c++, и у меня все еще остается проблема с увеличением и увеличением размера буфера.

Компиляция :

g++ -g main.cpp include/SerialPort.cpp include/Sensor.cpp  -o bin/main.exe -Iinclude
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...