telephonyprotocols/rawipnif/rawipnif2/inc/RawIP2Flow.h
changeset 0 3553901f7fa8
child 19 630d2f34d719
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/telephonyprotocols/rawipnif/rawipnif2/inc/RawIP2Flow.h	Tue Feb 02 01:41:59 2010 +0200
@@ -0,0 +1,173 @@
+// 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:
+// Defines the CRawIPFlow class, which provides a central point for the Flow
+// to communicate with NifMan and the BCA controller. This class creates an
+// interface to the IPv4 binder when it is required.
+// 
+//
+
+/**
+ @file
+*/
+
+#ifndef RAWIP2FLOW_H
+#define RAWIP2FLOW_H
+
+#include <comms-infras/nifif.h>
+#include <networking/packetlogger.h>
+#include <in_sock.h>
+#include <comms-infras/ss_flowbinders.h>
+#include <comms-infras/ss_subconnflow.h>
+#include "BinderBase.h"
+#include "bttlog.h"
+#include <comms-infras/linkmessages.h>		// for TLinkMessageId
+
+class CBcaController;
+class CBttLogger;
+class CPacketLogger;
+class CBCAProvision;
+
+class CRawIP2Flow : public ESock::CSubConnectionFlowBase, public ESock::MFlowBinderControl
+	{
+	friend class CRawIP2FlowFactory;
+
+public:
+
+    //-=========================================================
+    // Methods for handling incoming SCPR messages
+    //-=========================================================
+    void StartFlowL();
+	void StopFlow(TInt aError);
+	void SubConnectionGoingDown();
+	void SubConnectionError(TInt aError);
+	void Destroy();
+	
+	//-=========================================================
+	// CSubConnectionProviderBase methods
+	//-=========================================================
+	MFlowBinderControl* DoGetBinderControlL();
+
+	//-=========================================================
+	// Messages::ANode methods
+	//-=========================================================
+	virtual void ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aMessage);
+
+	//-=========================================================
+	// MFlowBinderControl methods
+	//-=========================================================
+	virtual ESock::MLowerControl* GetControlL(const TDesC8& aProtocol);
+	virtual ESock::MLowerDataSender* BindL(const TDesC8& aProtocol, ESock::MUpperDataReceiver* aReceiver, ESock::MUpperControl* aControl);
+	virtual void Unbind(ESock::MUpperDataReceiver* aReceiver, ESock::MUpperControl* aControl);
+	virtual CSubConnectionFlowBase* Flow(); //returns its own flow
+
+    //-=========================================================
+    // Custom methods
+    //-=========================================================
+    // provide compatability for classes using old CNifIfLink style API and PPP Internal Stop() calls
+    void Stop(TInt aReason, MNifIfNotify::TAction aAction);
+    // call from Binder - MLowerDataSender
+	ESock::MLowerDataSender::TSendResult Send(RMBufChain& aPdu, TUint aProtocol);
+
+	// Used to be :Pure virtuals inherited from MContextSmObserver
+	CBcaController* GetBcaController();
+	void UpdateContextState(RPacketContext::TContextStatus aState,	TInt aError);
+
+public: 
+	virtual void InitialiseL();
+	virtual void ShutDown( TInt aError);
+
+	virtual CBinderBase* GetBinder();
+
+public:
+	// Notify that link is Up/Down
+	void LinkLayerUp();
+	void LinkLayerDown(TInt aError);
+
+public:
+
+public:	// Context status retrieval.
+	inline RPacketContext::TContextStatus GetContextStatus();
+	
+protected:
+	CRawIP2Flow(ESock::CSubConnectionFlowFactoryBase& aFactory, const Messages::TNodeId& aSubConnId, ESock::CProtocolIntfBase* aProtocolIntf, CBttLogger* aTheLogger);
+	void ConstructL();
+	virtual ~CRawIP2Flow();
+	
+protected:
+    class TBinderControlProxy : public ESock::MFlowBinderControl
+        {
+        public:
+    	virtual ESock::MLowerControl* GetControlL(const TDesC8& aProtocol);
+    	virtual ESock::MLowerDataSender* BindL(const TDesC8& aProtocol, ESock::MUpperDataReceiver* aReceiver, ESock::MUpperControl* aControl);
+    	virtual void Unbind(ESock::MUpperDataReceiver* aReceiver, ESock::MUpperControl* aControl);
+    	virtual CSubConnectionFlowBase* Flow(); //returns its own flow
+    	CRawIP2Flow& RawIP2Flow()
+        	{
+        	ASSERT(iFlow);
+        	return *iFlow;  
+        	}
+    	
+        TBinderControlProxy(CRawIP2Flow& aFlow)
+        :iFlow(&aFlow)
+            {
+            }
+        
+        CRawIP2Flow* iFlow;
+        };
+    TBinderControlProxy* iBinderControl;
+
+private:
+	void ProvisionConfig(const ESock::RMetaExtensionContainerC& aConfigData);
+	void DynamicProvisionConfigL();
+
+	// Utility functions
+	void PostProgressMessage(TInt aStage, TInt aError);
+    void SendDataClientIdleIfNoClients();
+
+private:// Unowned
+	/** networking packet logger for debugging packets */
+	__PACKETLOG_DECLARATION_MEMBER;
+	CBttLogger* iTheLogger;
+
+	// The protocol to use (IPv4).Note: This is not owned by this class.
+	CBinderBase* iBinder;
+
+	const CBCAProvision* iBCAProvisionConfig;						// pointer to BCA provisioning structure in CAccessPointConfig
+	const CRawIpAgentConfig* iAgentProvision;				// pointer to Agent provisioning structure in CAccessPointConfig
+	TInt iProvisionError;						// error code saved during processing of ProvisionConfig message
+	
+
+private:// Owned
+	TInt iInitError;
+
+	RPacketContext::TContextStatus iContextStatus;
+
+	CBcaController* iBcaController;
+	TBool iStarting:1;
+	TBool iStarted:1;
+	TBool iStopping:1;
+	TBool iBlocked:1;
+	};
+
+inline RPacketContext::TContextStatus CRawIP2Flow::GetContextStatus()
+/**
+ * Returns Context status
+ *
+ * @return iContextStatus The context status
+ */
+	{
+	return iContextStatus;
+	}
+
+#endif // RAWIP2Flow_H