CDPP / AMDA_Kernel

Commit 3e19e9d5d76dca08b4b56ace2831cd8dc18e4be0

Authored by Hacene SI HADJ MOHAND
1 parent e4be1bd4
Exists in master and in 85 other branches 10038, 10098, 5390, 5770, 6728, 7616, 7811, 7875, 8034_7628, 8038, 8041, 8045_8044, 8295, 8459, 8528, 8928, 9016, 9016Bis, 9017, 9017-new, 9049, 9084, 9259, 9326, 9347, 9383, 9719, 9719.new, AllLegends, CDF_ISTP, CDF_ISTP_HOPEFULLY_ALL_WORKING, FER_10400, FER_10412, FER_10663, FER_10765, FER_11000, FER_11100, FER_11242, FER_11277, FER_11500, FER_11537, FER_11588, FER_11651, FER_19836, FER_5344, FER_6031, FER_6598, FER_6966, FER_7318, FER_7618, FER_7857, FER_8455, FER_9629, FER_CR41, FER_CR42, FER_CR43, FER_TFCat, Histo1D2D, JUNO_JEDI, MAZ_10936, MAZ_6018, MAZ_9016_New, MAZ_FIX_9016, SpeasyGet, amdadev, amdadev_test, cu2022, das2, density_maps, develop, evol_9042, expression-parser-bre, feature/9259, frames-transformation, pickle, rm_6015, rm_6616, rm_6912, rm_7926, rm_8050, rm_8932, shue, shue97, test-merge, ubuntu

completly vriable parameteres seems ok

Showing 1 changed file with 18 additions and 2 deletions   Show diff stats
Inline Side-by-side
src/ParamOutputImpl/Download/DownloadOutput.cc
  Diff comments   View file @3e19e9d
... ... @@ -11,6 +11,7 @@
11 11 #include "FileWriterASCIIVOTable.hh"
12 12 #include "FileWriterCDF.hh"
13 13 #include "Helper.hh"
  14 +#include "Process.hh"
14 15 #include "Properties.hh"
15 16 #include "TimeUtil.hh"
16 17 #include "AMDA-Kernel_Config.hh"
... ... @@ -82,7 +83,7 @@ void DownloadOutput::establishConnection()
82 83  
83 84 AMDA::Info::ParamInfoSPtr paramInfo = AMDA::Info::ParamMgr::getInstance()->getParamInfoFromId(paramProperties->getOriginalId());
84 85 // adding tableParams
85   - std::map<int, boost::shared_ptr<AMDA::Info::ParamTable>> tables =paramInfo->getTables();
  86 + std::map<int, boost::shared_ptr<AMDA::Info::ParamTable>> tables =paramInfo->getTables();
86 87 if(! tables.empty()){
87 88 for(auto table : tables){
88 89 if(table.second != nullptr){
... ... @@ -92,12 +93,27 @@ void DownloadOutput::establishConnection()
92 93 for(auto tableParamId : tableParamIds){
93 94 AMDA::Parameters::ParameterSPtr tableParam = _parameterManager.getParameter(tableParamId.second);
94 95 tableParam ->openConnection(this);
  96 + //chek if is a temporel serie than add it to downlowd (as dowlonded parameter)
  97 + // use addParameterInFile
  98 + AMDA::Parameters::Process* lProcess = dynamic_cast<AMDA::Parameters::Process*>(tableParam->getDataWriterTemplate().get());
  99 + std::list<std::string>clbList;
  100 + if( lProcess != NULL){
  101 + clbList= lProcess->getUsedClbInfo();
  102 + }
  103 + if(lProcess == NULL && clbList.empty() ){
  104 + ParamProperties* paramProperties = new ParamProperties();
  105 + paramProperties->setOriginalId(tableParamId.second);
  106 + paramProperties->setOutputId(tableParamId.second);
  107 + _downloadProperties.addParamProperties(paramProperties);
  108 + }
  109 + }
  110 +
95 111 }
96 112 }
97 113  
98 114 }
99 115 }
100   - }
  116 +
101 117  
102 118 } catch (...) {
103 119 LOG4CXX_ERROR(_logger, "DownloadOutput::establishConnection - It's impossible to open connection for " << paramProperties->getOutputId());
... ...