source: XIOS/dev/dev_trunk_omp/src/transformation/axis_algorithm_extract_domain.cpp @ 1677

Last change on this file since 1677 was 1677, checked in by yushan, 5 years ago

MARK: Dynamic workflow graph developement. Branch up to date with trunk @1663.

  • Property svn:executable set to *
File size: 4.9 KB
Line 
1/*!
2   \file axis_algorithm_reduce_domain.cpp
3   \author Ha NGUYEN
4   \since 23 June 2016
5   \date 23 June 2016
6
7   \brief Algorithm for extract a domain to an axis
8 */
9#include "axis_algorithm_extract_domain.hpp"
10#include "extract_domain_to_axis.hpp"
11#include "axis.hpp"
12#include "domain.hpp"
13#include "grid.hpp"
14#include "grid_transformation_factory_impl.hpp"
15
16namespace xios {
17CGenericAlgorithmTransformation* CAxisAlgorithmExtractDomain::create(CGrid* gridDst, CGrid* gridSrc,
18                                                                     CTransformation<CAxis>* transformation,
19                                                                     int elementPositionInGrid,
20                                                                     std::map<int, int>& elementPositionInGridSrc2ScalarPosition,
21                                                                     std::map<int, int>& elementPositionInGridSrc2AxisPosition,
22                                                                     std::map<int, int>& elementPositionInGridSrc2DomainPosition,
23                                                                     std::map<int, int>& elementPositionInGridDst2ScalarPosition,
24                                                                     std::map<int, int>& elementPositionInGridDst2AxisPosition,
25                                                                     std::map<int, int>& elementPositionInGridDst2DomainPosition)
26TRY
27{
28  std::vector<CAxis*> axisListDestP = gridDst->getAxis();
29  std::vector<CDomain*> domainListSrcP = gridSrc->getDomains();
30
31  CExtractDomainToAxis* extractDomain = dynamic_cast<CExtractDomainToAxis*> (transformation);
32  int axisDstIndex = elementPositionInGridDst2AxisPosition[elementPositionInGrid];
33  int domainSrcIndex = elementPositionInGridSrc2DomainPosition[elementPositionInGrid];
34
35  return (new CAxisAlgorithmExtractDomain(axisListDestP[axisDstIndex], domainListSrcP[domainSrcIndex], extractDomain));
36}
37CATCH
38
39//bool CAxisAlgorithmExtractDomain::_dummyRegistered = CAxisAlgorithmExtractDomain::registerTrans();
40bool CAxisAlgorithmExtractDomain::registerTrans()
41TRY
42{
43  CGridTransformationFactory<CAxis>::registerTransformation(TRANS_EXTRACT_DOMAIN_TO_AXIS, create);
44}
45CATCH
46
47
48CAxisAlgorithmExtractDomain::CAxisAlgorithmExtractDomain(CAxis* axisDestination, CDomain* domainSource, CExtractDomainToAxis* algo)
49 : CAxisAlgorithmTransformation(axisDestination, domainSource), pos_(-1), reduction_(0)
50TRY
51{
52  algo->checkValid(axisDestination, domainSource);
53  StdString op = "extract";
54
55  switch (algo->direction)
56  {
57    case CExtractDomainToAxis::direction_attr::jDir:
58      dir_ = jDir;
59      break;
60    case CExtractDomainToAxis::direction_attr::iDir:
61      dir_ = iDir;
62      break;
63    default:
64      break;
65  }
66
67  pos_ = algo->position;
68  if(CReductionAlgorithm::ReductionOperations_ptr == 0) 
69  {
70    CReductionAlgorithm::initReductionOperation();
71  }
72  reduction_ = CReductionAlgorithm::createOperation(CReductionAlgorithm::ReductionOperations_ptr->at(op));
73}
74CATCH
75
76void CAxisAlgorithmExtractDomain::apply(const std::vector<std::pair<int,double> >& localIndex,
77                                        const double* dataInput,
78                                        CArray<double,1>& dataOut,
79                                        std::vector<bool>& flagInitial,                     
80                                        bool ignoreMissingValue, bool firstPass)
81TRY
82{
83  std::cout<<"================================ CAxisAlgorithmExtractDomain::apply"<<std::endl;
84  reduction_->apply(localIndex, dataInput, dataOut, flagInitial, ignoreMissingValue, firstPass);
85}
86CATCH
87
88CAxisAlgorithmExtractDomain::~CAxisAlgorithmExtractDomain()
89TRY
90{
91  if (0 != reduction_) delete reduction_;
92}
93CATCH
94
95void CAxisAlgorithmExtractDomain::computeIndexSourceMapping_(const std::vector<CArray<double,1>* >& dataAuxInputs)
96TRY
97{
98  this->transformationMapping_.resize(1);
99  this->transformationWeight_.resize(1);
100
101  TransformationIndexMap& transMap = this->transformationMapping_[0];
102  TransformationWeightMap& transWeight = this->transformationWeight_[0];
103
104  CArray<int,1>& axisDstIndex = axisDest_->index;
105  int ni_glo = domainSrc_->ni_glo, nj_glo = domainSrc_->nj_glo;
106  if (jDir == dir_)
107  {
108    int nbAxisIdx = axisDstIndex.numElements();
109    for (int idxAxis = 0; idxAxis < nbAxisIdx; ++idxAxis)
110    {
111      int globalAxisIdx = axisDstIndex(idxAxis);
112      transMap[globalAxisIdx].resize(1);
113      transWeight[globalAxisIdx].resize(1);
114      transMap[globalAxisIdx][0] = globalAxisIdx * ni_glo + pos_;
115      transWeight[globalAxisIdx][0] = 1.0;
116
117    }
118  }
119  else if (iDir == dir_)
120  {
121    int nbAxisIdx = axisDstIndex.numElements();
122    for (int idxAxis = 0; idxAxis < nbAxisIdx; ++idxAxis)
123    {
124      int globalAxisIdx = axisDstIndex(idxAxis);
125      transMap[globalAxisIdx].resize(1);
126      transWeight[globalAxisIdx].resize(1);
127      transMap[globalAxisIdx][0] = globalAxisIdx + ni_glo * pos_;
128      transWeight[globalAxisIdx][0] = 1.0;
129    }
130  }
131  else
132  {}
133}
134CATCH
135}
Note: See TracBrowser for help on using the repository browser.