--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/networkcontrol/qosipscpr/src/ipscprstates.cpp	Tue Jan 26 15:23:49 2010 +0200
@@ -0,0 +1,182 @@
+// 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
+//
+//-=========================================================
+
+