X-Git-Url: https://git.teslayout.com/public/public/public/?a=blobdiff_plain;f=source%2Fcore%2Foam%2FModule.cpp;h=742b7e0e9eacd7fa0111b90a0dc51e12a2b904f9;hb=39033fd99e58e994a5e98c1060dcc79e0d81f9c9;hp=84991e59b3a8ca2c859e7e2e5c0abfc1d075b2b7;hpb=4e12ac57e93c052f716a6305ad8fc099c45899d1;p=anna.git

diff --git a/source/core/oam/Module.cpp b/source/core/oam/Module.cpp
index 84991e5..742b7e0 100644
--- a/source/core/oam/Module.cpp
+++ b/source/core/oam/Module.cpp
@@ -1,8 +1,8 @@
-// ANNA - Anna is Not 'N' Anymore
+// ANNA - Anna is Not Nothingness Anymore
 //
 // (c) Copyright 2005-2014 Eduardo Ramos Testillano & Francisco Ruiz Rayo
 //
-// https://bitbucket.org/testillano/anna
+// http://redmine.teslayout.com/projects/anna-suite
 //
 // Redistribution and use in source and binary forms, with or without
 // modification, are permitted provided that the following conditions
@@ -14,7 +14,7 @@
 // copyright notice, this list of conditions and the following disclaimer
 // in the documentation and/or other materials provided with the
 // distribution.
-//     * Neither the name of Google Inc. nor the names of its
+//     *  Neither the name of the copyright holder nor the names of its
 // contributors may be used to endorse or promote products derived from
 // this software without specific prior written permission.
 //
@@ -38,16 +38,17 @@
 #include <anna/core/oam/Module.hpp>
 #include <anna/core/functions.hpp>
 #include <anna/core/oam/Configuration.hpp>
+#include <anna/core/oam/CounterScope.hpp>
+#include <anna/core/oam/CounterRecorder.hpp>
 
 #include <anna/core/tracing/Logger.hpp>
 #include <anna/core/tracing/TraceWriter.hpp>
 #include <anna/core/tracing/TraceMethod.hpp>
 #include <anna/core/functions.hpp>
 #include <anna/xml/xml.hpp>
-#include <anna/core/oam/CounterManager.hpp>
 
 // Standard
-#include <stdarg.h>
+#include <cstdarg>
 
 
 #define UNDEFINED_EVENT_DESCRIPTION "<undefined>"
@@ -57,6 +58,15 @@
 //----------------------------------------------------------------------- Module
 //******************************************************************************
 
+//------------------------------------------------------------------------------
+//-------------------------------------------------------------- Module::~Module
+//------------------------------------------------------------------------------
+anna::oam::Module::~Module() {
+  for(scope_iterator scope_it = scope_begin(); scope_it != scope_end(); scope_it++)
+    delete (scope(scope_it));
+}
+
+
 //------------------------------------------------------------------------------
 //----------------------------------------------------------- Module::getScope()
 //------------------------------------------------------------------------------
@@ -251,9 +261,9 @@ void anna::oam::Module::initializeCounterScope(const int & scopeId, const std::s
     throw anna::RuntimeException("After use of counter registration can't initialize more scope ids!. Do initializations firstly", ANNA_FILE_LOCATION);
 
   // Scope range: 0 - 99
-  if(scopeId < 0 || scopeId >= anna::oam::CounterManager::MaxScope) {
+  if(scopeId < 0 || scopeId >= MaxScope) {
     std::string msg = "Scope Id must be in range [0 - ";
-    msg += anna::functions::asString(anna::oam::CounterManager::MaxScope - 1); // 99
+    msg += anna::functions::asString(MaxScope - 1); // 99
     msg += "]";
     throw anna::RuntimeException(msg, ANNA_FILE_LOCATION);
   }
@@ -275,7 +285,7 @@ void anna::oam::Module::initializeCounterScope(const int & scopeId, const std::s
   }
   );
   const char * c_description = (missingScopeDescription ? getClassName() : description.c_str());
-  a_active_counter_scope = &(anna::oam::CounterManager::instantiate().create(scopeId, c_description, true /* reuses */));
+  a_active_counter_scope = new CounterScope(scopeId, c_description);
   a_scopes[scopeId] = a_active_counter_scope;
 }
 
@@ -493,6 +503,71 @@ int anna::oam::Module::resetCounters(const int & scopeId) throw() {
 }
 
 
+//------------------------------------------------------------------------------
+//------------------------------------- Module::RecordingGuard::RecordingGuard()
+//------------------------------------------------------------------------------
+anna::oam::Module::RecordingGuard::RecordingGuard(anna::oam::Module* module) :
+  a_module(module) {                                                
+  module->a_counterRecording = true;                                               
+}                                                                                   
+                                                                                    
+
+//------------------------------------------------------------------------------
+//------------------------------------ Module::RecordingGuard::~RecordingGuard()
+//------------------------------------------------------------------------------
+anna::oam::Module::RecordingGuard::~RecordingGuard() {                            
+  a_module->a_counterRecording = false;                                            
+}                                                                                   
+
+
+//------------------------------------------------------------------------------
+//----------------------------------------------------- Module::recordCounters()
+//------------------------------------------------------------------------------
+void anna::oam::Module::recordCounters() throw(anna::RuntimeException) {
+  LOGMETHOD(anna::TraceMethod tttm("anna::oam::Module", "recordCounters", ANNA_FILE_LOCATION));
+
+  if(a_counterRecorder == NULL)
+    throw RuntimeException("anna::oam::Module has no counter recorder associated", ANNA_FILE_LOCATION);
+
+  LOGDEBUG(
+    std::string msg("Recording counters | ");
+    msg += a_counterRecorder->asString();
+    anna::Logger::write(Logger::Debug, msg, ANNA_FILE_LOCATION)
+  );
+  RecordingGuard guard(this);
+
+  a_counterRecorder->open();
+  Counter* counter = NULL;
+  CounterScope* cscope = NULL;
+
+  try {
+    for(scope_iterator scope_it = scope_begin(); scope_it != scope_end(); scope_it++) {
+      cscope = scope(scope_it);
+      if(cscope == NULL) continue;
+
+      Guard csGuard(cscope, "oam::CounterScope from oam::Module::record");
+
+      for(register int icounter = 0; icounter < CounterScope::MaxCounter; icounter ++) {
+        Counter* counter = cscope->a_counters [icounter];
+
+        if(counter == NULL)
+          continue;
+
+        if(counter->getValue() == 0)
+          continue;
+
+        a_counterRecorder->apply(*counter);
+        counter->reset();
+      }
+    }
+
+    a_counterRecorder->close();
+  } catch(anna::RuntimeException&) {
+    a_counterRecorder->close();
+    throw;
+  }
+}
+
 //------------------------------------------------------------------------------
 //----------------------------------------------------------- Module::asString()
 //------------------------------------------------------------------------------