+ lib utils

src/utils/doCheckPoint.h

@@ -0,0 +1,126 @@
+// (c) Thales group, 2010
+/*
+    Authors:
+             Johann Dreo <johann.dreo@thalesgroup.com>
+             Caner Candan <caner.candan@thalesgroup.com>
+*/
+
+#ifndef _doCheckPoint_h
+#define _doCheckPoint_h
+
+#include <utils/eoUpdater.h>
+#include <utils/eoMonitor.h>
+
+#include "doContinue.h"
+#include "doStat.h"
+
+//! eoCheckPoint< EOT > classe fitted to Distribution Object library
+
+template < typename D >
+class doCheckPoint : public doContinue< D >
+{
+public:
+    typedef typename D::EOType EOType;
+
+    doCheckPoint(doContinue< D >& _cont)
+    {
+	_continuators.push_back( &_cont );
+    }
+
+    bool operator()(const D& distrib)
+    {
+	for ( unsigned int i = 0, size = _stats.size(); i < size; ++i )
+	    {
+		(*_stats[i])( distrib );
+	    }
+
+	for ( unsigned int i = 0, size = _updaters.size(); i < size; ++i )
+	    {
+		(*_updaters[i])();
+	    }
+
+	for ( unsigned int i = 0, size = _monitors.size(); i < size; ++i )
+	    {
+		(*_monitors[i])();
+	    }
+
+	bool bContinue = true;
+	for ( unsigned int i = 0, size = _continuators.size(); i < size; ++i )
+	    {
+		if ( !(*_continuators[i])( distrib ) )
+		    {
+			bContinue = false;
+		    }
+	    }
+
+	if ( !bContinue )
+	    {
+		for ( unsigned int i = 0, size = _stats.size(); i < size; ++i )
+		    {
+			_stats[i]->lastCall( distrib );
+		    }
+
+		for ( unsigned int i = 0, size = _updaters.size(); i < size; ++i )
+		    {
+			_updaters[i]->lastCall();
+		    }
+
+		for ( unsigned int i = 0, size = _monitors.size(); i < size; ++i )
+		    {
+			_monitors[i]->lastCall();
+		    }
+	    }
+
+	return bContinue;
+    }
+
+    void add(doContinue< D >& cont) { _continuators.push_back( &cont ); }
+    void add(doStatBase< D >& stat) { _stats.push_back( &stat ); }
+    void add(eoMonitor& mon) { _monitors.push_back( &mon ); }
+    void add(eoUpdater& upd) { _updaters.push_back( &upd ); }
+
+    virtual std::string className(void) const { return "doCheckPoint"; }
+
+    std::string allClassNames() const
+    {
+	std::string s("\n" + className() + "\n");
+
+	s += "Stats\n";
+	for ( unsigned int i = 0, size = _stats.size(); i < size; ++i )
+	    {
+		s += _stats[i]->className() + "\n";
+	    }
+	s += "\n";
+
+	s += "Updaters\n";
+	for ( unsigned int i = 0; i < _updaters.size(); ++i )
+	    {
+		s += _updaters[i]->className() + "\n";
+	    }
+	s += "\n";
+
+	s += "Monitors\n";
+	for ( unsigned int i = 0; i < _monitors.size(); ++i )
+	    {
+		s += _monitors[i]->className() + "\n";
+	    }
+	s += "\n";
+
+	s += "Continuators\n";
+	for ( unsigned int i = 0, size = _continuators.size(); i < size; ++i )
+	    {
+		s += _continuators[i]->className() + "\n";
+	    }
+	s += "\n";
+
+	return s;
+    }
+
+private:
+    std::vector< doContinue< D >* > _continuators;
+    std::vector< doStatBase< D >* > _stats;
+    std::vector< eoMonitor* > _monitors;
+    std::vector< eoUpdater* > _updaters;
+};
+
+#endif // !_doCheckPoint_h