/*
* 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:  Sensor server property queue.
*
*/



#include "sensrvdefines.h"
#include "sensrvtrace.h"
#include "sensrvpropertyqueue.h"

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

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

    return self;
    }

// ---------------------------------------------------------------------------
// C++ constructor
// ---------------------------------------------------------------------------
//
CSensrvPropertyQueue::CSensrvPropertyQueue()
    : iPropertyPtrList(_FOFF(TLinkablePropertyPtr,iLink)),
      iPropertyPtrIter(iPropertyPtrList)
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvPropertyQueue::CSensrvPropertyQueue()" ) ) );

    // Nothing to do

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

    iHeap = &User::Heap();
    
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvPropertyQueue::ConstructL - return" ) ) );
    }


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

    RemoveAll();
       
    // iHeap is not owned
        
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvPropertyQueue::~CSensrvPropertyQueue - return" ) ) );
    }


// ---------------------------------------------------------------------------
// Adds property to the end of the queue
// ---------------------------------------------------------------------------
//
TInt CSensrvPropertyQueue::Append( const TSensrvProperty& aProperty )
    {
    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvPropertyQueue::Append(Property ID:%d)" ), aProperty.GetPropertyId() ) );

    TInt err(KErrNone);

    // Allocate linkable transaction pointer in same heap as queue
    TLinkablePropertyPtr* newPtr = reinterpret_cast<TLinkablePropertyPtr*>(iHeap->Alloc(sizeof(TLinkablePropertyPtr)));
    
    if (newPtr)
        {
        Mem::Copy(&(newPtr->iProperty), &aProperty, sizeof(TSensrvProperty));
        iPropertyPtrList.AddLast(*newPtr);                
        }
    else
        {
        ERROR_TRACE( ( _L( "Sensor Server - CCSensrvPropertyQueue::Append - ERROR: No memory to add item" ) ) );
        err = KErrNoMemory;
        }

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

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

    TSensrvProperty* property = NULL;
    if (!iPropertyPtrList.IsEmpty())
        {
        TLinkablePropertyPtr* ptr = iPropertyPtrList.First();
        
        if( ptr )
            {        
            property = &(ptr->iProperty);
            }    
        }

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvPropertyQueue::First - return %d" ), property ) );
    
    return property;
    }

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

    if (!iPropertyPtrList.IsEmpty())
        {
        TLinkablePropertyPtr* ptr = iPropertyPtrList.First();
        
        if( ptr )
            {        
            iPropertyPtrList.Remove(*ptr);        
                    
            // Pointers are allocated directly on heap, so free them directly also just to be on safe side.
            if (iHeap)
                {
                iHeap->Free(ptr);
                ptr = NULL;
                }
            }    
        }

    COMPONENT_TRACE( ( _L( "Sensor Server - CSensrvPropertyQueue::RemoveFirst - return" ) ) );
    }

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

    if (!iPropertyPtrList.IsEmpty())
        {
        TLinkablePropertyPtr* ptr = NULL;
        iPropertyPtrIter.SetToFirst(); 
        
        while ((ptr = iPropertyPtrIter++) != NULL)
            {        
            iPropertyPtrList.Remove(*ptr);
            iHeap->Free(ptr);
            ptr = NULL;
            };
        }
        
    iPropertyPtrList.Reset();
    }