--- a/hti/HtiCommPlugins/HtiBtCommPlugin/HtiBtCommServer/src/HtiBtCommInterface.cpp Thu Jul 15 20:25:38 2010 +0300
+++ /dev/null Thu Jan 01 00:00:00 1970 +0000
@@ -1,188 +0,0 @@
-/*
-* 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: Implementation of RHtiBtCommInterface class.
-* Symbian side component uses this interface to receive and
-* send HTI data to HtiBtCommServer.
-* HtiBtCommServer acts as proxy to send and receive data
-* to and from PC.
-*
-*/
-
-
-// INCLUDE FILES
-#include "HtiBtClientServerCommon.h"
-#include "HtiBtCommInterface.h"
-
-#include <e32uid.h>
-#include <HtiLogging.h>
-
-// CONSTANTS
-const TUint KBtCommServerDefaultMessageSlots = 4; // Read, write, readCancel, writeCancel
-
-// Constants
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C RHtiBtCommInterface::RHtiBtCommInterface()
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::RHtiBtCommInterface()" );
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C TInt RHtiBtCommInterface::Connect( TDesC8& aDeviceNameOrAddress,
- TInt aPort )
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::Connect()" );
-
- TInt error = StartThread(); // see HtiBtClientServerCommon.h
- if (error == KErrNone)
- {
- error = CreateSession( KBtCommServerName,
- Version(),
- KBtCommServerDefaultMessageSlots );
- }
- if ( error )
- return error;
-
- return ConnectBt( aDeviceNameOrAddress, aPort );
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C void RHtiBtCommInterface::Close()
- {
- HTI_LOG_FUNC_IN( "RHtiBtCommInterface::Close" );
-
- // Use thread finder to find the server thread
- TFullName threadName;
- TFullName matchPattern;
- matchPattern.Append( _L( "*" ) );
- matchPattern.Append( KBtCommServerName );
- matchPattern.Append( _L( "*" ) );
-
- TFindThread threadFinder;
- threadFinder.Find( matchPattern );
- TInt err = threadFinder.Next( threadName );
- if ( err )
- {
- HTI_LOG_FORMAT( "RHtiBtCommInterface::Close: Failed to find server thread: %d", err );
- User::Panic( _L( "BtIf Close, server thread not found" ), err );
- }
-
- HTI_LOG_TEXT( "RHtiBtCommInterface::Close: Found server thread:" );
- HTI_LOG_DES( threadName );
-
- RThread thread;
- err = thread.Open( threadName );
- if ( err )
- {
- HTI_LOG_FORMAT( "RHtiBtCommInterface::Close: Failed to open server thread: %d", err );
- User::Panic( _L( "BtIf Close, error opening server thread" ), err );
- }
- else
- {
- // initiate server shutdown
- RSessionBase::Close();
-
- // For clean server stop, wait for its death
- HTI_LOG_TEXT( "RHtiBtCommInterface::Close: Waiting for server thread to die..." );
- TRequestStatus status;
- thread.Logon( status );
- User::WaitForRequest( status );
- HTI_LOG_TEXT( "RHtiBtCommInterface::Close: Server thread dead." );
- }
-
- thread.Close();
- HTI_LOG_FUNC_OUT( "RHtiBtCommInterface::Close" );
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C TVersion RHtiBtCommInterface::Version(void) const
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::Connect()" );
- return ( TVersion( KBtCommServerMajorVersionNumber,
- KBtCommServerMinorVersionNumber,
- KBtCommServerBuildVersionNumber ) );
-
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C TInt RHtiBtCommInterface::GetSendBufferSize() const
- {
- return KClientSendBufferMaxSize;
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C TInt RHtiBtCommInterface::GetReceiveBufferSize() const
- {
- return KClientReceiveBufferMaxSize;
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C void RHtiBtCommInterface::Receive(TDes8& aData,
- TRequestStatus& aStatus)
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::Receive()" );
- SendReceive( EBtCommServerRecv, TIpcArgs( &aData ), aStatus );
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C void RHtiBtCommInterface::Send(const TDesC8& aData,
- TRequestStatus& aStatus)
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::Send()" );
- SendReceive( EBtCommServerSend, TIpcArgs( &aData ), aStatus );
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C void RHtiBtCommInterface::CancelReceive()
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::CancelReceive()" );
- SendReceive( ECancelBtCommServerRecv, TIpcArgs( NULL ) );
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C void RHtiBtCommInterface::CancelSend()
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::CancelSend()" );
- SendReceive( ECancelBtCommServerSend, TIpcArgs( NULL ) );
- }
-
-/*---------------------------------------------------------------------------*/
-EXPORT_C TInt RHtiBtCommInterface::GetPortNumber() const
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::GetPortNumber()" );
- TPckgBuf<TInt> pckg;
- TInt ret = SendReceive( EGetServicePortNumber, TIpcArgs( &pckg ) );
- if ( ret == KErrNone )
- {
- ret = pckg();
- }
- return ret;
- }
-
-/*---------------------------------------------------------------------------*/
-TInt RHtiBtCommInterface::ConnectBt( TDesC8& aDeviceNameOrAddress, TInt aPort )
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::ConnectBt()" );
- return SendReceive( EBtCommServerConnect,
- TIpcArgs( &aDeviceNameOrAddress, aPort ) );
- }
-
-/*---------------------------------------------------------------------------*/
-GLDEF_C TInt E32Main()
- {
- HTI_LOG_TEXT( "RHtiBtCommInterface::E32Main()" );
- return KErrNone;
- }
-
-// End of the file