// 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));+
−
		}+
−
	}+
−