OriginHost.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_OriginHost_hpp
#define anna_diameter_comm_OriginHost_hpp

// Standard
#include <string>
#include <fstream>

// Project
#include <anna/core/util/Millisecond.hpp>
#include <anna/core/util/Recycler.hpp>
#include <anna/core/DataBlock.hpp>
#include <anna/diameter/codec/Message.hpp>
#include <anna/diameter.comm/Message.hpp>
#include <anna/diameter/codec/MessagesDeque.hpp>


namespace anna {
  namespace diameter {
    namespace codec {
      class Engine;
    }
    namespace comm {
      class Engine;
      class Entity;
      class LocalServer;

class OriginHost {

  anna::diameter::comm::Engine *a_commEngine;
  anna::diameter::comm::Entity *a_entity; // we could get it finding the unique instante within comm engine, but it is more comfortable assign here.
  anna::diameter::comm::LocalServer* a_diameterServer; // idem
  anna::diameter::codec::Engine *a_codecEngine;

  // resources
  int a_requestRetransmissions;
  anna::Recycler<anna::diameter::comm::Message> a_commMessages;

  // main
  unsigned int a_applicationId;

  // Logs & burst
  std::string a_logFile;
  bool a_splitLog, a_detailedLog, a_dumpLog;
  std::string a_burstLogFile;
  std::ofstream a_burstLogStream;
  int a_burstCycle;
  bool a_burstRepeat;
  bool a_burstActive;
  std::map < int /* dummy, p.e. used for order number */, anna::diameter::comm::Message* > a_burstMessages;
  int a_burstLoadIndx;
  std::map<int, anna::diameter::comm::Message*>::const_iterator a_burstDeliveryIt;
  int a_otaRequest;
  int a_burstPopCounter;

  anna::diameter::codec::MessagesDeque a_reactingAnswers;

public:
  OriginHost(anna::diameter::comm::Engine* commEngine, unsigned int applicationId);
  ~OriginHost() {;}

  // OriginHost name:
  const std::string &getName() const ;

  // Core resources:
  anna::diameter::comm::Engine* getCommEngine() const { return a_commEngine; }
  unsigned int getApplicationId() const { return a_applicationId; }
  anna::diameter::codec::Engine *getCodecEngine() const { return a_codecEngine; }

  void createEntity(const std::string &entityRepresentation, const anna::Millisecond &bindTimeout, const anna::Millisecond &applicationTimeout) noexcept(false);
  anna::diameter::comm::Entity *getEntity() const { return a_entity; }

  void createDiameterServer(const std::string &serverRepresentation, int sessions, const anna::Millisecond &inactivityTimeout, const anna::Millisecond &applicationTimeout, const std::string &ceaPathfile) noexcept(false);
  anna::diameter::comm::LocalServer* getDiameterServer() { return a_diameterServer; }
  void setRequestRetransmissions(int r) { if (r >= 0) a_requestRetransmissions = r; }

  // Messages factory:
  anna::diameter::comm::Message *createCommMessage() noexcept(false);
  void releaseCommMessage(anna::diameter::comm::Message*) ;

  // Traffic logs & burst:
  void setLogs(const std::string &log, bool splitLog, bool detailedLog, bool dumpLog, const std::string &burstLog) {
    a_logFile = log;
    a_splitLog = splitLog;
    a_detailedLog = detailedLog;
    a_dumpLog = dumpLog;
    a_burstLogFile = burstLog;
  }

  bool logEnabled() const { return (((a_logFile == "") || (a_logFile == "null")) ? false : true); }
  void writeLogFile(const anna::DataBlock & db, const std::string &logExtension, const std::string &detail) const ;
  void writeLogFile(const anna::diameter::codec::Message & decodedMessage, const std::string &logExtension, const std::string &detail) const ;
  void writeBurstLogFile(const std::string &buffer) ;
  bool burstLogEnabled() const { return (((a_burstLogFile == "") || (a_burstLogFile == "null")) ? false : true); }
  int clearBurst() ; // returns removed
  int loadBurstMessage(const anna::DataBlock & db) noexcept(false);
  void repeatBurst(bool repeat) { a_burstRepeat = repeat; }
  int startBurst(int initialLoad) ;  // return processed on start, or -1 if burst list is empty, -2 if invalid initial load (0 or negative)
  int pushBurst(int loadAmount) ; // returns pushed (perhaps is less than provided because of no repeat mode and burst list exhausted), or -1 if burst list is empty, -2 if invalid load (0 or negative)
  int sendBurst(int loadAmount) ; // returns sent (burst always cycled using send), returns -1 if burst list is empty, -2 if invalid load (0 or negative)
  int popBurst(int releaseAmount) ; // returns popped (perhaps is less than provided because of OTA request), or -1 if burst stopped
  int stopBurst() ; // returns remaining on cycle, or -1 if burst already stopped
  bool burstActive() const { return a_burstActive; }
  bool sendBurstMessage(bool anyway = false) ;
  std::string lookBurst(int order = -1) const ;
  std::string gotoBurst(int order) ;

  anna::xml::Node* asXML(anna::xml::Node* parent) const ;
  std::string asXMLString() const ;

  anna::diameter::codec::MessagesDeque *getReactingAnswers() { return (anna::diameter::codec::MessagesDeque*)&a_reactingAnswers; }
};

}
}
}

#endif