/*

 * Copyright (c) 2009 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:  Implements the class TMSPubSubListener

 *

 */

#include "tmspubsublistener.h"

#include "tmspubsubobserver.h"

using namespace TMS;

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

// TMSPubSubListener::TMSPubSubListener

// C++ constructor can NOT contain any code, that

// might leave.

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

//

TMSPubSubListener::TMSPubSubListener(const TUid aUid, const TInt aKey,

        TMSPubSubObserver* aObserver) :

    CActive(CActive::EPriorityStandard),

    iUid(aUid),

    iId(aKey),

    iObserver(aObserver)

    {

    }

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

// TMSPubSubListener::~TMSPubSubListener

// Destructor.

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

//

TMSPubSubListener::~TMSPubSubListener()

    {

    Cancel();

    iProperty.Close();

    }

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

// TMSPubSubListener::RunL

// From CActive.

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

//

void TMSPubSubListener::RunL()

    {

    const TRequestStatus status(iStatus);

    StartListening();

    iObserver->HandleNotifyPSL(iUid, iId, status);

    }

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

// TMSPubSubListener::DoCancel

// From CActive.

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

//

void TMSPubSubListener::DoCancel()

    {

    iProperty.Cancel();

    }

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

// TMSPubSubListener::RunError

// From CActive.

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

//

TInt TMSPubSubListener::RunError(TInt /*aError*/)

    {

    return KErrNone;

    }

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

// TMSPubSubListener::NewL

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

//

TMSPubSubListener* TMSPubSubListener::NewL(const TUid aUid, const TInt aKey,

        TMSPubSubObserver* aObserver)

    {

    TMSPubSubListener* self = new (ELeave) TMSPubSubListener(aUid, aKey,

            aObserver);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop();

    return self;

    }

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

// TMSPubSubListener::StartListening

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

//

void TMSPubSubListener::StartListening()

    {

    iProperty.Subscribe(iStatus);

    SetActive();

    }

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

// TMSPubSubListener::ConstructL

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

//

void TMSPubSubListener::ConstructL()

    {

    if (iObserver)

        {

        CActiveScheduler::Add(this);

        }

    User::LeaveIfError(iProperty.Attach(iUid, iId, EOwnerThread));

    if (iObserver)

        {

        StartListening();

        }

    }

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

// TMSPubSubListener::Get

// Read integer value.

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

//

TInt TMSPubSubListener::Get(TInt& aVal)

    {

    return iProperty.Get(iUid, iId, aVal);

    }

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

// TMSPubSubListener::Get

// Read binary value.

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

//

TInt TMSPubSubListener::Get(TDes8& aVal)

    {

    return iProperty.Get(iUid, iId, aVal);

    }

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

// TMSPubSubListener::Get

// Read string value.

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

//

TInt TMSPubSubListener::Get(TDes16& aVal)

    {

    return iProperty.Get(iUid, iId, aVal);

    }

// End of File