CDPP / AMDA_Kernel

Blame view

src/InternLib/ProcessSamplingUnderRefParam.cc 6.02 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
86
87
88
89
90
91
 
	static_cast<Resampling::ResamplingAbstract*>(_operation)->init();

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

	_paramData->setMinSampling(static_cast<Resampling::ResamplingAbstract*>(_operation)->getSampling());

	return timeStamp;
}

unsigned int ProcessSamplingUnderRefParam::write()
{
fbe3c2bb   Benjamin Renard   First commit 
92
 
	int ret = 0;
a6490f4d   Benjamin Renard   Do not throw an e... 
93
 
	unsigned int nbDataBeforeCallProcess = _paramData->getDataNumber();
deefda79   Benjamin Renard   Addapt resampling... 
94
3ff2d228   Benjamin Renard   Fix bug in sampli... 
95
96
97
98
99
100
101
102
103
104
105
 
	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... 
106
107
108
 
		}
	}
3ff2d228   Benjamin Renard   Fix bug in sampli... 
109
110
 
	lParamDataIndexInfo = _parameterInput->getAsync(this).get();
bb672c4c   Benjamin Renard   Fix side effect i... 
111
112
 
	_operation->write(lParamDataIndexInfo);
	ret = _paramData->getDataNumber() - nbDataBeforeCallProcess;
a6490f4d   Benjamin Renard   Do not throw an e... 
113
c2fa3b5d   Benjamin Renard   Rework of legend ... 
114
115
116
117
 
	bool updateDims = (nbDataBeforeCallProcess == 0) && (ret > 0);
	if (updateDims)
		_paramData->updateDims();
a6490f4d   Benjamin Renard   Do not throw an e... 
118
119
120
121
122
123
 
	// 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... 
124
 
	else if (lParamDataIndexInfo._noMoreTimeInt) {
a6490f4d   Benjamin Renard   Do not throw an e... 
125
126
127
128
129
130
131
 
		_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... 
132
 
	_paramData->getIndexInfo()._noMoreTimeInt = lParamDataIndexInfo._noMoreTimeInt;
a6490f4d   Benjamin Renard   Do not throw an e... 
133
134
 

	return ret;
fbe3c2bb   Benjamin Renard   First commit 
135
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
177
 
}

/*
 * @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);
}

} /* namespace Parameters */
} /* namespace AMDA */