// 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:
//

/**
 @file
 @internalTechnology
 @released
*/

#if !defined(__ES_SAP_H__)
#define __ES_SAP_H__

#define SYMBIAN_NETWORKING_UPS

#include <es_prot.h>
#include <es_sock.h>
#include <comms-infras/ss_subconnflow.h>
#include <comms-infras/ss_flowbinders.h>
#include <comms-infras/ss_nodemessages_dataclient.h>

namespace ESock
{

class CNetworkFlow : public CSubConnectionFlowBase, protected MSessionData, protected MSessionControl,
                        protected MFlowBinderControl
/** Service Access Point for SAPs that have a seperate control side.

Provides transport services to a single protocol. Several of the calls to
CServProviderBase have pre-conditions attached to them - for example
a connection oriented protocol must have its local address set (either by
a SetLocalName() or AutoBind()) before it is opened. If the socket server
calls the CServProviderBase in such an erroneous way, the protocol should panic.

It also provides an interface towards subconnection providers to allow
SAPs to work with a seperate control path.

@internalTechnology
@released Since 9.0 */
	{
	friend class ProtocolManager;
public:

	IMPORT_C virtual ~CNetworkFlow();

protected:
	void SetLocalName(TSockAddr& anAddr);
	TInt SetRemName(TSockAddr& anAddr);
	TUint Write(const TDesC8& aDesc,TUint aOptions, TSockAddr* anAddr);
	TInt Write(RMBufChain& aData, TUint aOptions, TSockAddr* anAddr);
    void BindToL(const TCFDataClient::TBindTo& aBindTo);
    NetInterfaces::TInterfaceControl* FetchInterfaceControlL(TSupportedCommsApiExt aInterfaceId);

protected:

	virtual MFlowBinderControl* DoGetBinderControlL();
	//MFlowBinderControl
	virtual MSessionControl* GetControlL(TInt aSessionType,MSessionControlNotify& aSessionControlNotify);
	virtual void Unbind();
	virtual MSessionData* BindL(MSessionDataNotify& aNotify);
	virtual CSubConnectionFlowBase* Flow(); //returns its own flow

    TBool IsBoundToSession() const
        {
        return  iSessionControlNotify || iSessionDataNotify;
        }

	void ProcessDCIdleState();

#ifdef SYMBIAN_NETWORKING_UPS
	virtual TBool ActivityRunning() = 0;
#else
    inline TBool NoBearerGuard()
    	{ return iNoBearerRunning; }
    inline void SetNoBearerGuard()
    	{ iNoBearerRunning = ETrue; }
    inline void ClearNoBearerGuard()
    	{ iNoBearerRunning = EFalse; }
#endif

protected:
	IMPORT_C CNetworkFlow(CSubConnectionFlowFactoryBase& aFactory, const Messages::TNodeId& aSubConn, CProtocolIntfBase* aProtocolIntf);
	void UpdateDestinationAddress(const TSockAddr& aDest);

protected:
	TSockAddr iLocalAddress;
	TSockAddr iRemoteAddress;

	//upper flow
	MSessionControlNotify* iSessionControlNotify;
	MSessionDataNotify* iSessionDataNotify;
	//lower flow
	MFlowBinderControl* iLowerFlow;
	MLowerControl* iLowerControl; //just to keep the lower flow up

	enum TDCIdleState
		{
		EClientsPresent = 0, // presumption is we're always created for a client (ie HR or socket)
		EIdle = 1,
		EIdleSent = 2
		};
	TBool iLocalAddressSet:1;
	TBool iRemoteAddressSet:1;
	TBool iConnectionInfoSet:1;
	TBool iJoinOutstanding:1;
	TBool iLeaveOutstanding:1;	
#ifndef SYMBIAN_NETWORKING_UPS
	TBool iNoBearerRunning:1;			// NoBearer msg has been issued to SCPR
#endif
	TBool iIsStarted:1;	
	TDCIdleState iDCIdle:2;			
	};

} //namespace ESock

#endif	// __ES_SAP_H__