--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/videoutils_plat/videoconnutility_api/tsrc/VCXTestCommon/inc/VCXTestMessageWait.h	Thu Dec 17 09:14:38 2009 +0200
@@ -0,0 +1,149 @@
+/*
+* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of the License "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 VCXTESTMESSAGEWAIT_H_
+#define VCXTESTMESSAGEWAIT_H_
+
+//  INCLUDES
+#include <e32base.h>
+#include "MIptvTestTimerObserver.h"
+
+// CONSTANTS
+
+// MACROS
+
+// DATA TYPES
+
+// FUNCTION PROTOTYPES
+
+// FORWARD DECLARATIONS
+
+// CLASS DECLARATION
+class CIptvTestActiveWait;
+class CIptvTestTimer;
+
+/**
+* MVCXTestMessageWaitObserver
+*/
+class MVCXTestMessageWaitObserver
+    {
+    public:
+    
+	    /**
+	    * Called when message queue empties or there's timeout.
+	    */
+    	virtual void MessageWaitComplete( TInt aError ) = 0;
+    
+    };
+
+/**
+* CVCXTestMessageWait
+*/
+class CVCXTestMessageWait : public CBase, public MIptvTestTimerObserver
+    {
+    public:  // Constructors and destructor
+        /**
+        * Two-phased constructor.
+        */
+        IMPORT_C static CVCXTestMessageWait * NewL( MVCXTestMessageWaitObserver* aObserver );
+
+        /**
+        * Destructor.
+        */
+        IMPORT_C virtual ~CVCXTestMessageWait ();
+
+
+    public: // New functions
+
+		/**
+		* Resets already received messages, wait queue and cancels previous receiving.  
+		*/		
+		IMPORT_C void Reset();
+
+        /**
+        * Resets only already received messages.  
+        */      
+        IMPORT_C void ResetReceivedMessages();
+        
+		/**
+		* Adds message to the wait queue.
+		*/
+		IMPORT_C void AddMessage( TInt32 aMsg );
+		
+		/**
+		* Waits for a message. Calls observer callback when message is received. This will reset 
+		* previously added messages. 
+		*/		
+		IMPORT_C void WaitForMessageL( TInt32 aMsg, TInt aTimeoutSeconds, TBool aDoBlock );
+		
+		/**
+		* Waits for the added messages. Calls observer callback when messages have been received.
+		*/		
+		IMPORT_C void WaitForAllL( TInt aTimeoutSeconds, TBool aDoBlock );
+		
+        /**
+        * Waits until messages have not been received for the specified seconds. 
+        */      
+        IMPORT_C void CoolDownL( TInt aSeconds );		
+
+		/**
+		* Checks wait queue for the message.
+		*/		
+		IMPORT_C void ReceiveMessage( TInt32 aMsg, TInt aError );
+		
+    public: // From base classes.
+        
+        void TimerComplete( TInt aTimerId, TInt aError );
+    
+    private:
+
+        /**
+        * C++ default constructor.
+        */
+        CVCXTestMessageWait( MVCXTestMessageWaitObserver* aObserver );
+
+        /**
+        * By default Symbian 2nd phase constructor is private.
+        */
+        IMPORT_C void ConstructL();
+
+    private:    // Data
+		
+		MVCXTestMessageWaitObserver* iObserver;
+		
+	    CIptvTestActiveWait* iActiveWaitBlocking;
+	    
+	    CIptvTestTimer* iTimeoutTimer;
+	    
+	    // Messages which are received while waited messages array is empty.
+	    RArray<TInt32> iReceivedMessages;
+	    
+	    RArray<TInt32> iWaitedMessages;
+	  
+	    TInt iTimeoutSeconds;
+	    
+	    TBool iWaitStarted;
+	    
+	    TBool iCoolingDown;
+	    
+	    TInt iError;
+    };
+
+#endif // VCXTESTMESSAGEWAIT_H_
+
+// End of File