/*

* Copyright (c) 2002-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:

*

*/

#ifndef __TESTMSGQUEUE_H__

#define __TESTMSGQUEUE_H__

#include <test/testexecutestepbase.h>

#include <e32svr.h>

#include <sys/msg.h>

#include <errno.h>

#include <sys/ipc.h>

#include <string.h>

#include <stdlib.h>

#include <pthread.h>

#include <sys/ipc.h>

// MACROS

#define MAX_IPC_OBJ 1024

_LIT(KMessageQueueCreate,"MessageQueueCreate");

_LIT(KMessageQueueControl,"MessageQueueControl");

_LIT(KIntgTest1,"IntgTest1");

_LIT(KIntgTest2,"IntgTest2");

_LIT(KIntgTest3,"IntgTest3");

_LIT(KIntgTest4,"IntgTest4");

_LIT(KIntgTest5,"IntgTest5");

_LIT(KIntgTest6,"IntgTest6");

_LIT(KIntgTest7,"IntgTest7");

_LIT(KIntgTest8,"IntgTest8");

_LIT(KIntgTest9,"IntgTest9");

_LIT(KIntgTest10,"IntgTest10");

_LIT(KIntgTest11,"IntgTest11");

_LIT(KIntgTest12,"IntgTest12");

_LIT(KIntgTest13,"IntgTest13");

_LIT(KIntgTest14,"IntgTest14");

_LIT(KIntgTest15,"IntgTest15");

_LIT(KIntgTest16,"IntgTest16");

_LIT(KIntgTest17,"IntgTest17");

_LIT(KIntgTest6_1,"IntgTest6_1");

_LIT(Kmsggettest1,"msggettest1");

_LIT(Kmsggettest2,"msggettest2");

_LIT(Kmsggettest3,"msggettest3");

_LIT(Kmsggettest4,"msggettest4");

_LIT(Kmsggettest5,"msggettest5");

_LIT(Kmsggettest6,"msggettest6");

_LIT(KMsggetCreateKey,"MsggetCreateKey");

_LIT(Kmsgctltest1,"msgctltest1");

_LIT(Kmsgctltest2,"msgctltest2");

_LIT(Kmsgctltest3,"msgctltest3");

_LIT(Kmsgctltest4,"msgctltest4");

_LIT(Kmsgctltest5,"msgctltest5");

_LIT(Kmsgsndtest1,"msgsndtest1");

_LIT(Kmsgsndtest2,"msgsndtest2");

_LIT(Kmsgsndtest3,"msgsndtest3");

_LIT(Kmsgsndtest4,"msgsndtest4");

_LIT(Kmsgsndtest5,"msgsndtest5");

_LIT(Kmsgsndtest6,"msgsndtest6");

_LIT(Kmsgrcvtest1,"msgrcvtest1");

_LIT(Kmsgrcvtest2,"msgrcvtest2");

_LIT(Kmsgrcvtest3,"msgrcvtest3");

_LIT(Kmsgrcvtest4,"msgrcvtest4");

_LIT(Ksndrcvtest1,"sndrcvtest1");

_LIT(Ksndrcvtest2,"sndrcvtest2");

_LIT(Ksndrcvtest3,"sndrcvtest3");

_LIT(Ksndrcvtest4,"sndrcvtest4");

_LIT(Kthsndrcvtest1,"thsndrcvtest1");

class CTestMsgqueue : public CTestStep

	{

public:

	~CTestMsgqueue(); 

	CTestMsgqueue(const TDesC& aStepName);

	TVerdict doTestStepL();

	TVerdict doTestStepPreambleL();

	TVerdict doTestStepPostambleL();

	TInt IntgTest1();

	TInt IntgTest2();

	TInt IntgTest3();

	TInt IntgTest4();

	TInt IntgTest5();

	TInt IntgTest6();

	TInt IntgTest7();

	TInt IntgTest8();

	TInt IntgTest9();

	TInt IntgTest10();

	TInt IntgTest11();

	TInt IntgTest12();

	TInt IntgTest13();

	TInt IntgTest14();

	TInt IntgTest15();

	TInt IntgTest16();

	TInt IntgTest17();

	TInt IntgTest6_1();

	TInt msggettest1();

	TInt msggettest2();

	TInt msggettest3();

	TInt msggettest4();

	TInt msggettest5();

	TInt msggettest6();

	TInt MsggetCreateKey();

	TInt msgctltest1();

	TInt msgctltest2();

	TInt msgctltest3();

	TInt msgctltest4();

	TInt msgctltest5();

	TInt msgsndtest1();

	TInt msgsndtest2();

	TInt msgsndtest3();

	TInt msgsndtest4();

	TInt msgsndtest5();

	TInt msgsndtest6();

	TInt msgrcvtest1();

	TInt msgrcvtest2();

	TInt msgrcvtest3();

	TInt msgrcvtest4();

	TInt sndrcvtest1();

	TInt sndrcvtest2();

	TInt sndrcvtest3();

	TInt sndrcvtest4();

	TInt thsndrcvtest1();

 protected:  // Functions from base classes

        static void* ThreadEntryFunctionRead(void* arg);

        static void* ThreadEntryFunctionDestroyQ(void* arg);

        static void* ThreadEntryFunctionWrite(void* arg);

private:

	/**

        * Message queue create

        * @since MRT 2.0

        * @param aItem Script line containing parameters.

        * @return Symbian OS error code.

        */

        virtual TInt MessageQueueCreate(  );

        /**

        * Message queue close

        * @since MRT 2.0

        * @param aItem Script line containing parameters.

        * @return Symbian OS error code.

        */

        virtual TInt MessageQueueClose(  );

        /**

        * Message queue control

        * @since MRT 2.0

        * @param aItem Script line containing parameters.

        * @return Symbian OS error code.

        */

        virtual TInt MessageQueueControl(  );

        /**

        * Message queue send

        * @since MRT 2.0

        * @param aItem Script line containing parameters.

        * @return Symbian OS error code.

        */

        virtual TInt MessageQueueSend(  );

        /**

        * Message queue receive

        * @since MRT 2.0

        * @param aItem Script line containing parameters.

        * @return Symbian OS error code.

        */

        virtual TInt MessageQueueRecv(  );

        /**

        * Create Thread

        * @since MRT 2.0

        * @param aItem Script line containing parameters.

        * @return Symbian OS error code.

        */

        virtual TInt CreateThread(  );

        /**

        * Send Message to Queue

        * @since MRT 2.0

        * @param aItem Script line containing parameters.

        * @return Symbian OS error code.

        */

        virtual TInt SendMessage(  );

        /**

        * Recv Message from Queue

        * @since MRT 2.0

        * @param aItem Script line containing parameters.

        * @return Symbian OS error code.

        */

        virtual TInt RecvMessage(  );

        TInt MsgKey(  TInt& aKey );

        TInt MsgFlag(  TInt& aFlag );

        TInt MsgId(  TInt& aId );

        TInt MsgCmd(  TInt& aCmd );

        TInt MsgType(  TInt& aType );

        TInt MsgLen(  TInt& aLen );

        TInt MsgSegs(  TInt& aSegs );

        TInt ErrCode(  TInt& aErrCode );

        TInt CheckMessageQueueStats(struct msqid_ds& buf);

        void SetMessageQueueParms(struct msqid_ds* buf);

     public:     // Data

        TInt iErrno;

     private:    // Data

    	TInt iParamCnt;

        TInt iBlocked;

        TInt iThreadId;

        TInt *iNoOfMsqIds;

        TInt msgq_id;

	};

#endif