ANNA Suite  2020b
Multipurpose development suite for Telco applications
Public Member Functions | List of all members
anna::diameter::comm::OriginHost Class Reference

#include <OriginHost.hpp>

Public Member Functions

 OriginHost (anna::diameter::comm::Engine *commEngine, unsigned int applicationId)
 
 ~OriginHost ()
 
const std::string & getName () const
 
anna::diameter::comm::EnginegetCommEngine () const
 
unsigned int getApplicationId () const
 
anna::diameter::codec::EnginegetCodecEngine () const
 
void createEntity (const std::string &entityRepresentation, const anna::Millisecond &bindTimeout, const anna::Millisecond &applicationTimeout) noexcept(false)
 
anna::diameter::comm::EntitygetEntity () const
 
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::LocalServergetDiameterServer ()
 
void setRequestRetransmissions (int r)
 
anna::diameter::comm::MessagecreateCommMessage () noexcept(false)
 
void releaseCommMessage (anna::diameter::comm::Message *)
 
void setLogs (const std::string &log, bool splitLog, bool detailedLog, bool dumpLog, const std::string &burstLog)
 
bool logEnabled () const
 
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
 
int clearBurst ()
 
int loadBurstMessage (const anna::DataBlock &db) noexcept(false)
 
void repeatBurst (bool repeat)
 
int startBurst (int initialLoad)
 
int pushBurst (int loadAmount)
 
int sendBurst (int loadAmount)
 
int popBurst (int releaseAmount)
 
int stopBurst ()
 
bool burstActive () const
 
bool sendBurstMessage (bool anyway=false)
 
std::string lookBurst (int order=-1) const
 
std::string gotoBurst (int order)
 
anna::xml::NodeasXML (anna::xml::Node *parent) const
 
std::string asXMLString () const
 
anna::diameter::codec::MessagesDequegetReactingAnswers ()
 

Detailed Description

OriginHost with single access point for client and server That is to say: only one communication engine, then:

Constructor & Destructor Documentation

◆ OriginHost()

anna::diameter::comm::OriginHost::OriginHost ( anna::diameter::comm::Engine commEngine,
unsigned int  applicationId 
)

◆ ~OriginHost()

anna::diameter::comm::OriginHost::~OriginHost ( )
inline
73 {;}

Member Function Documentation

◆ asXML()

anna::xml::Node* anna::diameter::comm::OriginHost::asXML ( anna::xml::Node parent) const

◆ asXMLString()

std::string anna::diameter::comm::OriginHost::asXMLString ( ) const

◆ burstActive()

bool anna::diameter::comm::OriginHost::burstActive ( ) const
inline
116 { return a_burstActive; }

◆ burstLogEnabled()

bool anna::diameter::comm::OriginHost::burstLogEnabled ( ) const
inline
107 { return (((a_burstLogFile == "") || (a_burstLogFile == "null")) ? false : true); }

◆ clearBurst()

int anna::diameter::comm::OriginHost::clearBurst ( )

◆ createCommMessage()

anna::diameter::comm::Message* anna::diameter::comm::OriginHost::createCommMessage ( )
noexcept

◆ createDiameterServer()

void anna::diameter::comm::OriginHost::createDiameterServer ( const std::string &  serverRepresentation,
int  sessions,
const anna::Millisecond inactivityTimeout,
const anna::Millisecond applicationTimeout,
const std::string &  ceaPathfile 
)
noexcept

◆ createEntity()

void anna::diameter::comm::OriginHost::createEntity ( const std::string &  entityRepresentation,
const anna::Millisecond bindTimeout,
const anna::Millisecond applicationTimeout 
)
noexcept

◆ getApplicationId()

unsigned int anna::diameter::comm::OriginHost::getApplicationId ( ) const
inline
80 { return a_applicationId; }

◆ getCodecEngine()

anna::diameter::codec::Engine* anna::diameter::comm::OriginHost::getCodecEngine ( ) const
inline
81 { return a_codecEngine; }

◆ getCommEngine()

anna::diameter::comm::Engine* anna::diameter::comm::OriginHost::getCommEngine ( ) const
inline
79 { return a_commEngine; }

◆ getDiameterServer()

anna::diameter::comm::LocalServer* anna::diameter::comm::OriginHost::getDiameterServer ( )
inline
87 { return a_diameterServer; }

◆ getEntity()

anna::diameter::comm::Entity* anna::diameter::comm::OriginHost::getEntity ( ) const
inline
84 { return a_entity; }

◆ getName()

const std::string& anna::diameter::comm::OriginHost::getName ( ) const

◆ getReactingAnswers()

anna::diameter::codec::MessagesDeque* anna::diameter::comm::OriginHost::getReactingAnswers ( )
inline
124 { return (anna::diameter::codec::MessagesDeque*)&a_reactingAnswers; }
Definition: MessagesDeque.hpp:25

◆ gotoBurst()

std::string anna::diameter::comm::OriginHost::gotoBurst ( int  order)

◆ loadBurstMessage()

int anna::diameter::comm::OriginHost::loadBurstMessage ( const anna::DataBlock db)
noexcept

◆ logEnabled()

bool anna::diameter::comm::OriginHost::logEnabled ( ) const
inline
103 { return (((a_logFile == "") || (a_logFile == "null")) ? false : true); }

◆ lookBurst()

std::string anna::diameter::comm::OriginHost::lookBurst ( int  order = -1) const

◆ popBurst()

int anna::diameter::comm::OriginHost::popBurst ( int  releaseAmount)

◆ pushBurst()

int anna::diameter::comm::OriginHost::pushBurst ( int  loadAmount)

◆ releaseCommMessage()

void anna::diameter::comm::OriginHost::releaseCommMessage ( anna::diameter::comm::Message )

◆ repeatBurst()

void anna::diameter::comm::OriginHost::repeatBurst ( bool  repeat)
inline
110 { a_burstRepeat = repeat; }

◆ sendBurst()

int anna::diameter::comm::OriginHost::sendBurst ( int  loadAmount)

◆ sendBurstMessage()

bool anna::diameter::comm::OriginHost::sendBurstMessage ( bool  anyway = false)

◆ setLogs()

void anna::diameter::comm::OriginHost::setLogs ( const std::string &  log,
bool  splitLog,
bool  detailedLog,
bool  dumpLog,
const std::string &  burstLog 
)
inline
95  {
96  a_logFile = log;
97  a_splitLog = splitLog;
98  a_detailedLog = detailedLog;
99  a_dumpLog = dumpLog;
100  a_burstLogFile = burstLog;
101  }

◆ setRequestRetransmissions()

void anna::diameter::comm::OriginHost::setRequestRetransmissions ( int  r)
inline
88 { if (r >= 0) a_requestRetransmissions = r; }

◆ startBurst()

int anna::diameter::comm::OriginHost::startBurst ( int  initialLoad)

◆ stopBurst()

int anna::diameter::comm::OriginHost::stopBurst ( )

◆ writeBurstLogFile()

void anna::diameter::comm::OriginHost::writeBurstLogFile ( const std::string &  buffer)

◆ writeLogFile() [1/2]

void anna::diameter::comm::OriginHost::writeLogFile ( const anna::DataBlock db,
const std::string &  logExtension,
const std::string &  detail 
) const

◆ writeLogFile() [2/2]

void anna::diameter::comm::OriginHost::writeLogFile ( const anna::diameter::codec::Message decodedMessage,
const std::string &  logExtension,
const std::string &  detail 
) const

The documentation for this class was generated from the following file: