source: XIOS/trunk/src/node/axis.hpp @ 1558

Last change on this file since 1558 was 1558, checked in by oabramkina, 3 years ago

Adding transformation "extract" for axis.

  • Property copyright set to
    Software name : XIOS (Xml I/O Server)
    http://forge.ipsl.jussieu.fr/ioserver
    Creation date : January 2009
    Licence : CeCCIL version2
    see license file in root directory : Licence_CeCILL_V2-en.txt
    or http://www.cecill.info/licences/Licence_CeCILL_V2-en.html
    Holder : CEA/LSCE (Laboratoire des Sciences du CLimat et de l'Environnement)
    CNRS/IPSL (Institut Pierre Simon Laplace)
    Project Manager : Yann Meurdesoif
    yann.meurdesoif@cea.fr
  • Property svn:executable set to *
File size: 7.7 KB
Line 
1#ifndef __XIOS_CAxis__
2#define __XIOS_CAxis__
3
4/// XIOS headers ///
5#include "xios_spl.hpp"
6#include "group_factory.hpp"
7#include "virtual_node.hpp"
8
9#include "declare_group.hpp"
10#include "declare_ref_func.hpp"
11#include "declare_virtual_node.hpp"
12#include "attribute_array.hpp"
13#include "attribute_enum.hpp"
14#include "attribute_enum_impl.hpp"
15#include "server_distribution_description.hpp"
16#include "transformation.hpp"
17#include "transformation_enum.hpp"
18
19namespace xios {
20   /// ////////////////////// Déclarations ////////////////////// ///
21
22   class CAxisGroup;
23   class CAxisAttributes;
24   class CAxis;
25
26   ///--------------------------------------------------------------
27
28   // Declare/Define CAxisAttribute
29   BEGIN_DECLARE_ATTRIBUTE_MAP(CAxis)
30#  include "axis_attribute.conf"
31#  include "axis_attribute_private.conf"
32   END_DECLARE_ATTRIBUTE_MAP(CAxis)
33
34   ///--------------------------------------------------------------
35
36   class CAxis
37      : public CObjectTemplate<CAxis>
38      , public CAxisAttributes
39   {
40               /// typedef ///
41         typedef CObjectTemplate<CAxis>   SuperClass;
42         typedef CAxisAttributes SuperClassAttribute;
43         
44      public:
45         enum EEventId
46         {
47           EVENT_ID_DISTRIBUTION_ATTRIBUTE,           
48           EVENT_ID_DISTRIBUTED_VALUE,
49           EVENT_ID_NON_DISTRIBUTED_VALUE,
50           EVENT_ID_NON_DISTRIBUTED_ATTRIBUTES,
51           EVENT_ID_DISTRIBUTED_ATTRIBUTES
52         } ;
53
54      public:
55         typedef CAxisAttributes RelAttributes;
56         typedef CAxisGroup      RelGroup;
57         typedef CTransformation<CAxis>::TransformationMapTypes TransMapTypes;
58
59      public:
60         /// Constructeurs ///
61         CAxis(void);
62         explicit CAxis(const StdString & id);
63         CAxis(const CAxis & axis);       // Not implemented yet.
64         CAxis(const CAxis * const axis); // Not implemented yet.
65
66         static CAxis* createAxis();
67
68         /// Accesseurs ///
69         const std::set<StdString> & getRelFiles(void) const;
70
71         int getNumberWrittenIndexes(MPI_Comm writtenCom);
72         int getTotalNumberWrittenIndexes(MPI_Comm writtenCom);
73         int getOffsetWrittenIndexes(MPI_Comm writtenCom);
74         CArray<int, 1>& getCompressedIndexToWriteOnServer(MPI_Comm writtenCom);
75
76         std::map<int, StdSize> getAttributesBufferSize(CContextClient* client, const std::vector<int>& globalDim, int orderPositionInGrid,
77                                                        CServerDistributionDescription::ServerDistributionType disType = CServerDistributionDescription::BAND_DISTRIBUTION);
78
79         /// Test ///
80         bool IsWritten(const StdString & filename) const;
81         bool isWrittenCompressed(const StdString& filename) const;
82         bool isDistributed(void) const;
83         bool isCompressible(void) const;
84
85         /// Mutateur ///
86         void addRelFile(const StdString & filename);
87         void addRelFileCompressed(const StdString& filename);
88
89         /// Vérifications ///
90         void checkAttributes(void);
91
92         /// Destructeur ///
93         virtual ~CAxis(void);
94
95         virtual void parse(xml::CXMLNode & node);
96
97         void setContextClient(CContextClient* contextClient);
98
99         /// Accesseurs statiques ///
100         static StdString GetName(void);
101         static StdString GetDefName(void);
102         static ENodeType GetType(void);
103
104         static bool dispatchEvent(CEventServer& event);         
105         
106         void checkAttributesOnClient();
107         void checkAttributesOnClientAfterTransformation(const std::vector<int>& globalDim, int orderPositionInGrid,
108                                                         CServerDistributionDescription::ServerDistributionType distType = CServerDistributionDescription::BAND_DISTRIBUTION);
109         void sendCheckedAttributes(const std::vector<int>& globalDim, int orderPositionInGrid,
110                                    CServerDistributionDescription::ServerDistributionType disType = CServerDistributionDescription::BAND_DISTRIBUTION);
111
112         void checkEligibilityForCompressedOutput();
113         size_t getGlobalWrittenSize(void) ;
114
115         void computeWrittenIndex();
116         void computeWrittenCompressedIndex(MPI_Comm);
117         bool hasTransformation();
118         void solveInheritanceTransformation();
119         TransMapTypes getAllTransformations();         
120         void duplicateTransformation(CAxis*);
121         CTransformation<CAxis>* addTransformation(ETranformationType transType, const StdString& id="");
122         bool isEqual(CAxis* axis);
123         bool zoomByIndex();
124
125      public: 
126        bool hasValue;       
127        bool hasBounds;
128        bool hasLabel;
129
130        CArray<size_t,1> localIndexToWriteOnServer;       
131
132      private:
133         void checkData();
134         void checkMask();
135         void checkZoom();
136         void checkBounds();
137         void checkLabel();
138         void sendAttributes(const std::vector<int>& globalDim, int orderPositionInGrid,
139                             CServerDistributionDescription::ServerDistributionType distType);
140         void sendDistributionAttribute(const std::vector<int>& globalDim, int orderPositionInGrid,
141                                        CServerDistributionDescription::ServerDistributionType distType);
142         void computeConnectedClients(const std::vector<int>& globalDim, int orderPositionInGrid,
143                                     CServerDistributionDescription::ServerDistributionType distType);
144
145         void sendNonDistributedAttributes(void);
146         void sendDistributedAttributes(void);
147
148         static void recvNonDistributedAttributes(CEventServer& event);
149         static void recvDistributedAttributes(CEventServer& event);
150         static void recvDistributionAttribute(CEventServer& event);
151         void recvNonDistributedAttributes(int rank, CBufferIn& buffer);
152         void recvDistributedAttributes(vector<int>& rank, vector<CBufferIn*> buffers);
153         void recvDistributionAttribute(CBufferIn& buffer);
154
155         void setTransformations(const TransMapTypes&);
156
157      private:
158
159/** Clients that have to send a domain. There can be multiple clients in case of secondary server, otherwise only one client. */
160         std::list<CContextClient*> clients;
161         std::set<CContextClient*> clientsSet;
162
163         bool isChecked;
164         bool areClientAttributesChecked_;
165         bool isClientAfterTransformationChecked;
166         std::set<StdString> relFiles, relFilesCompressed;
167         TransMapTypes transformationMap_;         
168         //! True if and only if the data defined on the axis can be outputted in a compressed way
169         bool isCompressible_;
170         std::map<int, map<int,int> > nbSenders; // Mapping of number of communicating client to a server
171         std::map<int, std::unordered_map<int, vector<size_t> > > indSrv_; // Global index of each client sent to server
172         // std::map<int, vector<int> > indWrittenSrv_; // Global written index of each client sent to server
173         std::unordered_map<size_t,size_t> globalLocalIndexMap_;
174         std::vector<int> indexesToWrite;
175         std::map<int,int> numberWrittenIndexes_, totalNumberWrittenIndexes_, offsetWrittenIndexes_;
176         std::map<int, CArray<int, 1> > compressedIndexToWriteOnServer;
177         std::map<int, std::vector<int> > connectedServerRank_;
178         bool computedWrittenIndex_;                 
179
180       private:
181         static bool initializeTransformationMap(std::map<StdString, ETranformationType>& m);
182         static std::map<StdString, ETranformationType> transformationMapList_;
183         static bool dummyTransformationMapList_;
184
185         DECLARE_REF_FUNC(Axis,axis)
186   }; // class CAxis
187
188   ///--------------------------------------------------------------
189
190   // Declare/Define CAxisGroup and CAxisDefinition
191   DECLARE_GROUP(CAxis);
192} // namespace xios
193
194#endif // __XIOS_CAxis__
Note: See TracBrowser for help on using the repository browser.