wx_test/datamanagement.cpp at master · catslab/wx_test · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
#include "datamanagement.h"
#include <QThread>
#include <QSemaphore>
#include "common.h"
#include <QDebug>


DataManagement::DataManagement(QObject *parent) : QThread(parent)
{

}

void DataManagement::run()
{
    int BufferRead = 0;
    double mediane2 = 0, mediane3 = 0;
    QVector<unsigned int> adc_data(4);
    forever
    {
        usedBytes.acquire();
        //fprintf(stderr, "%c", buffer[i % BufferSize]);
        //enregistrement des valeurs

        //extraction pour affichage
        /*
        qDebug() << adc_buffer[BufferRead].sensor1;
        qDebug() << adc_buffer[BufferRead].sensor2;
        qDebug() << adc_buffer[BufferRead].sensor3;
        qDebug() << adc_buffer[BufferRead].sensor4;
        */
        adc_data[0] = adc_buffer[BufferRead].sensor1;
        adc_data[1] = adc_buffer[BufferRead].sensor2;
        adc_data[2] = adc_buffer[BufferRead].sensor3>>4;
        adc_data[3] = adc_buffer[BufferRead].sensor4;

        mediane3 += (adc_buffer[BufferRead].sensor3>>4)/CountDelta;
        mediane2 += (adc_buffer[BufferRead].sensor2)/CountDelta;

        freeBytes.release();
        if ( BufferRead % CountDelta == 0)
        {
            adc_data[2] = (int)mediane3;
            adc_data[1] = (int)mediane2;
            mediane3 = 0;
            mediane2 = 0;
            emit valueChanged(adc_data);
            emit bufferFillCountChanged(BufferRead);
        }

        //emit bufferFillCountChanged(usedBytes.available());

        emit consumerCountChanged(BufferRead);
        if ( BufferRead++ == BufferSize )
            BufferRead = 0;
    }

}

/*
DataManagement::~DataManagement()
{

}
*/