// Copyright (c) 2004-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:
//

/**
 @file
 @internalComponent
*/

#include "NetPSSignal.h"

using namespace NetSubscribe;

void TEventClientData::SignalErrorL( TInt aError )
	{
	if ( Event()->iErrHandler )
		{
		(Event()->iErrHandler)(Event()->iThis, aError);
		}
	};

void TEventDataArray::DispatchL( const Meta::SMetaData* aData, TInt aErr ) 
	{
	for (TInt n = 0; n < Count(); n++)
		{
		TEventClientData& data = (*this)[n];
		if ( aErr == KErrNone )
			{
			data.SignalL( aData );
			}
		else
			{
			data.SignalErrorL( aErr );
			}
		}
	}

TInt TEventDataArray::RegisterL( const TEventClientData& aData ) 
	{
	if (Find( aData.Event() ) != KErrNotFound)
		{
		User::Leave(KErrAlreadyExists);
		}
	AppendL( aData );
	return Count();
	}

TInt TEventDataArray::DeRegister( const TEventBase* aEvent )
	{
	TInt n = Find( aEvent );
	if ( n != KErrNotFound )
		{
		Remove(n);
		}
	return Count();
	}

TInt TEventDataArray::Find( const TEventBase* aEvent )
	{
	TInt n = 0;
	TInt count = Count();
	for (; n < count && (*this)[n].Event() != aEvent; n++)
		{
		}
	return n < Count() ? n : KErrNotFound;
	}
	
XSignal::~XSignal()
	/**
	virtual destructor so that the right instance destructor can be reached
	*/
	{
	iData.Close();
	}
	
TInt CSignalActive::RunError(TInt aError)
	{
	for (TInt n = 0; n < iData.Count(); n++)
		{
		TRAP_IGNORE(iData[n].SignalErrorL( aError ));
		}
	return KErrNone;
	}