//Editor-Info: -*- C++ -*-
//
//Subject: TOVE project
//
//File: gsmpactivestate.cpp 
//
//Version: $Revision: 1.12 $
//
//State: $State: Exp $
//
//Date: $Date: 1998/12/16 16:57:24 $
//
//Organisation:
//      Helsinki University of Technology
//      Laboratory of Telecommunications Software and Multimedia
//
//Author:
//      Harri Sunila
//
//Description:
//      See corresponding headerfile. 
//
//Copyright:
//      Copyright 1999 Helsinki University of Technology
//      ALL RIGHTS RESERVED BETWEEN JANUARY 1996 AND JUNE 1999 
//
//Licence:
//
//
//History: 

#include "gsmpactivestate.h"
#include "gsmpconnectionmanagementmessages.h"
#include "gsmpportmanagementmessages.h"
#include "gsmpconfigurationmessages.h"
#include "gsmpstatisticsmessages.h"
#include "gsmpeventmessages.h"
#include "gsmptimeouts.h"
#include "gsmpprotocol.h"
#include "gsmpport.h"
#include "pf/error.h"

gsmpActiveState *gsmpActiveState::_only = 0;

//
// Function: gsmpActiveState
//
// Description:  
//

gsmpActiveState :: gsmpActiveState(void)
{
    return;
}

//
// Function: ~gsmpActiveState
//
// Description:  
//

gsmpActiveState :: ~gsmpActiveState(void)
{
    _only = 0;
    return;
}

//
// Function: instance
//
// Description:  
//

gsmpActiveState *gsmpActiveState :: instance(void)
{
    if (_only == 0)
    {
        _only = new gsmpActiveState;
    }
    return _only;
}

//
// Function: gsmpSwitchConfigurationRequestMessageAct
//
// Description:  
//

void gsmpActiveState :: gsmpSwitchConfigurationRequestMessageAct(
    gsmpSwitchConfigurationRequestMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfUlong transactionIdentifier = message_->getTransactionIdentifier();
    protocol->addTimer(transactionIdentifier,
                       gsmpMessage::SWITCH_CONFIGURATION);
    protocol->toA(message_);
    return;
}

//
// Function: gsmpPortConfigurationRequestMessageAct
//
// Description:  
//

void gsmpActiveState :: gsmpPortConfigurationRequestMessageAct(
    gsmpPortConfigurationRequestMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfUlong transactionIdentifier = message_->getTransactionIdentifier();
    protocol->addTimer(transactionIdentifier,
                       gsmpMessage::PORT_CONFIGURATION);
    protocol->toA(message_);
    return;
}

//
// Function: gsmpAllPortsConfigurationRequestMessageAct
//
// Description:  
//

void gsmpActiveState :: gsmpAllPortsConfigurationRequestMessageAct(
    gsmpAllPortsConfigurationRequestMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfUlong transactionIdentifier = message_->getTransactionIdentifier();
    protocol->addTimer(transactionIdentifier,
                       gsmpMessage::ALL_PORTS_CONFIGURATION);
    protocol->toA(message_);
    return;
}

//
// Function: gsmpPortUpEventMessageAct
//
// Description:  
//

void gsmpActiveState :: gsmpPortUpEventMessageAct(
    gsmpPortUpEventMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfUlong port = message_->getPort();
    protocol->sendGsmpPortConfigurationRequestMessage(port);
    protocol->acceptEvent(message_);

    // Reset the corresponding event flag
    protocol->resetEventFlags(port,
                              gsmpPortManagementMessage::GSMP_PORT_UP);
    return;
}

//
// Function: gsmpPortDownEventMessageAct
//
// Description:  
//

void gsmpActiveState :: gsmpPortDownEventMessageAct(
    gsmpPortDownEventMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfUlong port = message_->getPort();
    protocol->acceptEvent(message_);

    // Reset the corresponding event flag
    protocol->resetEventFlags(port,
                              gsmpPortManagementMessage::GSMP_PORT_DOWN);
    return;
}

//
// Function: gsmpInvalidVPIVCIEventMessageAct
//
// Description:  
//

void gsmpActiveState :: gsmpInvalidVPIVCIEventMessageAct(
    gsmpInvalidVPIVCIEventMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfUlong port = message_->getPort();
    protocol->acceptEvent(message_);

    // Reset the corresponding event flag
    protocol->resetEventFlags(port,
                              gsmpPortManagementMessage::GSMP_INVALID_VPIVCI);
    return;
}

//
// Function: gsmpNewPortEventMessageAct
//
// Description:  
//

void gsmpActiveState :: gsmpNewPortEventMessageAct(
    gsmpNewPortEventMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfUlong port = message_->getPort();
    protocol->sendGsmpPortConfigurationRequestMessage(port);
    protocol->acceptEvent(message_);

    // Reset the corresponding event flag
    protocol->resetEventFlags(port,
                              gsmpPortManagementMessage::GSMP_NEW_PORT);
    return;
}

//
// Function: gsmpDeadPortEventMessageAct
//
// Description:  
//

void gsmpActiveState :: gsmpDeadPortEventMessageAct(
    gsmpDeadPortEventMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfUlong port = message_->getPort();
    protocol->removePortSessionNumber(port);
    protocol->acceptEvent(message_);

    // Reset the corresponding event flag
    protocol->resetEventFlags(port,
                              gsmpPortManagementMessage::GSMP_DEAD_PORT);
    return;
}

//
// Function: processConnetionManagementMessage
//
// Description:  
//

void gsmpActiveState :: processConnectionManagementMessage(
    gsmpConnectionManagementMessage *message_,
    pfProtocol *protocol_)
{
    gsmpProtocol *protocol = dynamic_cast<gsmpProtocol *>(protocol_);
    THROW_IF_DYNAMIC_CAST_FAILED(protocol);
    pfByte result = message_->getResult();
    pfByte code = message_->getCode();
    pfUlong transactionIdentifier = message_->getTransactionIdentifier();
    pfUlong inputPort = message_->getInputPort();
    pfUlong portSessionNumber = protocol->getPortSessionNumber(inputPort);
    switch (result)
    {
        case gsmpMessage::GSMP_ACK_ALL:        // Request
            if (portSessionNumber == 0)
            {
                message_->setResult(gsmpMessage::GSMP_FAILURE);
                message_->setCode(gsmpMessage::GSMP_E_PORT_NOT_EXIST);
                protocol->acceptResponse(transactionIdentifier, message_);
            }
            else
            {
                message_->setPortSessionNumber(portSessionNumber);
                pfByte messageType = message_->getMessageType();
                protocol->addTimer(transactionIdentifier, messageType);
                protocol->toA(message_);
            }
            break;
        case gsmpMessage::GSMP_SUCCESS:        // Response.
            protocol->removeTimer(transactionIdentifier);
            protocol->acceptResponse(transactionIdentifier, message_);
            break;
        case gsmpMessage::GSMP_FAILURE:
            protocol->removeTimer(transactionIdentifier);
            // Check the reason, why operation failed
            switch (code)
            {
                case gsmpMessage::GSMP_E_INVAL_PORT_SESS: 
                    // We must obtain the correct Port Session Number.
                    protocol->sendGsmpPortConfigurationRequestMessage(
                        inputPort);
                    break;
                default:
                    break;
            }
            protocol->acceptResponse(transactionIdentifier, message_);
            break;
    }
    return;
}