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