/*
* Copyright (c) 2002-2005 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:  Event queue stores an event until all the clients can
*                receive it.
*
*/

#include "ConnMonServ.h"
#include "ConnMonSess.h"
#include "CEventQueue.h"

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

// -----------------------------------------------------------------------------
// CEventQueue::ConstructL
// -----------------------------------------------------------------------------
//
void CEventQueue::ConstructL( CConnMonServer* aServer )
    {
    iServer=aServer;

    // Allocate nodes
    for ( TInt i=0; i < KEventQueueSize; i++ )
        {
        TEventNode* node = new( ELeave ) TEventNode;
        iSlots.AddFirst( *node );
        }

    // Initialize latest event time
    iLastEventTime.UniversalTime();
    }

// Destructor
CEventQueue::~CEventQueue()
    {
    TEventNode* node;

    // Deallocate nodes
    for ( node=iSlots.First(); node; node=iSlots.First() )
        {
        iSlots.Remove( *node );
        delete node;
        }

    for ( node=iEvents.First(); node; node=iEvents.First() )
        {
        if ( node->iEvent.iExtra.iPtr )
            {
            delete node->iEvent.iExtra.iPtr;
            node->iEvent.iExtra.iPtr = NULL;
            }

        iEvents.Remove( *node );
        delete node;
        }

    iServer = NULL;
    }

// -----------------------------------------------------------------------------
// CEventQueue::Add
// -----------------------------------------------------------------------------
//
void CEventQueue::Add( const TEventInfo& aEventInfo, const TUint8* aPtr, TInt aSize  )
    {
    TTimeIntervalMicroSeconds microSecond( 1 );
    iLastEventTime = iLastEventTime + microSecond;

    // Get the first free slot - remove oldest event if queue is full
    TEventNode* node = iSlots.First();

    if ( !node )
        {
        //return;
        node = iEvents.First();
        FreeEvent( node );
        node = iSlots.First();
        }

    iSlots.Remove( *node );

    // Plug in values
    node->iEvent.iInfo        = aEventInfo;
    node->iEvent.iTime        = iLastEventTime;
    node->iEvent.iExtra.iPtr  = aPtr;
    node->iEvent.iExtra.iSize = aSize;

    // Add to the event queue
    iEvents.AddLast( *node );

    // Offer the event to all the clients that are listening
    // and have requested a new event.
    TInt numOffered( 0 );
    iServer->SendEventToSessions( node->iEvent, numOffered );

    // Remove immediately from the queue if all the listeners have got the event
    if ( numOffered == iServer->NumberOfListeners() )
        {
        FreeEvent( node );
        }
    }

// -----------------------------------------------------------------------------
// CEventQueue::CheckEvents
// See if there is a new event in the queue for aSession.
// -----------------------------------------------------------------------------
//
void CEventQueue::CheckEvents( CConnMonSession* aSession )
    {
    TSglQueIter< TEventNode > iter( iEvents );

    if ( aSession == 0 )
        {
        return;
        }

    for ( TEventNode* node = iter++; node; node = iter++ )
        {
        if ( aSession->CanReceiveEvent() )
            {
            if ( aSession->SendEventToClient( node->iEvent ) )
                {
                break;
                }
            }
        }
    }

// -----------------------------------------------------------------------------
// CEventQueue::FreeEvent
// -----------------------------------------------------------------------------
//
void CEventQueue::FreeEvent( TEventNode* aNode )
    {
    if ( aNode != 0 )
        {
        if ( aNode->iEvent.iExtra.iPtr )
            {
            delete aNode->iEvent.iExtra.iPtr;
            aNode->iEvent.iExtra.iPtr = NULL;
            }

        iEvents.Remove( *aNode );

        aNode->iEvent.iInfo.Reset();
        aNode->iEvent.iExtra.Reset();

        iSlots.AddFirst( *aNode );
        }
    }

// End-of-file