// 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 <f32file.h>
#include <e32math.h>
#include <s32mem.h>

#include "MmfBtAudioServerProxy.h"
#include "MmfBtAudioServerStart.h"
#include "../../../inc/common/mmfBtBase.hrh"
#include "MmfBtAudioClientServer.h"

#define KMaxServerNameLength 256

static const TUid KUidAudioServer = {KUidMmfBtAudioServerDllUnicodeDefine};


EXPORT_C TInt RMMFAudioServerProxy::Open()
	{

	const TUidType serverUid(KNullUid,KNullUid,KUidAudioServer);
		
	// Assume the server is already running and attempt to create a session
	// 4 message slots
	TInt err = CreateSession(KAudioServerName, TVersion(KMMFAudioServerVersion,
														KMMFAudioServerMinorVersionNumber,
														KMMFAudioServerBuildVersionNumber));
	if(err == KErrNotFound)
		{
		// Server not running
		// Construct the server binary name
		TBuf<KMaxServerNameLength> serverFile;
		RProcess server;

		_LIT(KEmpty,"");

		err = server.Create(KAudioServerFileName, KEmpty, serverUid);
		if(err != KErrNone)
			return err;
		// Synchronise with the server
		TRequestStatus reqStatus;
		server.Rendezvous(reqStatus);
		
		if (reqStatus!=KRequestPending)
			{
			server.Kill(0);
			}
		else
			{
			// Start the test harness
			server.Resume();
			// Server will call the reciprocal static synchronise call
			}
		User::WaitForRequest(reqStatus); // wait for rendezvous or death
		server.Close();
		if(reqStatus.Int() != KErrNone)
			return reqStatus.Int();
		
		// Create the root server session
		err = CreateSession(KAudioServerName, TVersion(KMMFAudioServerVersion,
														KMMFAudioServerMinorVersionNumber,
														KMMFAudioServerBuildVersionNumber));
		}
	return err;		
		
	}

EXPORT_C TInt RMMFAudioServerProxy::SetDevSoundInfo()
	{
	return SendReceive(EMMFAudioLaunchRequests);
	}

EXPORT_C HBufC* RMMFAudioServerProxy::GetDevSoundServerNameL()
	{
	TInt len = GetDevSoundServerNameLengthL();
	len++;
	HBufC8* devSoundServerName = HBufC8::NewLC(len);
	TPtr8 devSoundServerNamePtr = devSoundServerName->Des();
	User::LeaveIfError(SendReceiveResult(EMMFDevSoundServerName,
					                     KNullDesC8,
					                     KNullDesC8,
					                     devSoundServerNamePtr));

	RDesReadStream stream;
	stream.Open(*devSoundServerName);
	CleanupClosePushL(stream);

	HBufC* devSoundServerNameFlat = HBufC::NewL(stream, KMaxTInt);
	
	CleanupStack::PopAndDestroy();//stream
	CleanupStack::PopAndDestroy(devSoundServerName);

	return devSoundServerNameFlat;
	}


TInt RMMFAudioServerProxy::GetDevSoundServerNameLengthL()
	{
	TPckgBuf<TInt> descriptorSizePckg;
	User::LeaveIfError(SendReceiveResult(EMMFDevSoundServerNameLength,
					                     KNullDesC8,
					                     KNullDesC8,
					                     descriptorSizePckg));

	return descriptorSizePckg();
	}