examples/Base/IPC/pubsub/publishstd.cpp

Go to the documentation of this file.

// Copyright (c) 2008-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:
// Demonstrates standard state pattern of publishing a byte-array property
//



#include "publish.h"

LOCAL_D CConsoleBase* console;

void PublishL(RProperty& aProperty,TDes16& aBuf)
        {
        console->Printf(KTxtPublish);

        // Publish the property
        // Failure to publish values in standard state publishing pattern is treated as a serious error
        User::LeaveIfError(aProperty.Set(aBuf));
        console->Printf(KTxtArray);

        // Print the value of the byte-array
        TInt bufLength = aBuf.Length();
        for(TInt ix = 0; ix < bufLength; ix++)
                {
                console->Printf(KTxtArrayElement,aBuf[ix]);
                }
        console->Printf(KTxtNewLine);
        }

void DoExampleL()
        {
        console->Printf(KTxtStPublish);
        console->Printf(KTxtDefine);

        // Define and pre-allocate memory to the byte-array property
        RProperty::Define(KMyPropertyCat, KMyPropertyName,RProperty::EByteArray,KAllowAllPolicy,KAllowAllPolicy,KArraySize);
        RProperty myProperty;
        // Create a handle to the property
        User::LeaveIfError(myProperty.Attach(KMyPropertyCat,KMyPropertyName,EOwnerThread));
        console->Printf(KTxtCreateHandle);

        // Byte-Array property value to be published
        TUint16 array[KArraySize] = {10,20,30,40};

        // Descriptor that the array contents are copied into
        TBuf16<KBufSize> buf;

        // Copy array contents into the descriptor
        buf.Copy(&array[0],sizeof(array));
        buf.SetLength(KArraySize);

        // Publish the property
        PublishL(myProperty,buf);

        // Change the array contents
        array[0] = 0x00ab;
        array[1] = 0x00bc;
        array[2] = 0x00cd;
        array[3] = 0x00de;
        array[4] = 0x00ef;
        array[5] = 0x00fa;

        buf.Copy(&array[0],sizeof(array));
        // Copy array contents into the descriptor
        buf.SetLength(KArraySize);

        // Wait for a key press
        console->Printf(KTxtEnter);
        while(console->Getch()!= EKeyEnter)
                {
                console->Printf(KTxtEnter);
                }

        // Publish the property
        PublishL(myProperty,buf);

        // Indicate the publisher will not publish any more values
        // The subscriber stops its subscription to the property when this value is published
        buf.Copy(KStop);
        console->Printf(KTxtEnter);

        // Wait for a key press
        while(console->Getch()!= EKeyEnter)
                {
                console->Printf(KTxtEnter);
                }

        // Publish the property
        PublishL(myProperty,buf);

        // Close the handle to the property

        myProperty.Close();

        // Wait for a key press
        while(console->Getch()!= EKeyEnter)
                {
                console->Printf(KTxtEnter);
                }

        // The publisher has finished so delete the property
        User::LeaveIfError(RProperty::Delete(KMyPropertyCat, KMyPropertyName));
        }

GLDEF_C TInt E32Main()
        {
        __UHEAP_MARK;
        CTrapCleanup* cleanup = CTrapCleanup::New();

        TRAPD(createError, console = Console::NewL(KTextConsoleTitle, TSize(KConsFullScreen,KConsFullScreen)));
        if (createError)
                return createError;

        TRAPD(mainError, DoExampleL());
        if (mainError)
                console->Printf(KTextFailed, mainError);
        console->Printf(KTextPressAnyKey);
        console->Getch();

        delete console;
        delete cleanup;
        __UHEAP_MARKEND;
        return KErrNone;
        }

---