// Copyright (c) 2005-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 <obex/transport/mobextransportnotify.h>

#include <obexbttransportinfo.h>

#include "ObexRfcommConnector.h"

#include "ObexActiveRfcommConnector.h"

#include "ObexListenerRfcommConnector.h"

#include "logger.h"

#include "obexbtfaults.h"

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, "RFCOMM");

#endif

#ifdef _DEBUG

_LIT(KPanicCat, "RfcommConnector");

#endif

CObexRfcommConnector* CObexRfcommConnector::NewL(MObexTransportNotify& aOwner, 

						 TBTSockAddr& aAddr)

	{

	LOG_STATIC_FUNC_ENTRY

	CObexRfcommConnector* self = new(ELeave) CObexRfcommConnector(aOwner, aAddr);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

CObexRfcommConnector::CObexRfcommConnector(MObexTransportNotify& aObserver, 

										   TBTSockAddr& aAddr)

 :	CObexConnector(aObserver),

	iAddr(aAddr)

	{

	LOG_FUNC

	LOG(_L8("\taAddr:"));

	LOGHEXDESC(aAddr);

	}

void CObexRfcommConnector::ConstructL()

	{

	LOG_FUNC

	LEAVEIFERRORL(iSocketServ.Connect());

	LEAVEIFERRORL(iSocketServ.FindProtocol(_L("RFCOMM"), iProtocolDesc));

	iConnector = new(ELeave) CObexActiveRfcommConnector(*this, iSocketServ, iSocket, iProtocolDesc, iAddr);

	iReceiver = new(ELeave) CObexListenerRfcommConnector(*this, iSocketServ, iSocket, iProtocolDesc, iAddr);

	BaseConstructL();

	}

CObexRfcommConnector::~CObexRfcommConnector()

	{

	LOG_FUNC

	delete iConnector;

	delete iReceiver;

	iSocket.Close();

	iSocketServ.Close();

	}

void CObexRfcommConnector::ConnectL()

	{

	LOG_FUNC

	__ASSERT_DEBUG(iConnector, PANIC(KPanicCat, ERfcommConnectorInternalError));

	iConnector->ConnectL();

	}

void CObexRfcommConnector::CancelConnect()

	{

	LOG_FUNC

	__ASSERT_DEBUG(iConnector, PANIC(KPanicCat, ERfcommConnectorInternalError));

	iConnector->Cancel();

	}

void CObexRfcommConnector::AcceptL()

	{

	LOG_FUNC

	__ASSERT_DEBUG(iReceiver, PANIC(KPanicCat, ERfcommConnectorInternalError));

	iReceiver->AcceptL();

	}

void CObexRfcommConnector::CancelAccept()

	{

	LOG_FUNC

	__ASSERT_DEBUG(iReceiver, PANIC(KPanicCat, ERfcommConnectorInternalError));

	iReceiver->Cancel();

	}

TBool CObexRfcommConnector::BringTransportDown()

	{

	LOG_FUNC

	// There's a nasty contract going on here- at most, only one of these AOs 

	// should be active at any time. They each use this object's iSocket, 

	// opening and closing it, and asserting its SubSessionHandle at various 

	// points. They may be better designed as a single AO state machine.

	__ASSERT_DEBUG(iConnector, PANIC(KPanicCat, ERfcommConnectorInternalError));

	iConnector->Cancel();

	__ASSERT_DEBUG(iReceiver, PANIC(KPanicCat, ERfcommConnectorInternalError));

	iReceiver->Cancel();

	// For cases where the underlying transport has gone we'll

	// do an Immediate Shutdown to prevent Close() from blocking.

	// This should stop dialogs from "freezing". 

	//returns true as this transport proceeds with taking down the transport

	if ( iTransportUp )

		{

		TRequestStatus status;

		iSocket.Shutdown(RSocket::EImmediate, status);

		User::WaitForRequest(status);

		iTransportUp = EFalse;

		}

	iSocket.Close();

	return ETrue;

	}

/** Used to set any link layer specific error condition flags. Bluetooth has 

none, so the function is a stub. */

void CObexRfcommConnector::SignalTransportError()

	{

	LOG_FUNC

	}

/**

Returns the socket instance iSocket

@return RSocket

*/

RSocket& CObexRfcommConnector::GetSocket()

	{

	LOG_LINE

	LOG_FUNC

	return iSocket;

	}

/**

This method is used to field completed connections from both the active 

connector and the listen/acceptor.

*/

void CObexRfcommConnector::ConnectComplete(TInt aError, TObexConnectionInfo& aSockinfo)

	{

	LOG_FUNC

	LOG1(_L8("\taError = %d"), aError);

	if ( aError == KErrNone )

		{

		Observer().TransportUp(aSockinfo);

		iTransportUp = ETrue;

		}

	else

		{

		Observer().Error(aError);

		__ASSERT_DEBUG(!iTransportUp, PANIC(KPanicCat, ERfcommConnectorInternalError));

		}

	}