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

Last change on this file since 646 was 646, checked in by rlacroix, 6 years ago

Fix compilation after r645.

Partial recompilation was hidding the problem.

  • 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.5 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 "declare_ref_func.hpp"
16#include "transformation_enum.hpp"
17#include "variable.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   class CGarbageCollector;
34   class COutputPin;
35   class CSourceFilter;
36   class CStoreFilter;
37   class CFileWriterFilter;
38
39   ///--------------------------------------------------------------
40
41   // Declare/Define CFieldAttribute
42   BEGIN_DECLARE_ATTRIBUTE_MAP(CField)
43#  include "field_attribute.conf"
44   END_DECLARE_ATTRIBUTE_MAP(CField)
45
46   ///--------------------------------------------------------------
47   class CField
48      : public CObjectTemplate<CField>
49      , public CFieldAttributes
50   {
51         /// friend ///
52         friend class CFile;
53
54         /// typedef ///
55         typedef CObjectTemplate<CField>   SuperClass;
56         typedef CFieldAttributes SuperClassAttribute;
57
58      public :
59
60         typedef CFieldAttributes RelAttributes;
61         typedef CFieldGroup      RelGroup;
62
63         enum EEventId
64         {
65           EVENT_ID_UPDATE_DATA, EVENT_ID_READ_DATA, EVENT_ID_READ_DATA_READY,
66           EVENT_ID_ADD_VARIABLE, EVENT_ID_ADD_VARIABLE_GROUP
67         } ;
68
69         /// Constructeurs ///
70         CField(void);
71         explicit CField(const StdString & id);
72         CField(const CField & field);       // Not implemented yet.
73         CField(const CField * const field); // Not implemented yet.
74
75         /// Accesseurs ///
76
77         CGrid* getRelGrid(void) const ;
78         CFile* getRelFile(void) const ;
79
80         func::CFunctor::ETimeType getOperationTimeType() const;
81
82      public :
83
84         StdSize getNStep(void) const;
85
86         template <int N> void getData(CArray<double, N>& _data) const;
87
88         boost::shared_ptr<COutputPin> getInstantDataFilter();
89
90         /// Mutateur ///
91         void setRelFile(CFile* _file);
92         void incrementNStep(void);
93         void resetNStep() ;
94         void resetNStepMax();
95
96         std::map<int, StdSize> getGridDataSize();
97
98       public :
99         bool isActive(void) const;
100         bool hasOutputFile ;
101
102         /// Traitements ///
103         void solveGridReference(void);
104         void solveServerOperation(void);
105         void solveCheckMaskIndex(bool doSendingIndex);
106         void solveAllReferenceEnabledField(bool doSending2Sever);
107         void solveGridDomainAxisRef(bool checkAtt);
108         void solveTransformedGrid();
109
110         void buildFilterGraph(CGarbageCollector& gc, bool enableOutput);
111         boost::shared_ptr<COutputPin> getSelfReference(CGarbageCollector& gc);
112         boost::shared_ptr<COutputPin> getTemporalDataFilter(CGarbageCollector& gc, CDuration outFreq);
113
114//         virtual void fromBinary(StdIStream & is);
115
116         /// Destructeur ///
117         virtual ~CField(void);
118
119         /// Accesseurs statiques ///
120         static StdString GetName(void);
121         static StdString GetDefName(void);
122
123         static ENodeType GetType(void);
124
125        template <int N> void setData(const CArray<double, N>& _data) ;
126        static bool dispatchEvent(CEventServer& event) ;
127        void sendUpdateData(const CArray<double,1>& data);
128        static void recvUpdateData(CEventServer& event) ;
129        void recvUpdateData(vector<int>& ranks, vector<CBufferIn*>& buffers) ;
130        void writeField(void) ;
131        void sendReadDataRequest(void);
132        bool sendReadDataRequestIfNeeded(void);
133        static void recvReadDataRequest(CEventServer& event);
134        void recvReadDataRequest(void);
135        bool readField(void);
136        static void recvReadDataReady(CEventServer& event);
137        void recvReadDataReady(vector<int> ranks, vector<CBufferIn*> buffers);
138        void outputField(CArray<double,3>& fieldOut) ;
139        void outputField(CArray<double,2>& fieldOut) ;
140        void outputField(CArray<double,1>& fieldOut) ;
141        void inputField(CArray<double,3>& fieldOut);
142        void inputField(CArray<double,2>& fieldOut);
143        void inputField(CArray<double,1>& fieldOut);
144        void scaleFactorAddOffset(double scaleFactor, double addOffset) ;
145        void invertScaleFactorAddOffset(double scaleFactor, double addOffset);
146        void parse(xml::CXMLNode & node) ;
147
148        void setVirtualVariableGroup(CVariableGroup* newVVariableGroup);
149        void setVirtualVariableGroup(void);
150        CVariableGroup* getVirtualVariableGroup(void) const;
151        vector<CVariable*> getAllVariables(void) const;
152        virtual void solveDescInheritance(bool apply, const CAttributeMap * const parent = 0);
153
154        CVariable* addVariable(const string& id="") ;
155        CVariableGroup* addVariableGroup(const string& id="") ;
156        void sendAddVariable(const string& id="") ;
157        void sendAddVariableGroup(const string& id="") ;
158        static void recvAddVariable(CEventServer& event) ;
159        void recvAddVariable(CBufferIn& buffer) ;
160        static void recvAddVariableGroup(CEventServer& event) ;
161        void recvAddVariableGroup(CBufferIn& buffer) ;
162        void sendAddAllVariables();
163
164
165        const std::pair<StdString, StdString>& getRefDomainAxisIds();
166
167      public :
168         /// Propriétés privées ///
169         CVariableGroup* vVariableGroup ;
170
171         CGrid*  grid ;
172         CFile*  file;
173
174         CDuration freq_operation_srv, freq_write_srv;
175
176         StdSize nstep, nstepMax;
177         bool isEOF;
178         boost::shared_ptr<CDate> lastlast_Write_srv, last_Write_srv, last_operation_srv;
179         CDate lastDataRequestedFromServer;
180
181         map<int,boost::shared_ptr<func::CFunctor> > foperation_srv;
182
183         map<int, CArray<double,1>* > data_srv ;
184         string content ;
185
186         bool areAllReferenceSolved;
187         std::pair<StdString,StdString> domAxisIds_;
188         bool isReadDataRequestPending;
189
190         DECLARE_REF_FUNC(Field,field)
191
192      private:
193         //! The type of operation attached to the field
194         func::CFunctor::ETimeType operationTimeType;
195
196         //! The output pin of the filter providing the instant data for the field
197         boost::shared_ptr<COutputPin> instantDataFilter;
198         //! The output pin of the filters providing the result of the field's temporal operation
199         std::map<CDuration, boost::shared_ptr<COutputPin>, DurationFakeLessComparator> temporalDataFilters;
200         //! The source filter for data provided by the client
201         boost::shared_ptr<CSourceFilter> clientSourceFilter;
202         //! The source filter for data provided by the server
203         boost::shared_ptr<CSourceFilter> serverSourceFilter;
204         //! The terminal filter which stores the instant data
205         boost::shared_ptr<CStoreFilter> storeFilter;
206         //! The terminal filter which writes the data to file
207         boost::shared_ptr<CFileWriterFilter> fileWriterFilter;
208   }; // class CField
209
210   ///--------------------------------------------------------------
211
212   // Declare/Define CFieldGroup and CFieldDefinition
213   DECLARE_GROUP(CField);
214
215   ///-----------------------------------------------------------------
216
217   template <>
218      void CGroupTemplate<CField, CFieldGroup, CFieldAttributes>::solveRefInheritance(void);
219
220   ///-----------------------------------------------------------------
221} // namespace xios
222
223
224#endif // __XIOS_CField__
Note: See TracBrowser for help on using the repository browser.