// 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;

     }