Updated license

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

// ANNA - Anna is Not Nothingness Anymore
//
// (c) Copyright 2005-2014 Eduardo Ramos Testillano & Francisco Ruiz Rayo
//
// https://bitbucket.org/testillano/anna
//
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions
// are met:
//
//     * Redistributions of source code must retain the above copyright
// notice, this list of conditions and the following disclaimer.
//     * Redistributions in binary form must reproduce the above
// copyright notice, this list of conditions and the following disclaimer
// in the documentation and/or other materials provided with the
// distribution.
//     * Neither the name of Google Inc. nor the names of its
// contributors may be used to endorse or promote products derived from
// this software without specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
//
// Authors: eduardo.ramos.testillano@gmail.com
//          cisco.tierra@gmail.com


#ifndef anna_diameter_comm_Engine_hpp
#define anna_diameter_comm_Engine_hpp


// STL
#include <map>
#include <string>
#include <algorithm>

#include <anna/app/Component.hpp>
#include <anna/core/util/Recycler.hpp>

#include <anna/diameter.comm/Server.hpp>
#include <anna/diameter.comm/ServerSession.hpp>
#include <anna/config/defines.hpp>
#include <anna/diameter.comm/ClientSession.hpp>
#include <anna/diameter.comm/ServerSession.hpp>

// Standard
#include <time.h>


//------------------------------------------------------------------------------
//---------------------------------------------------------------------- #define
//------------------------------------------------------------------------------

namespace anna {
class DataBlock;
class Millisecond;
}



namespace anna {

namespace diameter {

namespace codec {
class Engine;
}

namespace comm {


class Entity;
class Server;
class LocalServer;

/**
 *  General manager for connections to several diameter servers and from diameter clients.
 *
 *  Optimizes creation, finding and releasing of established client-sessions to a certain number of
 *  diameter servers through entities.
 *  Optimizes creation, finding and releasing of established server-sessions from a certain number of
 *  diameter clients through local servers.
 *
 *  Implementation example:
 *
 *  \code
 *
 *     class MyEngine : public diameter::comm::Engine {
 *     public:
 *        MyEngine () {;}
 *
 *     private:
 *        anna::Recycler<MyEntity> a_entities;
 *
 *        anna::diameter::comm::Entity* allocateEntity () throw () { return a_entities.create (); }
 *
 *        void releaseEntity (anna::diameter::comm::Entity* entity) throw () {
 *           MyEntity* aux = static_cast <MyEntity*> (entity);
 *           a_entities.release (aux);
 *        }
 *
 *
 *        anna::diameter::comm::LocalServer* allocateLocalServer () throw () { return a_localServers.create (); }
 *
 *        void releaseLocalServer (anna::diameter::comm::LocalServer* localServer) throw () {
 *           MyLocalServer* aux = static_cast <MyLocalServer*> (localServer);
 *           a_localServers.release (aux);
 *        }
 *     };
 *
 *  \endcode
 */
class Engine : public anna::app::Component {
public:

  /**
     Logical name for this anna::app::Component.
     \return Logical name for this anna::app::Component.
  */
  static const char* getClassName() throw() { return "anna::diameter::comm::Engine"; }

  /**
     Diameter application node realm name (used to be the site domain name).

     @param name Diameter application node realm name. Used in order to configure the Origin-Realm for outgoing messages.
     If not configured or empty string provided, host domainname will be set.
  */
  void setRealm(const std::string & name) throw();


  /**
     Gets the configured diameter application node realm name.

     @return Diameter application node realm name.
  */
  const std::string & getRealm() const throw() { return a_realm; }


  /**
     Diameter application host name as solved by #anna::functions::getHostname()

     @param name Host name. Used in order to configure the Origin-Host for outgoing messages.
     If not configured or empty string provided, hostname (system name) will be set.
  */
  void setHost(const std::string & name) throw();


  /**
     Gets the configured diameter application host name.

     @return Diameter application host name.
  */
  const std::string & getHost() const throw() { return a_host; }


  /**
   * Propagate auto recovery configuration to entities within engine. Recovery period is configured at
   * #anna::comm::Communicator::setRecoveryTime. All the client client-sessions created throught #createEntity,
   * will be created based on the engine auto-recovery value (enable by default). But you could access entities,
   * servers or client-sessions independently to change this behaviour.
   *
   * @param autoRecovery Auto recovery indicator. True by default.
   */
  void raiseAutoRecovery(bool autoRecovery = true) throw(anna::RuntimeException);

  /**
   * Returns automatic bind indicator for client-sessions. By default \em true will be used.
   * \return Value for automatic connection bind.
   */
  bool getAutoBind() const throw() { return a_autoBind; }

  /**
   * Sets automatic connection bind indicator for client-sessions. If not asigned, it will be \em true.
   * \param autoBind Value for automatic connection bind.
   *
   * In order to change bind timer, first client-session must be created without autobind, modify time
   * parameter and then invoking bind.
   */
  void setAutoBind(const bool autoBind) throw() { a_autoBind = autoBind; }

  /**
     Sets the milliseconds wait to achieve a client connection to server by mean connect primitive.
     This is a general value for born client-sessions over engine. Particular configuration could be done
     through #ClientSession::setMaxConnectionDelay.

     \param maxConnectionDelay Milliseconds wait to get connection
  */
  void setMaxConnectionDelay(const anna::Millisecond & maxConnectionDelay) throw() { a_maxConnectionDelay = maxConnectionDelay; }

  /**
     Gets the milliseconds wait to achieve a client connection to server by mean connect primitive.
     Returns the global engine value, but it could be overwritten through each client session (#ClientSession::setMaxConnectionDelay).
     Default value is 'anna::comm::ClientSocket::DefaultMaxConnectionDelay'.

     \return Milliseconds wait to get connection
  */
  const anna::Millisecond & getMaxConnectionDelay() throw() { return a_maxConnectionDelay; }

  /**
   * Binds engine entities.
   *
   * @return Returns true if all client-session were successfully bound
   */
  bool bind() throw(anna::RuntimeException);

  /**
   * Sets CER and DWR diameter messages to be used over created client-sessions.
   * Its recommended to set this global configuration although it is possible to configure each client-session separately.
   *
   * @param cer Capabilities-Exchange-Request message (encoded) for the client-sessions bind.
   * @param dwr Device-Watchdog-Request message (encoded) for the client-sessions keep-alive.
   */
  void setCERandDWR(const anna::DataBlock & cer, const anna::DataBlock & dwr) throw(anna::RuntimeException);


  /**
   * Sets the watchdog period (DWR) for client-sessions.
   * Its recommended to set this global configuration although it is possible to configure each client-session separately.
   *
   * @param wp Watchdog period.
   */
  void setWatchdogPeriod(const anna::Millisecond & wp) throw(anna::RuntimeException);

  /**
   * Gets the number of client-sessions per server.
   * \return numberOfClientSessionsPerServer Number of client-sessions per server.
   */
  int getNumberOfClientSessionsPerServer() const throw() { return a_numberOfClientSessionsPerServer; }

  /**
   * Sets the number of client-sessions per server.
   * Its recommended to set this global configuration although it is possible to configure each client-session separately.
   * \param numberOfClientSessionsPerServer Number of client-sessions per server.
   */
  void setNumberOfClientSessionsPerServer(int numberOfClientSessionsPerServer) throw() { a_numberOfClientSessionsPerServer = numberOfClientSessionsPerServer; }

  /**
   * Gets true when end-to-end sequence is freezed on requests sendings.
   * Engine starts with false value, sequencing end-to-end as hop-by-hop does.
   * \return Freeze end-to-end indicator.
   */
  bool getFreezeEndToEndOnSending() const throw() { return a_freezeEndToEndOnSending; }

  /**
   * Freeze end-to-end indicator on requests sendings.
   * \param freezeEndToEndOnSending Freeze end-to-end indicator.
   */
  void setFreezeEndToEndOnSending(bool freezeEndToEndOnSending = true) throw() { a_freezeEndToEndOnSending = freezeEndToEndOnSending; }

  /**
   * Returns client-session instance identified by (address, port, socketId) provided.
   *
   * \param addr Diameter server address (ip or hostname).
   * \param port Diameter server port.
   * @param socketId Diameter server socket id.
   * \param emode Action when no client-session is found with provided parameters (Throw/Ignore).
   *
   * \return The client-session instance identified by (address, port, socketId) provided.
   *
   * \warning If no client-session found, an exception is launched by default.
   */
  ClientSession* findClientSession(const std::string & addr, int port, int socketId, anna::Exception::Mode::_v emode = anna::Exception::Mode::Throw) throw(anna::RuntimeException);


  /**
   * Same as #findClientSession, but providing client session key (<address>:<port>|<socket id>)
   */
  ClientSession* findClientSession(const std::string & key, anna::Exception::Mode::_v emode = anna::Exception::Mode::Throw) throw(anna::RuntimeException);


  /**
   * Returns server instance identified by pair (address, port) provided.
   *
   * \param addr Diameter server address (ip or hostname).
   * \param port Diameter server port.
   * \param emode Action when no client-session is found with provided parameters (Throw/Ignore).
   *
   * \return The server instance identified by pair (address, port) provided.
   *
   * \warning If no server found, an exception is launched by default.
   */
  Server* findServer(const std::string & addr, int port, anna::Exception::Mode::_v emode = anna::Exception::Mode::Throw) throw(anna::RuntimeException);

  /**
   * Returns entity instance identified by internal index.
   *
   * \param socketList Diameter entity servers list.
   * \param emode Action when no client-session is found with provided parameters (Throw/Ignore).
   *
   * \return The entity instance identified by id provided.
   *
   * \warning If no entity found, an exception is launched by default.
   */
  Entity* findEntity(const socket_v & socketList, anna::Exception::Mode::_v emode = anna::Exception::Mode::Throw) throw(anna::RuntimeException);

  /**
   * Returns entity instance identified by internal index.
   *
   * \param addr1 Diameter primary server address (ip or hostname).
   * \param port1 Diameter primary server port.
   * \param addr2 Diameter secondary server address (ip or hostname).
   * \param port2 Diameter secondary server port.
   * \param emode Action when no client-session is found with provided parameters (Throw/Ignore).
   *
   * \return The entity instance identified by id provided.
   *
   * \warning If no entity found, an exception is launched by default.
   */
  Entity* findEntity(const std::string & addr1, int port1, const std::string & addr2, int port2, anna::Exception::Mode::_v emode = anna::Exception::Mode::Throw) throw(anna::RuntimeException);

  /**
   * Creates a diameter entity with provided parameters.
   *
   * Depending on auto-bind configuration, capabilities exchange request will be or won't be performed over the entity client-sessions.
   *
   * \param socketList Diameter server priority list (priority-ordered) in order to define whole entity.
   * @param description Optional entity description (empty by default)
   *
   * \return The entity created or exception when any server (address/port) already exists for another entity.
   *
   * \warning The entity won't be almost operative until a notification by mean 'ClientSession::eventResponse'
   * indicates that 'ClassCode::Bind' has been correctly performed for any included client-session.
   */
  Entity* createEntity(const socket_v & socketList, const std::string & description = "")
  throw(anna::RuntimeException);

  /**
   * Creates a standard (dual) diameter entity with provided parameters.
   *
   * Depending on auto-bind configuration, capabilities exchange request will be or won't be performed over the entity client-sessions.
   *
   * \param addr1 Diameter primary server address (ip or hostname).
   * \param port1 Diameter primary server port.
   * \param addr2 Diameter secondary server address (ip or hostname).
   * \param port2 Diameter secondary server port.
   * @param description Optional entity description (empty by default)
   *
   * \return The standard entity created or exception when any server (address/port) already exists for another entity.
   *
   * \warning The entity won't be almost operative until a notification by mean 'ClientSession::eventResponse'
   * indicates that 'ClassCode::Bind' has been correctly performed for any included client-session.
   */
  Entity* createEntity(const std::string & addr1, int port1, const std::string & addr2, int port2, const std::string & description = "")
  throw(anna::RuntimeException);


  /**
   * Returns local server instance identified by pair (address, port) provided.
   *
   * @param addr Diameter server socket address (ip or hostname).
   * @param port Diameter server socket port.
   * \param emode Action when no local server is found with provided parameters (Throw/Ignore).
   *
   * \return The local server instance identified by pair (address, port) provided.
   *
   * \warning If no local server found, an exception is launched by default.
   */
  LocalServer* findLocalServer(const std::string & addr, int port, anna::Exception::Mode::_v emode = anna::Exception::Mode::Throw) throw(anna::RuntimeException);

  /**
   * Returns server-session instance identified by INetAddress serialization provided.
   *
   * @param socketId Hash for Client Socket INetAddress serialization
   * \param emode Action when no server-session is found with provided parameters (Throw/Ignore).
   *
   * \return The server-session instance identified by global unique socketId provided.
   *
   * \warning If no server-session found, an exception is launched by default.
   */
  ServerSession* findServerSession(int socketId, anna::Exception::Mode::_v emode = anna::Exception::Mode::Throw) throw(anna::RuntimeException);

  /**
   * Creates a diameter local server with provided parameters.
   *
   * Server socket address could be an IPv4 or hostname. Default port will be standard 3868 for diameter agents,
   * but any other could be configured. Socket server could be created with any max accepted connections: zero
   * value means temporarily disabled and negative values assume no limit (shared bind) for incomming connections.
   *
   * @param addr Diameter server socket address (ip or hostname).
   * @param port Diameter server socket port (standard 3868 by default).
   * @param maxConnections Diameter server max sessions allowed (no limit by default).
   * @param allowedInactivityTime Max inactivity time for server sessions over the local server before being reset.
   * @param category Optional socket server category (1 by default).
   * @param description Optional socket server description (empty by default).
   *
   * \return The local server created or exception when is already created.
   */
  LocalServer *createLocalServer(const std::string & addr, int port = Session::DefaultPort, int maxConnections = -1, const anna::Millisecond & allowedInactivityTime = ServerSession::DefaultAllowedInactivityTime, int category = 1, const std::string & description = "")
  throw(anna::RuntimeException);


  /**
     Close all the engine resources (entities and local servers)
     Optionally all resources may be freed passing true

     @param destroy Free all engine entity resources
  */
  void close(bool destroy = false) throw(anna::RuntimeException) { closeEntities(destroy); closeLocalServers(destroy); }


  /**
     Close all the engine entities (close servers, then close client-sessions within them). Depending on client-session configuration
     ('OnDisconnect' behaviour), pending answers will be wait (graceful) or ignored (immediate-abrupt close).
     Optionally all entities resources may be freed passing true; in this case, close is immediately performed:
     @param destroy Free all engine entity resources
  */
  void closeEntities(bool destroy = false) throw(anna::RuntimeException);


  /**
   * Close entity servers (then, client-sessions included) and optionally free resources including entity itself.
   * If entity is null, this operation has no effect.
   *
   * \param entity Diameter entity to be closed.
   * \param destroy Deletes entity over the engine and all its resources.
   */
  void closeEntity(Entity* entity, bool destroy = false) throw(anna::RuntimeException);


  /**
     Close all the engine local server sockets including their children server sessions.
     Optionally all local server resources may be freed passing true.

     @param destroy Free all engine local servers resources and server sessions within them.
  */
  void closeLocalServers(bool destroy = false) throw(anna::RuntimeException);

  /**
   * Close local server socket and its children server sessions.
   * This is useful when detecting service lost. When service is ready to handle traffic, a new server socket would
   * be created by mean #LocalServer::enable() and new connections could be accepted.
   * Optionally local server resources may be freed passing true.
   *
   * \param localServer Local server to be closed.
   * \param destroy Deletes local server over engine and all its resources (server sessions within it).
   */
  void closeLocalServer(LocalServer * localServer, bool destroy = false) throw(anna::RuntimeException);

  /**
     Gets the number of requests messages over-the-air for entities.

     @return OTA messages.
  */
  int getOTARequestsForEntities() const throw();

  /**
     Gets the number of requests messages over-the-air for local servers.

     @return OTA messages.
  */
  int getOTARequestsForLocalServers() const throw();

  /**
     Gets the number of requests messages over-the-air for entities plus local servers.

     @return OTA messages.
  */
  int getOTARequests() const throw() { return (getOTARequestsForEntities() + getOTARequestsForLocalServers()); }

  /**
     Returns idle state (no pending answers) for entities.

     @return Idle state.
  */
  bool idleForEntities() const throw() { return (getOTARequestsForEntities() == 0); }

  /**
     Returns idle state (no pending answers).

     @return Idle state.
  */
  bool idleForLocalServers() const throw() { return (getOTARequestsForLocalServers() == 0); }

  /**
     Returns idle state (no pending answers for entities or local servers).

     @return Idle state.
  */
  bool idle() const throw() { return (getOTARequests() == 0); }

  /**
     Sent a message to all the engine entities.
     It is used, i.e., in Disconnect-Peer-Request procedure over the engine.

     \param message Message which is being sent.

     @return Returns true (success) only when broadcast is success over all the engine entities. If any entity fails,
     then false is returned. Broadcast try to send all over the resources in spite of any fail.
  */
  bool broadcastEntities(const Message*message) throw(anna::RuntimeException);
  bool broadcastEntities(const Message& message) throw(anna::RuntimeException) { return broadcastEntities(&message); }

  /**
     Sent a message through all the engine local servers.
     It is used, i.e., in Disconnect-Peer-Request procedure over the engine.

     \param message Message which is being sent.

     @return Returns true (success) only when broadcast is success over all the engine local servers. If any local server fails,
     then false is returned. Broadcast try to send all over the resources in spite of any fail.
  */
  bool broadcastLocalServers(const Message*message) throw(anna::RuntimeException);
  bool broadcastLocalServers(const Message& message) throw(anna::RuntimeException) { return broadcastLocalServers(&message); }

  /**
  * Class string representation
  *
  * @return String with class content
  */
  virtual std::string asString(void) const throw();

  /**
     Class XML representation.
     \param parent XML node over which we will put instance information.
     \return XML documentcon with class content.
  */
  virtual anna::xml::Node* asXML(anna::xml::Node* parent) const throw();


  /**
     When there is not bound server session over the engine, this virtual method will be invoked.
     Applications must decide to do any other tasks at this idle/isolated situation.
     Default implementation do nothing.
  */
  virtual void availabilityLostForLocalServers(Engine *) const throw() {;}

  /**
     When there is any bound server session over the engine, this virtual method will be invoked.
     Applications must decide to do be ready for incoming traffic.
     Default implementation do nothing.
  */
  virtual void availabilityRecoveredForLocalServers(Engine *) const throw() {;}

  /**
     When there is not bound entity over the engine, this virtual method will be invoked.
     Many applications must change communicator status to Unavailable when no engines are available.
     Default implementation do nothing.
  */
  virtual void availabilityLostForEntities(Engine *) const throw() {;}

  /**
     When there is any bound entity over the engine, this virtual method will be invoked.
     Many applications must recover communicator status to Available when any engine are available.
     Default implementation do nothing.
  */
  virtual void availabilityRecoveredForEntities(Engine *) const throw() {;}

  /**
     When there is not bound server-session over the local server, this virtual method will be invoked.
     Default implementation do nothing.
  */
  virtual void availabilityLost(LocalServer *) const throw() {;}

  /**
     When there is any bound server-session over the local server, this virtual method will be invoked.
     Default implementation do nothing.
  */
  virtual void availabilityRecovered(LocalServer *) const throw() {;}

  /**
     When there is not bound server over the entity, this virtual method will be invoked.
     Default implementation do nothing.
  */
  virtual void availabilityLost(Entity *) const throw() {;}

  /**
     When there is any bound server over the entity, this virtual method will be invoked.
     Default implementation do nothing.
  */
  virtual void availabilityRecovered(Entity *) const throw() {;}

  /**
     When there is not bound client-session over the server, this virtual method will be invoked.
     Default implementation do nothing.
  */
  virtual void availabilityLost(Server *) const throw() {;}

  /**
     When there is any bound client-session over the server, this virtual method will be invoked.
     Default implementation do nothing.
  */
  virtual void availabilityRecovered(Server *) const throw() {;}

  /**
     When a subyacent client session is going to be bound, this method is invoked before.
     Default implementation do nothing.
  */
  virtual void bindingClientSession(const ClientSession *) const throw() {;}

  /**
   * Class user should implement this method in order to define Disconnect-Peer-Answer for last received DPR.
   * Origin-Host and Origin-Realm are configured at comm::Engine with hostname and FQDN (Fully Qualified Domain Name).
   * Default implementation imply DPA with DIAMETER_SUCCESS Result-Code, allowing remote disconnection.
   * Any other implementation is responsible to build a valid DPA diameter message.
   * DPR/DPA procedure is disabled with empty definition of this method: no DPA will be sent when DPR is received.
   *
   * @param dpa DPA datablock passed as reference
   * @param dpr Corresponding DPR received (sequence values must be taken into account in order to build DPA)
  */
  virtual void readDPA(anna::DataBlock &dpa, const anna::DataBlock & dpr) throw();

  /**
   * Class user should implement this method in order to define Capabilities-Exchange-Answer for received CER over server socket.
   * Origin-Host and Origin-Realm are configured at comm::Engine with hostname and FQDN (Fully Qualified Domain Name).
   * Default implementation imply CEA with DIAMETER_SUCCESS Result-Code, and own domain node parameters, but application should
   * analyze the CER message in order to accept it or not (with apropiate non-success Result-Code).
   * Any other implementation is responsible to build a valid CEA diameter message:
   *
   * If one peer sends a CER message to another Peer and receiver does not have support for
   *
   *  1) any common application then it must return the CEA with Result-Code Avp set to DIAMETER_NO_COMMON_APPLICATION
   *     and should disconnect the transport layer connection (automatically done by diameter::comm module).
   *  2) no common security mechanism then it must return the CEA with Result-Code Avp set to DIAMETER_NO_COMMON_SECURITY
   *     and should disconnect the transport layer connection (automatically done by diameter::comm module).
   *  3) if CER is received from any unknown peer then receiver should discard the message, or send the CEA with the
   *     Result-Code Avp set to DIAMETER_UNKNOWN_PEER.
   *
   *  If the local implementation policy permits to receive CER from unknown hosts, a successful CEA MAY be returned,
   *  and the life time of the peer entry in PEER-Table is equal to the lifetime of the transport connection.
   *  If in any case transport connection fails then all the pending transactions destined to the unknown peer can be discarded.
   *
   *  The CER and CEA messages MUST NOT be proxied, redirected or relayed. Since CER/CEA messages can not be proxied, but still
   *  it is possible that proxy will receive a CER message and proxy does not have any peer to handle the application requested
   *  in CER, in this case proxy set the E bit in CEA and set the Result-Code Avp to DIAMETER_UNABLE_TO_DELIVER, sends back to
   *  CER generator peer.
   *
   * @param cea CEA datablock passed as reference. Empty cea implies to discard CER received.
   * @param cer Corresponding CER received (sequence values must be taken into account in order to build CEA)
  */
  virtual void readCEA(anna::DataBlock &cea, const anna::DataBlock & cer) throw();

  /**
   * Class user should implement this method in order to define Device-Watchdog-Answer for received DWR over server socket.
   * Origin-Host and Origin-Realm are configured at comm::Engine with hostname and FQDN (Fully Qualified Domain Name).
   * Default implementation imply DWA with DIAMETER_SUCCESS Result-Code, and own domain node parameters.
   * Any other implementation is responsible to build a valid DWA diameter message.
   *
   * @param dwa DWA datablock passed as reference
   * @param dwr Corresponding DWR received (sequence values must be taken into account in order to build DWA)
  */
  virtual void readDWA(anna::DataBlock &dwa, const anna::DataBlock & dwr) throw();

  /**
     Reset engine statistics.
     At the moment, only diameter servers processing time is observed.
  */
  void resetStatistics() throw();


protected:
  /**
     Constructor.
  */
  Engine();


  // INTERNAL CREATORS AND CLOSE METHODS
  Server *createServer(Entity*, const socket_t&) throw(anna::RuntimeException);
  void closeServer(Server*, bool) throw(anna::RuntimeException);
  ClientSession *createClientSession(Server*, int) throw(anna::RuntimeException);
  void closeClientSession(ClientSession*, bool) throw(anna::RuntimeException);

  // INTERNAL ALLOCATORS
  Server* allocateServer() throw();
  void releaseServer(Server*) throw();
  ClientSession* allocateClientSession() throw();
  void releaseClientSession(ClientSession*) throw();


  /**
     Entity allocator method.

     It is recommended to use anna::Recycler for entities creation/releasing.

     \see anna::Recycler
  */
  virtual Entity* allocateEntity() throw() { return NULL; }


  /**
     Invoked to free entities.
     \see anna::Recycler
  */
  virtual void releaseEntity(Entity*) throw() {;}


  /**
     Local server allocator method.

     It is recommended to use anna::Recycler for entities creation/releasing.

     \see anna::Recycler
  */
  virtual LocalServer* allocateLocalServer() throw() { return NULL; }


  /**
     Invoked to free local servers.
     \see anna::Recycler
  */
  virtual void releaseLocalServer(LocalServer*) throw() {;}



private:

  std::string a_realm;
  std::string a_host;
  bool a_autoBind;
  int a_numberOfClientSessionsPerServer;
  bool a_freezeEndToEndOnSending;


  // ClientSessions messages:
  anna::DataBlock a_cer;
  anna::DataBlock a_dwr;
  anna::Millisecond a_watchdogPeriod;

//   // ServerSessions messages:
//   anna::DataBlock a_cea;
//   anna::DataBlock a_dwa;

  // Client connectivity
  anna::Millisecond a_maxConnectionDelay;


  // Availability
  bool a_availableForEntities; // any of the entities must be bound
  void availabilityLostForEntities() throw();
  void availabilityRecoveredForEntities() throw();
  bool refreshAvailabilityForEntities() throw(); // return true if change

  bool a_availableForLocalServers; // any of the local servers must be bound
  void availabilityLostForLocalServers() throw();
  void availabilityRecoveredForLocalServers() throw();
  bool refreshAvailabilityForLocalServers() throw(); // return true if change

  void eraseDeprecatedIdleEntities() throw();

  // Component:
  void do_initialize() throw() {;}
  void do_stop() throw();

  // Integrity:
  void checkEntityCollision(const socket_v &) throw(anna::RuntimeException);


  //////////////////////////
  // CLIENT FUNCTIONALITY //
  //////////////////////////

  //typedef int clientSession_key; // exclusiveHash('ADDR:PORT|id')
  typedef std::string clientSession_key; // 'ADDR:PORT|id'
  typedef std::map <clientSession_key, ClientSession*> clientSession_container;
  typedef clientSession_container::value_type clientSession_value_type;
  typedef clientSession_container::iterator clientSession_iterator;
  typedef clientSession_container::const_iterator const_clientSession_iterator;
  clientSession_container a_clientSessions;
  anna::Recycler<ClientSession> a_clientSessionsRecycler;
  clientSession_iterator clientSession_find(const clientSession_key&) throw();
  clientSession_iterator clientSession_begin() throw() { return a_clientSessions.begin(); }
  clientSession_iterator clientSession_end() throw() { return a_clientSessions.end(); }
  static ClientSession* clientSession(clientSession_iterator ii) throw() { return ii->second; }
  const_clientSession_iterator clientSession_begin() const throw() { return a_clientSessions.begin(); }
  const_clientSession_iterator clientSession_end() const throw() { return a_clientSessions.end(); }
  static const ClientSession* clientSession(const_clientSession_iterator ii) throw() { return ii->second; }

  typedef socket_t server_key;
  server_key getServerKey(const std::string & addr, int port) const throw();
  typedef std::map <server_key, Server*> server_container;
  typedef server_container::value_type server_value_type;
  typedef server_container::iterator server_iterator;
  typedef server_container::const_iterator const_server_iterator;
  server_container a_servers;
  anna::Recycler<Server> a_serversRecycler;
  server_iterator server_find(const server_key&) throw();
  server_iterator server_begin() throw() { return a_servers.begin(); }
  server_iterator server_end() throw() { return a_servers.end(); }
  static Server* server(server_iterator ii) throw() { return ii->second; }
  const_server_iterator server_begin() const throw() { return a_servers.begin(); }
  const_server_iterator server_end() const throw() { return a_servers.end(); }
  static const Server* server(const_server_iterator ii) throw() { return ii->second; }

  //typedef int entity_key; // exclusiveHash('IP1:PORT1 IP2:PORT2 IP3:PORT3 ...')
  typedef std::string entity_key; // 'ADDR1:PORT1 ADDR2:PORT2 ADDR3:PORT3 ...'
  entity_key getEntityKey(const socket_v &) const throw();
  entity_key getEntityKey(const std::string & addr1, int port1, const std::string & addr2, int port2) const throw();
  typedef std::map <entity_key, Entity*> entity_container;
  typedef entity_container::value_type entity_value_type;
  typedef entity_container::iterator entity_iterator;
  typedef entity_container::const_iterator const_entity_iterator;
  entity_container a_entities;
  entity_iterator entity_find(const entity_key&) throw();
  entity_iterator entity_begin() throw() { return a_entities.begin(); }
  entity_iterator entity_end() throw() { return a_entities.end(); }
  static Entity* entity(entity_iterator ii) throw() { return ii->second; }
  const_entity_iterator entity_begin() const throw() { return a_entities.begin(); }
  const_entity_iterator entity_end() const throw() { return a_entities.end(); }
  static const Entity* entity(const_entity_iterator ii) throw() { return ii->second; }


  //////////////////////////
  // SERVER FUNCTIONALITY //
  //////////////////////////

  // Local servers
  typedef std::map <socket_t, LocalServer*> localServer_container;
  typedef localServer_container::value_type localServer_value_type;
  typedef localServer_container::iterator localServer_iterator;
  typedef localServer_container::const_iterator const_localServer_iterator;
  localServer_container a_localServers;
  localServer_iterator localServer_find(const socket_t&) throw();
  localServer_iterator localServer_begin() throw() { return a_localServers.begin(); }
  localServer_iterator localServer_end() throw() { return a_localServers.end(); }
  static LocalServer* localServer(localServer_iterator ii) throw() { return ii->second; }
  const_localServer_iterator localServer_begin() const throw() { return a_localServers.begin(); }
  const_localServer_iterator localServer_end() const throw() { return a_localServers.end(); }
  static const LocalServer* localServer(const_localServer_iterator ii) throw() { return ii->second; }

  // Server sessions are managed within LocalServer (not at engine) due to dynamic cration nature


  friend class Session;
  friend class ServerSession;
  friend class ServerSocket;
  friend class Server;
  friend class Entity;
  friend class LocalServer;
  //friend class Message;
};

}
}
}

#endif