X-Git-Url: https://git.teslayout.com/public/public/public/?a=blobdiff_plain;f=include%2Fanna%2Fdiameter.comm%2FServer.hpp;h=8d5dea9b6c7b4fd1e7966a0b90d91d7179907c0a;hb=26c27c2b83f99e6df420addc90010eb0d4a7724e;hp=f7c383173a5150ce4516c77a1254a90cf03e96cf;hpb=93366a0bda79e6fd6e7dad6316bfcf8cc82f5731;p=anna.git

diff --git a/include/anna/diameter.comm/Server.hpp b/include/anna/diameter.comm/Server.hpp
index f7c3831..8d5dea9 100644
--- 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,10 +74,8 @@ class Server {
   Engine *a_engine;
 
   // Statistics
-  int a_processing_time__StatisticConceptId;
-  int a_received_message_size__StatisticConceptId;
-  anna::statistics::Accumulator a_statisticsAccumulator;
-  void initializeStatisticConcepts() throw();
+  MessageStatistics a_messageStatistics;
+  void initializeStatisticResources() throw();
   void resetStatistics() throw();
 
   // Availability
@@ -100,6 +101,9 @@ public:
    */
   Server(int maxClientSessions = 1) : a_maxClientSessions(maxClientSessions) { initialize(); }
 
+  /** Destructor */
+  virtual ~Server() {;}
+
 
   /**
   * Add a server to the entity and create all the client-sessions configured at #setSocketsPerDiameterServer within that server.
@@ -267,10 +271,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:
 
@@ -281,6 +285,13 @@ protected:
   */
   virtual void eventPeerShutdown(const ClientSession*) throw();
 
+  /**
+     Handler about a request retransmission over the session.
+
+     \param request Message retransmitted
+  */
+  virtual void eventRequestRetransmission(const ClientSession*, Message *request) throw();
+
   /**
      Handler for diameter server (client-session) responses
 
@@ -324,4 +335,3 @@ protected:
 }
 
 #endif
-