diff -r 000000000000 -r 4e1aa6a622a0 resourcemgmt/hwresourcesmgr/test/mocksy/src/cmocksysession.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/resourcemgmt/hwresourcesmgr/test/mocksy/src/cmocksysession.cpp	Tue Feb 02 00:53:00 2010 +0200
@@ -0,0 +1,169 @@
+// Copyright (c) 2007-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:
+//
+
+#include "cmocksysession.h"
+#include "rmocksy.h"
+#include "cmocksyengine.h"
+
+
+/**
+Panic the client.
+*/
+void PanicClient(const RMessagePtr2& aMessage, TMockSYPanic aPanic)
+	{
+	_LIT(KPanic,"MockSY");
+	aMessage.Panic(KPanic,aPanic);
+	}
+
+/**
+Factory function.
+*/
+CSession2* CMockSYSession::NewL(CMockSYEngine& aEngine)
+	{
+	CMockSYSession* self=new(ELeave) CMockSYSession(aEngine);
+	CleanupStack::PushL(self);
+	self->ConstructL();
+	CleanupStack::Pop(self);
+	return self;
+	}
+	
+/**
+Constructor
+*/
+CMockSYSession::CMockSYSession(CMockSYEngine& aEngine)
+	:iEngine(aEngine)
+	{
+	}
+	
+/**
+2nd phase construction 
+*/
+void CMockSYSession::ConstructL()
+	{
+	iEngine.AddListenerL(*this);
+	}
+
+/**
+Destructor
+*/
+CMockSYSession::~CMockSYSession()
+	{
+	iEngine.RemoveListener(*this);
+	iEngine.SessionClosed();
+	if (!iNotifyDoneMsg.IsNull())
+		{
+		iNotifyDoneMsg.Complete(KErrCancel);
+		}
+	}
+
+/**
+Engine listener
+*/
+void CMockSYSession::Notify(TNotificationType aNotification)
+	{
+	switch (aNotification)
+		{
+		case EHandlingTerminated:
+		case EFailure:
+			{
+			if (!iNotifyDoneMsg.IsNull())
+				{
+				iNotifyDoneMsg.Complete(aNotification==EHandlingTerminated?KErrNone:KErrCorrupt);
+				}
+			}
+			break;
+		default:
+			; // don't care about other notifications
+		}
+	}
+		
+/**
+Handles the servicing of a client request that has been passed
+to the server.
+*/
+void CMockSYSession::ServiceL(const RMessage2& aMessage)
+	{
+	switch(aMessage.Function())
+		{
+		case RMockSY::KExpect:
+			{
+			HBufC8* data = HBufC8::NewLC(aMessage.GetDesLengthL(3));
+			TPtr8 dataPtr = data->Des();
+			aMessage.ReadL(3,dataPtr);
+			CleanupStack::Pop(data);
+			iEngine.QueueEpectedCallL(aMessage.Int0(),aMessage.Int1(),aMessage.Int2(),data);
+			aMessage.Complete(KErrNone);	
+			}
+		break;
+		
+		case RMockSY::KComplete:
+			{
+			HBufC8* data = HBufC8::NewLC(aMessage.GetDesLengthL(3));
+			TPtr8 dataPtr = data->Des();
+			aMessage.ReadL(3,dataPtr);
+			CleanupStack::Pop(data);
+			iEngine.QueueReturnCallL(aMessage.Int0(),aMessage.Int1(), aMessage.Int2(),data);
+			aMessage.Complete(KErrNone);	
+			}
+		break;
+		
+		case RMockSY::KNotifyTerminated:
+			{			
+			if (!iNotifyDoneMsg.IsNull())
+				{
+				PanicClient(aMessage,EPanicAlreadyReceiving);				
+				}
+			else
+				{
+				iNotifyDoneMsg = aMessage;
+				}
+			}
+		break;
+		
+		case RMockSY::KGetNextLogLine:
+			{
+			HBufC* line = iEngine.GetNextLogLine();
+			TInt ret;
+			if (line!=NULL)
+				{
+				ret=aMessage.Write(0,line->Des());
+				delete line;
+				}
+			else
+				{
+				ret=aMessage.Write(0,KNullDesC);
+				}
+			aMessage.Complete(ret);	
+			}
+		break;
+	
+		case RMockSY::KGetStatus:
+			{
+			TBool retVal;
+			TPckg<TBool> retValPckg(retVal);
+			retVal = iEngine.HasWaitingEvents();
+			aMessage.Write(0,retValPckg);
+			retVal = iEngine.HasPendingEvents();
+			aMessage.Write(1,retValPckg);
+			retVal = iEngine.HasFailure();
+			aMessage.Write(2,retValPckg);
+			aMessage.Complete(KErrNone);	
+			}
+		break;
+		
+		default:
+			PanicClient(aMessage,EPanicIllegalFunction);				
+		}
+	}