TB10.1 Example Applications: examples/Base/IPC/pubsub/subscribestd.cpp Source File

00001 // Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
-00002 // All rights reserved.
-00003 // This component and the accompanying materials are made available
-00004 // under the terms of "Eclipse Public License v1.0"
-00005 // which accompanies this distribution, and is available
-00006 // at the URL "http://www.eclipse.org/legal/epl-v10.html".
-00007 //
-00008 // Initial Contributors:
-00009 // Nokia Corporation - initial contribution.
-00010 //
-00011 // Contributors:
-00012 //
-00013 // Description:
-00014 // Demonstrates the standard state pattern of subscribing to a byte-array property
-00015 //
-00016 
-00017 
-00018 
-00023 #include "subscribe.h"
-00024 LOCAL_D CConsoleBase* console;
-00025 
-00029 CArrayPropertyWatch::CArrayPropertyWatch():CActive(EPriority)
-00030         {
-00031         }
-00032 
-00037 void CArrayPropertyWatch::ConstructL(CConsoleBase* aConsole)
-00038         {
-00039         User::LeaveIfError(iProperty.Attach(KMyPropertyCat,KMyPropertyName));
-00040         iConsole = aConsole;
-00041         CActiveScheduler::Add(this);
-00042         }
-00043 
-00049 CArrayPropertyWatch* CArrayPropertyWatch::NewL(CConsoleBase* aConsole)
-00050         {
-00051         CArrayPropertyWatch* self = new (ELeave) CArrayPropertyWatch;
-00052         CleanupStack::PushL(self);
-00053         self->ConstructL(aConsole);
-00054         CleanupStack::Pop(self);
-00055         return self;
-00056         }
-00057 
-00061 CArrayPropertyWatch::~CArrayPropertyWatch()
-00062         {
-00063         iProperty.Close();
-00064         Cancel();
-00065         }
-00066 
-00070 void CArrayPropertyWatch::DoCancel()
-00071         {
-00072         iProperty.Cancel();
-00073         }
-00074 
-00079 void CArrayPropertyWatch::RunL()
-00080         {
-00081         // Get the value of the property
-00082         TBuf16<KArraySize> buf;
-00083         TInt err = iProperty.Get(buf);
-00084         if(err == KErrNotFound)
-00085                 {
-00086                 // Leave the function if the property is not defined
-00087                 CActiveScheduler::Stop();
-00088                 User::Leave(err);
-00089                 }
-00090         else
-00091                 {
-00092                 if(buf == KStop)
-00093                         {
-00094                         CActiveScheduler::Stop();
-00095                         }
-00096                 else
-00097                         {
-00098                         // Re-subscribe to the property
-00099                         WatchL();
-00100                         }
-00101                 }
-00102         }
-00103 
-00108 void CArrayPropertyWatch::PrintProperty(TDes16& aBuf)
-00109         {
-00110         iConsole->Printf(KTxtArray);
-00111         TInt bufLength = aBuf.Length();
-00112         for(TInt ix = 0; ix < bufLength;ix++)
-00113                 {
-00114                 iConsole->Printf(KTxtArrayElement,aBuf[ix]);
-00115                 }
-00116         iConsole->Printf(KTxtNewLine);
-00117         }
-00118 
-00122 void CArrayPropertyWatch::WatchL()
-00123         {
-00124         // Get the value of the property
-00125         TBuf16<KArraySize> buf;
-00126         TInt err = iProperty.Get(buf);
-00127         if(err == KErrNotFound)
-00128                 {
-00129                 // Leave if the property is not found
-00130                 User::Leave(err);
-00131                 }
-00132         PrintProperty(buf);
-00133         // Subscribe to the property
-00134         iProperty.Subscribe(iStatus);
-00135         // Issue an outstanding request
-00136         SetActive();
-00137         }
-00138 
-00139 void DoExampleL()
-00140         {
-00141         CActiveScheduler* scheduler = new (ELeave) CActiveScheduler();
-00142         CleanupStack::PushL(scheduler);
-00143         CActiveScheduler::Install(scheduler);
-00144 
-00145         console->Printf(KTxtSpecSt);
-00146 
-00147         // Create the byte-array property watch active object
-00148         CArrayPropertyWatch* obj = CArrayPropertyWatch::NewL(console);
-00149         CleanupStack::PushL(obj);
-00150 
-00151         // Subscribe to the property and start the scheduler
-00152         obj->WatchL();
-00153         CActiveScheduler::Start();
-00154 
-00155         CleanupStack::PopAndDestroy(obj);
-00156         CleanupStack::PopAndDestroy(scheduler);
-00157         }
-00158 
-00159 GLDEF_C TInt E32Main()
-00160         {
-00161         __UHEAP_MARK;
-00162         CTrapCleanup* cleanup = CTrapCleanup::New();
-00163 
-00164         TRAPD(createError, console = Console::NewL(KTextConsoleTitle, TSize(KConsFullScreen,KConsFullScreen)));
-00165         if (createError)
-00166                 return createError;
-00167 
-00168         TRAPD(mainError, DoExampleL());
-00169         if (mainError)
-00170                 console->Printf(KTextFailed, mainError);
-00171         console->Printf(KTextPressAnyKey);
-00172         console->Getch();
-00173 
-00174         delete console;
-00175         delete cleanup;
-00176         __UHEAP_MARKEND;
-00177         return KErrNone;
-00178         }
-