// Copyright (c) 2010 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 "mediaclientpolicyserversession.h"
#include <e32std.h>
#include "mediaclientvideotrace.h"

// Policy Server EXE name
_LIT( KIvePolicyServerImg, "ivepolicyserver" );

// Policy Server thread name
_LIT( KIvePolicyServerName, "!ivepolicyserver0x10204C27" ); 

// Number of asynchronous message slots
const TInt KIveAsyncMessageSlots = 1;

static TInt StartServer()
    {
    DEBUG_PRINTF("medialclientsession StartServer +++");
    
    RProcess server;
    TInt error = server.Create(KIvePolicyServerImg, KNullDesC);
    if (error != KErrNone)
        {
        DEBUG_PRINTF2("medialclientsession StartServer server creation failed %d", error);
        return error;
        }
        
    TRequestStatus status;

    server.Rendezvous(status);
    if (status != KRequestPending)
        {
        server.Kill( 0 );
        // abort startup
        }
    else
        {
        server.Resume();
        // logon OK - start the server
        }

    User::WaitForRequest(status);
    // wait for start or death
    error = (server.ExitType() == EExitPanic) ? KErrGeneral : status.Int();
    server.Close();
   
    DEBUG_PRINTF(" medialclientsession StartServer ---");
    return error;
    }

RMediaClientPolicyServerSession::RMediaClientPolicyServerSession():
    RSessionBase()
    {
    DEBUG_PRINTF(" RMediaClientPolicyServerSession::RMediaClientPolicyServerSession +++");
    DEBUG_PRINTF(" RMediaClientPolicyServerSession::RMediaClientPolicyServerSession ---");
    }

TInt RMediaClientPolicyServerSession::Connect()
    {
    DEBUG_PRINTF(" RMediaClientPolicyServerSession::Connect +++");
    
    TInt error = KErrNone;
    for (TInt i = 0; i < 2; i++)
        {
        // Try to create session.
        error = CreateSession(KIvePolicyServerName, TVersion( 0, 0, 0 ), KIveAsyncMessageSlots);

        if (error != KErrNotFound && error != KErrServerTerminated) 
            {
            DEBUG_PRINTF("RMediaClientPolicyServerSession::Connect Server found and session created."); 
            DEBUG_PRINTF2("RMediaClientPolicyServerSession::Connect --- returns %d", error);
            return error;
            }
  
        // If session failed, try to start server once.
        if (i == 0)
            {            
            DEBUG_PRINTF("RMediaClientPolicyServerSession::Connect StartServer");
            // Start server
            error = StartServer();                     
            if (error != KErrNone && error != KErrAlreadyExists)
                {
                DEBUG_PRINTF("RMediaClientPolicyServerSession::Connect Server startup failed.");
                DEBUG_PRINTF2("RMediaClientPolicyServerSession::Connect --- returns %d", error);
                return error;
                }
            }
        else
            {
            DEBUG_PRINTF2("RMediaClientPolicyServerSession::Connect Session creation failed error %d", error);
            }
        }
    
    DEBUG_PRINTF2("RMediaClientPolicyServerSession::Connect --- returns %d", error);
    return error;
    }

TInt RMediaClientPolicyServerSession::SendMessage( TInt aFunction, const TIpcArgs &aArgs ) const 
    {
    DEBUG_PRINTF("RMediaClientPolicyServerSession::SendMessage +++");

    TInt error = SendReceive( aFunction, aArgs );    
    
    DEBUG_PRINTF2("RMediaClientPolicyServerSession::SendMessage --- returns %d", error);
    return error;
    }