// btserialclient.cpp
// 
// Copyright (c) 2008 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

// Transient server example - client interface implementation

#include <fshell/btserialclient.h>
#include "btserialclientserver.h"
#include "..\connection\btdebug.h"

_LIT(KSubThreadName, "btconsolethread");
static const TInt KMaxHeapSize = 0x100000; // 1M

TInt RBtSerialSession::StartServer()
//
// Start the server process. Simultaneous launching
// of two such processes should be detected when the second one attempts to
// create the server object, failing with KErrAlreadyExists.
//
	{
	TInt err = iSubThread.Create(KSubThreadName, &ServerThread, KDefaultStackSize, KMinHeapSize, KMaxHeapSize, &iServer);
	
	if (err != KErrNone)
		{
		return err;
		}
	
	TRequestStatus rendezvous;
	iSubThread.Rendezvous(rendezvous);
	
	iSubThread.Resume();
	User::WaitForRequest(rendezvous);
	
	return rendezvous.Int();
	}

//______________________________________________________________________________
//						RBtSerialSession
EXPORT_C TInt RBtSerialSession::Connect()
	{
	TInt err = StartServer();
	if (err == KErrNone)
		{
		TVersion ver;
		err = CreateSession(iServer, ver);
		}
	return err;
	}

EXPORT_C void RBtSerialSession::Close()
	{
	TRACE1("RBtSerialSession::Close closing IPC session");
	RSessionBase::Close();
	// when we close the session (above) the server thread will exit.
	// logon and wait for it
	TRequestStatus stat;
	iSubThread.Logon(stat);
	TRACE1("RBtSerialSession::Close waiting for thread to exit");
	User::WaitForRequest(stat);	
	iSubThread.Close();
	TRACE2("RBtSerialSession::Close done (%d)", stat.Int());
	}
	
EXPORT_C void RBtSerialSession::WaitForConnection(TRequestStatus& aStatus)
	{
	SendReceive(EBtSerialWaitForConnection, aStatus);
	}
	
EXPORT_C void RBtSerialSession::CancelWaitForConnection()
	{
	SendReceive(EBtSerialCancelWaitForConnection);
	}
	
EXPORT_C TInt RBtSerialSession::IsConnected() const
	{
	return SendReceive(EBtSerialIsConnected);
	}
	
EXPORT_C void RBtSerialSession::Write(const TDesC8& aData, TRequestStatus& aStatus)
	{
	SendReceive(EBtSerialWrite, TIpcArgs(&aData), aStatus);
	}
	
EXPORT_C void RBtSerialSession::CancelWrite()
	{
	SendReceive(EBtSerialCancelWrite);
	}
	
EXPORT_C void RBtSerialSession::Read(TDes8& aData, TRequestStatus& aStatus) const
	{
	SendReceive(EBtSerialRead, TIpcArgs(&aData), aStatus);
	}
	
EXPORT_C void RBtSerialSession::CancelRead() const
	{
	SendReceive(EBtSerialCancelRead);
	}

EXPORT_C TInt RBtSerialSession::GetConnectedDeviceName(TDes& aName)
	{
	return SendReceive(EBtSerialGetConnectedDeviceName, TIpcArgs(&aName));
	}
	
EXPORT_C TInt RBtSerialSession::GetConnectedDeviceAddr(TBTDevAddr& aAddr)
	{
	TPckg<TBTDevAddr> pckg(aAddr);
	return SendReceive(EBtSerialGetConnectedDeviceAddr, TIpcArgs(&pckg));
	}