ServerSession.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_ServerSession_hpp
#define anna_diameter_comm_ServerSession_hpp


// STL
#include <string>

#include <anna/core/util/Millisecond.hpp>
#include <anna/core/util/defines.hpp> // U32
#include <anna/core/RuntimeException.hpp>

#include <anna/diameter.comm/Session.hpp>
#include <anna/diameter/defines.hpp>
#include <anna/diameter.comm/Message.hpp>
#include <anna/diameter.comm/ServerSessionReceiver.hpp>
#include <anna/diameter.comm/ReceiverFactoryImpl.hpp>


namespace anna {
class DataBlock;
namespace timex {
class Engine;
}

namespace comm {
class ClientSocket;
}
}


namespace anna {

namespace diameter {

namespace comm {


class LocalServer;
class OriginHost;


class ServerSession : public Session {
public:

  ServerSession();


  /* virtual */void initialize() ;

  static const anna::Millisecond DefaultAllowedInactivityTime;

  void setAllowedInactivityTime(const anna::Millisecond & allowedInactivityTime) ;

  /* virtual */const std::string& getAddress() const ;

  /* virtual */int getPort() const ;

  int getKey() const { return getSocketId(); }

  LocalServer *getParent() { return a_parent; }


  void setClientSocket(anna::comm::ClientSocket *clientSocket) ;

  anna::comm::ClientSocket *getClientSocket() { return a_clientSocket; }

  /* virtual */const Response* send(const Message* message) noexcept(false);
  /* virtual */bool unbind(bool forceDisconnect /* se usa en timer, para el actionTimer del tipo SessionUnbind, etc. */ = false) noexcept(false); // returns true if done at call time (no pendings or ignore pendings, except Disconnecting state by mean DPR/DPA)


  /* virtual */std::string asString() const ;


  /* virtual */anna::xml::Node* asXML(anna::xml::Node* parent) const ;

protected:

  // Deprecated state
  bool a_deprecated;

private:

  // Receiver factory
  ReceiverFactoryImpl<ServerSession, ServerSessionReceiver> a_receiverFactory;

  // Parent information
  LocalServer *a_parent;

  // Client Socket
  anna::comm::ClientSocket *a_clientSocket;

  /* virtual */void expire(anna::timex::Engine *timeController) noexcept(false);

  // Activity:
  /* virtual */void updateIncomingActivityTime() ;
  /* virtual */void updateOutgoingActivityTime() ;
  void countSendings(const diameter::CommandId & cid, unsigned int aid, bool ok) ;

  // Handlers:
  void eventPeerShutdown() ;

  void eventRequestRetransmission(Message *request) ;

  void eventResponse(const Response& response, const anna::diameter::comm::OriginHost *myNode) noexcept(false);

  void eventRequest(const anna::DataBlock& request, const anna::diameter::comm::OriginHost *myNode) noexcept(false);
  //void eventRequest(const Message& request) noexcept(false);

  void eventUnknownResponse(const anna::DataBlock& response, const anna::diameter::comm::OriginHost *myNode) noexcept(false);

  void eventDPA(const anna::DataBlock& response, const anna::diameter::comm::OriginHost *myNode) noexcept(false);



  /* virtual */void receive(const anna::comm::Message& message) noexcept(false);
  /* virtual */void finalize() ;

  /* virtual */void expireResponse(Response*) ;

  anna::U32 getAuthApplicationIdFromCER(const anna::DataBlock &cer, bool &found) const;

  void sendCEA(const Engine*, const anna::DataBlock &cerDataBlock) noexcept(false);
  void sendDWA(const Engine*, const anna::DataBlock &dwrDataBlock) noexcept(false);


  friend class anna::diameter::comm::Timer;
  friend class LocalServer;
  friend class Engine;
  friend class ServerSessionReceiver;
};

}
}
}

#endif