--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/ssock/ss_flowrequeststates.cpp	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,257 @@
+// Copyright (c) 1997-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:
+//
+
+#include <comms-infras/ss_log.h>
+#include <comms-infras/ss_coreprstates.h>
+#include "ss_flowrequest.h"
+#include "ss_flowrequeststates.h"
+#include <comms-infras/ss_mcprnodemessages.h>
+#include <cs_subconparams.h>
+#include <comms-infras/ss_nodemessages_dataclient.h>
+#include <comms-infras/ss_nodemessages_internal_esock.h>
+#include <comms-infras/ss_nodemessages_serviceprovider.h>
+#include <comms-infras/ss_nodemessages_selector.h>
+#include <elements/nm_messages_peer.h>
+
+#include <comms-infras/ss_protocolparameterset.h>
+
+
+#ifdef _DEBUG
+// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module
+// (if it could happen through user error then you should give it an explicit, documented, category + code)
+_LIT(KSpecAssert_ESockSSockFlwRqS, "ESockSSockFlwRqS");
+#endif
+
+using namespace ESock;
+using namespace CorePanics;
+using namespace FlowRequestStates;
+using namespace Messages;
+using namespace MeshMachine;
+
+#ifdef _DEBUG
+_LIT (KCFlowRequestPanic,"FlowRequestPanic");
+#endif
+
+//
+//Implicit and common
+DEFINE_SMELEMENT(FlowRequestStates::TAwaitingImplicitFlowRequest, NetStateMachine::MState, FlowRequestStates::TContext)
+TBool FlowRequestStates::TAwaitingImplicitFlowRequest::Accept()
+	{
+	TCFInternalEsock::TFlowRequest* flowReqMsg = message_cast<TCFInternalEsock::TFlowRequest>(&iContext.iMessage);
+	return flowReqMsg && flowReqMsg->iFlowParams.iFlowRequestType == TFlowParams::EImplicit;
+	}
+
+DEFINE_SMELEMENT(FlowRequestStates::TAwaitingConnFlowRequest, NetStateMachine::MState, FlowRequestStates::TContext)
+TBool FlowRequestStates::TAwaitingConnFlowRequest::Accept()
+	{
+	TCFInternalEsock::TFlowRequest* flowReqMsg = message_cast<TCFInternalEsock::TFlowRequest>(&iContext.iMessage);
+	return flowReqMsg && flowReqMsg->iFlowParams.iFlowRequestType == TFlowParams::EExplicitConnection;
+	}
+
+DEFINE_SMELEMENT(FlowRequestStates::TAwaitingSubConnFlowRequest, NetStateMachine::MState, FlowRequestStates::TContext)
+TBool FlowRequestStates::TAwaitingSubConnFlowRequest::Accept()
+	{
+	TCFInternalEsock::TFlowRequest* flowReqMsg = message_cast<TCFInternalEsock::TFlowRequest>(&iContext.iMessage);
+	return flowReqMsg && flowReqMsg->iFlowParams.iFlowRequestType == TFlowParams::EExplicitSubConnection;
+	}
+
+DEFINE_SMELEMENT(FlowRequestStates::TRequestCSRCreation, NetStateMachine::MStateTransition, FlowRequestStates::TImplicitContext)
+void FlowRequestStates::TRequestCSRCreation::DoL()
+	{
+	//const TImplicitContext& ctx = iContext;
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+	__ASSERT_DEBUG(iContext.Node().iCSR.IsNull(), User::Panic(KCFlowRequestPanic, KPanicExpectedNoCSR));
+	iContext.iNodeActivity->PostRequestTo(iContext.Node().iTierManagerFC,
+		TCFInternalEsock::TCreateCSR(iContext.Node().iTierId).CRef(), EFalse);
+	}
+
+DEFINE_SMELEMENT(FlowRequestStates::TSelectMetaPlane, NetStateMachine::MStateTransition, FlowRequestStates::TImplicitContext)
+void FlowRequestStates::TSelectMetaPlane::DoL()
+	{
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+	__ASSERT_DEBUG(iContext.Node().iCSR.IsNull(), User::Panic(KCFlowRequestPanic, KPanicExpectedNoCSR));
+	iContext.Node().iCSR = message_cast<TCFInternalEsock::TCSRCreated>(iContext.iMessage).iNodeId;
+	__ASSERT_DEBUG(!iContext.Node().iCSR.IsNull(), User::Panic(KCFlowRequestPanic, KPanicNoCSR));
+    TSelectionPrefs prefs(TSelectionPrefs::ERequestCommsBinder); //Always get the same default connection (legacy -> on IpProto layer)
+	iContext.iNodeActivity->PostRequestTo(iContext.Node().iCSR, TCFSelector::TSimpleSelect(prefs).CRef());
+	}
+
+DEFINE_SMELEMENT(FlowRequestStates::TJoinReceivedSCpr, NetStateMachine::MStateTransition, FlowRequestStates::TImplicitContext)
+void FlowRequestStates::TJoinReceivedSCpr::DoL()
+	{
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+	__ASSERT_DEBUG(iContext.iPeer == iContext.Node().ServiceProvider(), User::Panic(KCFlowRequestPanic, KPanicExpectedNoServiceProvider));
+
+	TCFServiceProvider::TCommsBinderResponse& br = message_cast<TCFServiceProvider::TCommsBinderResponse>(iContext.iMessage);
+
+    iContext.Node().AddClientL(br.iNodeId, TClientType(TCFClientType::EServProvider, TCFClientType::EDefault));
+    iContext.iNodeActivity->PostRequestTo(br.iNodeId, TCFServiceProvider::TJoinRequest(iContext.NodeId(),
+		TClientType(TCFClientType::ECtrl)).CRef());
+	}
+
+DEFINE_SMELEMENT(FlowRequestStates::TRequestCommsBinderFromSCpr, NetStateMachine::MStateTransition, FlowRequestStates::TContext)
+void FlowRequestStates::TRequestCommsBinderFromSCpr::DoL()
+	{
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+	RNodeInterface* scpr = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider, TCFClientType::EDefault));
+
+	__ASSERT_DEBUG(scpr, User::Panic(KCFlowRequestPanic, KPanicNoServiceProvider));
+  	iContext.iNodeActivity->PostRequestTo(*scpr, TCFServiceProvider::TCommsBinderRequest(TSubConnOpen::ECreateNew, iContext.Node().iFlowParameters).CRef());
+	}
+
+DEFINE_SMELEMENT(FlowRequestStates::TRemoveRequestor, NetStateMachine::MStateTransition, FlowRequestStates::TContext)
+void FlowRequestStates::TRemoveRequestor::DoL()
+	{
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+	iContext.iNodeActivity->RemoveOriginator(0);
+	//Remove the orignator client added to the list
+	RNodeInterface* requestor = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::ECtrl));
+	if(requestor)
+		{
+//TODO bug fix 1245412 DEF122892 cant be applied - investigate 1221893 & 1245412 & te_rsubconnectionsuite.script crashes		TInt atFound = iContext.Activity()->FindOriginator(*requestor);
+		iContext.Node().RemoveClient(requestor->RecipientId(), iContext);
+//TODO bug fix cant be applied - investigate		if(atFound != KErrNotFound)
+//			{
+//			iContext.Activity()->RemoveOriginator(atFound);
+//			}
+		}
+	}
+
+DEFINE_SMELEMENT(FlowRequestActivities::CFlowRequestActivity::TStoreFlowParams, NetStateMachine::MStateTransition, TContext)
+void FlowRequestActivities::CFlowRequestActivity::TStoreFlowParams::DoL()
+	{
+	// Make sure we are being executed in the context of a node that has an activity running
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+
+	// Fetch our message and create a bundle of flow parameters from it
+	TCFInternalEsock::TFlowRequest& flowRequestMessage = message_cast<TCFInternalEsock::TFlowRequest>(iContext.iMessage);
+
+	CFlowRequestParameters* params = CFlowRequestParameters::NewL();
+	CleanupStack::PushL(params);
+	params->SetFlowParams(flowRequestMessage.iFlowParams);
+
+	RCFParameterFamilyBundle bundle;
+	bundle.CreateL();
+	CleanupClosePushL(bundle);
+    RParameterFamily family = bundle.CreateFamilyL(KFlowParametersFamily);
+
+	family.AddParameterSetL (params, RParameterFamily::ERequested);
+
+	// Save the flow parameter bundle in the activity
+	__ASSERT_DEBUG(iContext.Node().iFlowParameters.IsNull(), User::Panic(KSpecAssert_ESockSSockFlwRqS, 1));
+	iContext.Node().iFlowParameters.Open(bundle);
+
+	// Cleanup
+	CleanupStack::Pop(&bundle);
+	CleanupStack::Pop(params);
+	}
+
+
+DEFINE_SMELEMENT(FlowRequestStates::TSendNoBearer, NetStateMachine::MStateTransition, FlowRequestStates::TContext)
+void FlowRequestStates::TSendNoBearer::DoL()
+	{
+	// Make sure we are being executed in the context of a node that has an activity running
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+
+	// Fetch the subconnection. It has been designated as our control provider
+	RNodeInterface* subconn = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(
+		TClientType(TCFClientType::ECtrlProvider, TCFClientType::EDefault));
+
+	__ASSERT_DEBUG(subconn != NULL, User::Panic(KCFlowRequestPanic, KPanicNoControlProvider));
+
+	// Send TNoBearer to the subconnection
+	iContext.iNodeActivity->PostRequestTo(*subconn,
+		TCFControlProvider::TNoBearer(iContext.Node().iFlowParameters).CRef());
+	}
+
+
+DEFINE_SMELEMENT(FlowRequestStates::TJoinSubConnection, NetStateMachine::MStateTransition, FlowRequestStates::TContext)
+void FlowRequestStates::TJoinSubConnection::DoL()
+	{
+	// Make sure we are being executed in the context of a node that has an activity running
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+
+	// Fetch the subconnection. It has been designated as our control provider
+	RNodeInterface* subconn = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(
+		TClientType(TCFClientType::ECtrlProvider, TCFClientType::EDefault));
+
+	__ASSERT_DEBUG(subconn != NULL, User::Panic(KCFlowRequestPanic, KPanicNoControlProvider));
+
+	// Join the subconnection
+	iContext.iNodeActivity->PostRequestTo(*subconn,
+		TCFPeer::TJoinRequest(
+			iContext.Node().Id(), TClientType(TCFClientType::EData)).CRef());
+	}
+
+DEFINE_SMELEMENT(FlowRequestStates::TLeaveSubConnection, NetStateMachine::MStateTransition, FlowRequestStates::TContext)
+void FlowRequestStates::TLeaveSubConnection::DoL()
+	{
+	// Make sure we are being executed in the context of a node that has an activity running
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+
+	// Fetch the subconnection. Its our control provider and must be present
+	RNodeInterface* subconn = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(
+		TClientType(TCFClientType::ECtrlProvider, TCFClientType::EDefault));
+	__ASSERT_DEBUG(subconn != NULL, User::Panic(KCFlowRequestPanic, KPanicNoControlProvider));
+
+	// Send the leave request to our subconnection
+	iContext.iNodeActivity->PostRequestTo(*subconn, TEPeer::TLeaveRequest().CRef());
+	subconn->SetFlags(TCFClientType::ELeaving);
+	}
+
+
+DEFINE_SMELEMENT(FlowRequestStates::TForwardBindToMsgToOriginator, NetStateMachine::MStateTransition, FlowRequestStates::TContext)
+void FlowRequestStates::TForwardBindToMsgToOriginator::DoL()
+	{
+	//This is assumed to be executed as a direct response to TCommsBinderResponse
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+
+	// Create and send the comms binder from the incoming one
+	TCFDataClient::TBindTo& incomingBindTo = message_cast<TCFDataClient::TBindTo>(iContext.iMessage);
+    iContext.iNodeActivity->PostToOriginators(TCFDataClient::TBindTo(incomingBindTo.iNodeId).CRef());
+    iContext.iNodeActivity->ClearPostedTo();
+	}
+
+//
+//Cpr specific
+DEFINE_SMELEMENT(FlowRequestStates::TJoinCpr, NetStateMachine::MStateTransition, FlowRequestStates::TContext)
+void FlowRequestStates::TJoinCpr::DoL()
+	{
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+	RNodeInterface* cpr = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider));
+
+	//The sc has been already added
+	__ASSERT_DEBUG(cpr != NULL, User::Panic(KCFlowRequestPanic, KPanicNoServiceProvider));
+
+	//Join the service provider
+	iContext.iNodeActivity->PostRequestTo(*cpr, TCFServiceProvider::TJoinRequest(iContext.NodeId(), TClientType(TCFClientType::ECtrl)).CRef());
+	}
+
+//
+//SCpr specific
+DEFINE_SMELEMENT(FlowRequestStates::TJoinSCpr, NetStateMachine::MStateTransition, FlowRequestStates::TContext)
+void FlowRequestStates::TJoinSCpr::DoL()
+	{
+	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCFlowRequestPanic, KPanicNoActivity));
+	RNodeInterface* scpr = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider, TCFClientType::EDefault));
+
+	//The sc has been already added
+	__ASSERT_DEBUG(scpr != NULL, User::Panic(KCFlowRequestPanic, KPanicNoServiceProvider));
+
+	//Join the service provider
+	iContext.iNodeActivity->PostRequestTo(*scpr, TCFServiceProvider::TJoinRequest(iContext.NodeId(), TClientType(TCFClientType::ECtrl)).CRef());
+	}
+
+