1 | #ifndef __XIOS_NC4_DATA_OUTPUT__ |
---|
2 | #define __XIOS_NC4_DATA_OUTPUT__ |
---|
3 | |
---|
4 | /// XIOS headers /// |
---|
5 | #include "xios_spl.hpp" |
---|
6 | #include "onetcdf4.hpp" |
---|
7 | #include "data_output.hpp" |
---|
8 | |
---|
9 | namespace xios |
---|
10 | { |
---|
11 | /// ////////////////////// Déclarations ////////////////////// /// |
---|
12 | |
---|
13 | class CNc4DataOutput |
---|
14 | : protected CONetCDF4 |
---|
15 | , public virtual CDataOutput |
---|
16 | { |
---|
17 | public : |
---|
18 | |
---|
19 | /// Définition de type /// |
---|
20 | typedef CONetCDF4 SuperClassWriter; |
---|
21 | typedef CDataOutput SuperClass; |
---|
22 | |
---|
23 | /// Constructeurs /// |
---|
24 | CNc4DataOutput |
---|
25 | (CFile* file, const StdString & filename, bool exist); |
---|
26 | CNc4DataOutput |
---|
27 | (CFile* file, const StdString & filename, bool exist, bool useClassicFormat, |
---|
28 | bool useCFConvention, |
---|
29 | MPI_Comm comm_file, bool multifile, bool isCollective = true, |
---|
30 | const StdString& timeCounterName = "time_counter"); |
---|
31 | |
---|
32 | CNc4DataOutput(const CNc4DataOutput & dataoutput); // Not implemented. |
---|
33 | CNc4DataOutput(const CNc4DataOutput * const dataoutput); // Not implemented. |
---|
34 | |
---|
35 | /// Accesseur /// |
---|
36 | const StdString & getFileName(void) const; |
---|
37 | |
---|
38 | /// Destructeur /// |
---|
39 | virtual ~CNc4DataOutput(void); |
---|
40 | |
---|
41 | bool singleDomain ; |
---|
42 | bool isCollective ; |
---|
43 | int compressionLevel ; |
---|
44 | |
---|
45 | CFile* file; |
---|
46 | |
---|
47 | protected : |
---|
48 | |
---|
49 | /// Ecriture /// |
---|
50 | virtual void writeDomain_ (CDomain* domain); |
---|
51 | virtual void writeAxis_ (CAxis* axis); |
---|
52 | virtual void writeScalar_ (CScalar* scalar); |
---|
53 | virtual void writeGridCompressed_(CGrid* grid); |
---|
54 | virtual void writeTimeDimension_(void); |
---|
55 | virtual void writeField_ (CField* field); |
---|
56 | virtual void writeAttribute_(CVariable* var); |
---|
57 | virtual void writeAttribute_(CVariable* var, const string& fieldId); |
---|
58 | virtual void writeFieldData_(CField* field); |
---|
59 | virtual void writeFile_ (CFile* file); |
---|
60 | virtual void closeFile_ (void); |
---|
61 | virtual void syncFile_ (void); |
---|
62 | virtual void writeTimeAxis_ (CField* field, |
---|
63 | const boost::shared_ptr<CCalendar> cal); |
---|
64 | |
---|
65 | protected : |
---|
66 | void writeUnstructuredDomain (CDomain* domain); |
---|
67 | void writeUnstructuredDomainUgrid (CDomain* domain); |
---|
68 | void writeLocalAttributes(int ibegin, int ni, int jbegin, int nj, StdString domid); |
---|
69 | void writeLocalAttributes_IOIPSL(const StdString& dimXid, const StdString& dimYid, |
---|
70 | int ibegin, int ni, int jbegin, int nj, int ni_glo, int nj_glo, int rank, int size); |
---|
71 | void writeTimeAxisAttributes(const StdString & axis_name, |
---|
72 | const StdString & calendar, |
---|
73 | const StdString & units, |
---|
74 | const StdString & time_origin, |
---|
75 | const StdString & time_bounds = StdString("bounds"), |
---|
76 | const StdString & standard_name = StdString("time"), |
---|
77 | const StdString & long_name = StdString("Time axis")); |
---|
78 | |
---|
79 | void writeFileAttributes(const StdString & name, |
---|
80 | const StdString & description, |
---|
81 | const StdString & conventions, |
---|
82 | const StdString & production, |
---|
83 | const StdString & timeStamp); |
---|
84 | |
---|
85 | void writeMaskAttributes(const StdString & mask_name, |
---|
86 | int data_dim, |
---|
87 | int data_ni = 0, |
---|
88 | int data_nj = 0, |
---|
89 | int data_ibegin = 0, |
---|
90 | int data_jbegin = 0); |
---|
91 | |
---|
92 | void writeAxisAttributes(const StdString & axis_name, |
---|
93 | const StdString & axis, |
---|
94 | const StdString & standard_name, |
---|
95 | const StdString & long_name, |
---|
96 | const StdString & units, |
---|
97 | const StdString & nav_model); |
---|
98 | |
---|
99 | StdSize getRecordFromTime(Time time, double factorUnit); |
---|
100 | |
---|
101 | private : |
---|
102 | |
---|
103 | /// Traitement /// |
---|
104 | StdString getTimeStamp(void) const; |
---|
105 | |
---|
106 | bool isWrittenDomain(const std::string& domainName) const; |
---|
107 | bool isWrittenCompressedDomain(const std::string& domainName) const; |
---|
108 | bool isWrittenAxis(const std::string& axisName) const; |
---|
109 | bool isWrittenCompressedAxis(const std::string& axisName) const; |
---|
110 | bool isWrittenScalar(const std::string& scalarName) const; |
---|
111 | |
---|
112 | void setWrittenDomain(const std::string& domainName); |
---|
113 | void setWrittenCompressedDomain(const std::string& domainName); |
---|
114 | void setWrittenAxis(const std::string& axisName); |
---|
115 | void setWrittenCompressedAxis(const std::string& axisName); |
---|
116 | void setWrittenScalar(const std::string& scalarName); |
---|
117 | |
---|
118 | /// Propriétés privées /// |
---|
119 | MPI_Comm comm_file; |
---|
120 | const StdString filename; |
---|
121 | std::map<Time, StdSize> timeToRecordCache; |
---|
122 | |
---|
123 | std::set<std::string> writtenDomains, writtenCompressedDomains; |
---|
124 | std::set<std::string> writtenAxis, writtenCompressedAxis; |
---|
125 | std::set<std::string> writtenScalar; |
---|
126 | |
---|
127 | enum { none, centered, instant, record} timeCounterType ; |
---|
128 | bool hasTimeInstant ; |
---|
129 | bool hasTimeCentered ; |
---|
130 | }; // class CNc4DataOutput |
---|
131 | |
---|
132 | } // namespace xios |
---|
133 | |
---|
134 | #endif //__XIOS_NC4_DATA_OUTPUT__ |
---|