/*

* 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:  Inline implementation of message monitor

*

*/

#include <mpxlog.h>

#include "mpxsession.h"

#include "mpxmessagemonitor.h"

const TInt KMPXGetNextMessage=0;

const TInt KMPXCancelGetNextMessage=1;

// ============================== MEMBER FUNCTIONS ============================

// ----------------------------------------------------------------------------

// Two phases constructor

// ----------------------------------------------------------------------------

// 

EXPORT_C CMPXMessageMonitor* CMPXMessageMonitor::NewL(

    const RMPXSession& aSession,

    MMPXMessageObserver& aObserver)

    {

    CMPXMessageMonitor* self = new(ELeave)CMPXMessageMonitor(aSession, aObserver);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

// ----------------------------------------------------------------------------

// Destructor

// ----------------------------------------------------------------------------

//    

EXPORT_C CMPXMessageMonitor::~CMPXMessageMonitor() 

    {

    MPX_FUNC_EX("CMPXMessageMonitor::~CMPXMessageMonitor");

    Cancel();

    }

// ----------------------------------------------------------------------------

// C++ constructor

// ----------------------------------------------------------------------------

//    

CMPXMessageMonitor::CMPXMessageMonitor(

    const RMPXSession& aSession,

    MMPXMessageObserver& aObserver)

:   CActive(EPriorityHigh),

    iSession(aSession),

    iObserver(aObserver)

    {

    CActiveScheduler::Add(this);

    }

// ----------------------------------------------------------------------------

// 2nd phase construction: 

// ----------------------------------------------------------------------------

//    

void CMPXMessageMonitor::ConstructL()

    {

    MPX_FUNC_EX("CMPXMessageMonitor::ConstructL");

    GetNextMessage();

    }

// ----------------------------------------------------------------------------

// Start to monitor messages

//

// ----------------------------------------------------------------------------

//    

EXPORT_C void CMPXMessageMonitor::GetNextMessage()

    {

    MPX_FUNC_EX("CMPXMessageMonitor::GetNextMessage");

    if (!IsActive())

        {

        MPX_DEBUG1("CMPXMessageMonitor::GetNextMessage send request");

        iSession.SendReceive(KMPXGetNextMessage, 

                             TIpcArgs(&iMsgDataPkg, &iErrorPkg),

                             iStatus);

        SetActive();

        }

    }

// ----------------------------------------------------------------------------

// From CActive: a new message must have arrived so retrieve it and pass back

// to observer, then wait for next message

// ----------------------------------------------------------------------------

//    

EXPORT_C void CMPXMessageMonitor::RunL()

    {

    MPX_FUNC_EX("CMPXMessageMonitor::RunL");

    // Try again in case server is down for IAD

    if (iStatus == KErrDied || iStatus == KErrServerTerminated)

        {

        MPX_DEBUG1("-->CMPXMessageMonitor::RunL Reconnecting session for IAD");

        // attempt to bring the server back up

        if (iSession.Reconnect() != KErrNone)

            {            

            MPX_DEBUG1("-->CMPXMessageMonitor::RunL Reconnect Failed");

            User::LeaveIfError(iStatus.Int());

            }

        }

    else

        {

        User::LeaveIfError(iStatus.Int());

        iObserver.MessageReceived(iMsgDataPkg(), iErrorPkg());

        }

    }

// ----------------------------------------------------------------------------

// From CActive: no more messages are required 

// ----------------------------------------------------------------------------

//     

EXPORT_C void CMPXMessageMonitor::DoCancel()

    {

    MPX_FUNC_EX("CMPXMessageMonitor::DoCancel");

    if (IsActive())

        {

        TRAP_IGNORE(iSession.SendReceiveL(KMPXCancelGetNextMessage));

        }

    }

// ----------------------------------------------------------------------------

// Handle leave in the RunL() 

// ----------------------------------------------------------------------------

//     

EXPORT_C TInt CMPXMessageMonitor::RunError(TInt aError)

    {

    MPX_DEBUG3("-->CMPXMessageMonitor::RunError 0x%08x, error %d", this, aError);

    if (KErrCancel!=aError && KErrServerTerminated!=aError)

        {

        GetNextMessage();

        }

    MPX_DEBUG3("<--CMPXMessageMonitor::RunError 0x%08x, error %d", this, aError);

    return KErrNone;

    }

// End of file