source: XIOS/trunk/src/node/field.hpp @ 638

Last change on this file since 638 was 638, checked in by rlacroix, 7 years ago

Add a source filter and two terminal filters.

  • 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: 8.7 KB
Line 
1#ifndef __XIOS_CField__
2#define __XIOS_CField__
3
4/// XIOS headers ///
5#include "xios_spl.hpp"
6#include "group_factory.hpp"
7#include "functor.hpp"
8#include "functor_type.hpp"
9#include "duration.hpp"
10#include "date.hpp"
11#include "declare_group.hpp"
12#include "calendar_util.hpp"
13#include "array_new.hpp"
14#include "attribute_array.hpp"
15#include "expr_node.hpp"
16#include "declare_ref_func.hpp"
17#include "transformation_enum.hpp"
18
19
20namespace xios {
21
22   /// ////////////////////// Déclarations ////////////////////// ///
23
24   class CFieldGroup;
25   class CFieldAttributes;
26   class CField;
27
28   class CFile;
29   class CGrid;
30   class CContext ;
31   class CGenericFilter;
32
33   ///--------------------------------------------------------------
34
35   // Declare/Define CFieldAttribute
36   BEGIN_DECLARE_ATTRIBUTE_MAP(CField)
37#  include "field_attribute.conf"
38   END_DECLARE_ATTRIBUTE_MAP(CField)
39
40   ///--------------------------------------------------------------
41   class CField
42      : public CObjectTemplate<CField>
43      , public CFieldAttributes
44   {
45         /// friend ///
46         friend class CFile;
47
48         /// typedef ///
49         typedef CObjectTemplate<CField>   SuperClass;
50         typedef CFieldAttributes SuperClassAttribute;
51
52      public :
53
54         typedef CFieldAttributes RelAttributes;
55         typedef CFieldGroup      RelGroup;
56
57         enum EEventId
58         {
59           EVENT_ID_UPDATE_DATA, EVENT_ID_READ_DATA, EVENT_ID_READ_DATA_READY,
60           EVENT_ID_ADD_VARIABLE, EVENT_ID_ADD_VARIABLE_GROUP
61         } ;
62
63         /// Constructeurs ///
64         CField(void);
65         explicit CField(const StdString & id);
66         CField(const CField & field);       // Not implemented yet.
67         CField(const CField * const field); // Not implemented yet.
68
69         /// Accesseurs ///
70
71         CGrid* getRelGrid(void) const ;
72         CFile* getRelFile(void) const ;
73
74      public :
75
76         StdSize getNStep(void) const;
77
78         const CDuration & getFreqOperation(void) const;
79         const CDuration & getFreqWrite(void) const;
80
81         boost::shared_ptr<CDate> getLastWriteDate(void) const;
82         boost::shared_ptr<CDate> getLastOperationDate(void) const;
83
84         boost::shared_ptr<func::CFunctor> getFieldOperation(void) const;
85
86         CArray<double, 1> getData(void) const;
87         template <int N> void getData(CArray<double, N>& _data) const;
88
89
90         /// Mutateur ///
91         void setRelFile(CFile* _file);
92         void incrementNStep(void);
93         void resetNStep() ;
94         void resetNStepMax();
95
96         template <int N> bool updateData(const CArray<double, N>&   data);
97         template <int N> bool updateFilteredData(CArray<double, N>&   data);
98         template<int N>
99         void updateDataWithoutOperation(const CArray<double, N>& _data, CArray<double,1>& updatedData);
100         bool updateDataFromExpression(const CArray<double, 1>&   data);
101         void setDataFromExpression(const CArray<double, 1>& _data) ;
102
103         bool updateDataServer
104               (const CDate & currDate,
105                const std::deque< CArray<double, 1>* > storedClient);
106
107         std::map<int, StdSize> getGridDataSize();
108
109       public :
110         bool isActive(void) const;
111         bool active ;
112         bool hasOutputFile ;
113         bool hasFieldOut ;
114
115         /// Traitements ///
116         void processEnabledField(void) ;
117
118         void solveGridReference(void);
119         void solveOperation(void);
120         void solveCheckMaskIndex(bool doSendingIndex);
121         void solveAllReferenceEnabledField(bool doSending2Sever);
122         void buildAllExpressionEnabledField();
123         void solveGridDomainAxisRef(bool checkAtt);
124         void solveTransformedGrid();
125         CGrid* getGridRefOfBaseReference();
126
127//         virtual void fromBinary(StdIStream & is);
128
129         /// Destructeur ///
130         virtual ~CField(void);
131
132         /// Accesseurs statiques ///
133         static StdString GetName(void);
134         static StdString GetDefName(void);
135
136         static ENodeType GetType(void);
137
138        template <int N> void setData(const CArray<double, N>& _data) ;
139        static bool dispatchEvent(CEventServer& event) ;
140        void sendUpdateData(void) ;
141        void sendUpdateData(const CArray<double,1>& data);
142        static void recvUpdateData(CEventServer& event) ;
143        void recvUpdateData(vector<int>& ranks, vector<CBufferIn*>& buffers) ;
144        void writeField(void) ;
145        void sendReadDataRequest(void);
146        bool sendReadDataRequestIfNeeded(void);
147        static void recvReadDataRequest(CEventServer& event);
148        void recvReadDataRequest(void);
149        bool readField(void);
150        static void recvReadDataReady(CEventServer& event);
151        void recvReadDataReady(vector<int> ranks, vector<CBufferIn*> buffers);
152        void outputField(CArray<double,3>& fieldOut) ;
153        void outputField(CArray<double,2>& fieldOut) ;
154        void outputField(CArray<double,1>& fieldOut) ;
155        void inputField(CArray<double,3>& fieldOut);
156        void inputField(CArray<double,2>& fieldOut);
157        void inputField(CArray<double,1>& fieldOut);
158        void scaleFactorAddOffset(double scaleFactor, double addOffset) ;
159        void invertScaleFactorAddOffset(double scaleFactor, double addOffset);
160        void parse(xml::CXMLNode & node) ;
161        CArray<double,1>* getInstantData(void)  ;
162
163        void setVirtualVariableGroup(CVariableGroup* newVVariableGroup);
164        void setVirtualVariableGroup(void);
165        CVariableGroup* getVirtualVariableGroup(void) const;
166        vector<CVariable*> getAllVariables(void) const;
167        virtual void solveDescInheritance(bool apply, const CAttributeMap * const parent = 0);
168
169        CVariable* addVariable(const string& id="") ;
170        CVariableGroup* addVariableGroup(const string& id="") ;
171        void sendAddVariable(const string& id="") ;
172        void sendAddVariableGroup(const string& id="") ;
173        static void recvAddVariable(CEventServer& event) ;
174        void recvAddVariable(CBufferIn& buffer) ;
175        static void recvAddVariableGroup(CEventServer& event) ;
176        void recvAddVariableGroup(CBufferIn& buffer) ;
177        void sendAddAllVariables();
178
179
180        const std::pair<StdString, StdString>& getRefDomainAxisIds();
181
182        const std::vector<CField*>& getFilterSources();
183        void applyFilter(const CArray<double, 1>& dataToSend, CArray<double,1>& dataToReceive);
184        void sendAndReceiveTransformedData(const std::map<int, CArray<int,1>* >& localIndexToSend,
185                                           const CArray<double, 1>& dataSrc,
186                                           const std::map<int,std::vector<std::vector<std::pair<int,double> > > >& localIndexToReceive,
187                                           CArray<double,1>& dataDest);
188      public :
189         /// Propriétés privées ///
190         CVariableGroup* vVariableGroup ;
191
192         CGrid*  grid ;
193         CFile*  file;
194         CField* fieldOut ;
195
196         CDuration freq_operation, freq_write;
197         CDuration freq_operation_srv, freq_write_srv;
198
199         StdSize nstep, nstepMax;
200         bool isEOF;
201         boost::shared_ptr<CDate>    last_Write, last_operation;
202         boost::shared_ptr<CDate>    lastlast_Write_srv,last_Write_srv, last_operation_srv;
203         CDate lastDataRequestedFromServer;
204
205         boost::shared_ptr<func::CFunctor> foperation;
206         map<int,boost::shared_ptr<func::CFunctor> > foperation_srv;
207
208         CArray<double, 1> data;
209         CArray<double, 1> instantData;
210         CArray<double, 1> filteredData;
211         bool hasInstantData ;
212         map<int, CArray<double,1>* > data_srv ;
213         bool isOnceOperation ;
214         bool isFirstOperation ;
215         string content ;
216
217         list< pair<CField *,int> > fieldDependency ;
218         void buildExpression(void) ;
219         void addDependency(CField* field, int slotId) ;
220         void resetSlots(void) ;
221         vector<bool> slots ;
222         CDate* slotUpdateDate ;
223         CFieldNode * expression ;
224         bool hasExpression ;
225         bool slotsFull(void) ;
226         void setSlot(int slotId);
227         bool processed ;
228         bool areAllReferenceSolved;
229         bool areAllExpressionBuilt;
230         std::pair<StdString,StdString> domAxisIds_;
231         bool isReadDataRequestPending;
232         std::vector<CField*> filterSources_;
233         DECLARE_REF_FUNC(Field,field)
234
235   }; // class CField
236
237   ///--------------------------------------------------------------
238
239   // Declare/Define CFieldGroup and CFieldDefinition
240   DECLARE_GROUP(CField);
241
242   ///-----------------------------------------------------------------
243
244   template <>
245      void CGroupTemplate<CField, CFieldGroup, CFieldAttributes>::solveRefInheritance(void);
246
247   ///-----------------------------------------------------------------
248} // namespace xios
249
250
251#endif // __XIOS_CField__
Note: See TracBrowser for help on using the repository browser.