/*

 * Copyright (c) 2005-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:   DRM PlayUtility Session

 *

 */

 #include "mmfdrmSession.h"

 #include "DRMPlayClientServer.h"

 #ifdef _DEBUG

 #define DEP_PRN0(str)   RDebug::Print(str)

 #define DEP_PRN1(str, v1)   RDebug::Print(str, v1)

 #define DEP_PRN2(str, v1, v2)   RDebug::Print(str, v1, v2)

 #else

 #define DEP_PRN0(str)

 #define DEP_PRN1(str, v1)

 #define DEP_PRN2(str, v1, v2)

 #endif // _DEBUG

 // Standard server startup code

 //

 static TInt StartServer()

     {

     DEP_PRN0(_L("DRM Client: Starting server..."));

     // EPOC is easy, we just create a new server process. Simultaneous

     // launching of two such processes should be detected when the second one

     // attempts to create the server object, failing with KErrAlreadyExists.

     RProcess server;

     //TInt r=server.Create(KHelloWorldServerImg,KNullDesC,serverUid);

     TInt r=server.Create(KDRMPlayServerImg,KNullDesC);

     if (r!=KErrNone)

         {

         DEP_PRN1(_L(" DRM Client: server start failed %d"),r);

         return r;

         }

     TRequestStatus stat;

     server.Rendezvous(stat);

     if (stat!=KRequestPending)

         server.Kill(0);     // abort startup

     else

         server.Resume();    // logon OK - start the server

     DEP_PRN0(_L("DRM Client: Started"));

     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;

     }

 RDrmSession::RDrmSession()

     {

     }

 RDrmSession::~RDrmSession()

     {

     if ( Handle() )

         {

         Disconnect();

         }

     }

 TInt RDrmSession::Connect()

     {

     // Try 2 times

     TInt retry(2);

     for (;;)

         {

         TInt r = CreateSession( KDRMPlayServerName, 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;

         }

     }

 void RDrmSession::Disconnect()

     {

     RSessionBase::Close();

     }

 TVersion RDrmSession::Version() const

     {

     return(TVersion(KDRMPlayServMajorVersionNumber,

                     KDRMPlayServMinorVersionNumber,

                     KDRMPlayServBuildVersionNumber));

     }

 //Sync send no data

 TInt RDrmSession::Send(TInt aFunction)

     {

     TInt status(KErrSessionClosed);

     if (Handle())

         {

         status = RSessionBase::SendReceive(aFunction);

         }

     return status;

     }

 //Sync send with data

 TInt RDrmSession::Send(TInt aFunction,const TIpcArgs& aArgs)

     {

     TInt status(KErrSessionClosed);

     if (Handle())

         {

         status = RSessionBase::SendReceive(aFunction, aArgs);

         }

     return status;

     }

 //Async send no data

 void RDrmSession::Send(TInt aFunction,TRequestStatus& aStatus)

     {

     if (Handle())

         {

         RSessionBase::SendReceive(aFunction, aStatus);

         }

     else

         {

         TRequestStatus* s = &aStatus;

         User::RequestComplete( s , KErrSessionClosed );

         }

     }

 //Async send with data

 void RDrmSession::Send(TInt aFunction,const TIpcArgs& aArgs,TRequestStatus& aStatus)

     {

     if (Handle())

         {

         RSessionBase::SendReceive(aFunction, aArgs, aStatus);

         }

     else

         {

         TRequestStatus* s = &aStatus;

         User::RequestComplete( s , KErrSessionClosed );

         }

     }

 // End of file