--- /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<KMaxLength> 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 );
+ }
+