diff -r 000000000000 -r dfb7c4ff071f commsfwsupport/commselements/NetSubscribe/src/NetPSSignal.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/commsfwsupport/commselements/NetSubscribe/src/NetPSSignal.cpp Thu Dec 17 09:22:25 2009 +0200 @@ -0,0 +1,86 @@ +// 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 CPSSubscribe::RegisterNewSignalL(TEventClientData& aData, const SSignalId& aSignalId ) + { + CPSSignal* pSignal = CPSSignal::NewLC(aSignalId); + pSignal->RegisterClientL( aData ); + iSignals.AppendL(pSignal); + CleanupStack::Pop(pSignal); + } + +CPSSignal* CPSSignal::NewLC( const SSignalId& aSignalId ) + { + CPSSignal* pSignal = new(ELeave)CPSSignal(aSignalId); + CleanupStack::PushL(pSignal); + pSignal->ConstructL(); + return pSignal; + } + +void CPSSignal::ConstructL() +/** + * subscribes to the property + */ + { + User::LeaveIfError(iProperty.Attach(TUid::Uid(iSignalId.iTypeId.iType), iSignalId.iHandle )); + + iProperty.Subscribe(iStatus); + SetActive(); + } + +CPSSignal::~CPSSignal() + { + Cancel(); + iProperty.Close(); + delete iUsrData; + } + +void CPSSignal::DoCancel() + { + iProperty.Cancel(); + } + +void CPSSignal::RunL() + { + TInt nErr = iStatus.Int(); + //set active first since a leave is trapped by RunError and subscription continues + iProperty.Subscribe(iStatus); + SetActive(); + //get data + TBuf8 buf; + User::LeaveIfError( iProperty.Get(buf) ); + TPtrC8 ptr( buf ); + if ( iUsrData ) + { + User::LeaveIfError( iSignalId.iTypeId.Check( ptr ) ); + User::LeaveIfError(iUsrData->Load( ptr )); + } + else + { + iUsrData = Meta::SMetaDataECom::LoadL(ptr); + User::LeaveIfError( iSignalId.iTypeId == iUsrData->GetTypeId() ? KErrNone : KErrArgument ); + } + iData.DispatchL( iUsrData, nErr ); + } +