// Copyright (c) 2007-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 "tdirectgdieglcontent_client.h"
#include "tdirectgdieglcontent_clientserver.h"
#include <graphics/sgimage.h>

/**
Starts 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.
@return KErrNone if successful, error code if server startup failed.
*/
TInt REglContentSession::StartServer()
	{
	const TUidType serverUid(KNullUid, KNullUid, KServerUid3);
	TInt r = iServer.Create(KEglContentServerName, KNullDesC, serverUid);
	if(r != KErrNone)
		return r;
	TRequestStatus stat;
	iServer.Rendezvous(stat);
	if(stat != KRequestPending)
		iServer.Kill(0);     // abort startup
	else
		iServer.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 = (iServer.ExitType() == EExitPanic) ? KErrGeneral : stat.Int();
	return r;
	}

/**
Connect to the server, attempting to start it if necessary
@return KErrNone if successful, error code if connection to server failed.
*/
TInt REglContentSession::Connect()
	{
	TInt retry = 2;
	for(;;)
		{
		TInt r = CreateSession(KEglContentServerName, TVersion(0, 0, 0), 1);
		if((r != KErrNotFound) && (r != KErrServerTerminated))
			return r;
		if((--retry) == 0)
			return r;
		r = StartServer();
		if((r != KErrNone) && (r != KErrAlreadyExists))
			return r;
		}
	}

/**
Force server termination and close server session.
*/
void REglContentSession::Close()
	{
	SendReceive(ETerminateServer, TIpcArgs());

	// wait until process terminate
	TRequestStatus status;
	iServer.Logon(status);
	User::WaitForRequest(status);

	iServer.Close();
	RSessionBase::Close();
	}

/**
Send a request to the server for an image in sync mode. Function returns when the image is available.
@param aImageId reference to drawable id for image id storing.
@return KErrNone if successful, error code if request sending failed.
*/
TInt REglContentSession::GetSyncImage(TSgDrawableId& aImageId)
	{
	TPckg<TSgDrawableId> idPckg(aImageId);
	return SendReceive(EGetSyncImage, TIpcArgs(&idPckg));
	}

/**
Send a request to the server for an image in async mode. Function returns when the image is available.
Command to render the next images is issued.
@param aImageId reference to drawable id for image id storing.
@param aFrameNumber reference to variable to store frame number
@return KErrNone if successful, error code if request sending failed.
*/
TInt REglContentSession::GetAsyncImage(TSgDrawableId& aImageId, TInt& aFrameNumber)
	{
	TPckg<TSgDrawableId> idPckg(aImageId);
	TPckg<TInt> fnumPckg(aFrameNumber);
	return SendReceive(EGetAsyncImage, TIpcArgs(&idPckg, &fnumPckg));
	}

/**
Send a request to the server for an image in async debug mode. Function returns when the image is available.
Command to render the next image (only one) is issued.
@param aImageId reference to drawable id for image id storing.
@param aFrameNumber reference to variable to store frame number
@return KErrNone if successful, error code if request sending failed.
*/
TInt REglContentSession::GetAsyncImageDebug(TSgDrawableId& aImageId, TInt& aFrameNumber)
	{
	TPckg<TSgDrawableId> idPckg(aImageId);
	TPckg<TInt> fnumPckg(aFrameNumber);
	return SendReceive(EGetAsyncImageDebug, TIpcArgs(&idPckg, &fnumPckg));
	}