/*
* Copyright (c) 2005-2006 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:    tbcpfloorcontorlimpl.cpp
*
*/




#include <e32base.h>
#include <e32std.h>
#include <e32def.h>
#include "fctbcpfloorcontrolimpl.h"
#include "fcconnectioncontainer.h"
#include "fcsender.h"
#include "fcreceiver.h"
#include "utf.h"
#include "fcinterfaceinitparams.h"
#include "fcnotifier.h"

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::NewL
// -----------------------------------------------------------------------------
//
CTBCPFloorControlImpl* CTBCPFloorControlImpl::NewL(TAny* aInitParams)
	{
	TFCInterfaceInitParams* initParams= 
					static_cast<TFCInterfaceInitParams*>( aInitParams);

	CTBCPFloorControlImpl* self = 
			new (ELeave) CTBCPFloorControlImpl(initParams->iMsgObserver);
	CleanupStack::PushL( self );
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}


// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::CTBCPFloorControlImpl
// -----------------------------------------------------------------------------
//
 CTBCPFloorControlImpl::CTBCPFloorControlImpl(MFCMessageObserver &aObserver)
: iMsgObserver (aObserver)
	{		
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::ConstructL
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::ConstructL()
	{
	iSender = CFCSender::NewL(iSocket, *this);
	iReceiver = CFCReceiver::NewL(iSocket, *this);
	iConnection = CFCConnectionContainer::NewL(*this);
	//Open the socketserver First
	User::LeaveIfError( iSocketServ.Connect( KESockDefaultMessageSlots) );
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::~CTBCPFloorControlImpl
// -----------------------------------------------------------------------------
//
CTBCPFloorControlImpl::~CTBCPFloorControlImpl()
	{
	if (iReceiver)
		{		
		iReceiver->Cancel();
		}
	if (iSender)
		{
		iSender->Cancel();
		}
	if(iConnection)
		{
		iConnection->CloseConnection();

		}
	iSocket.Close();
	delete iReceiver;
	delete iSender;
	delete iConnection;
	iSocketServ.Close();
	}
	
// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::ConnectL
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::ConnectL(TBool aReceiver)
	{
	//Open RConnection by calling CFCConnectionContainer
	iStartListen = aReceiver;
	User::LeaveIfError(iConnection->OpenConnection(iIapId, iSocketServ));
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::ResetSocketL
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::ResetSocketL()
	{
	iSocket.Close();
	User::LeaveIfError(iSocket.Open(iSocketServ, KAfInet, KSockDatagram,
					   KProtocolInetUdp, iConnection->Connection()));
	iSocket.SetOpt(KSoReuseAddr, KSolInetIp, 1);
	TInetAddr addr;
	addr.SetAddress(KInetAddrAny);
	addr.SetPort(iLocalPort);
	iSocket.Bind(addr);
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::Stop
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::Stop()
	{
	if (iReceiver)
		{		
		iReceiver->Cancel();
		}
	if (iSender)
		{
		iSender->Cancel();
		}
	if(iConnection)
		{
		iConnection->CloseConnection();
		}
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::SendToNetL
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::SendToNetL(HBufC8* aData)
	{
	iSender->SendL(aData, iRemoteAddr);
 	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::StartListenL
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::StartListen()
	{
	iReceiver->Listen();
 	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::CancelSend
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::CancelSend()
	{
	 iSender->Cancel();
	 //DoCancel
	}
	
// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::SetIapId
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::SetIapId(TUint32 aIapId )
	{
	//require from user 
	iIapId=aIapId;
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::SetAddress
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::SetAddressL(const TDesC& aAddr, TUint aPort)
	{
	TInetAddr address;
	User::LeaveIfError(address.Input(aAddr));
	
    if (address.Family() == KAfInet6 )
		{
		iRemoteAddr.SetAddress( address.Ip6Address() ); 
		}
	else
		{
		iRemoteAddr.SetAddress( address.Address() ); 		
		}

	iRemoteAddr.SetPort(aPort);
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::SetLocalPort
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::SetLocalPort(TUint aPort)
	{
	iLocalPort=aPort;
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::ReceivedData
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::ReceivedData(HBufC8* aData)
	{
	iMsgObserver.ReceivedData( aData, this );
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::ConnectionStarted
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::ConnectionStarted( TInt aError )
	{
	TRAPD(leaveErr ,ConnectionStartedL(aError) );
	if(leaveErr!=KErrNone)
		{
		ErrorNotify( leaveErr );	
		}
	}	

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::ConnectionStartedL
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::ConnectionStartedL( TInt aError )
	{
	if(aError!=KErrNone)
		{
		//return to Application-->ErrorNotify
		iMsgObserver.ErrorNotify( aError, this );
		}
	else
		{
		User::LeaveIfError(iSocket.Open(iSocketServ, KAfInet, KSockDatagram,
								KProtocolInetUdp, iConnection->Connection()));
		
		
		iSender->ConnectedL();
		
		TInetAddr addr;
		addr.SetAddress(KInetAddrAny);
		addr.SetPort(iLocalPort);
		iSocket.Bind(addr);

		if(iStartListen)
			{
			StartListen();
			}	
		}
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::Name
// -----------------------------------------------------------------------------
//
const TDesC8& CTBCPFloorControlImpl::Name() const
	{
	return KTBCP;
	}

// -----------------------------------------------------------------------------
// CTBCPFloorControlImpl::ErrorNotify
// -----------------------------------------------------------------------------
//
void CTBCPFloorControlImpl::ErrorNotify( TInt aErrCode)
	{
	if(aErrCode!=KErrNone)
		{
		TRAP_IGNORE(ResetSocketL());
		iMsgObserver.ErrorNotify( aErrCode, this );
		}
	}