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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
/*
* Copyright (C) 2013, 2014, 2015 by the Konclude Developer Team.
*
* This file is part of the reasoning system Konclude.
* For details and support, see <http://konclude.com/>.
*
* Konclude is free software: you can redistribute it and/or modify it under
* the terms of version 2.1 of the GNU Lesser General Public License (LGPL2.1)
* as published by the Free Software Foundation.
*
* You should have received a copy of the GNU Lesser General Public License
* along with Konclude. If not, see <http://www.gnu.org/licenses/>.
*
* Konclude is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. For more
* details, see GNU Lesser General Public License.
*
*/
#include "CAnalyseDataUpdater.h"
namespace Konclude {
namespace Test {
namespace Analyse {
CAnalyseDataUpdater::CAnalyseDataUpdater()
: CIntervalThread("Analyse-Data-Updater") {
nextTimerID = 1;
startThread();
waitSynchronization();
}
CAnalyseDataUpdater::~CAnalyseDataUpdater() {
stopThread();
}
CAnalyseDataUpdater *CAnalyseDataUpdater::installAnalyseDataUpdate(CAnalyseDataSeries *dataSeries, qint64 updateInterval) {
timerMutex.lock();
qint64 timerID = nextTimerID++;
CAnalyseDataUpdateItem *analyseDataUpdateItem = new CAnalyseDataUpdateItem(dataSeries,updateInterval,timerID);
analyseUpdateHash.insert(dataSeries,analyseDataUpdateItem);
timerIDUpdateHash.insert(timerID,analyseDataUpdateItem);
timerMutex.unlock();
startTimerWithInterval(timerID,updateInterval);
return this;
}
CAnalyseDataUpdater *CAnalyseDataUpdater::installAnalyseDataUpdateObserver(CAnalyseDataSeries *dataSeries, CAnalyseDataObserver *observer) {
timerMutex.lock();
CAnalyseDataUpdateItem *updateItem = analyseUpdateHash.value(dataSeries,0);
if (updateItem) {
updateItem->addUpdateObserver(observer);
}
timerMutex.unlock();
return this;
}
bool CAnalyseDataUpdater::processTimer(qint64 timerID) {
bool timerProcessed = false;
timerMutex.lock();
if (timerIDUpdateHash.contains(timerID)) {
CAnalyseDataUpdateItem *analyseDataUpdateItem = timerIDUpdateHash.value(timerID);
if (analyseDataUpdateItem) {
CAnalyseDataSeries *dataSeries = analyseDataUpdateItem->getAnalyseDataSeries();
if (dataSeries) {
CAnalyseDataDescription *dataDes = dataSeries->getAnalyseDataDescription();
if (dataDes) {
CAnalyseData *newAnalyseData = dataDes->createData();
qint64 valueCount = dataDes->getAnalyseValueCount();
for (int i = 0; i < valueCount; ++i) {
CAnalyseValueDescription *valueDes = dataDes->getValueDescription(i);
CAnalyseUpdateDescription *updateDes = dataDes->getUpdateDescription(i);
if (valueDes && updateDes) {
CAnalyseValueUpdateReader *updateReader = updateDes->getUpdateReader();
if (updateReader) {
CAnalyseValue *analyseValue = updateReader->getAnalyseValueUpdate(valueDes);
if (analyseValue) {
newAnalyseData->setValue(i,analyseValue);
}
}
}
}
CAnalyseDataLinker *dataLinker = new CAnalyseDataLinker();
dataSeries->addAnalyseData((CAnalyseDataLinker *)(dataLinker->init(newAnalyseData)));
analyseDataUpdateItem->notifyObserversDataUpdate();
}
}
}
timerProcessed = true;
}
timerMutex.unlock();
return timerProcessed;
}
}; // end namespace Analyse
}; // end namespace Test
}; // end namespace Konclude
|
