pana_session.cxx

/* BEGIN_COPYRIGHT                                                        */
/*                                                                        */
/* Open Diameter: Open-source software for the Diameter and               */
/*                Diameter related protocols                              */
/*                                                                        */
/* Copyright (C) 2002-2004 Open Diameter Project                          */
/*                                                                        */
/* This library is free software; you can redistribute it and/or modify   */
/* it under the terms of the GNU Lesser General Public License as         */
/* published by the Free Software Foundation; either version 2.1 of the   */
/* License, or (at your option) any later version.                        */
/*                                                                        */
/* This library is distributed in the hope that it will be useful,        */
/* but WITHOUT ANY WARRANTY; without even the implied warranty of         */
/* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU      */
/* Lesser General Public License for more details.                        */
/*                                                                        */
/* You should have received a copy of the GNU Lesser General Public       */
/* License along with this library; if not, write to the Free Software    */
/* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307    */
/* USA.                                                                   */
/*                                                                        */
/* In addition, when you copy and redistribute some or the entire part of */
/* the source code of this software with or without modification, you     */
/* MUST include this copyright notice in each copy.                       */
/*                                                                        */
/* If you make any changes that are appeared to be useful, please send    */
/* sources that include the changed part to                               */
/* diameter-developers@lists.sourceforge.net so that we can reflect your  */
/* changes to one unified version of this software.                       */
/*                                                                        */
/* END_COPYRIGHT                                                          */

#include "ace/OS.h"
#include "pana_exceptions.h"
#include "pana_session.h"
#include "pana_memory_manager.h"

PANA_SessionAttribute::PANA_SessionAttribute()
{
    m_LastPayload = NULL;
    Reset();
}

PANA_SessionAttribute::~PANA_SessionAttribute()
{
    Reset();
}

void PANA_SessionAttribute::Reset()
{
   if (m_LastPayload) {
      m_LastPayload->Release();
   }

   while (! m_RxMessageQueue.empty()) {
      PANA_Message &msg = *(m_RxMessageQueue.front());
      m_RxMessageQueue.pop_front();
      delete &msg;
   }

   m_PeerDeviceId.clear();
   
   m_InitialPacTsec        = 0; // TBD: compute this
   m_InitialPaaTsec        = 0;
   m_LastTransmittedTsec   = 0;
   m_LastReceivedRsec      = 0;
   m_PeerPort              = 0;
   m_LastPayload           = NULL;
   m_SessionLifetime       = 0;
   m_SeparateAuth          = false;
   m_BindCount             = 0;
   m_BindResult[0]         = 0;
   m_BindResult[1]         = 0;
   m_TerminationCause      = PANA_TC_INVALID;
}

void PANA_Session::ValidateMessage(PANA_Message &msg)
{
   /* Peer address adjustments */
   PANA_DeviceId *ipId = msg.srcDevices().search(PANA_DeviceId::IPV4_ADDRESS);
   PANA_DeviceId *ipIdS = m_PeerDeviceId.search(PANA_DeviceId::IPV4_ADDRESS);
   if ((ipId && ipIdS) && (! (*ipId == *ipIdS))) {
      m_PeerDeviceId.replace(*ipId);
   }
   

   /*
      When a message is received, it is considered as valid in terms of 
      sequence numbers if and only if (i) its tseq is greater than the  
      tseq of the last accepted message and (ii) its rseq falls in the 
      range between the tseq of the last acknowledged message + 1 and the 
      tseq of the last transmitted message. 
    */ 
#if __MAJOR_TBD__
   if (! ((msg.tseq() > m_LastReceivedTsec_) && 
       ((msg.rseq() >= (m_LastReceivedRsec_ + 1)) && 
        (msg.rseq() <= m_LastTransmittedTsec_)))) {
        throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                             "PANA session received msg with invalid seq number"));
   }
#endif // __MAJOR_TBD__

   /*
     When a MAC AVP is included, the AVP value matches the MAC value 
     computed against the received message. 
    */
   if (m_SA.MSK().size() > 0) {
      ACE_DEBUG((LM_INFO, "(%P|%t) SA Present, validating MAC\n"));    
      if (m_SA.ValidateMacValue(msg) == false) {
         throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                              "PANA session received msg with invalid MAC value"));
      }
   }

   // verify the session id
   if (m_SessionId.size() > 0) {

      AAAAvpContainer *c_sessionId = msg.avpList().search("Session-Id");
      if (c_sessionId == NULL) {
         throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                              "PANA session received msg with no session ID"));
      }
      diameter_utf8string_t &id = (*c_sessionId)[0]->dataRef(Type2Type<diameter_utf8string_t>());

      if (ACE_OS::memcmp(m_SessionId.data(), id.data(), id.size())) {
         throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                              "PANA session received invalid message, session id does not match"));
      }
   }

   // verify the peer deivce id
   if (m_PeerDeviceId.size() > 0) {
      AAAAvpContainer *c_deviceId = msg.avpList().search("Device-Id");
      if (c_deviceId) {
         PANA_TVData_t &deviceId = (*c_deviceId)[0]->dataRef(Type2Type<PANA_TVData_t>());
         PANA_DeviceId *knownId = m_PeerDeviceId.search(PANA_DeviceId::TYPE(deviceId.type));
         if (knownId) {
             if (ACE_OS::memcmp(deviceId.value.data(), knownId->id().data(), knownId->id().size())) {
                throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE,
                                     "Device ID AVP value does not match device id of known peer"));
             }
         }
      }
   }

   // Update sequence number
   m_LastReceivedTsec = msg.tseq();
   m_LastReceivedRsec = msg.rseq();
}

void PANA_Session::DestinationAddressFormatting(PANA_Message &msg,
                                                AAAMessageBlock *eapPayload)
{
   ACE_DEBUG((LM_INFO, "(%P|%t) SEND: No Tx address formatting present\n"));
}

void PANA_Session::SendReAuthenticateRequest()
{
   /*
       PaC      PAA     Message(tseq,rseq)[AVPs] 
       ------------------------------------------------------ 
          ----->        PANA-Reauth-Request(q,p)[MAC] 
          <-----        PANA-Reauth-Answer(p+1,q)[MAC] 
    
       Figure 5: Example Sequence for PaC-initiated Re-authentication 
    
       PaC      PAA     Message(tseq,rseq)[AVPs] 
       ------------------------------------------------------ 
          <-----        PANA-Reauth-Request(p,q)[MAC] 
          ----->        PANA-Reauth-Answer(q+1,p)[MAC] 
    
       Figure 6: Example Sequence for PAA-initiated Re-authentication 

       9.3.9 PANA-Reauth-Request (PRAR)

         PANA-Reauth-Request (PRAR) is either sent by the PaC or the PAA.

               PANA-Reauth-Request ::= < PANA-Header: 5, REQ >
                             < Session-Id >
                             < Device-Id >
                          *  [ AVP ]
                         0*1 < MAC >
    */

   ACE_DEBUG((LM_INFO, "(%P|%t) Sending re-auth request\n"));

   if (m_SA.MSK().size() == 0) {
      throw (PANA_Exception(PANA_Exception::FAILED, 
                            "No MSK setup for this session"));
   }

   AAAAvpContainerManager cm;
   AAAAvpContainerEntryManager em;
   PANA_Message *msg;

   ACE_NEW_NORETURN(msg, PANA_Message);
   if (msg == NULL) {
      throw (PANA_Exception(PANA_Exception::NO_MEMORY, 
                            "Failed to allocate msg message"));
   }

   // Populate header
   PANA_MsgHeader::Flags flg = { 1, 0, 0, 0 };
   msg->flags(flg);
   msg->type(PANA_MTYPE_REAUTH);
   msg->tseq(++ m_LastTransmittedTsec);
   msg->rseq(m_LastReceivedTsec);

   // Populate AVP's
   AAAAvpContainerEntry *e;
   AAAAvpContainer *c_sessionId = cm.acquire("Session-Id");
   AAAAvpContainer *c_deviceId = cm.acquire("Device-Id");

   // Add the AVP's to containers
   e = em.acquire(AAA_AVP_UTF8_STRING_TYPE);
   diameter_utf8string_t &sessionId = e->dataRef(Type2Type<diameter_utf8string_t>());
   c_sessionId->add(e);

   e = em.acquire(AAA_AVPDataType(AAA_AVP_DEVICEID_TYPE));
   PANA_TVData_t &deviceId = e->dataRef(Type2Type<PANA_TVData_t>());
   c_deviceId->add(e);

   // Add containers to listen
   msg->avpList().add(c_sessionId);
   msg->avpList().add(c_deviceId);

   // Populate data
   PANA_DeviceIdContainer srcDevices;
   m_TxChannel.GetLocalAddress(srcDevices);
   PANA_DeviceId *id = srcDevices.search(m_ReqDeviceId);
   if (id) {
      deviceId.type = id->type();
      deviceId.value.assign(id->id().data(), id->id().size());
   }
   else {
      throw (PANA_Exception(PANA_Exception::FAILED, 
                           "No MAC address given in the device list"));
   }
   sessionId.assign(m_SessionId.data(), m_SessionId.size());

   // Send message
   DestinationAddressFormatting(*msg);
   m_TxChannel.Send(*this, *msg);

   PANA_RtQueueNullData data;
   if (m_RtQueue.Schedule(data)) {
       m_Timer.Schedule(PANA_TID_PRAR_RETRY, data.Timeout());       
   }

   ACE_DEBUG((LM_INFO, "(%P|%t) SEND: Re-Auth-Request, tseq=%d, rseq=%d\n",
              msg->tseq(), msg->rseq()));
}

void PANA_Session::RetryReAuthenticateRequest()
{
   m_Timer.Cancel(PANA_TID_PRAR_RETRY);
   
   PANA_RtQueueData *data = NULL;
   if (m_RtQueue.ReSchedule(data)) {
       SendReAuthenticateRequest();
       m_Timer.Schedule(PANA_TID_PRAR_RETRY, data->Timeout());       
   }
   else {
       m_Timer.Schedule(PANA_TID_DISCONNECT, 0);
   }
}

void PANA_Session::ReceiveReAuthenticateRequest()
{
   PANA_Message &msg = *(m_RxMessageQueue.front());
   m_RxMessageQueue.pop_front();

   // cancel discovery retry if any
   m_Timer.Cancel(PANA_TID_DISC_RETRY);
   m_RtQueue.ClearFront();
   
   // cancel start answer retry if any
   m_Timer.Cancel(PANA_TID_PSA_RETRY);
   m_RtQueue.ClearFront();

   AAAAvpContainer* c_deviceId = msg.avpList().search("Device-Id");
   if (c_deviceId) {
       PANA_TVData_t &deviceId = (*c_deviceId)[0]->dataRef(Type2Type<PANA_TVData_t>());
       PANA_DeviceId id(PANA_DeviceId::TYPE(deviceId.type), deviceId.value);
       PANA_DeviceId *knownId = m_PeerDeviceId.search(PANA_DeviceId::TYPE(deviceId.type));
       if (knownId && !(*knownId == id)) {
           throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                         "Device id type in re-auth request does not match known peer id"));
       }
       else if (! knownId) {
           m_PeerDeviceId.clone(id);
           m_ReqDeviceId = PANA_DeviceId::TYPE(deviceId.type);
       }
   }

   ACE_DEBUG((LM_INFO, "(%P|%t) RECV: ReAuthenticate-Req, tseq=%d, rseq=%d\n",
              msg.tseq(), msg.rseq()));
   
   SendReAuthenticateAnswer();

   ReAuthenticate(PANA_REAUTH_PANA);

   if (c_deviceId) {
       PANA_TVData_t &deviceId = (*c_deviceId)[0]->dataRef(Type2Type<PANA_TVData_t>());
       PANA_DeviceId id(PANA_DeviceId::TYPE(deviceId.type), deviceId.value);
       m_Event.AuthorizePeer(id, true);
   }

   m_Timer.Schedule(PANA_TID_SESSION, m_SessionLifetime);  
   delete &msg;
}

void PANA_Session::SendReAuthenticateAnswer()
{
   /*
       PaC      PAA     Message(tseq,rseq)[AVPs] 
       ------------------------------------------------------ 
          ----->        PANA-Reauth-Request(q,p)[MAC] 
          <-----        PANA-Reauth-Answer(p+1,q)[MAC] 
    
       Figure 5: Example Sequence for PaC-initiated Re-authentication 
    
       PaC      PAA     Message(tseq,rseq)[AVPs] 
       ------------------------------------------------------ 
          <-----        PANA-Reauth-Request(p,q)[MAC] 
          ----->        PANA-Reauth-Answer(q+1,p)[MAC] 
    
       Figure 6: Example Sequence for PAA-initiated Re-authentication 

       9.3.10 PANA-Reauth-Answer (PRAA)

         PANA-Reauth-Answer (PRAA) is sent in response to a
         PANA-Reauth-Request.

              PANA-Reauth-Answer ::= < PANA-Header: 5 >
                            < Session-Id >
                            < Device-Id >
                         *  [ AVP ]
                        0*1 < MAC >
    */

   ACE_DEBUG((LM_INFO, "(%P|%t) Sending re-auth answer\n"));

   if (m_SA.MSK().size() == 0) {
      throw (PANA_Exception(PANA_Exception::FAILED, 
                           "No MSK setup for this session"));
   }

   AAAAvpContainerManager cm;
   AAAAvpContainerEntryManager em;
   PANA_Message *msg;

   ACE_NEW_NORETURN(msg, PANA_Message);
   if (msg == NULL) {
      throw (PANA_Exception(PANA_Exception::NO_MEMORY, 
                            "Failed to allocate msg message"));
   }

   // Populate header
   PANA_MsgHeader::Flags flg = { 0, 0, 0, 0 }; // TBD: answer
   msg->flags(flg);
   msg->type(PANA_MTYPE_REAUTH);
   msg->tseq(++ m_LastTransmittedTsec);
   msg->rseq(m_LastReceivedTsec);

   // Populate AVP's
   AAAAvpContainerEntry *e;
   AAAAvpContainer *c_sessionId = cm.acquire("Session-Id");
   AAAAvpContainer *c_deviceId = cm.acquire("Device-Id");

   // Add the AVP's to containers
   e = em.acquire(AAA_AVP_UTF8_STRING_TYPE);
   diameter_utf8string_t &sessionId = e->dataRef(Type2Type<diameter_utf8string_t>());
   c_sessionId->add(e);

   e = em.acquire(AAA_AVPDataType(AAA_AVP_DEVICEID_TYPE));
   PANA_TVData_t &deviceId = e->dataRef(Type2Type<PANA_TVData_t>());
   c_deviceId->add(e);

   // Add containers to listen
   msg->avpList().add(c_sessionId);
   msg->avpList().add(c_deviceId);

   // Populate data
   PANA_DeviceIdContainer srcDevices;
   m_TxChannel.GetLocalAddress(srcDevices);
   PANA_DeviceId *id = srcDevices.search(m_ReqDeviceId);
   if (id) {
      deviceId.type = id->type();
      deviceId.value.assign(id->id().data(), id->id().size());
   }
   else {
      throw (PANA_Exception(PANA_Exception::FAILED, 
                           "No MAC address given in the device list"));
   }
   sessionId.assign(m_SessionId.data(), m_SessionId.size());

   // Send message
   DestinationAddressFormatting(*msg);
   m_TxChannel.Send(*this, *msg);

   ACE_DEBUG((LM_INFO, "(%P|%t) SEND: Re-Auth-Answer, tseq=%d, rseq=%d\n",
              msg->tseq(), msg->rseq()));
}

void PANA_Session::ReceiveReAuthenticateAnswer()
{
   PANA_Message &msg = *(m_RxMessageQueue.front());
   m_RxMessageQueue.pop_front();

   m_Timer.Cancel(PANA_TID_PRAR_RETRY);
   m_RtQueue.ClearFront();
   
   AAAAvpContainer* c_deviceId = msg.avpList().search("Device-Id");
   if (c_deviceId) {
       PANA_TVData_t &deviceId = (*c_deviceId)[0]->dataRef(Type2Type<PANA_TVData_t>());
       if (m_ReqDeviceId != deviceId.type) {
           throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                           "Device id type in bind answer does not match request"));
       }
       PANA_DeviceId id(PANA_DeviceId::TYPE(deviceId.type), deviceId.value);
       PANA_DeviceId *knownId = m_PeerDeviceId.search(PANA_DeviceId::TYPE(deviceId.type));
       if (knownId && !(*knownId == id)) {
           throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                         "Device id type in re-auth answer does not match known peer id"));
       }
       else if (! knownId) {
           m_PeerDeviceId.clone(id);
       }
   }

   ACE_DEBUG((LM_INFO, "(%P|%t) RECV: ReAuthenticate-Answer, tseq=%d, rseq=%d\n",
              msg.tseq(), msg.rseq()));

   ReAuthenticate(PANA_REAUTH_PANA);

   if (c_deviceId) {
       PANA_TVData_t &deviceId = (*c_deviceId)[0]->dataRef(Type2Type<PANA_TVData_t>());
       PANA_DeviceId id(PANA_DeviceId::TYPE(deviceId.type), deviceId.value);
       m_Event.AuthorizePeer(id, true);
   }

   m_Timer.Schedule(PANA_TID_SESSION, m_SessionLifetime);   
   delete &msg;
}

void PANA_Session::SendTerminationRequest()
{
   /*
       PaC      PAA     Message(tseq,rseq)[AVPs] 
       ------------------------------------------------------ 
          ----->        PANA-Termination-Request(q,p)[MAC] 
          <-----        PANA-Termination-Answer(p+1,q)[MAC] 
    
       Figure 7: Example Sequence for Session Termination 

       9.3.11 PANA-Termination-Request (PTR)

         PANA-Termination-Request (PTR) is sent either by the PaC or the PAA.

              PANA-Termination-Request ::= < PANA-Header: 6, REQ >
                            < Session-Id >
                            < Termination-Cause >
                         *  [ AVP ]
                        0*1 < MAC >
   */

   ACE_DEBUG((LM_INFO, "(%P|%t) Sending termination request\n"));

   AAAAvpContainerManager cm;
   AAAAvpContainerEntryManager em;
   PANA_Message *msg;

   ACE_NEW_NORETURN(msg, PANA_Message);
   if (msg == NULL) {
      throw (PANA_Exception(PANA_Exception::NO_MEMORY, 
                           "Failed to allocate msg message"));
   }

   // Populate header
   PANA_MsgHeader::Flags flg = { 1, 0, 0, 0 }; 
   msg->flags(flg);
   msg->type(PANA_MTYPE_TERM);
   msg->tseq(++ m_LastTransmittedTsec);
   msg->rseq(m_LastReceivedTsec);

   // Populate AVP's
   AAAAvpContainerEntry *e;
   AAAAvpContainer *c_sessionId = cm.acquire("Session-Id");
   AAAAvpContainer *c_termCause = cm.acquire("Termination-Cause");

   // Add the AVP's to containers
   e = em.acquire(AAA_AVP_UTF8_STRING_TYPE);
   diameter_utf8string_t &sessionId = e->dataRef(Type2Type<diameter_utf8string_t>());
   c_sessionId->add(e);

   e = em.acquire(AAA_AVP_UINTEGER32_TYPE);
   diameter_unsigned32_t &termCause = e->dataRef(Type2Type<diameter_unsigned32_t>());
   c_termCause->add(e);

   // Add containers to listen
   msg->avpList().add(c_sessionId);
   msg->avpList().add(c_termCause);

   // Populate data
   sessionId.assign(m_SessionId.data(), m_SessionId.size());
   termCause = m_TerminationCause;

   // Send message
   DestinationAddressFormatting(*msg);
   m_TxChannel.Send(*this, *msg);

   PANA_RtQueueNullData data;
   if (m_RtQueue.Schedule(data)) {
       m_Timer.Schedule(PANA_TID_PTR_RETRY, data.Timeout());       
   }

   ACE_DEBUG((LM_INFO, "(%P|%t) SEND: Termination-Request, tseq=%d, rseq=%d\n",
              msg->tseq(), msg->rseq()));
}

void PANA_Session::RetryTerminationRequest()
{
   m_Timer.Cancel(PANA_TID_PTR_RETRY);
   
   PANA_RtQueueData *data = NULL;
   if (m_RtQueue.ReSchedule(data)) {
       SendTerminationRequest();
       m_Timer.Schedule(PANA_TID_PTR_RETRY, data->Timeout());       
   }
   else {
       m_Timer.Schedule(PANA_TID_DISCONNECT, 0);
   }
}

void PANA_Session::ReceiveTerminationRequest()
{
   PANA_Message &msg = *(m_RxMessageQueue.front());
   m_RxMessageQueue.pop_front();

   ACE_DEBUG((LM_INFO, "(%P|%t) RECV: Termination-Req, tseq=%d, rseq=%d\n",
              msg.tseq(), msg.rseq()));

   AAAAvpContainer* c_cause = msg.avpList().search("Termination-Cause");
   if (c_cause == NULL) {
       throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                            "PANA client received term msg with no term cause"));
   }
   diameter_unsigned32_t &cause = (*c_cause)[0]->dataRef(Type2Type<diameter_unsigned32_t>());
   SendTerminationAnswer();
   Disconnect(cause);
   delete &msg;
}

void PANA_Session::SendTerminationAnswer()
{
   /*
       PaC      PAA     Message(tseq,rseq)[AVPs] 
       ------------------------------------------------------ 
          ----->        PANA-Termination-Request(q,p)[MAC] 
          <-----        PANA-Termination-Answer(p+1,q)[MAC] 
    
       Figure 7: Example Sequence for Session Termination 

       9.3.12 PANA-Termination-Answer (PTA)

         PANA-Termination-Answer (PTA) is sent either by the PaC or the PAA in
         response to PANA-Termination-Request.

              PANA-Termination-Answer ::= < PANA-Header: 6 >
                             < Session-Id >
                          *  [ AVP ]
                         0*1 < MAC >
    */
   AAAAvpContainerManager cm;
   AAAAvpContainerEntryManager em;
   PANA_Message *msg;

   ACE_NEW_NORETURN(msg, PANA_Message);
   if (msg == NULL) {
      throw (PANA_Exception(PANA_Exception::NO_MEMORY, 
                           "Failed to allocate msg message"));
   }

   // Populate header
   PANA_MsgHeader::Flags flg = { 0, 0, 0, 0 }; 
   msg->flags(flg);
   msg->type(PANA_MTYPE_TERM);
   msg->tseq(++ m_LastTransmittedTsec);
   msg->rseq(m_LastReceivedTsec);

   // Populate AVP's
   AAAAvpContainerEntry *e;
   AAAAvpContainer *c_sessionId = cm.acquire("Session-Id");

   // Add the AVP's to containers
   e = em.acquire(AAA_AVP_UTF8_STRING_TYPE);
   diameter_utf8string_t &sessionId = e->dataRef(Type2Type<diameter_utf8string_t>());
   c_sessionId->add(e);

   // Add containers to listen
   msg->avpList().add(c_sessionId);

   // Populate data
   sessionId.assign(m_SessionId.data(), m_SessionId.size());

   // send message
   DestinationAddressFormatting(*msg);
   m_TxChannel.Send(*this, *msg);

   ACE_DEBUG((LM_INFO, "(%P|%t) SEND: Termination-Answer, tseq=%d, rseq=%d\n",
              msg->tseq(), msg->rseq()));
}

void PANA_Session::ReceiveTerminationAnswer()
{
   PANA_Message &msg = *(m_RxMessageQueue.front());
   m_RxMessageQueue.pop_front();

   m_Timer.Cancel(PANA_TID_PTR_RETRY);
   m_RtQueue.ClearFront();
   
   ACE_DEBUG((LM_INFO, "(%P|%t) RECV: Termination-Answer, tseq=%d, rseq=%d\n",
              msg.tseq(), msg.rseq()));

   Disconnect(m_TerminationCause);
   delete &msg;
}

void PANA_Session::ReAuthenticate(PANA_REAUTH cause)
{
   ACE_DEBUG((LM_INFO, "(%P|%t) EVENT: Re-Authentication, cause=%d\n", cause));
   m_Timer.Cancel(PANA_TID_SESSION);
   m_Event.ReAuthentication(cause);
}

void PANA_Session::Disconnect(ACE_UINT32 cause) 
{ 
   ACE_DEBUG((LM_INFO, "(%P|%t) EVENT: Disconnect, cause=%d\n", cause));

   // cancel reauth request retry if any
   m_Timer.Cancel(PANA_TID_PRAR_RETRY);
   m_RtQueue.ClearFront();

   // cancel termination request retry if any
   m_Timer.Cancel(PANA_TID_PTR_RETRY);
   m_RtQueue.ClearFront();

   // cancel bind answer retry if any
   m_Timer.Cancel(PANA_TID_PBR_RETRY);
   m_RtQueue.ClearFront();

   // cancel all other session global timers
   m_Timer.Cancel(PANA_TID_DISCONNECT);
   m_Timer.Cancel(PANA_TID_SESSION);

   // tell the user
   m_Event.Disconnect(cause); 
}

PANA_BIND_RESULT PANA_Session::BindResult(int rcode)
{
   if (m_SeparateAuth) {
       if (m_BindCount < PANA_BIND_COUNT_MAX) {
           m_BindCount ++;
           m_BindResult[m_BindCount - 1] = rcode;
       }
   }
   else {
       m_BindResult[0] = rcode;
   }
   return BindResult();
}

PANA_BIND_RESULT PANA_Session::BindResult()
{
   PANA_BIND_RESULT br = PANA_BIND_FAILED;
   if (m_SeparateAuth) {
      if (m_BindCount < PANA_BIND_COUNT_MAX) {
         return (PANA_BIND_INTERIM);
      }
      else {
         for (unsigned int i = 0; i < m_BindCount; i ++) {
             if (PANA_RCODE_SUCCESS(m_BindResult[i])) {
                br = (i == 0) ? PANA_BIND_SUCCESS_INITIAL :
                                PANA_BIND_SUCCESS_FINAL;
                break;
             }
         }
      }
   }
   else {
      br = PANA_RCODE_SUCCESS(m_BindResult[0]) ?
                PANA_BIND_SUCCESS_FINAL :
                PANA_BIND_FAILED;
   }
   return (br);
}

void PANA_Session::BindResultReset()
{
   m_BindCount = 0;
   for (int i = 0; i < PANA_BIND_COUNT_MAX; i++) {
       m_BindResult[i] = PANA_BIND_INVALID;
   }
}

void PANA_Session::SendErrorMessage(ACE_UINT32 rcode, AAAAvpContainer *failedAvp)
{
   /*
       PANA-Error message MAY be sent by either PaC or PAA when a badly
       formed PANA message is received or in case of other errors.  If the
       cause of this error message was a request message (e.g.,
       PANA-PAA-Discover or *-Request), then the request MAY be
       retransmitted immediately without waiting for its retransmission
       timer to go off. If the cause of the error was a response message,
       the receiver of the PANA-Error message SHOULD NOT resend the same
       response until it receives the next request.

       9.3.13 PANA-Error (PER)

          PANA-Error is sent either by the PaC or the PAA.
  
                PANA-Error ::= < PANA-Header: 7 >
                               < Session-Id >
                               < Result-Code >
                               { Failed-AVP }
                            *  [ AVP ]
                           0*1 < MAC >
   */
   AAAAvpContainerManager cm;
   AAAAvpContainerEntryManager em;
   PANA_Message *msg;

   ACE_NEW_NORETURN(msg, PANA_Message);
   if (msg == NULL) {
      throw (PANA_Exception(PANA_Exception::NO_MEMORY, 
                           "Failed to allocate msg message"));
   }

   // Populate header
   PANA_MsgHeader::Flags flg = { 0, 0, 0, 0 };
   msg->flags(flg);
   msg->type(PANA_MTYPE_ERROR);
   msg->tseq(++ m_LastTransmittedTsec);
   msg->rseq(m_LastReceivedTsec);

   // Populate AVP's
   AAAAvpContainerEntry *e;
   AAAAvpContainer *c_sessionId = cm.acquire("Session-Id");
   AAAAvpContainer *c_resultCode = cm.acquire("Result-Code");
   AAAAvpContainer *c_failedAvp = cm.acquire("Failed-AVP");        

   // Add the AVP's to containers
   e = em.acquire(AAA_AVP_UTF8_STRING_TYPE);
   diameter_utf8string_t &sessionId = e->dataRef(Type2Type<diameter_utf8string_t>());
   c_sessionId->add(e);

   e = em.acquire(AAA_AVP_UINTEGER32_TYPE);
   diameter_unsigned32_t &resultCode = e->dataRef(Type2Type<diameter_unsigned32_t>());
   c_resultCode->add(e);

   e = em.acquire(AAA_AVP_GROUPED_TYPE);
   diameter_grouped_t &grpfailedAvp = e->dataRef(Type2Type<diameter_grouped_t>());
   c_failedAvp->add(e);

   // Add containers to listen
   msg->avpList().add(c_sessionId);
   msg->avpList().add(c_resultCode);
   msg->avpList().add(c_failedAvp);

   // Populate data
   sessionId.assign(m_SessionId.data(), m_SessionId.size());
   resultCode = rcode;
   grpfailedAvp.add(failedAvp);

   // Send message
   DestinationAddressFormatting(*msg);
   m_TxChannel.Send(*this, *msg);

   ACE_DEBUG((LM_INFO, "(%P|%t) SEND: Error-Message, tseq=%d, rseq=%d\n",
              msg->tseq(), msg->rseq()));
}

void PANA_Session::ReceiveErrorMessage(PANA_Message &msg)
{
   ACE_DEBUG((LM_INFO, "(%P|%t) RECV: Error-Message, tseq=%d, rseq=%d\n",
              msg.tseq(), msg.rseq()));

   AAAAvpContainer* c_rcode = msg.avpList().search("Result-Code");
   if (c_rcode == NULL) {
       throw (PANA_Exception(PANA_Exception::INVALID_MESSAGE, 
                            "PANA client received error msg with no result code"));
   }
   diameter_unsigned32_t &rcode = (*c_rcode)[0]->dataRef(Type2Type<diameter_unsigned32_t>());
   m_Event.Error(rcode);
}

void PANA_Session::Reset()
{
   PANA_SessionAttribute::Reset();
   m_InStatefulDiscovery = false;
   m_RtQueue.Clear();
}

---