source: Sophya/trunk/SophyaLib/BaseTools/ppfbinstream.h@ 4068

Last change on this file since 4068 was 3750, checked in by ansari, 16 years ago

Prise en charge de float 128 bits (r_16, complex<r_16>) par les NDataBlock<T> et PPersist, controlee par le flag de compilation SO_LDBLE128 defini ds machdefs.h , Reza 03/03/2010
File size: 11.4 KB
Line 
1// This may look like C code, but it is really -*- C++ -*-
2
3#ifndef PPFBINSTREAM_H_SEEN
4#define PPFBINSTREAM_H_SEEN
5
6// PPF (Portable Persistence Format) Input/Output streams
7//
8// E. Aubourg CEA DAPNIA/SPP 1999
9// R. Ansari LAL IN2P3/CNRS 2000-2003
10
11
12#include "machdefs.h"
13#include "rawstream.h"
14
15#include <time.h>
16
17#include <complex>
18#include <string>
19#include <map>
20#include <vector>
21
22
23
24namespace SOPHYA {
25
26class PPFBinaryIOStream {
27public:
28
29 enum PPFByteOrdering {PPS_NATIVE = -1, PPS_LITTLE_ENDIAN = 0, PPS_BIG_ENDIAN = 1};
30
31 // Value of item identification tags in PPF binary streams
32 enum PPFItemTag {
33 PPS_NULL = 0, // this is a null object
34 PPS_STRING = 1, // string, length (4b) + data
35 PPS_OBJECT = 2, // classId, data...
36 PPS_REFERENCE = 3, // objectId
37 PPS_NAMETAG_TABLE = 4, // Name tag table (Written at the end of file/stream)
38 PPS_EOF = 5, // Just before tag infomation, offset to PPS_TAG
39 PPS_ENDOBJECT = 6, // marks the end of a given object information
40 PPS_NAMETAG_MARK = 7, // To have a name tag, position marker in a file
41 PPS_POSTAG_MARK = 8, // Position tag mark + 8 bytes (=stream position)
42 PPS_POSTAG_TABLE = 9, // Position tag table + 8 bytes (=stream position)
43 PPS_SIMPLE = 16, // 16 + number of bytes, up to 8 bytes
44 PPS_SIMPLE_ARRAY4 = 32, // 32 + number of bytes, up to 8 bytes, then 4 bytes of length
45 PPS_SIMPLE_ARRAY8 = 48 // 48 + number of bytes, up to 8 bytes, then 8 bytes of length
46 };
47
48 // The following values are used with PPS_SIMPLE and PPS_SIMPLE_ARRAY (Using OR)
49 enum PPFItemTagDataType {
50 PPS_DATATYPE_CHAR = 0, // 0 : DataType=character
51 PPS_DATATYPE_FLOAT = 64, // 64 : DataType=float
52 PPS_DATATYPE_COMPLEX = 65, // 65 : DataType=complex
53 PPS_DATATYPE_INTEGER = 128, // 128 :DataType=integer
54 PPS_DATATYPE_UNSIGNED = 192 // 192 :DataType=Unsigned integer
55 };
56
57 PPFBinaryIOStream();
58 virtual ~PPFBinaryIOStream();
59
60 inline int Version() {return version;} // PIn/OutPersist version number
61 inline time_t CreationDate() { return creationdate; }
62 string CreationDateStr();
63 string InfoString();
64
65 inline int_8 NbPosTags() {return _nbpostag; }
66 inline int_8 NbNameTags() {return tags.size(); }
67 inline int_8 NbObjects() {return _nbobjs; }
68 inline int_8 NbTopLevelObjects() {return _nbtlobjs; }
69 inline int_8 NbReferences() {return _nbrefs; }
70 inline int_4 MaxNestedObjsLevel() {return _maxnestlevel; }
71
72 string GetTagName(int itag); // 0..NbTags-1
73 vector<string> const & GetNameTags();
74
75protected:
76 // La liste des NameTag ds le flot
77 map<string, int_8> tags;
78 int version; // PPersist(In/Out) version
79 time_t creationdate; // Date de creation du fichier
80
81 // Variables pour garder le compte des objets et des tags
82 // Le nombre d'objets a l'ecriture est mis a jour par la classe
83 // derivee POutPersist
84 int_8 _nbpostag; // Nb de tag de positionnement
85 int_8 _nbobjs; // Nb total d'objets
86 int_8 _nbtlobjs; // Nb d'objets de niveau 1
87 int_8 _nbrefs; // Nb de references PPS_REFERENCE
88 int_4 _maxnestlevel; // Niveau maximum d'objets emboites
89};
90
91
92//! Input PPF (Portable Persist Format) streams
93class PPFBinaryInputStream : public PPFBinaryIOStream {
94public:
95 PPFBinaryInputStream(RawInOutStream * is, bool ad, bool scan=false);
96 PPFBinaryInputStream(string const& flnm, bool scan=true);
97 virtual ~PPFBinaryInputStream();
98
99 inline string FileName() { return s->getFileName(); } // Retourne le nom de fichier
100
101 // Gestion des tags
102 bool GotoPositionTag(int_8 pos);
103 bool GotoNameTag(string const& name);
104 bool GotoNameTagNum(int itag); // 0..NbTags-1
105
106 // Saut jusqu'au prochain objet
107 bool SkipToNextObject();
108 // Saut d'un item de base (tag+donnees correspondantes), le suivant ds le flot
109 bool SkipNextItem();
110 // Lecture du tag de type next item + infos correspondantes
111 // Le stream est re-positionne avant le tag
112 char NextItemTag(short & datasz, size_t & sz);
113
114 // Lecture donnees de base et tableaux de donnees de base
115 // Basic data type (and corresponding arrays) reading
116 void GetByte (char& c);
117 void GetBytes(void* ptr, size_t bytes);
118 void GetR4 (r_4&);
119 void GetR4s (r_4*, size_t);
120 void GetR8 (r_8&);
121 void GetR8s (r_8*, size_t);
122 void GetI1 (int_1&);
123 void GetI1s (int_1*, size_t);
124 void GetU1 (uint_1&);
125 void GetU1s (uint_1*, size_t);
126 void GetI2 (int_2&);
127 void GetI2s (int_2*, size_t);
128 void GetU2 (uint_2&);
129 void GetU2s (uint_2*, size_t);
130 void GetI4 (int_4&);
131 void GetI4s (int_4*, size_t);
132 void GetU4 (uint_4&);
133 void GetU4s (uint_4*, size_t);
134 void GetI8 (int_8&);
135 void GetI8s (int_8*, size_t);
136 void GetU8 (uint_8&);
137 void GetU8s (uint_8*, size_t);
138 void GetLine (char* ptr, size_t len);
139 void GetStr (string&);
140 void GetZ4 (complex<r_4> &);
141 void GetZ4s (complex<r_4> *, size_t);
142 void GetZ8 (complex<r_8> &);
143 void GetZ8s (complex<r_8> *, size_t);
144#ifdef SO_LDBLE128
145 void GetR16 (r_16&);
146 void GetR16s (r_16*, size_t);
147 void GetZ16 (complex<r_16> &);
148 void GetZ16s (complex<r_16> *, size_t);
149#endif
150
151 inline void Get(char& c) {GetByte(c);}
152 inline void Get(r_4& x) {GetR4(x);}
153 inline void Get(r_8& x) {GetR8(x);}
154 inline void Get(uint_1& x) {GetU1(x);}
155 inline void Get(int_1& x) {GetI1(x);}
156 inline void Get(uint_2& x) {GetU2(x);}
157 inline void Get(int_2& x) {GetI2(x);}
158 inline void Get(uint_4& x) {GetU4(x);}
159 inline void Get(int_4& x) {GetI4(x);}
160 inline void Get(uint_8& x) {GetU8(x);}
161 inline void Get(int_8& x) {GetI8(x);}
162 inline void Get(complex<r_4> & x) {GetZ4(x);}
163 inline void Get(complex<r_8> & x) {GetZ8(x);}
164
165 inline void Get(r_4* x, size_t n) {GetR4s(x,n);}
166 inline void Get(r_8* x, size_t n) {GetR8s(x,n);}
167 inline void Get(uint_1* x, size_t n) {GetU1s(x,n);}
168 inline void Get(int_1* x, size_t n) {GetI1s(x,n);}
169 inline void Get(uint_2* x, size_t n) {GetU2s(x,n);}
170 inline void Get(int_2* x, size_t n) {GetI2s(x,n);}
171 inline void Get(uint_4* x, size_t n) {GetU4s(x,n);}
172 inline void Get(int_4* x, size_t n) {GetI4s(x,n);}
173 inline void Get(uint_8* x, size_t n) {GetU8s(x,n);}
174 inline void Get(int_8* x, size_t n) {GetI8s(x,n);}
175 inline void Get(string& x) {GetStr(x);}
176 inline void Get(complex<r_4> * x, size_t n) { GetZ4s(x, n); }
177 inline void Get(complex<r_8> * x, size_t n) { GetZ8s(x, n); }
178#ifdef SO_LDBLE128
179 inline void Get(r_16& x) {GetR16(x);}
180 inline void Get(r_16* x, size_t n) {GetR16s(x,n);}
181 inline void Get(complex<r_16> & x) {GetZ16(x);}
182 inline void Get(complex<r_16> * x, size_t n) { GetZ16s(x, n); }
183#endif
184 // Reading a list (table) of position tags
185 void GetPosTagTable(int_8*, size_t);
186 void GetPosTagTable(vector<int_8>&);
187
188 void AnalyseTags(int lev=0); // List (all or some) tags ...
189
190protected:
191 void Init(bool scan);
192 void ReadNameTagTableV2();
193 void ReadNameTagTable();
194
195 void SkipItem(bool fgrdi=true, unsigned char itag=0);
196
197 void CheckTag (unsigned char datasz, unsigned char datatype);
198 void CheckArrayTag(unsigned char datasz, size_t sz, unsigned char datatype);
199 void GetTypeTag (unsigned char& c);
200 void GetRawByte (char& c);
201 void GetRawUByte (unsigned char& c);
202 void GetRawBytes(void* ptr, size_t bytes);
203 void GetRawI2 (int_2&);
204 void GetRawI4 (int_4&);
205 void GetRawI8 (int_8&);
206 void GetRawU8 (uint_8&);
207
208 RawInOutStream* s;
209 bool _ads; // delete/close the stream at the end
210
211 bool bigEndian;
212 // Si on a fait une lecture non sequentielle -> seqread = false
213 bool seqread;
214};
215
216//! Output stream for PPersit objects.
217class PPFBinaryOutputStream : public PPFBinaryIOStream {
218public:
219 PPFBinaryOutputStream(RawInOutStream* os, bool ad, int endianness = PPS_NATIVE);
220 PPFBinaryOutputStream(string const& flnm, int endianness = PPS_NATIVE);
221 virtual ~PPFBinaryOutputStream();
222
223 inline string FileName() { return s->getFileName(); } // Retourne le nom de fichier
224
225 // Ecriture de tags
226 int_8 WritePositionTag();
227 void WriteNameTag(string const& name);
228 inline void WriteTag(string const& name) { WriteNameTag(name); }
229
230 void PutByte (char c);
231 void PutBytes(void const* ptr, size_t bytes);
232 void PutR4 (r_4);
233 void PutR4s (r_4 const*, size_t);
234 void PutR8 (r_8);
235 void PutR8s (r_8 const*, size_t);
236 void PutI1 (int_1);
237 void PutI1s (int_1 const*, size_t);
238 void PutU1 (uint_1);
239 void PutU1s (uint_1 const*, size_t);
240 void PutI2 (int_2);
241 void PutI2s (int_2 const*, size_t);
242 void PutU2 (uint_2);
243 void PutU2s (uint_2 const*, size_t);
244 void PutI4 (int_4);
245 void PutI4s (int_4 const*, size_t);
246 void PutU4 (uint_4);
247 void PutU4s (uint_4 const*, size_t);
248 void PutI8 (int_8);
249 void PutI8s (int_8 const*, size_t);
250 void PutU8 (uint_8);
251 void PutU8s (uint_8 const*, size_t);
252 void PutLine (char const* ptr, size_t len=0); // deprecated ?
253 void PutStr (string const&);
254 void PutZ4 (complex<r_4>);
255 void PutZ4s (complex<r_4> const*, size_t);
256 void PutZ8 (complex<r_8>);
257 void PutZ8s (complex<r_8> const*, size_t);
258#ifdef SO_LDBLE128
259 void PutR16 (r_16);
260 void PutR16s (r_16 const*, size_t);
261 void PutZ16 (complex<r_16>);
262 void PutZ16s (complex<r_16> const*, size_t);
263#endif
264
265 void Put(char c) {PutByte(c);}
266 void Put(r_4 x) {PutR4(x);}
267 void Put(r_8 x) {PutR8(x);}
268 void Put(complex<r_4> x) {PutZ4(x);}
269 void Put(complex<r_8> x) {PutZ8(x);}
270 void Put(uint_1 x) {PutU1(x);}
271 void Put(int_1 x) {PutI1(x);}
272 void Put(uint_2 x) {PutU2(x);}
273 void Put(int_2 x) {PutI2(x);}
274 void Put(uint_4 x) {PutU4(x);}
275 void Put(int_4 x) {PutI4(x);}
276 void Put(uint_8 x) {PutU8(x);}
277 void Put(int_8 x) {PutI8(x);}
278 void Put(r_4 const* x, size_t n) {PutR4s(x,n);}
279 void Put(r_8 const* x, size_t n) {PutR8s(x,n);}
280 void Put(complex<r_4> const* x, size_t n) {PutZ4s(x,n);}
281 void Put(complex<r_8> const* x, size_t n) {PutZ8s(x,n);}
282#ifdef SO_LDBLE128
283 void Put(r_16 x) {PutR16(x);}
284 void Put(r_16 const* x, size_t n) {PutR16s(x,n);}
285 void Put(complex<r_16> x) {PutZ16(x);}
286 void Put(complex<r_16> const* x, size_t n) {PutZ16s(x,n);}
287#endif
288 void Put(uint_1 const* x, size_t n) {PutU1s(x,n);}
289 void Put(int_1 const* x, size_t n) {PutI1s(x,n);}
290 void Put(uint_2 const* x, size_t n) {PutU2s(x,n);}
291 void Put(int_2 const* x, size_t n) {PutI2s(x,n);}
292 void Put(uint_4 const* x, size_t n) {PutU4s(x,n);}
293 void Put(int_4 const* x, size_t n) {PutI4s(x,n);}
294 void Put(uint_8 const* x, size_t n) {PutU8s(x,n);}
295 void Put(int_8 const* x, size_t n) {PutI8s(x,n);}
296 void Put(string const& s) {PutStr(s);}
297
298 // Writing a list of position tag table
299 void PutPosTagTable(int_8 const *, size_t);
300 void PutPosTagTable(vector<int_8> const&);
301
302
303protected:
304 void Init(int endianness);
305 void WriteNameTagTable();
306 void WriteNameTagTableV2();
307
308 void PutArrayTag(unsigned char datasz, size_t sz, unsigned char datatype);
309 void PutRawByte (char);
310 void PutRawUByte (unsigned char);
311 void PutRawI2 (int_2);
312 void PutRawI4 (int_4);
313 void PutRawI8 (int_8);
314 void PutRawU8 (uint_8);
315 void PutRawBytes(void const* ptr, size_t bytes);
316
317 // Attributs, variables
318 RawInOutStream* s;
319 bool _ads; // delete/close the stream at the end
320
321 bool bigEndian;
322};
323
324
325
326} // namespace
327
328#endif
Note: See TracBrowser for help on using the repository browser.