/*

* Copyright (c) 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:  Client/server interface for GOOM Monitor.

*

*/

#include <coemain.h>

#include <goommonitorsession.h>

#include "goommonitorclientserver.h"

#include "goompanic.h"

#include "goomtraces.h"

enum TGoomClientInternalFlags{

    EGoonCFlagsNone,

    EGoonCFlagsConnected = 1

    };

#define ASYNCH_NOTIFICATION_ONLY

EXPORT_C TInt RGOomMonitorSession::Connect()

    {

    FUNC_LOG;

    iFlags = EGoonCFlagsNone; // initialization

    if (CreateSession(KGraphicsMemoryMonitorServerName, TVersion(0,0,0)) == KErrNone)

        {

        iFlags = EGoonCFlagsConnected;

        }    

    // always return KErrNone for now        

    return KErrNone;

    }

EXPORT_C TBool RGOomMonitorSession::IsConnected()

    {

    FUNC_LOG;

    return iFlags&EGoonCFlagsConnected;

    }

EXPORT_C TInt RGOomMonitorSession::RequestFreeMemory(TInt aBytesRequested)

    {

    FUNC_LOG;

    if (IsConnected())

        {

        TIpcArgs p(aBytesRequested,0);

        return SendReceive(EGOomMonitorRequestFreeMemory, p);

        }

    return KErrNone;    

    }

EXPORT_C TInt RGOomMonitorSession::RequestOptionalRam(TInt aBytesRequested, TInt aMinimumBytesNeeded, TInt aPluginId, TInt& aBytesAvailable)

    {

    FUNC_LOG;

    if (IsConnected())

        {

        TIpcArgs p(aBytesRequested, aMinimumBytesNeeded, aPluginId, aBytesAvailable);

        TInt ret = SendReceive(EGOomMonitorRequestOptionalRam, p);

        if (ret >= 0)

            {

            aBytesAvailable = ret;

            ret = KErrNone;

            }

        return ret;

        }

    return KErrNone;

    }    

EXPORT_C void RGOomMonitorSession::RequestOptionalRam(TInt aBytesRequested, TInt aMinimumBytesNeeded, TInt aPluginId, TRequestStatus& aStatus)

    {

    FUNC_LOG;

    if (IsConnected())

        {

        TIpcArgs p(aBytesRequested, aMinimumBytesNeeded, aPluginId);

        SendReceive(EGOomMonitorRequestOptionalRam, p, aStatus);

        }

    else

        {

        TRequestStatus* sptr = &aStatus;

        User::RequestComplete(sptr, KErrNone);

        }    

    }

EXPORT_C void RGOomMonitorSession::RequestFreeMemory(TInt aBytesRequested, TRequestStatus& aStatus)

    {

    FUNC_LOG;

    if (IsConnected())

        {

        TIpcArgs p(aBytesRequested,0);

        SendReceive(EGOomMonitorRequestFreeMemory, p, aStatus);

        }

    else

        {

        TRequestStatus* sptr = &aStatus;

        User::RequestComplete(sptr, KErrNone);

        }    

    }

EXPORT_C void RGOomMonitorSession::CancelRequestFreeMemory()

    {

    FUNC_LOG;

    if (IsConnected())

        {

        SendReceive(EGOomMonitorCancelRequestFreeMemory, TIpcArgs());

        }

    }

EXPORT_C void RGOomMonitorSession::ThisAppIsNotExiting(TInt aWgId)

    {

    FUNC_LOG;

    if (IsConnected())

        {

        TIpcArgs p(aWgId);

        SendReceive(EGOomMonitorThisAppIsNotExiting, p);

        }

    }

EXPORT_C void RGOomMonitorSession::SetGOomPriority(TGOomPriority aPriority)

    {

    FUNC_LOG;

    if (!IsConnected())

        {

        return;

        }

    CCoeEnv* coeEnv = CCoeEnv::Static();

    __ASSERT_DEBUG(coeEnv, GOomMonitorPanic(KNoCoeEnvFound));

    if (coeEnv)

        {

        TInt wgId = coeEnv->RootWin().Identifier();

        TIpcArgs p(wgId);

        switch (aPriority)

            {

            case EGOomPriorityNormal:

                SendReceive(EGOomMonitorSetPriorityNormal, p);

                break;

            case EGOomPriorityHigh:

                SendReceive(EGOomMonitorSetPriorityHigh, p);

                break;

            case EGOomPriorityBusy:

                SendReceive(EGOomMonitorSetPriorityBusy, p);

                break;

            default:

                GOomMonitorPanic(KGOomInvalidPriority);

                break;

            }

        }

    }

EXPORT_C void RGOomMonitorSession::ApplicationAboutToStart(const TUid& aAppUid)

    {

    FUNC_LOG;

    if (IsConnected())

        {

#ifdef ASYNCH_NOTIFICATION_ONLY            

        SendReceive(EGoomMonitorAppAboutToStart, TIpcArgs(aAppUid.iUid));

#else

        SendReceive(EGOomMonitorRequestFreeMemory, TIpcArgs(0,aAppUid.iUid));

#endif

        }

    }

EXPORT_C void RGOomMonitorSession::UsesAbsoluteMemTargets(TBool aUseAbsoluteAmount)

    {

    FUNC_LOG;    

    if (IsConnected())

        {

        SendReceive(EGoomMonitorAppUsesAbsoluteMemTargets, TIpcArgs(aUseAbsoluteAmount));

        }    

    }    

EXPORT_C TInt RGOomMonitorSession::Connect(TRequestStatus& aStatus)

    {

    FUNC_LOG;

    iFlags = EGoonCFlagsNone; // initialization

    TInt err = CreateSession( KGraphicsMemoryMonitorServerName, 

        TVersion( 0, 0, 0 ), 1, EIpcSession_Unsharable, 0, &aStatus ); 

    if ( err == KErrNone )    

        {

        iFlags = EGoonCFlagsConnected;

        }    

    return err;

    }

EXPORT_C void RGOomMonitorSession::AppAboutToStart(TRequestStatus& aStatus, const TUid& aAppUid)

    {

    FUNC_LOG;

    if (IsConnected())

        {

#ifdef ASYNCH_NOTIFICATION_ONLY            

        SendReceive(EGoomMonitorAppAboutToStart, TIpcArgs(aAppUid.iUid), aStatus);

#else

        SendReceive(EGOomMonitorRequestFreeMemory, TIpcArgs(0,aAppUid.iUid), aStatus);

#endif

        }

    }