/*
* Copyright (c) 2006 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 "t_oomclient.h"
#include "../inc/clientserver.h"

const TInt KServerDefaultMessageSlots = 1; //Number of message slots available per session.
const TInt KServerRetryCount = 2;

static TInt 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.
//
	{
	const TUidType serverUid(KNullUid,KNullUid,KServerUid3);
	RProcess server;
	TInt r=server.Create(KAllocServerImg,KNullDesC,serverUid);
	if (r!=KErrNone)
		return r;
	TRequestStatus stat;
	server.Rendezvous(stat);
	if (stat!=KRequestPending)
		server.Kill(0);		// abort startup
	else
		server.Resume();	// logon OK - start the server
	User::WaitForRequest(stat);		// wait for start or death
	// we can't use the 'exit reason' if the server panicked as this
	// is the panic 'reason' and may be '0' which cannot be distinguished
	// from KErrNone
	r=(server.ExitType()==EExitPanic) ? KErrGeneral : stat.Int();
	server.Close();
	return r;
	}

EXPORT_C TInt ROOMAllocSession::Connect()
//
// Connect to the server, attempting to start it if necessary
//
	{
	TInt retry=KServerRetryCount;
	for (;;)
		{
		TInt r=CreateSession(KAllocServerName,TVersion(0,0,0),KServerDefaultMessageSlots);
		if (r!=KErrNotFound && r!=KErrServerTerminated)
			return r;
		if (--retry==0)
			return r;
		r=StartServer();
		if (r!=KErrNone && r!=KErrAlreadyExists)
			return r;
		}
	}

EXPORT_C TInt ROOMAllocSession::Reset()
	{
	return SendReceive(EAllocServReset);
	}

EXPORT_C TInt ROOMAllocSession::StartAllocating()
	{
	return SendReceive(EAllocServStart);
	}

EXPORT_C TInt ROOMAllocSession::StopAllocating()
	{
	return SendReceive(EAllocServStop);
	}

EXPORT_C TInt ROOMAllocSession::MemoryLow(TUid aPlugin)
	{
	return SendReceive(EAllocServMemoryLow, TIpcArgs(aPlugin.iUid));
	}

EXPORT_C TInt ROOMAllocSession::MemoryGood(TUid aPlugin)
	{
	return SendReceive(EAllocServMemoryGood, TIpcArgs(aPlugin.iUid));
	}

EXPORT_C TInt ROOMAllocSession::Configure(TUid aPlugin, TUint aAllocRate, TUint aAllocInitial, TUint aAllocLimit)
	{
	return SendReceive(EAllocServConfig,TIpcArgs(aPlugin.iUid, aAllocRate, aAllocInitial, aAllocLimit));
	}