--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/hti/HtiCommPlugins/HtiBtCommPlugin/BtEngine/src/btservicesearcher.cpp Wed Oct 13 16:17:58 2010 +0300
@@ -0,0 +1,382 @@
+/*
+* Copyright (c) 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: Bluetooth service searcher.
+*
+*/
+
+
+// INCLUDE FILES
+#include "btservicesearcher.h"
+#include "btservicesearcher.pan"
+
+#include "HtiBtEngineLogging.h"
+
+// ============================ MEMBER FUNCTIONS ==============================
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::CBTServiceSearcher()
+// Constructor.
+// ----------------------------------------------------------------------------
+//
+CBTServiceSearcher::CBTServiceSearcher()
+: iIsDeviceSelectorConnected( EFalse )
+ {
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::~CBTServiceSearcher()
+// Destructor.
+// ----------------------------------------------------------------------------
+//
+CBTServiceSearcher::~CBTServiceSearcher()
+ {
+ if ( iIsDeviceSelectorConnected )
+ {
+ iDeviceSelector.CancelNotifier( KDeviceSelectionNotifierUid );
+ iDeviceSelector.Close();
+ }
+ delete iSdpSearchPattern;
+ iSdpSearchPattern = NULL;
+
+ delete iAgent;
+ iAgent = NULL;
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::SelectDeviceByDiscoveryL()
+// Select a device.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::SelectDeviceByDiscoveryL(
+ TRequestStatus& aObserverRequestStatus )
+ {
+ if ( ! iIsDeviceSelectorConnected )
+ {
+ User::LeaveIfError( iDeviceSelector.Connect() );
+ iIsDeviceSelectorConnected = ETrue;
+ }
+
+ iSelectionFilter().SetUUID( ServiceClass() );
+
+ iDeviceSelector.StartNotifierAndGetResponse(
+ aObserverRequestStatus,
+ KDeviceSelectionNotifierUid,
+ iSelectionFilter,
+ iResponse );
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::SelectDeviceByNameL()
+// Select a device by BT device name.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::SelectDeviceByNameL( const TDesC& aDeviceName,
+ TRequestStatus& aObserverRequestStatus )
+ {
+ LOG_D( "CBTServiceSearcher::SelectDeviceByNameL" );
+
+ RSocketServ socketServ;
+ User::LeaveIfError( socketServ.Connect() );
+ CleanupClosePushL( socketServ );
+
+ TProtocolDesc pInfo;
+ _LIT( KL2Cap, "BTLinkManager" );
+ User::LeaveIfError(
+ socketServ.FindProtocol( TProtocolName( KL2Cap ), pInfo ) );
+
+ LOG_D( "CBTServiceSearcher: Found protocol" );
+
+ RHostResolver hr;
+ User::LeaveIfError( hr.Open( socketServ,
+ pInfo.iAddrFamily, pInfo.iProtocol ) );
+ CleanupClosePushL( hr );
+
+ LOG_D( "CBTServiceSearcher: HostResolver open" );
+
+ TInquirySockAddr addr;
+ TNameEntry entry;
+ addr.SetIAC( KGIAC );
+ addr.SetAction( KHostResName | KHostResInquiry );
+
+ User::LeaveIfError( hr.GetByAddress( addr, entry ) );
+ LOG_D( "CBTServiceSearcher: GetByAddress ok" );
+ TBool isFound = EFalse;
+ TInt err = KErrNone;
+ while ( !isFound && !err )
+ {
+ if ( !aDeviceName.CompareF( entry().iName ) )
+ {
+ LOG_D( "CBTServiceSearcher: Name match" );
+ isFound = ETrue;
+ }
+ else
+ {
+ LOG_D( "CBTServiceSearcher: Not match - getting next" );
+ err = hr.Next( entry );
+ }
+ }
+ CleanupStack::PopAndDestroy( 2 ); // hr, socketServ
+
+ iStatusObserver = &aObserverRequestStatus;
+
+ if ( isFound )
+ {
+ TInquirySockAddr& sa = TInquirySockAddr::Cast( entry().iAddr );
+ iResponse().SetDeviceAddress( sa.BTAddr() );
+ iResponse().SetDeviceName( entry().iName );
+ TBTDeviceClass deviceClass( sa.MajorServiceClass(),
+ sa.MajorClassOfDevice(),
+ sa.MinorClassOfDevice() );
+ iResponse().SetDeviceClass( deviceClass );
+ User::RequestComplete( iStatusObserver, KErrNone );
+ }
+
+ else
+ {
+ LOG_E( "CBTServiceSearcher: Device not found! Can't connect!" );
+ User::RequestComplete( iStatusObserver, err );
+ }
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::FindServiceL()
+// Find a service on the specified device.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::FindServiceL( const TBTDevAddr& aDeviceAddress,
+ TRequestStatus& aObserverRequestStatus )
+ {
+ iResponse().SetDeviceAddress( aDeviceAddress );
+ if ( !iResponse().IsValidBDAddr() )
+ {
+ User::Leave( KErrArgument );
+ }
+ iHasFoundService = EFalse;
+
+ // delete any existing agent and search pattern
+ delete iSdpSearchPattern;
+ iSdpSearchPattern = NULL;
+
+ delete iAgent;
+ iAgent = NULL;
+
+ iAgent = CSdpAgent::NewL(*this, BTDevAddr());
+
+ iSdpSearchPattern = CSdpSearchPattern::NewL();
+
+ iSdpSearchPattern->AddL( ServiceClass() );
+ // return code is the position in the list that the UUID is inserted at
+ // and is intentionally ignored
+
+ iAgent->SetRecordFilterL( *iSdpSearchPattern );
+
+ iStatusObserver = &aObserverRequestStatus;
+
+ iAgent->NextRecordRequestL();
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::NextRecordRequestComplete()
+// Process the result of the next record request.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::NextRecordRequestComplete(
+ TInt aError,
+ TSdpServRecordHandle aHandle,
+ TInt aTotalRecordsCount)
+ {
+ TRAPD( error,
+ NextRecordRequestCompleteL( aError, aHandle, aTotalRecordsCount );
+ );
+
+ if ( error != KErrNone )
+ {
+ Panic( EBTServiceSearcherNextRecordRequestComplete );
+ }
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::NextRecordRequestCompleteL()
+// Process the result of the next record request.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::NextRecordRequestCompleteL(
+ TInt aError,
+ TSdpServRecordHandle aHandle,
+ TInt aTotalRecordsCount )
+ {
+ if ( aError == KErrEof )
+ {
+ Finished();
+ return;
+ }
+
+ if ( aError != KErrNone )
+ {
+ LOGFMT_E("CBTServiceSearcher: NextRecordRequestCompleteL: %d", aError );
+ Finished( aError );
+ return;
+ }
+
+ if ( aTotalRecordsCount == 0 )
+ {
+ LOG_I("CBTServiceSearcher: NextRecordRequestCompleteL: No records found");
+ Finished( KErrNotFound );
+ return;
+ }
+
+ // Request its attributes
+ iAgent->AttributeRequestL( aHandle, KSdpAttrIdProtocolDescriptorList );
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::AttributeRequestResult()
+// Process the next attribute requested.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::AttributeRequestResult(
+ TSdpServRecordHandle aHandle,
+ TSdpAttributeID aAttrID,
+ CSdpAttrValue* aAttrValue )
+ {
+ TRAPD( error,
+ AttributeRequestResultL( aHandle, aAttrID, aAttrValue );
+ );
+ if ( error != KErrNone )
+ {
+ Panic( EBTServiceSearcherAttributeRequestResult );
+ }
+
+ // Delete obsolete local atribute pointer.
+ delete aAttrValue;
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::AttributeRequestResultL()
+// Process the next attribute requested.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::AttributeRequestResultL(
+ TSdpServRecordHandle /*aHandle*/,
+ TSdpAttributeID aAttrID,
+ CSdpAttrValue* aAttrValue )
+ {
+ __ASSERT_ALWAYS( aAttrID == KSdpAttrIdProtocolDescriptorList,
+ User::Leave( KErrNotFound ) );
+
+ TSdpAttributeParser parser( ProtocolList(), *this );
+
+ // Validate the attribute value, and extract the RFCOMM channel
+ aAttrValue->AcceptVisitorL( parser );
+
+ if ( parser.HasFinished() )
+ {
+ // Found a suitable record so change state
+ iHasFoundService = ETrue;
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CBTServiceSearcher::AttributeRequestComplete()
+// Process the attribute request completion.
+// -----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::AttributeRequestComplete( TSdpServRecordHandle aHandle,
+ TInt aError )
+ {
+ TRAPD( error,
+ AttributeRequestCompleteL( aHandle, aError );
+ );
+ if ( error != KErrNone )
+ {
+ Panic( EBTServiceSearcherAttributeRequestComplete );
+ }
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::AttributeRequestCompleteL()
+// Process the attribute request completion.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::AttributeRequestCompleteL( TSdpServRecordHandle
+ /*aHandle*/,
+ TInt aError )
+ {
+ if ( aError != KErrNone )
+ {
+ LOGFMT_W("CBTServiceSearcher::AttributeRequestCompleteL: %d", aError);
+ }
+ else
+ {
+ // done with attributes of this service record, request next
+ iAgent->NextRecordRequestL();
+ }
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::Finished()
+// The search has finished and notify the observer
+// that the process is complete.
+// ----------------------------------------------------------------------------
+//
+void CBTServiceSearcher::Finished( TInt aError /* default = KErrNone */ )
+ {
+ if ( aError == KErrNone && !HasFoundService() )
+ {
+ aError = KErrNotFound;
+ }
+ User::RequestComplete( iStatusObserver, aError );
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::HasFinishedSearching()
+// Is the instance still wanting to search.
+// ----------------------------------------------------------------------------
+//
+TBool CBTServiceSearcher::HasFinishedSearching() const
+ {
+ return EFalse;
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::BTDevAddr()
+// Returns the bluetooth device address.
+// ----------------------------------------------------------------------------
+//
+const TBTDevAddr& CBTServiceSearcher::BTDevAddr()
+ {
+ return iResponse().BDAddr();
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::ResponseParams()
+// Returns information about the device selected by the user.
+// ----------------------------------------------------------------------------
+//
+const TBTDeviceResponseParams& CBTServiceSearcher::ResponseParams()
+ {
+ return iResponse();
+ }
+
+// ----------------------------------------------------------------------------
+// CBTServiceSearcher::HasFoundService()
+// True if a service has been found.
+// ----------------------------------------------------------------------------
+//
+TBool CBTServiceSearcher::HasFoundService() const
+ {
+ return iHasFoundService;
+ }
+
+// End of File