--- a/obex/obexprotocol/obexbttransport/src/ObexActiveRfcommConnector.cpp Tue Sep 28 20:14:08 2010 +0800
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,109 +0,0 @@
-// 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 "ObexActiveRfcommConnector.h"
-#include "connectobserver.h"
-#include "logger.h"
-#include "obexbtfaults.h"
-
-#ifdef __FLOG_ACTIVE
-_LIT8(KLogComponent, "RFCOMM");
-#endif
-
-#ifdef _DEBUG
-_LIT(KPanicCat, "ActiveRfcommConn");
-#endif
-
-CObexActiveRfcommConnector::CObexActiveRfcommConnector(MConnectObserver& aParent,
- RSocketServ& aSocketServ,
- RSocket& aSocket,
- const TProtocolDesc& aProtocolDesc,
- const TBTSockAddr& aAddr)
- : CActive(EPriorityStandard),
- iParent(aParent),
- iSocketServ(aSocketServ),
- iSocket(aSocket),
- iProtocolDesc(aProtocolDesc),
- iAddr(aAddr)
- {
- LOG_FUNC
- LOG(_L8("\taAddr:"));
- LOGHEXDESC(aAddr);
-
- CActiveScheduler::Add(this);
- }
-
-CObexActiveRfcommConnector::~CObexActiveRfcommConnector()
- {
- LOG_FUNC
-
- Cancel();
- }
-
-void CObexActiveRfcommConnector::RunL()
- {
- LOG_LINE
- LOG_FUNC
- LOG1(_L8("\tiStatus = %d"), iStatus.Int());
-
- // This exists purely as a sanity-check on our internal state.
- __ASSERT_DEBUG(iSocket.SubSessionHandle(), PANIC(KPanicCat, EActiveRfcommConnInternalError));
-
- 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();
- }
-
- iParent.ConnectComplete(iStatus.Int(), sockinfo);
- }
-
-void CObexActiveRfcommConnector::DoCancel()
- {
- LOG_FUNC
-
- // This exists purely as a sanity-check on our internal state.
- __ASSERT_DEBUG(iSocket.SubSessionHandle(), PANIC(KPanicCat, EActiveRfcommConnInternalError));
- iSocket.CancelConnect();
- iSocket.Close();
- }
-
-void CObexActiveRfcommConnector::ConnectL()
- {
- LOG_FUNC
-
- __ASSERT_DEBUG(!iSocket.SubSessionHandle(), PANIC(KPanicCat, EActiveRfcommConnInternalError));
- LEAVEIFERRORL(iSocket.Open(iSocketServ,
- iProtocolDesc.iAddrFamily,
- iProtocolDesc.iSockType,
- iProtocolDesc.iProtocol));
-
- // iAddr is logically const, and needs constness casting away for this
- // API.
- iSocket.Connect(const_cast<TBTSockAddr&>(iAddr), iStatus);
- SetActive();
- }