// Copyright (c) 2006-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of "Eclipse Public License v1.0"
// which accompanies this distribution, and is available
// at the URL "http://www.eclipse.org/legal/epl-v10.html".
//
// Initial Contributors:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
// IP SubConnection Provider states/transitions
// 
//

/**
 @file
 @internalComponent
*/

#include <comms-infras/corescpractivities.h>
#include "IPSCPRStates.h"
#include <elements/nm_messages_peer.h>

#include "../../iptransportlayer/src/ipscprlog.h"

using namespace Messages;
using namespace ESock;
using namespace NetStateMachine;
using namespace QoSIpSCprStates;
//-=========================================================
//
// Activities
//
//-=========================================================
DEFINE_SMELEMENT(TStoreAddressUpdateAndAddClientToQoSChannel, NetStateMachine::MStateTransition, QoSIpSCprStates::TContext)
void TStoreAddressUpdateAndAddClientToQoSChannel::DoL()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TStoreAddressUpdateAndAddClientToQoSChannel::DoL [%08x]"), this));
   IPBaseSCprStates::TStoreAddressUpdate storeAddressUpdate(iContext);
   storeAddressUpdate.DoL();
   
   RIPDataClientNodeInterface* client = 
   	    static_cast<RIPDataClientNodeInterface*>(iContext.iPeer);        
   
   if (client && !(client->Flags() & TCFClientType::EJoining))
       {
       client->SetFlags(TCFClientType::EJoining);
       QoSIpSCprStates::TAddClientToQoSChannel addToChannel(iContext);
       addToChannel.DoL();
       client->ClearFlags(TCFClientType::EJoining);
       }
   }


DEFINE_SMELEMENT(TAddClientToQoSChannel, NetStateMachine::MStateTransition, QoSIpSCprStates::TContext)
void TAddClientToQoSChannel::DoL()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TAddClientToQoSChannel::DoL [%08x]"), this));
	RIPDataClientNodeInterface* clientToBeAdded = static_cast<RIPDataClientNodeInterface*>(
	    iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TCFClientType::EJoining)));
    ASSERT(clientToBeAdded);
    
    if (clientToBeAdded)
        {
        iContext.Node().DataClientJoiningL(*clientToBeAdded);
        if (iContext.iNodeActivity)
            {
        	clientToBeAdded->iActivityAwaitingResponse = iContext.iNodeActivity->ActivityId();
            }
    	clientToBeAdded->ClearFlags(TCFClientType::EJoining);        
        }
	}
	
DEFINE_SMELEMENT(TRemoveClientToQoSChannel, NetStateMachine::MStateTransition, QoSIpSCprStates::TContext)
void TRemoveClientToQoSChannel::DoL()
	{
	RIPDataClientNodeInterface* clientToBeRemoved = static_cast<RIPDataClientNodeInterface*>(
	    iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TClientType::ELeaving)));
    ASSERT(clientToBeRemoved);
    
    if (clientToBeRemoved)
        {
        iContext.Node().DataClientLeaving(*clientToBeRemoved);
        if (iContext.iNodeActivity)
            {
        	clientToBeRemoved->iActivityAwaitingResponse = iContext.iNodeActivity->ActivityId();
            }
    	clientToBeRemoved->ClearFlags(TClientType::ELeaving);
        }
	}
	
DEFINE_SMELEMENT(TRemoveLeavingClientFromQoSChannel, NetStateMachine::MStateTransition, QoSIpSCprStates::TContext)
void TRemoveLeavingClientFromQoSChannel::DoL()
    {    
	__IPCPRLOG(IpCprLog::Printf(_L("TRemoveClientFromQoSChannel::DoL [%08x]"), this));
    if (iContext.iPeer && 
        iContext.iPeer->Type() & TCFClientType::EData &&
        !iContext.iPeer->Flags() & TCFClientType::EJoining)
        {
    	RIPDataClientNodeInterface& client = 
    	    static_cast<RIPDataClientNodeInterface&>(*iContext.iPeer);
        iContext.Node().DataClientLeaving(static_cast<RIPDataClientNodeInterface&>(client));
        }
    PRStates::TProcessClientLeave processClientLeave(iContext);
    processClientLeave.DoL();
    }
	
DEFINE_SMELEMENT(TSetParameters, NetStateMachine::MStateTransition, QoSIpSCprStates::TContext)
void TSetParameters::DoL()
    {
	__IPCPRLOG(IpCprLog::Printf(_L("TSetParameters::DoL [%08x]"), this));
	iContext.Node().SetQoSParametersL();
#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
	iContext.PostToSender(TCFScpr::TSetParamsResponse(iContext.Node().iParameterBundle).CRef());
#else
	iContext.PostToSender(TCFScpr::TParamsResponse(iContext.Node().iParameterBundle).CRef());
#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
    }

DEFINE_SMELEMENT(TOpenInternalSocket, NetStateMachine::MStateTransition, QoSIpSCprStates::TContext)
void TOpenInternalSocket::DoL()
    {
	__IPCPRLOG(IpCprLog::Printf(_L("TOpenInternalSocket::DoL [%08x]"), this));

	TNodeCtxId originator(iContext.iNodeActivity->ActivityId(), iContext.NodeId());
	CQoSSocketOpener* opener = CQoSSocketOpener::NewL(iContext.Node(), originator); // cleans up itself when RunL runs
	opener->Open();
    }

//-=========================================================
//
//States
//
//-=========================================================
DEFINE_SMELEMENT(TAwaitingJoinComplete, NetStateMachine::MState, QoSIpSCprStates::TContext)
TBool TAwaitingJoinComplete::Accept()
    {
	__IPCPRLOG(IpCprLog::Printf(_L("TAwaitingJoinComplete::Accept [%08x]"), this));
	return iContext.iMessage.IsMessage<TCFPeer::TJoinComplete>();
    }
    
DEFINE_SMELEMENT(TAwaitingLeaveComplete, NetStateMachine::MState, QoSIpSCprStates::TContext)
TBool TAwaitingLeaveComplete::Accept()
    {
	return iContext.iMessage.IsMessage<TEPeer::TLeaveComplete>();
    }    

//-=========================================================
//
//State Forks
//
//-=========================================================

DEFINE_SMELEMENT(TNoTagOrSendApplyResponse, NetStateMachine::MStateFork, QoSIpSCprStates::TContext)
TInt TNoTagOrSendApplyResponse::TransitionTag()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TNoTagOrSendApplyResponse::TransitionTag [%08x]"), this));
	RNodeInterface* joiningClient = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TCFClientType::EJoining));
	RNodeInterface* leavingClient = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TClientType::ELeaving));
	ASSERT(!(joiningClient && leavingClient) );
	
	if (joiningClient)
    	{
    	return SCprStates::KClientsJoining;
    	}
    else if (leavingClient)
    	{
    	return SCprStates::KClientsLeaving;
    	}
    return MeshMachine::KNoTag;
	}

//-=========================================================
//
//Transitions
//
//-=========================================================