diff -r 866b4af7ffbe -r 4dc88a4ac6f4 obex/obexprotocol/obexbttransport/src/ObexActiveRfcommConnector.cpp --- 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 -#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 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(iAddr), iStatus); - SetActive(); - }