/*
* Copyright (c) 2007 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:  Channel change notifications queue implementation
*
*/



#include "sensrvdefines.h"
#include "sensrvtrace.h"
#include "sensrvchannelchangequeue.h"

// ---------------------------------------------------------------------------
// 2-phase constructor
// ---------------------------------------------------------------------------
//
CSensrvChannelChangeQueue* CSensrvChannelChangeQueue::NewL()
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::NewL()" ) ) );

    CSensrvChannelChangeQueue* self = new( ELeave ) CSensrvChannelChangeQueue();
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self); 
    
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::NewL - return 0x%x" ), self ) );

    return self;
    }

// ---------------------------------------------------------------------------
// C++ constructor
// ---------------------------------------------------------------------------
//
CSensrvChannelChangeQueue::CSensrvChannelChangeQueue()
    : iChangesList(_FOFF(TChannelChangeNotification,iLink)),
      iChangesListIter(iChangesList)
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::CSensrvChannelChangeQueue()" ) ) );

    // Nothing to do

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::CSensrvChannelChangeQueue - return" ) ) );
    }
    
// ---------------------------------------------------------------------------
// 2nd phase of construction
// ---------------------------------------------------------------------------
//
void CSensrvChannelChangeQueue::ConstructL()
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::ConstructL()" ) ) );
    
    // Nothing to do

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::ConstructL - return" ) ) );
    }


// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
CSensrvChannelChangeQueue::~CSensrvChannelChangeQueue()
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::~CSensrvChannelChangeQueue()" ) ) );

    RemoveAll();
       
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::~CSensrvChannelChangeQueue - return" ) ) );
    }


// ---------------------------------------------------------------------------
// Adds property to the end of the queue
// ---------------------------------------------------------------------------
//
TInt CSensrvChannelChangeQueue::Append( const TSensrvChannelInfo& aChannelInfo,
                                        TSensrvChannelChangeType aChangeType )
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::Append(Channel ID:%d)" ), aChannelInfo.iChannelId ) );

    TInt err(KErrNone);

    // Allocate linkable transaction pointer in same heap as queue
    TChannelChangeNotification* newPtr = new TChannelChangeNotification();
    
    if (newPtr)
        {
        newPtr->iChannelInfo = aChannelInfo;
        newPtr->iChangeType = aChangeType;
        iChangesList.AddLast(*newPtr);                
        }
    else
        {
        ERROR_TRACE( ( _L( "Sensor Server - CCSensrvChannelChangeQueue::Append - ERROR: No memory to add item" ) ) );
        err = KErrNoMemory;
        }

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::Append - return %d" ), err ) );
    
    return err;
    }

// ---------------------------------------------------------------------------
// Gets the first property
// ---------------------------------------------------------------------------
//
CSensrvChannelChangeQueue::TChannelChangeNotification* CSensrvChannelChangeQueue::First()
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::First()" ) ) );

    TChannelChangeNotification* ptr = NULL;
    
    if (!iChangesList.IsEmpty())
        {
        ptr = iChangesList.First();
        }
    
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::First - return %d" ), ptr ) );
    
    return ptr;
    }

// ---------------------------------------------------------------------------
// Remove the first property
// ---------------------------------------------------------------------------
//
void CSensrvChannelChangeQueue::RemoveFirst()
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::RemoveFirst()" ) ) );

    TChannelChangeNotification* ptr = NULL;
    
    if (!iChangesList.IsEmpty())
        {
        ptr = iChangesList.First();
        iChangesList.Remove(*ptr);
        delete ptr;
        }
    
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::RemoveFirst - return" ) ) );
    }

// ---------------------------------------------------------------------------
// Remove all properties from queue
// ---------------------------------------------------------------------------
//
void CSensrvChannelChangeQueue::RemoveAll()
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvChannelChangeQueue::RemoveAll()" ) ) );

    if (!iChangesList.IsEmpty())
        {
        TChannelChangeNotification* ptr = NULL;
        iChangesListIter.SetToFirst(); 
        
        while ((ptr = iChangesListIter++) != NULL)
            {        
            iChangesList.Remove(*ptr);
            delete ptr;
            };
        }
        
    iChangesList.Reset();
    }