Message statistics

[anna.git] / include / anna / diameter.comm / Server.hpp

diff --git a/include/anna/diameter.comm/Server.hpp b/include/anna/diameter.comm/Server.hpp
index 69f5e80..6735e5f 100644 (file)
--- a/include/anna/diameter.comm/Server.hpp
+++ b/include/anna/diameter.comm/Server.hpp
@@ -13,14 +13,17 @@
 // STL
 #include <string>
 #include <vector>
+#include <map>
 
+// Project
 #include <anna/core/util/Millisecond.hpp>
 #include <anna/core/RuntimeException.hpp>
-
 #include <anna/diameter/defines.hpp>
 #include <anna/config/defines.hpp>
 #include <anna/diameter.comm/ClassCode.hpp>
-#include <anna/statistics/Accumulator.hpp>
+#include <anna/diameter.comm/MessageStatistics.hpp>
+
+
 
 
 namespace anna {
@@ -71,9 +74,7 @@ class Server {
   Engine *a_engine;
 
   // Statistics
-  int a_processing_time__StatisticConceptId;
-  int a_received_message_size__StatisticConceptId;
-  anna::statistics::Accumulator *a_statisticsAccumulator;
+  MessageStatistics a_messageStatistics;
   void initializeStatisticResources() throw();
   void resetStatistics() throw();
 
@@ -267,10 +268,10 @@ public:
 
 
   // Statistics
-  void updateProcessingTimeStatisticConcept(const double &value) throw();
-  void updateReceivedMessageSizeStatisticConcept(const double &value) throw();
-  int getProcessingTimeStatisticConcept() const throw() { return a_processing_time__StatisticConceptId; }
-  int getReceivedMessageSizeStatisticConcept() const throw() { return a_received_message_size__StatisticConceptId; }
+  void updateProcessingTimeStatisticConcept(const double &value, const anna::diameter::CommandId &cid) throw();
+  void updateReceivedMessageSizeStatisticConcept(const double &value, const anna::diameter::CommandId &cid) throw();
+//  int getProcessingTimeStatisticConcept() const throw() { return a_processing_time__StatisticConceptId; }
+//  int getReceivedMessageSizeStatisticConcept() const throw() { return a_received_message_size__StatisticConceptId; }
 
 protected: