// Copyright (c) 2008-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:

//

/**

 @file

 @internalComponent

*/

#include "mmcameraclientinterface.h"

#include <e32uid.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.

 */

static TInt StartServer()

    {

    const TUidType serverUid(KNullUid, KExecutableImageUid, KECamServerUid3);

    RProcess server;

    TInt err = server.Create(KMMCameraServerExe, KNullDesC, serverUid);

    if (err != KErrNone)

		{

        return err;

		}

    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

    err = (server.ExitType() == EExitPanic) ? KErrGeneral : stat.Int();

    server.Close();

    return err;

    }

/**

 * Connect to the server.

 * 

 * Will attempt to start the server if it has not yet been started or has been shut down.

 */

TInt RMMCameraSession::Connect()

    {

    TInt serverStartRetries = 2;

    for (;;)

        {

        // Attempt to create a session to the server

        TInt err = CreateSession(KMMCameraServerName, TVersion(0, 0, 0), KECamNumAsynchMsg);

        if (err != KErrNotFound && err != KErrServerTerminated)

			{

            return err;

			}

		if (--serverStartRetries == 0)

			{

            return err;

			}

		// Server not found or shut down so (re)start the server

        err = StartServer();

        if (err != KErrNone && err != KErrAlreadyExists)

            {

			return err;

			}

        }

    }

//

// Synchronous interface APIs

//

TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId, TCameraParameterId aParameterId, TDes8& aMessage)

	{

	if (aMessage.Length() > KECamMaxMessage)

    	{

    	return KErrArgument;

    	}

	return SendReceive(aMsgId, TIpcArgs(aParameterId, &aMessage));

	}

TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId, TCameraParameterId aParameterId, TInt aMessage)

	{

	return SendReceive(aMsgId, TIpcArgs(aParameterId, aMessage));

	}

TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId, TDes8& aMessage)

    {

    if (aMessage.Length() > KECamMaxMessage)

    	{

    	return KErrArgument;

    	}

    return SendReceive(aMsgId, TIpcArgs(&aMessage));

    }

TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId, TInt aMessage)

	{

	return SendReceive(aMsgId, TIpcArgs(aMessage));

	}

TInt RMMCameraSession::SendMessage(TECamMsgId aMsgId)

	{

	return SendReceive(aMsgId);

	}

TInt RMMCameraSession::SendRxMessage(TECamMsgId aMsgId, TCameraParameterId aParameterId, TDes8& aMessage) const

	{

	if (aMessage.Length() > KECamMaxMessage)

    	{

    	return KErrArgument;

    	}

	return SendReceive(aMsgId, TIpcArgs(aParameterId, &aMessage));

	}

TInt RMMCameraSession::SendRxMessage(TECamMsgId aMsgId, TCameraParameterId aParameterId, TInt aMessage) const

	{

	return SendReceive(aMsgId, TIpcArgs(aParameterId, aMessage));

	}

TInt RMMCameraSession::SendRxMessage(TECamMsgId aMsgId, TDes8& aMessage) const

	{

	if (aMessage.Length() > KECamMaxMessage)

    	{

    	return KErrArgument;

    	}

    return SendReceive(aMsgId, TIpcArgs(&aMessage));

	}

//

// Asynchronous interface APIs

//

TInt RMMCameraSession::ReceiveMessage(TECamMsgId aMsgId, TDes8& aMessage, TRequestStatus& aStatus)

    {

    if (aMessage.Length() > KECamMaxMessage)

    	{

    	return KErrArgument;

    	}

    SendReceive(aMsgId, TIpcArgs(&aMessage), aStatus);

	return KErrNone;

    }

void RMMCameraSession::ReceiveMessage(TECamMsgId aMsgId, TInt aMessage, TRequestStatus& aStatus)

    {

    SendReceive(aMsgId, TIpcArgs(aMessage), aStatus);

    }