src/utils/Report.cpp

#include "utils/Report.hpp"

#include <iomanip>

#include "utils/SystemUtilities.hpp"

using namespace std;

namespace OpenMD {
//____ Report
  namespace Report {
    MyStreamer &debug::operator()(MyStreamer &stream) const {
      stream.setLevel(myLevel);
      stream << "DEBUG:  ";
      return stream;
    }

    MyStreamer &reportlevel::operator()(MyStreamer &stream) const {
      stream.setReportLevel(myReportlevel);
      return stream;
    }
    //___________________________________________________________ 
    // Currently defaulting to std::cerr
    MyStreamer report(&(std::cerr));

    // MyStreamer
    MyStreamer::MyStreamer(ostream *a) {
      setStream(a);
    }

    // Allows the changing of the stream
    ostream *MyStreamer::setStream(ostream *a) {
      ostream *tmp = myStream;
      myStream = (a != NULL) ? a : &(cerr);
      myResetFlags = myStream->flags();
      myAbort = false;
      myQuit = false;
      myAllNodes = false;
      myAllNodesSerial = false;
      myAllSlavesSerial = false;
      myIAmMaster = true;
      myDoHint = true;
      mySilentHint = 0;
      myReportLevel = 0;
      myLevel = 0;
      return tmp;
    }

    void MyStreamer::setAbort(bool flag) {
      myAbort = flag;
    }

    void MyStreamer::setQuit(bool flag) {
      myQuit = flag;
    }

    void MyStreamer::setAllNodes(bool flag) {
      myAllNodes = flag;
    }

    void MyStreamer::setf(ios::fmtflags flag) {
      myStream->setf(flag);
    }

    void MyStreamer::setf(ios::fmtflags flag, ios::fmtflags mask) {
      myStream->setf(flag, mask);
    }

    void MyStreamer::precision(int prec) {
      myStream->precision(prec);
    }

    void MyStreamer::width(int wide) {
      myStream->width(wide);
    }

    void MyStreamer::reset() {
      myStream->flags(myResetFlags);
    }

    // MyStreamer
    // Standard Overloads

    MyStreamer &MyStreamer::operator<<(bool a) {
      if (print()){
        if (a) {
                  *myStream << "true";
                }else{
                  *myStream << "false";
                }
          }
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(char a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(unsigned char a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(signed char a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(char *a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(const char *a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(unsigned char *a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(signed char *a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(short a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(unsigned short a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(int a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(unsigned int a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(long a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(unsigned long a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(long long a) {
      if (print())
#if (defined (_GLIBCPP_USE_LONG_LONG) || !defined (__GNUC__))
        *myStream << a;
#else
        *myStream << (long)a;
#endif
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(unsigned long long a) {
      if (print())
#if (defined (_GLIBCPP_USE_LONG_LONG) || !defined (__GNUC__))
        *myStream << a;
#else
        *myStream << (unsigned long)a;
#endif
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(float a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(double a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(const ostream &a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(ostream *a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(ios & (*f)(ios &)) {
      if (print())
        (*f)(*myStream);
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(ostream & (*f)(ostream &)) {
      if (print())
        (*f)(*myStream);
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(const string &a) {
      if (print())
        *myStream << a;
      return *this;
    }

    MyStreamer &MyStreamer::operator<<(MyStreamer & (*f)(MyStreamer &)) {
      (*f)(*this);
      return *this;
    }

    // Our Output Levels

    MyStreamer &plain(MyStreamer &stream) {
      stream.myLevel = -4;
      return stream;
    }

    MyStreamer &error(MyStreamer &stream) {
      stream.myAbort = true;
      stream.myLevel = -3;
      if (stream.print())
        stream << "Fatal Error:  ";
      return stream;
    }

    MyStreamer &recoverable(MyStreamer &stream) {
      stream.myLevel = -2;
      if (stream.print())
        stream << "Recoverable Error:  ";
      return stream;
    }

    MyStreamer &warning(MyStreamer &stream) {
      stream.myLevel = -1;
      if (stream.print())
        stream << "Warning:  ";
      return stream;
    }

    MyStreamer &hint(MyStreamer &stream) {
      stream.myLevel = 0;
      if (!stream.myDoHint)
        stream.mySilentHint++;
      if (stream.print())
        stream << "Hint:  ";
      return stream;
    }

    MyStreamer &operator<<(MyStreamer &stream, const reportlevel &rl) {
      return rl(stream);
    }

    MyStreamer &operator<<(MyStreamer &stream, const debug &d) {      
      return d(stream);
    }

    MyStreamer &allnodes(MyStreamer &stream) {
      stream.myAllNodes = true;
      return stream;
    }

    MyStreamer &quit(MyStreamer &stream) {
      stream.myQuit = true;
      return stream;
    }

    MyStreamer &aborting(MyStreamer &stream) {
      stream.myAbort = true;
      return stream;
    }

    MyStreamer &dohint(MyStreamer &stream) {
      stream.myDoHint = true;
      return stream;
    }

    MyStreamer &donthint(MyStreamer &stream) {
      stream.myDoHint = false;
      return stream;
    }

    // Our Output Controll
    MyStreamer &allnodesserial(MyStreamer &stream) {
      stream.myAllNodes = true;
      stream.myAllNodesSerial = true;
      stream << flush;
      openMDStartSerial(false);
      return stream;
    }

    MyStreamer &allslavesserial(MyStreamer &stream) {
      stream.myAllNodes = true;
      stream.myAllSlavesSerial = true;
      stream << flush;
      openMDStartSerial(true);
      return stream;
    }

    MyStreamer &endr(MyStreamer &stream) {
      stream << endl;
      if (!stream.myDoHint)
        stream.mySilentHint = max(stream.mySilentHint - 1, 0);
      if (stream.myQuit)
        if (!stream.myAllNodesSerial || !stream.myAllSlavesSerial)
          openMDExit();
        else
          openMDAbort();
      else if (stream.myAbort)
        openMDAbort();
      else if (stream.myAllNodesSerial)
        openMDEndSerial(false);
      else if (stream.myAllSlavesSerial)
        openMDEndSerial(true);
      stream.myAllSlavesSerial = false;
      stream.myAllNodesSerial = false;
      stream.myAllNodes = false;
      return stream;
    }
  }
}
Revision:	1492
Committed:	Mon Aug 16 18:07:50 2010 UTC (14 years, 8 months ago) by chuckv
File size:	7811 byte(s)
Log Message:	Adding exception and reporting mechanism from ProtoMol to OpenMD.
#	User	Rev	Content
1	chuckv	1492	#include "utils/Report.hpp"
2	chuckv	1490
3			#include <iomanip>
4
5	chuckv	1492	#include "utils/SystemUtilities.hpp"
6	chuckv	1490
7			using namespace std;
8
9	chuckv	1492	namespace OpenMD {
10	chuckv	1490	//____ Report
11			namespace Report {
12			MyStreamer &debug::operator()(MyStreamer &stream) const {
13			stream.setLevel(myLevel);
14			stream << "DEBUG: ";
15			return stream;
16			}
17
18			MyStreamer &reportlevel::operator()(MyStreamer &stream) const {
19			stream.setReportLevel(myReportlevel);
20			return stream;
21			}
22			//___________________________________________________________
23			// Currently defaulting to std::cerr
24			MyStreamer report(&(std::cerr));
25
26			// MyStreamer
27			MyStreamer::MyStreamer(ostream *a) {
28			setStream(a);
29			}
30
31			// Allows the changing of the stream
32			ostream MyStreamer::setStream(ostream a) {
33			ostream *tmp = myStream;
34			myStream = (a != NULL) ? a : &(cerr);
35			myResetFlags = myStream->flags();
36			myAbort = false;
37			myQuit = false;
38			myAllNodes = false;
39			myAllNodesSerial = false;
40			myAllSlavesSerial = false;
41			myIAmMaster = true;
42			myDoHint = true;
43			mySilentHint = 0;
44			myReportLevel = 0;
45			myLevel = 0;
46			return tmp;
47			}
48
49			void MyStreamer::setAbort(bool flag) {
50			myAbort = flag;
51			}
52
53			void MyStreamer::setQuit(bool flag) {
54			myQuit = flag;
55			}
56
57			void MyStreamer::setAllNodes(bool flag) {
58			myAllNodes = flag;
59			}
60
61			void MyStreamer::setf(ios::fmtflags flag) {
62			myStream->setf(flag);
63			}
64
65			void MyStreamer::setf(ios::fmtflags flag, ios::fmtflags mask) {
66			myStream->setf(flag, mask);
67			}
68
69			void MyStreamer::precision(int prec) {
70			myStream->precision(prec);
71			}
72
73			void MyStreamer::width(int wide) {
74			myStream->width(wide);
75			}
76
77			void MyStreamer::reset() {
78			myStream->flags(myResetFlags);
79			}
80
81			// MyStreamer
82			// Standard Overloads
83
84			MyStreamer &MyStreamer::operator<<(bool a) {
85			if (print()){
86			if (a) {
87			*myStream << "true";
88			}else{
89			*myStream << "false";
90			}
91			}
92			return *this;
93			}
94
95			MyStreamer &MyStreamer::operator<<(char a) {
96			if (print())
97			*myStream << a;
98			return *this;
99			}
100
101			MyStreamer &MyStreamer::operator<<(unsigned char a) {
102			if (print())
103			*myStream << a;
104			return *this;
105			}
106
107			MyStreamer &MyStreamer::operator<<(signed char a) {
108			if (print())
109			*myStream << a;
110			return *this;
111			}
112
113			MyStreamer &MyStreamer::operator<<(char *a) {
114			if (print())
115			*myStream << a;
116			return *this;
117			}
118
119			MyStreamer &MyStreamer::operator<<(const char *a) {
120			if (print())
121			*myStream << a;
122			return *this;
123			}
124
125			MyStreamer &MyStreamer::operator<<(unsigned char *a) {
126			if (print())
127			*myStream << a;
128			return *this;
129			}
130
131			MyStreamer &MyStreamer::operator<<(signed char *a) {
132			if (print())
133			*myStream << a;
134			return *this;
135			}
136
137			MyStreamer &MyStreamer::operator<<(short a) {
138			if (print())
139			*myStream << a;
140			return *this;
141			}
142
143			MyStreamer &MyStreamer::operator<<(unsigned short a) {
144			if (print())
145			*myStream << a;
146			return *this;
147			}
148
149			MyStreamer &MyStreamer::operator<<(int a) {
150			if (print())
151			*myStream << a;
152			return *this;
153			}
154
155			MyStreamer &MyStreamer::operator<<(unsigned int a) {
156			if (print())
157			*myStream << a;
158			return *this;
159			}
160
161			MyStreamer &MyStreamer::operator<<(long a) {
162			if (print())
163			*myStream << a;
164			return *this;
165			}
166
167			MyStreamer &MyStreamer::operator<<(unsigned long a) {
168			if (print())
169			*myStream << a;
170			return *this;
171			}
172
173			MyStreamer &MyStreamer::operator<<(long long a) {
174			if (print())
175			#if (defined (_GLIBCPP_USE_LONG_LONG) \|\| !defined (__GNUC__))
176			*myStream << a;
177			#else
178			*myStream << (long)a;
179			#endif
180			return *this;
181			}
182
183			MyStreamer &MyStreamer::operator<<(unsigned long long a) {
184			if (print())
185			#if (defined (_GLIBCPP_USE_LONG_LONG) \|\| !defined (__GNUC__))
186			*myStream << a;
187			#else
188			*myStream << (unsigned long)a;
189			#endif
190			return *this;
191			}
192
193			MyStreamer &MyStreamer::operator<<(float a) {
194			if (print())
195			*myStream << a;
196			return *this;
197			}
198
199			MyStreamer &MyStreamer::operator<<(double a) {
200			if (print())
201			*myStream << a;
202			return *this;
203			}
204
205			MyStreamer &MyStreamer::operator<<(const ostream &a) {
206			if (print())
207			*myStream << a;
208			return *this;
209			}
210
211			MyStreamer &MyStreamer::operator<<(ostream *a) {
212			if (print())
213			*myStream << a;
214			return *this;
215			}
216
217			MyStreamer &MyStreamer::operator<<(ios & (*f)(ios &)) {
218			if (print())
219			(f)(myStream);
220			return *this;
221			}
222
223			MyStreamer &MyStreamer::operator<<(ostream & (*f)(ostream &)) {
224			if (print())
225			(f)(myStream);
226			return *this;
227			}
228
229			MyStreamer &MyStreamer::operator<<(const string &a) {
230			if (print())
231			*myStream << a;
232			return *this;
233			}
234
235			MyStreamer &MyStreamer::operator<<(MyStreamer & (*f)(MyStreamer &)) {
236			(f)(this);
237			return *this;
238			}
239
240			// Our Output Levels
241
242			MyStreamer &plain(MyStreamer &stream) {
243			stream.myLevel = -4;
244			return stream;
245			}
246
247			MyStreamer &error(MyStreamer &stream) {
248			stream.myAbort = true;
249			stream.myLevel = -3;
250			if (stream.print())
251			stream << "Fatal Error: ";
252			return stream;
253			}
254
255			MyStreamer &recoverable(MyStreamer &stream) {
256			stream.myLevel = -2;
257			if (stream.print())
258			stream << "Recoverable Error: ";
259			return stream;
260			}
261
262			MyStreamer &warning(MyStreamer &stream) {
263			stream.myLevel = -1;
264			if (stream.print())
265			stream << "Warning: ";
266			return stream;
267			}
268
269			MyStreamer &hint(MyStreamer &stream) {
270			stream.myLevel = 0;
271			if (!stream.myDoHint)
272			stream.mySilentHint++;
273			if (stream.print())
274			stream << "Hint: ";
275			return stream;
276			}
277
278			MyStreamer &operator<<(MyStreamer &stream, const reportlevel &rl) {
279			return rl(stream);
280			}
281
282			MyStreamer &operator<<(MyStreamer &stream, const debug &d) {
283			return d(stream);
284			}
285
286			MyStreamer &allnodes(MyStreamer &stream) {
287			stream.myAllNodes = true;
288			return stream;
289			}
290
291			MyStreamer &quit(MyStreamer &stream) {
292			stream.myQuit = true;
293			return stream;
294			}
295
296			MyStreamer &aborting(MyStreamer &stream) {
297			stream.myAbort = true;
298			return stream;
299			}
300
301			MyStreamer &dohint(MyStreamer &stream) {
302			stream.myDoHint = true;
303			return stream;
304			}
305
306			MyStreamer &donthint(MyStreamer &stream) {
307			stream.myDoHint = false;
308			return stream;
309			}
310
311			// Our Output Controll
312			MyStreamer &allnodesserial(MyStreamer &stream) {
313			stream.myAllNodes = true;
314			stream.myAllNodesSerial = true;
315			stream << flush;
316	chuckv	1492	openMDStartSerial(false);
317	chuckv	1490	return stream;
318			}
319
320			MyStreamer &allslavesserial(MyStreamer &stream) {
321			stream.myAllNodes = true;
322			stream.myAllSlavesSerial = true;
323			stream << flush;
324	chuckv	1492	openMDStartSerial(true);
325	chuckv	1490	return stream;
326			}
327
328			MyStreamer &endr(MyStreamer &stream) {
329			stream << endl;
330			if (!stream.myDoHint)
331			stream.mySilentHint = max(stream.mySilentHint - 1, 0);
332			if (stream.myQuit)
333			if (!stream.myAllNodesSerial \|\| !stream.myAllSlavesSerial)
334	chuckv	1492	openMDExit();
335	chuckv	1490	else
336	chuckv	1492	openMDAbort();
337	chuckv	1490	else if (stream.myAbort)
338	chuckv	1492	openMDAbort();
339	chuckv	1490	else if (stream.myAllNodesSerial)
340	chuckv	1492	openMDEndSerial(false);
341	chuckv	1490	else if (stream.myAllSlavesSerial)
342	chuckv	1492	openMDEndSerial(true);
343	chuckv	1490	stream.myAllSlavesSerial = false;
344			stream.myAllNodesSerial = false;
345			stream.myAllNodes = false;
346			return stream;
347			}
348			}
349			}