--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/obex/obexprotocol/obexbttransport/src/ObexListenerRfcommConnector.cpp	Tue Oct 19 11:00:12 2010 +0800
@@ -0,0 +1,138 @@
+// 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/obexconnector.h>
+#include "ObexListenerRfcommConnector.h"
+#include "connectobserver.h"
+#include "logger.h"
+#include "obexbtfaults.h"
+
+#ifdef __FLOG_ACTIVE
+_LIT8(KLogComponent, "RFCOMM");
+#endif
+
+#ifdef _DEBUG
+_LIT(KPanicCat, "ListRfcomm");
+#endif
+
+CObexListenerRfcommConnector::CObexListenerRfcommConnector(MConnectObserver& aParent,
+														   RSocketServ& aSocketServ,
+														   RSocket& aSocket,
+														   const TProtocolDesc& aProtocolDesc,
+														   TBTSockAddr& aAddr)
+ :	CActive(EPriorityStandard),
+	iParent(aParent),
+	iSocketServ(aSocketServ),
+	iSocket(aSocket),
+	iProtocolDesc(aProtocolDesc),
+	iAddr(aAddr)
+	{
+	LOG_FUNC
+	LOG(_L8("\taAddr:"));
+	LOGHEXDESC(aAddr);
+
+	CActiveScheduler::Add(this);
+	}
+
+CObexListenerRfcommConnector::~CObexListenerRfcommConnector()
+	{
+	LOG_FUNC
+
+	Cancel();
+
+	// iListeningSocket will only have been open if there was a request 
+	// outstanding, in which case it will have been closed in DoCancel, so no 
+	// need to do it here.
+	__ASSERT_DEBUG(!iListeningSocket.SubSessionHandle(), PANIC(KPanicCat, EListRfcommInternalError));
+	}
+
+void CObexListenerRfcommConnector::RunL()
+	{
+	LOG_LINE
+	LOG_FUNC
+	LOG1(_L8("\tiStatus = %d"), iStatus.Int());
+
+	// These exists purely as sanity-checks on our internal state.
+	__ASSERT_DEBUG(iSocket.SubSessionHandle(), PANIC(KPanicCat, EListRfcommInternalError));
+	__ASSERT_DEBUG(iListeningSocket.SubSessionHandle(), PANIC(KPanicCat, EListRfcommInternalError));
+
+	TObexConnectionInfo sockinfo;
+	if ( iStatus == KErrNone )
+		{
+		sockinfo.iSocketType = TObexConnectionInfo::ESocketStream;
+
+		TPckgBuf<TUint> optBuf(65535); //If all else fails we should get a max 64K buffer
+		iSocket.GetOpt(KRFCOMMMaximumMTU, KSolBtRFCOMM, optBuf);
+
+		// Set socket buffer sizes based on negotiated MTU
+		iSocket.SetOpt(KSOSendBuf, KSOLSocket, optBuf);
+		iSocket.SetOpt(KSORecvBuf, KSOLSocket, optBuf);		
+		}
+	else
+		{
+		iSocket.Close();
+		}
+
+	iListeningSocket.Close();
+	iParent.ConnectComplete(iStatus.Int(), sockinfo);
+	}
+
+void CObexListenerRfcommConnector::DoCancel()
+	{
+	LOG_FUNC
+
+	// These exist purely as sanity-checks on our internal state.
+	__ASSERT_DEBUG(iSocket.SubSessionHandle(), PANIC(KPanicCat, EListRfcommInternalError));
+	__ASSERT_DEBUG(iListeningSocket.SubSessionHandle(), PANIC(KPanicCat, EListRfcommInternalError));
+	iListeningSocket.CancelAccept();
+	iListeningSocket.Close();
+	iSocket.Close();
+	}
+
+void CObexListenerRfcommConnector::AcceptL()
+	{
+	LOG_FUNC
+
+	__ASSERT_DEBUG(!iSocket.SubSessionHandle(), PANIC(KPanicCat, EListRfcommInternalError));
+
+	__ASSERT_DEBUG(!iListeningSocket.SubSessionHandle(), PANIC(KPanicCat, EListRfcommInternalError));
+	LEAVEIFERRORL(iListeningSocket.Open(iSocketServ,
+										iProtocolDesc.iAddrFamily,
+										iProtocolDesc.iSockType,
+										iProtocolDesc.iProtocol));
+	CleanupClosePushL(iListeningSocket);
+
+	LEAVEIFERRORL(iListeningSocket.Bind(iAddr));
+	if ( iAddr.Port() == KRfcommPassiveAutoBind )
+		{
+		const TUint port = iListeningSocket.LocalPort();
+		LOG1(_L8("\tKRfcommPassiveAutoBind was specified- really using port %d"), port);
+		// This updates the concrete transport controller's iTransportInfo member (by reference).
+		iAddr.SetPort(port);
+		}
+	// We try to set the Object Transfer bit in our service class.  If this fails we
+	// ignore it, as it's better to carry on without it than to fail to start listening.
+	(void)iListeningSocket.SetOpt(KBTRegisterCodService, KSolBtRFCOMM, EMajorServiceObjectTransfer);
+	LEAVEIFERRORL(iListeningSocket.Listen(4)); // queue size of 4
+
+	// NB Client does SDP & Sec registration.
+
+	LEAVEIFERRORL(iSocket.Open(iSocketServ));
+
+	CleanupStack::Pop(&iListeningSocket);
+
+	iListeningSocket.Accept(iSocket, iStatus);
+	SetActive();
+	}