// Copyright (c) 2007-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:
// IPProto demultiplexor implementation
// 
//

/**
 @file
 @internalComponent
*/

#include <nifmbuf.h>
#include "IPProtoDeMux.h"

CIPProtoBinder::CIPProtoBinder(CIPShimSubConnectionFlow& aFlow)
	:iBinderControl(NULL),
	 iLowerControl(NULL),
	 iFlow(aFlow),
	 iNif(NULL)
	{    
	
	}


CIPProtoBinder* CIPProtoBinder::NewL(CIPShimSubConnectionFlow& aFlow, const TDesC8& aProtocolName)
	{
	CIPProtoBinder* me = new (ELeave) CIPProtoBinder(aFlow);
	me->SetProtocolName(aProtocolName);
    return me;
	}
	
void CIPProtoBinder::StartL()
	{
	ASSERT(iNif);
	iNif->StartL();
	}

CIPProtoBinder::~CIPProtoBinder()
	{
	ASSERT(iNif == NULL); // should have been unbound by this stage
	}

void CIPProtoBinder::BindL(CIPShimIfBase* aNif)
	{
	__CFLOG_2(KIPProtoTag1, KIPProtoTag2, _L("CIPProtoBinder %08x:\tBindL(%08x)"), this, aNif); 
	ASSERT(iNif == NULL); // shouldn't be binding twice
	iNif = aNif;
	}

void CIPProtoBinder::Unbind()
	{
	__CFLOG_1(KIPProtoTag1, KIPProtoTag2, _L("CIPProtoBinder %08x:\tUnbind()"), this); 
	ASSERT(iNif);
	iNif = NULL;
	}

void CIPProtoBinder::BindToLowerFlowL(ESock::MFlowBinderControl& aLowerBinderControl)
	{
	ASSERT(iNif);

	__CFLOG_2(KIPProtoTag1, KIPProtoTag2, _L8("CIPProtoBinder %08x:\tBindToLowerFlowL(): protocol '%S'"), this, &iNif->ProtocolName()); 

	iBinderControl = &aLowerBinderControl;
	iLowerControl = iBinderControl->GetControlL(iNif->ProtocolName());
	iLowerDataSender = iBinderControl->BindL(iNif->ProtocolName(), this, this);
	}	
	
void CIPProtoBinder::UnbindFromLowerFlow()
	{
	__CFLOG_1(KIPProtoTag1, KIPProtoTag2, _L("CIPProtoBinder %08x:\tUnbindFromLowerFlow()"), this); 

	if (!iBinderControl)
		return;
	
	iBinderControl->Unbind(this, this);
	iBinderControl = NULL;

	iLowerControl = NULL;
	iLowerDataSender = NULL;
	}

//-=========================================
// MUpperDataReceiver methods
//-=========================================        
void CIPProtoBinder::Process(RMBufChain& aData)
	{
	if (iNif)
		{
		ASSERT(iNif->iUpperProtocol);
		iNif->iUpperProtocol->Process(aData, reinterpret_cast<CProtocolBase*>(iNif));
		}
	}

//-=========================================
// MUpperControl methods
//-=========================================        
void CIPProtoBinder::StartSending()
	{
	__CFLOG_1(KIPProtoTag1, KIPProtoTag2, _L("CIPProtoBinder %08x:\tStartSending()"), this);
	Flow().BinderReady();	
	iNif->StartSending();
	}
	
void CIPProtoBinder::Error(TInt aError)
	{
	__CFLOG_2(KIPProtoTag1, KIPProtoTag2, _L("CIPProtoBinder %08x:\tError(%d)"), this, aError);
	Flow().BinderError(aError, this);
	}
//-=========================================
// MLowerDataSender methods
//-========================================= 
ESock::MLowerDataSender::TSendResult CIPProtoBinder::Send(RMBufChain& aData)
	{
	return iLowerDataSender->Send(aData);
	}

//-=========================================
// MLowerControl methods
//-========================================= 
TInt CIPProtoBinder::GetName(TDes& aName)
	{
	return iLowerControl->GetName(aName);
	}
	
TInt CIPProtoBinder::BlockFlow(TBlockOption aOption)
	{
	__CFLOG_2(KIPProtoTag1, KIPProtoTag2, _L("CIPProtoBinder %08x:\tBlockFlow(%d)"), this, aOption);
	return iLowerControl->BlockFlow(aOption);
	}
TInt CIPProtoBinder::GetConfig(TBinderConfig& aConfig)
	{
	return iLowerControl->GetConfig(aConfig);
	}
	
TInt CIPProtoBinder::Control(TUint aLevel, TUint aName, TDes8& aOption)
	{
	return iLowerControl->Control(aLevel, aName, aOption);
	}

//-========================================= 
void CIPProtoBinder::SetProtocolName(const TDesC8& aProtocol)
	{
	iProtocolName.Copy(aProtocol);
	}


const TDesC8& CIPProtoBinder::ProtocolName()
	{
	ASSERT(iProtocolName.Length());
	return iProtocolName;
	}