CDPP / AMDA_Kernel

Blame view

src/InternLib/ProcessSamplingUnderRefParam.cc 6.3 KB
Edit Raw Normal View History
fbe3c2bb   Benjamin Renard   First commit 
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
 
/**
 * ProcessSamplingUnderTimeList.cc
 *
 *  Created on: Jul 25, 2014
 *      Author: AKKA IS
 */
#include <stdlib.h>
#include <string>

#include "ProcessSamplingUnderRefParam.hh"
#include "Parameter.hh"
#include "ParameterManager.hh"
#include "ParameterCreatorFromExpression.hh"
#include "Resampling.hh"
#include "ParamMgr.hh"

using namespace std;
using namespace boost;
using namespace log4cxx;

namespace AMDA {
namespace Parameters {

ProcessSamplingUnderRefParam::ProcessSamplingUnderRefParam(Parameter &parameter) :
		SingleParamProcess_CRTP(parameter), _paramRefInput(NULL) {
}

ProcessSamplingUnderRefParam::ProcessSamplingUnderRefParam(const ProcessSamplingUnderRefParam& pProcess, Parameter &parameter)
: SingleParamProcess_CRTP(pProcess,parameter), _paramRefInput(pProcess._paramRefInput) {
}

ProcessSamplingUnderRefParam::~ProcessSamplingUnderRefParam() {
	if (_refParameterSPtr != nullptr)
	{
		_refParameterSPtr->closeConnection(this);
	}
}


void ProcessSamplingUnderRefParam::establishConnection() {
deefda79   Benjamin Renard   Addapt resampling... 
41
 
	if ((_refParameterSPtr != nullptr) && (_refParameterSPtr != _parameterInput)) {
fbe3c2bb   Benjamin Renard   First commit 
42
 
		_refParameterSPtr->openConnection(this);
deefda79   Benjamin Renard   Addapt resampling... 
43
 
	}
fbe3c2bb   Benjamin Renard   First commit 
44
45
 

	SingleParamProcess_CRTP::establishConnection();
deefda79   Benjamin Renard   Addapt resampling... 
46
47
48
49
50
51
52
 

	if ((_refParameterSPtr == nullptr) && (_attributList.size() == 1) ) {
		_refParameterSPtr =  _parameterInput->getParameterManager().getParameter(_attributList[0]);
		if ((_refParameterSPtr != nullptr) && (_refParameterSPtr != _parameterInput)) {
			_refParameterSPtr->openConnection(this);
		}
	}
fbe3c2bb   Benjamin Renard   First commit 
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
}

TimeStamp ProcessSamplingUnderRefParam::init() {
	/// Init input parameter
	TimeStamp timeStamp = _parameterInput->init( this, _timeIntervalList);
	/// Calibration information copy
	Parameter::InfoList lInfoList = _parameterInput->getInfoList();
	_parameter.getInfoList().insert(lInfoList.begin(), lInfoList.end());
	_paramInput = _parameterInput->getParamData(this).get();

	// check reference parameter
	if (_refParameterSPtr == nullptr) {
		BOOST_THROW_EXCEPTION(AMDA::AMDA_exception() << AMDA::errno_code(AMDA_PROCESS_ERR) << AMDA::ex_msg(std::string("ProcessSamplingUnderRefParam : cannot retrieve reference parameter ")));
	}

	timeStamp = std::max(timeStamp, _refParameterSPtr->init( this, _timeIntervalList));

	_paramRefInput = _refParameterSPtr->getParamData(this).get();

	double computedGapSize = _refParameterSPtr->getParameterManager().getComputedGapSize(_parameterInput->getGapThreshold(), _paramInput->getMinSampling());
46ee40b3   Benjamin Renard   Fix reference fil... 
73
 
	//_parameter.setGapThreshold(computedGapSize/_paramRefInput->getMinSampling());
fbe3c2bb   Benjamin Renard   First commit 
74
75
76
 

	// ProcessSamplingClassic _operation creation
	Resampling::CreateResampling lCreateResampling(*this, _timeIntervalList,
3ff2d228   Benjamin Renard   Fix bug in sampli... 
77
 
			*_paramInput, *_paramRefInput, computedGapSize, _parameterInput->getDataWriterTemplate()->useNearestValue(), _refParameterSPtr == _parameterInput);
fbe3c2bb   Benjamin Renard   First commit 
78
 
	_operation = lCreateResampling.getResampling();
3ff2d228   Benjamin Renard   Fix bug in sampli... 
79
fbe3c2bb   Benjamin Renard   First commit 
80
81
82
83
84
85
 
	static_cast<Resampling::ResamplingAbstract*>(_operation)->init();

	/// Get result ParamData
	_paramData = ParamDataSPtr(_operation->getParamOutput());

	_paramData->setMinSampling(static_cast<Resampling::ResamplingAbstract*>(_operation)->getSampling());
98295b6e   Benjamin Renard   Fix gap threshold... 
86
 
	_parameter.setGapThreshold(_refParameterSPtr->getGapThreshold());
fbe3c2bb   Benjamin Renard   First commit 
87
88
89
90
91
92
 

	return timeStamp;
}

unsigned int ProcessSamplingUnderRefParam::write()
{
fbe3c2bb   Benjamin Renard   First commit 
93
 
	int ret = 0;
a6490f4d   Benjamin Renard   Do not throw an e... 
94
 
	unsigned int nbDataBeforeCallProcess = _paramData->getDataNumber();
deefda79   Benjamin Renard   Addapt resampling... 
95
3ff2d228   Benjamin Renard   Fix bug in sampli... 
96
97
98
99
100
101
102
103
104
105
106
 
	ParamDataIndexInfo lParamDataIndexInfo;
	if (_refParameterSPtr != _parameterInput) {
		if (static_cast<Resampling::ResamplingAbstract*>(_operation)->isNewInt()) {
			_paramRefInput = _refParameterSPtr->getParamData(this).get();
			ParamDataIndexInfo lRefParamDataIndexInfo;
			do {
				lRefParamDataIndexInfo = _refParameterSPtr->getAsync(this).get();
				for (unsigned int index = lRefParamDataIndexInfo._startIndex; index < lRefParamDataIndexInfo._startIndex + lRefParamDataIndexInfo._nbDataToProcess; index++) {
					static_cast<Resampling::ResamplingAbstract*>(_operation)->pushTime(_paramRefInput->getTime(index));
				}
			} while (!lRefParamDataIndexInfo._timeIntToProcessChanged && !lRefParamDataIndexInfo._noMoreTimeInt);
deefda79   Benjamin Renard   Addapt resampling... 
107
108
109
 
		}
	}
3ff2d228   Benjamin Renard   Fix bug in sampli... 
110
111
 
	lParamDataIndexInfo = _parameterInput->getAsync(this).get();
bb672c4c   Benjamin Renard   Fix side effect i... 
112
113
 
	_operation->write(lParamDataIndexInfo);
	ret = _paramData->getDataNumber() - nbDataBeforeCallProcess;
a6490f4d   Benjamin Renard   Do not throw an e... 
114
c2fa3b5d   Benjamin Renard   Rework of legend ... 
115
116
117
118
 
	bool updateDims = (nbDataBeforeCallProcess == 0) && (ret > 0);
	if (updateDims)
		_paramData->updateDims();
a6490f4d   Benjamin Renard   Do not throw an e... 
119
120
121
122
123
124
 
	// Reset operation to prepare static data for the next TimeInterval.
	if (lParamDataIndexInfo._timeIntToProcessChanged) {
		_paramData->getIndexInfo()._endTimeIntIndexList.push_back(_paramData->getDataNumber());
		_operation->reset();
	}
	// There is no more time interval to process
fa4b7852   Benjamin Renard   Fix bug around ti... 
125
 
	else if (lParamDataIndexInfo._noMoreTimeInt) {
a6490f4d   Benjamin Renard   Do not throw an e... 
126
127
128
129
130
131
132
 
		_paramData->getIndexInfo()._endTimeIntIndexList.push_back(_paramData->getDataNumber());
	} else {
		// Nothing to do.
	}

	// Pull up information on which time interval changed.
	_paramData->getIndexInfo()._timeIntToProcessChanged = lParamDataIndexInfo._timeIntToProcessChanged;
fa4b7852   Benjamin Renard   Fix bug around ti... 
133
 
	_paramData->getIndexInfo()._noMoreTimeInt = lParamDataIndexInfo._noMoreTimeInt;
a6490f4d   Benjamin Renard   Do not throw an e... 
134
135
 

	return ret;
fbe3c2bb   Benjamin Renard   First commit 
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
 
}

/*
 * @brief Get min sampling
 */
double ProcessSamplingUnderRefParam::getMinSampling()
{
	if (_refParameterSPtr == nullptr)
		return 0;
	if (_refParameterSPtr->getDataWriterTemplate() == nullptr)
		return 0;
	return _refParameterSPtr->getDataWriterTemplate()->getMinSampling();
}

/**
 * @overload SingleParamProcess_CRTP::updateInfo update parameter info in relation to the sampling process
 */
void ProcessSamplingUnderRefParam::updateInfo(Parameter & parameter)
{
	LOG4CXX_DEBUG(_logger, "ProcessSamplingUnderRefParam::updateInfo - " << parameter.getId());

	SingleParamProcess::updateInfo(parameter);

	//Param info
	AMDA::Info::ParamInfoSPtr paramInfo = AMDA::Info::ParamMgr::getInstance()->getParamInfoFromId(parameter.getInfoId());

	if (paramInfo == nullptr)
		return;

	std::string processInfo = "Resampling of '";
	processInfo += _parameterInput->getId();
	processInfo += "' under times list of '";
	processInfo += _refParameterSPtr->getId();
	processInfo += "'";

	if (_parameterInput->getDataWriterTemplate()->useNearestValue())
			processInfo += ". Use nearest value.";

	paramInfo->setProcessInfo(processInfo);
}
69f40c91   Benjamin Renard   Fix gap propagation 
177
178
179
180
181
182
 
double ProcessSamplingUnderRefParam::getGapThreshold() {
	double gapSize = _parameterInput->getGapThreshold() * _parameterInput->getDataWriterTemplate()->getMinSampling();
	
	return gapSize / this->getMinSampling();
}
fbe3c2bb   Benjamin Renard   First commit 
183
184
 
} /* namespace Parameters */
} /* namespace AMDA */