ApplicationMessageOamModule.hpp

Go to the documentation of this file.

// ANNA - Anna is Not Nothingness Anymore                                                         //
//                                                                                                //
// (c) Copyright 2005-2015 Eduardo Ramos Testillano & Francisco Ruiz Rayo                         //
//                                                                                                //
// See project site at http://redmine.teslayout.com/projects/anna-suite                           //
// See accompanying file LICENSE or copy at http://www.teslayout.com/projects/public/anna.LICENSE //


#ifndef anna_diameter_comm_ApplicationMessageOamModule_hpp
#define anna_diameter_comm_ApplicationMessageOamModule_hpp


// Project
#include <anna/core/mt/Mutex.hpp>
#include <anna/core/Singleton.hpp>
#include <anna/core/define.autoenum.hpp>
#include <anna/core/oam/Module.hpp>

// Standard
#include <string>
#include <map>

namespace anna {

namespace diameter {

namespace comm {


class ApplicationMessageOamModule : public anna::oam::Module, public anna::Singleton <ApplicationMessageOamModule> {

  std::map<std::string /* event id */, int /* base offset */> a_eventMap;
  std::map<unsigned int /* stack id */, int /* scope id */> a_stackMap;

  int a_counter_types;

  anna::Mutex a_mutex; // counter scope switch

public:

  struct Counter {
    enum _v
    {
      None = -1,

      Request_SentOK_AsClient,
      Request_SentNOK_AsClient,
      Answer_SentOK_AsClient,
      Answer_SentNOK_AsClient,
      Request_Received_AsClient,
      Answer_Received_AsClient,
      Answer_UnknownReceived_AsClient,

      Request_SentOK_AsServer,
      Request_SentNOK_AsServer,
      Answer_SentOK_AsServer,
      Answer_SentNOK_AsServer,
      Request_Received_AsServer,
      Answer_Received_AsServer,
      Answer_UnknownReceived_AsServer
    };

    anna_declare_enum(Counter);
  };

  /* virtual */std::string getDefaultInternalCounterDescription(const int & counterType) const { return Counter::asCString((Counter::_v)counterType); }

  // map stack id with a scope id
  void createStackCounterScope(int /* scope id */, unsigned int /* stack id */) noexcept(false);

  // translate message code into offset and invoke parent class count method. The message applicationId will be used as stack id
  // resultCode shall be -1 for non-answers
  void count (int messageCode, int resultCode, unsigned int stackId, const int & type, const int & amount = 1) noexcept(false);

  // Number of different counter types for each message
  int getCounterTypes() const { return a_counter_types; }

  // -1 if multistack 
  int monoStackScopeId() const {
    return ((a_stackMap.size() != 1) ? -1 : a_stackMap.begin()->second);
  }

private:

  // private constructor
  ApplicationMessageOamModule() : anna::oam::Module("Application Message Comm OAM Events") { a_counter_types = Counter::calculateSize(); }


  friend class anna::Singleton <ApplicationMessageOamModule>;
};

}
}
}

#endif