/*

* 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: 

*    Implementation for the CDosEventListenerBase class.

*

*/

#include "dos_debug.h"

#include <e32svr.h>

//

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

// CDosEventListenerBase Constructor (Not owned session)

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

//

EXPORT_C CDosEventListenerBase::CDosEventListenerBase(RDosServer& aServer)

: iNotifierList(_FOFF(CDosEventNotifier,iLink)) , iNotifierIter(iNotifierList)

{

	iDosServer = aServer;

	iOwnServer = EFalse;

	iNotifierCount = 0;

	iEventList = NULL;

}

//

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

// CDosEventListenerBase Constructor (owned session)

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

//

EXPORT_C CDosEventListenerBase::CDosEventListenerBase()

: iNotifierList(_FOFF(CDosEventNotifier,iLink)) , iNotifierIter(iNotifierList)

{

    // Correcting CodeScanner 'High' defect for ignoring Connect() return value

	(void)iDosServer.Connect();

	iOwnServer = ETrue;

	iNotifierCount = 0;

	iEventList = NULL;

}

//

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

// CDosEventListenerBase Destructor

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

//

EXPORT_C CDosEventListenerBase::~CDosEventListenerBase()

{

	if (!iNotifierList.IsEmpty())

	{

		CDosEventNotifier* item;

	    iNotifierIter.SetToFirst();

	    while ((item = iNotifierIter++) != NULL)

		{

			delete item;

		}

		iNotifierList.Reset();

	}

	if(iOwnServer)

		iDosServer.Close();

	if (iEventList) delete[] iEventList;

}

//

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

// CDosEventListenerBase::StartListeningL (array of events)

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

//

EXPORT_C void CDosEventListenerBase::StartListeningL(TRegisterEvent* aEventArray, TInt aEventCount)

{

	//

	// Added reset

	if (!iNotifierList.IsEmpty())

	{

		CDosEventNotifier* item;

	    iNotifierIter.SetToFirst();

	    while ((item = iNotifierIter++) != NULL)

		{

			delete item;

		}

		iNotifierList.Reset();

	}

	// End of addition

	//

	iNotifierCount = aEventCount;

	CDosEventNotifier* tmp;

	if(iEventList)

	{

	   delete iEventList;

	   iEventList = NULL;

	}

	iEventList = new TRegisterEvent[iNotifierCount];

	if(!iEventList)

		User::LeaveIfError( KErrNoMemory );

	for(TInt i=iNotifierCount-1;i>=0;i--)

	{

		tmp = CDosEventNotifier::NewL(iDosServer,this);

		iNotifierList.AddFirst(*tmp);

		iEventList[i].iEvent = aEventArray[i].iEvent;

		iEventList[i].iParamSize = aEventArray[i].iParamSize;

		iEventList[i].iQueue = aEventArray[i].iQueue;

	}

	RegisterAndListenL();

}

//

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

// CDosEventListenerBase::StartListeningL (one event)

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

//

EXPORT_C void CDosEventListenerBase::StartListeningL(TUint aEvent,TInt aParamSize,TQueueType aQueue)

{

	CDosEventNotifier* tmp = NULL;

	iNotifierCount = 1;

	tmp = CDosEventNotifier::NewL(iDosServer,this);

	if (iEventList)

	{

		delete iEventList;

		iEventList = NULL;

	}

	iEventList = new TRegisterEvent;

	if( !iEventList )

	    {

		User::LeaveIfError( KErrNoMemory );

	    }

	iEventList->iEvent = aEvent;

	iEventList->iParamSize = aParamSize;

	iEventList->iQueue = aQueue;

	iNotifierList.AddLast(*tmp);

	if (!iNotifierList.IsEmpty())

	{

		CDosEventNotifier* item;

	    iNotifierIter.SetToFirst();

	    while ((item = iNotifierIter++) != NULL)

		{

	    COM_TRACE_3( "[DOSSERVER]\t StartListeningL (single event): event:%d, size:%d, queue:%d", iEventList->iEvent, iEventList->iParamSize, iEventList->iQueue );

		item->StartListeningL(iEventList->iEvent, iEventList->iParamSize, iEventList->iQueue);

		}

	}

}

//

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

// CDosEventListenerBase::RegisterAndListenL

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

//

void CDosEventListenerBase::RegisterAndListenL()

{

	if (!iNotifierList.IsEmpty())

	{

		CDosEventNotifier* item;

		TInt i=0;

	    iNotifierIter.SetToFirst();

	    while ((item = iNotifierIter++) != NULL)

		{

		COM_TRACE_3( "[DOSSERVER]\t RegisterAndListenL: event:%d, size:%d, queue:%d", iEventList[i].iEvent,iEventList[i].iParamSize,iEventList[i].iQueue );

		item->StartListeningL(iEventList[i].iEvent,iEventList[i].iParamSize,iEventList[i].iQueue);

		i++;

		}

	}

}

//

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

// CDosEventListenerBase::Stop

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

//

EXPORT_C void CDosEventListenerBase::Stop()

{

	COM_TRACE_( "CDosEventListenerBase::Stop() - STOP!" );

	if (!iNotifierList.IsEmpty())

	{

		CDosEventNotifier* item;

	    iNotifierIter.SetToFirst();

	    while ((item = iNotifierIter++) != NULL)

		{

			item->Cancel();

		}

	}

}

//

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

// CDosEventListenerBase::OnError

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

//

EXPORT_C void CDosEventListenerBase::OnError(TInt /*aError*/, TBool& /*aStopListening*/)

{

	//Does nothing. The derived class may implement this function,

}

//

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

// CDosEventListenerBase::HandleEvent

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

//

void CDosEventListenerBase::HandleEventL(const TRegisterEvent& aEvent,HBufC8* aParameter)

{

    API_TRACE_( "[DOSSERVER] CDosEventListenerBase::HandleEventL(...)" );

	TAny* par = NULL;

	if(aParameter)

		par = (TAny*)aParameter->Ptr();

    COM_TRACE_2( "[DOSSERVER] CDosEventListenerBase::GeneralEventL(0x%x, 0x%x)", aEvent, par );

	GeneralEventL(aEvent,par);

}

//

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

// CDosEventListenerBase Empty default implementation of

// the events.

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

//

EXPORT_C void CDosEventListenerBase::GeneralEventL(const TRegisterEvent& /*aEvent*/,TAny* /*aParameter*/)

{

}