sl@0: // Copyright (c) 1994-2010 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: // Client handling
sl@0: // 
sl@0: //
sl@0: 
sl@0: #include "CLIENT.H"
sl@0: 
sl@0: #include "ANIM.H"
sl@0: #include "Direct.H"
sl@0: #include "EVENT.H"
sl@0: #include "KEYCLICK.H"
sl@0: #include "server.h"
sl@0: #include "gc.h"
sl@0: #include "rootwin.h"
sl@0: #include "windowgroup.h"
sl@0: #include "wstop.h"
sl@0: #include "panics.h"
sl@0: #include "../CLIENT/w32comm.h"
sl@0: #include "password.h"
sl@0: #include "pointer.h"
sl@0: #include <u32hal.h> // EHalGroupEmulator
sl@0: #include "WsMemMgr.h"
sl@0: #include <e32hashtab.h>  // for RHashMap
sl@0: #include "registeredsurfacemap.h"
sl@0: #include <graphics/wselement.h>
sl@0: 
sl@0: #include "windowelementset.h"
sl@0: #include "drawresource.h"
sl@0: 
sl@0: extern CDebugLogBase* wsDebugLog;
sl@0: _LIT(KWSERVSessionPanicCategory,"WSERV");
sl@0: 
sl@0: GLREF_D TPtr nullDescriptor;
sl@0: 
sl@0: TWsCmdHeaderBase CWsClient::iCurrentCommand;
sl@0: TBuf8<EClientBufferMaxSize> CWsClient::iCmdBuf;
sl@0: TInt CWsClient::iReply;
sl@0: TInt CWsClient::iReplyOffset;
sl@0: CWsClient* CWsClient::iCurrentClient;
sl@0: CWsObject* CWsClient::iDestObj;
sl@0: const TUint8* CWsClient::iNextCmd;
sl@0: 
sl@0: TUint CWsClient::iConnectionId = CDebugLogBase::EDummyConnectionId+1;
sl@0: CArrayFixFlat<CWsClient::TWsCursorArrayItem>* CWsClient::iSystemPointerCursors = NULL;
sl@0: TInt CWsClient::iDefaultSystemPointerCursorIndex = 0;		//Negative when there isn't one
sl@0: CWsPointerCursor* CWsClient::iDefaultSystemPointerCursor;
sl@0: CWsClient* CWsClient::iSystemPointerCursorListOwner = NULL;
sl@0: CArrayFixFlat<CWsClient::TWsCursorArrayItem>* CWsClient::iTextCursorArray = NULL;
sl@0: 
sl@0: TKeyArrayFix CWsClient::iCursorKey(_FOFF(CWsClient::TWsCursorArrayItem,iIndex), ECmpTInt);
sl@0: 
sl@0: /**
sl@0: Used for enforcing the redraw calling convention in emulator builds.
sl@0: When enabled this will panic any client calling a CWindowGc draw operation outside a 
sl@0: RWindow::BeginRedraw() / RWindow::EndRedraw() pair (known as non-redraw drawing).
sl@0: 
sl@0: Enable by adding "debug_wserv_exe_EnforceRedrawCallingConvention X" to epoc.ini 
sl@0: where X is either 0 (zero) for "off" or 1 (one) for "on". 
sl@0: 
sl@0: Then enable globally in WServ AutoFlush by defining __AUTO_FLUSH in ../client/client.h 
sl@0: or locally by calling RWsSession::SetAutoFlush(ETrue) for a specific client programatically, 
sl@0: or locally pressing Ctrl-Alt-Shift-F in the emulator.
sl@0: */
sl@0: TBool CWsClient::iDebug_EnforceRedrawCallingConvention = EFalse;
sl@0: 
sl@0: // Security policy stings
sl@0: static _LIT_SECURITY_POLICY_C1(KSecurityPolicy_WriteDeviceData,ECapabilityWriteDeviceData);
sl@0: static _LIT_SECURITY_POLICY_C1(KSecurityPolicy_SwEvent,ECapabilitySwEvent);
sl@0: static _LIT_SECURITY_POLICY_C1(KSecurityPolicy_PowerMgmt,ECapabilityPowerMgmt);
sl@0: 
sl@0: //
sl@0: // class CWsClient
sl@0: // 
sl@0: 
sl@0: CWsClient::CWsClient(RThread aClient) : iClient(aClient), iGraphicMessageQueue(this), iInternalFlags(ERemoveKeyCode|EFinishedProcessingCommands)
sl@0: 	{
sl@0: 	iScreen = CWsTop::Screen();
sl@0: 	}
sl@0: 
sl@0: CWsClient::~CWsClient()
sl@0: 	{
sl@0: 	CWsTop::WindowServer()->RemoveAllGraphicDrawers(*this); // deindexes all graphic drawers owned by this client
sl@0: 
sl@0: 	delete iTempCustomTextCursor.iCursor;
sl@0: 	FreeSystemPointerCursorList();
sl@0: 	CWsTop::ClientDestroyed(this);
sl@0: 	if (wsDebugLog)
sl@0: 		{
sl@0: 		_LIT(ClientDestuct,"Client %d destructing");
sl@0: 		wsDebugLog->MiscMessage(CDebugLogBase::ELogIntermediate,ClientDestuct, iConnectionHandle);
sl@0: 		}
sl@0: 		
sl@0: 	iInternalFlags |= EClientIsClosing;
sl@0: 	delete iObjectIndex;
sl@0: 	delete iEventQueue;
sl@0: 	delete iRedrawQueue;
sl@0: 	delete iPriorityKeyEvent;
sl@0: 	CWsTop::ClearSurfaceMap(this);
sl@0: 
sl@0: 	CWsTop::SessionExited(this);
sl@0: 	iClient.Close();
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CompleteInitializationL()
sl@0: 	{
sl@0: 	iObjectIndex = new(ELeave) CWsObjectIx();
sl@0: 	iObjectIndex->ConstructL();
sl@0: 	
sl@0:     iEventQueue = new(ELeave) CEventQueue(this);
sl@0: 	iEventQueue->ConstructL();
sl@0:     
sl@0:     iRedrawQueue = new(ELeave) CRedrawQueue(this);
sl@0: 	iRedrawQueue->ConstructL();
sl@0:     
sl@0:     iPriorityKeyEvent = new(ELeave) CPriorityKey(this);
sl@0: 	
sl@0: 	CWsCliObj::NewL(this);
sl@0: 	
sl@0: 	iComputeMode = RWsSession::EPriorityControlComputeOff;
sl@0: 	
sl@0: 	CWsTop::NewSession(this);
sl@0: 	
sl@0: #ifdef __WINS__
sl@0: 	TBool halValue = EFalse;
sl@0: 	if (UserSvr::HalFunction(EHalGroupEmulator, EEmulatorHalIntProperty, 
sl@0: 		(TAny*)"debug_wserv_exe_EnforceRedrawCallingConvention", &halValue) == KErrNone)
sl@0: 		{
sl@0: 		iDebug_EnforceRedrawCallingConvention = halValue;
sl@0: 		}
sl@0: #endif
sl@0: 	
sl@0: 	iInternalFlags |= EIsInitialised;
sl@0: 	}
sl@0: 
sl@0: TBool CWsClient::DebugEnforceRedrawCallingConvention()
sl@0: 	{
sl@0: 	return iDebug_EnforceRedrawCallingConvention;
sl@0: 	}
sl@0: 
sl@0: void CWsClient::StartInitializationL(TUint aConnectionHandle)
sl@0: 	{
sl@0: 	if (wsDebugLog)
sl@0: 		wsDebugLog->NewClient(aConnectionHandle);
sl@0: 	
sl@0: 	if (iObjectIndex)
sl@0: 		PPanic(EWservPanicReInitialise);
sl@0: 	else
sl@0: 		{
sl@0: 		iConnectionHandle = aConnectionHandle;
sl@0: 		CompleteInitializationL();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Convert a handle to object checking it is of the correct type.
sl@0: //
sl@0: void CWsClient::HandleToWindow(TInt aHandle,CWsWindowBase** pWin)
sl@0: 	{
sl@0: 	if ((*pWin=(CWsWindowBase* )HandleToObjUntyped(aHandle))==NULL ||
sl@0: 		((*pWin)->Type()!=WS_HANDLE_WINDOW && (*pWin)->Type()!=WS_HANDLE_GROUP_WINDOW))
sl@0: 		PPanic(EWservPanicWindow);
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Convert a handle to object checking it is of the correct type.
sl@0: //
sl@0: void CWsClient::HandleToClientWindow(TInt aHandle,CWsClientWindow** pWin)
sl@0: 	{
sl@0: 	if ((*pWin=(CWsClientWindow*)HandleToObj(aHandle, WS_HANDLE_WINDOW))==NULL)
sl@0: 		PPanic(EWservPanicWindow);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CreateNewPointerCursorL(const TWsClCmdCreatePointerCursor &aCmd)
sl@0: 	{
sl@0: 	CWsPointerCursor* pc=new(ELeave) CWsPointerCursor(this);
sl@0: 	CleanupStack::PushL(pc);
sl@0: 	pc->ConstructL(aCmd);
sl@0: 	CleanupStack::Pop();
sl@0: 	}
sl@0: 
sl@0: // Create a new custom text cursor
sl@0: void CWsClient::StartSetCustomTextCursorL(const TWsClCmdCustomTextCursorData& aCmd)
sl@0: 	{
sl@0: 	if (!iTextCursorArray)
sl@0: 		{
sl@0: 		const TInt textCursorArrayGranularity = 4;
sl@0: 		iTextCursorArray = new(ELeave) CArrayFixFlat<TWsCursorArrayItem>(textCursorArrayGranularity);
sl@0: 		}
sl@0: 		
sl@0: 	TInt arrayIndex = KErrNotFound;
sl@0: 	if (FindCursorArrayItem(iTextCursorArray, aCmd.identifier, arrayIndex))
sl@0: 		User::Leave(KErrAlreadyExists);
sl@0: 	
sl@0: 	delete iTempCustomTextCursor.iCursor;
sl@0: 	iTempCustomTextCursor.iCursor = NULL;
sl@0: 	iTempCustomTextCursor.iCursor = new(ELeave) CWsCustomTextCursor(this, aCmd.alignment);
sl@0: 	
sl@0: 	static_cast<CWsCustomTextCursor*>(iTempCustomTextCursor.iCursor)->ConstructL(aCmd.flags);
sl@0: 	iTempCustomTextCursor.iIndex = aCmd.identifier;
sl@0: 	}
sl@0: 
sl@0: // Add new custom text cursor to global list
sl@0: void CWsClient::CompleteSetCustomTextCursorL(TInt aError)
sl@0: 	{
sl@0: 	if (aError)
sl@0: 		{
sl@0: 		delete iTempCustomTextCursor.iCursor;
sl@0: 		iTempCustomTextCursor.iCursor = NULL;
sl@0: 		User::Leave(aError);
sl@0: 		}
sl@0: 
sl@0: 	TWsCursorArrayItem entry = iTempCustomTextCursor;
sl@0: 	iTempCustomTextCursor.iCursor = NULL;
sl@0: 	CleanupStack::PushL(entry.iCursor);
sl@0: 
sl@0: 	TInt arrayIndex;
sl@0: 	if (FindCursorArrayItem(iTextCursorArray, entry.iIndex, arrayIndex))
sl@0: 		User::Leave(KErrAlreadyExists);
sl@0: 	else
sl@0: 		iTextCursorArray->InsertIsqL(entry, iCursorKey);
sl@0: 
sl@0: 	CleanupStack::Pop(entry.iCursor);
sl@0: 	}
sl@0: 
sl@0: CWsCustomTextCursor* CWsClient::FindCustomTextCursor(TInt aIdentifier)
sl@0: 	{
sl@0: 	TInt arrayIndex;
sl@0: 	if (!FindCursorArrayItem(iTextCursorArray, aIdentifier, arrayIndex))
sl@0: 		return NULL;
sl@0: 
sl@0: 	return TextCursor(arrayIndex);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CreateNewSpriteL(const TWsClCmdCreateSprite &aCmd)
sl@0: 	{
sl@0: 	CWsSprite* sprite = new(ELeave) CWsSprite(this);
sl@0: 	CleanupStack::PushL(sprite);
sl@0: 	sprite->ConstructL(aCmd);
sl@0: 	CleanupStack::Pop();
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CreateNewBitmapL(const TWsClCmdCreateBitmap &aCmd)
sl@0: 	{
sl@0: 	DWsBitmap* bitmap = new(ELeave) DWsBitmap(this);
sl@0: 	CleanupStack::PushL(bitmap);
sl@0: 	bitmap->ConstructL(aCmd);
sl@0: 	CleanupStack::Pop();
sl@0: 	}
sl@0: 
sl@0: /** Creates a new window.
sl@0: 
sl@0: If the parent is a window group then a new CWsTopClientWindow instance is created. If the parent is
sl@0: a window then a new CWsClientWindow instance is created.
sl@0: 
sl@0: @param aCmd The command received from the client
sl@0: @internalComponent
sl@0: @released
sl@0: */
sl@0: void CWsClient::CreateNewWindowL(const TWsClCmdCreateWindow &aCmd)
sl@0: 	{
sl@0: 	CWsWindowBase* parent;
sl@0: 	HandleToWindow(aCmd.parent,&parent);
sl@0: 	CWsClientWindow* win = NULL;
sl@0: 	TBool deviceIsInvalid = EFalse;
sl@0: 	CScreen* screen = parent->Screen();
sl@0: 	if (parent->WinType()==EWinTypeGroup)
sl@0: 		{
sl@0: 		__ASSERT_DEBUG(!((CWsWindowGroup*)parent)->ScreenDeviceDeleted(),PPanic(EWservPanicGroupWinScreenDeviceDeleted));
sl@0: 		win=new(ELeave) CWsTopClientWindow(this, screen);
sl@0: 		deviceIsInvalid=!((CWsWindowGroup*)parent)->ScreenDeviceValid();
sl@0: 		}
sl@0: 	else
sl@0: 		win=new(ELeave) CWsClientWindow(this, screen);
sl@0: 
sl@0: 	CleanupStack::PushL(win);
sl@0: 	win->ConstructL(aCmd,parent,deviceIsInvalid);
sl@0: 	CleanupStack::Pop(win);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CreateNewWindowGroupL(const TWsClCmdCreateWindowGroup &aCmd)
sl@0: 	{
sl@0: 	CWsWindowGroup::NewL(this, NULL, aCmd); //screen is initialised inside the constructL
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CreateNewAnimDllL(const TWsClCmdUnion &aParams)
sl@0: 	{
sl@0: 	CWsAnimDll* animDll = new(ELeave) CWsAnimDll(this);
sl@0: 	CleanupStack::PushL(animDll);
sl@0: 	animDll->LoadL(BufferTPtr((TText*)(aParams.LoadAnimDll+1),aParams.LoadAnimDll->length));
sl@0: 	CleanupStack::Pop();
sl@0: 	}	
sl@0: 
sl@0: void CWsClient::CreateNewScreenDeviceL(TInt aDefaultScreenNumber, TUint aClientScreenDevicePointer)
sl@0: 	{
sl@0: 	DWsScreenDevice* screenDevice = new(ELeave) DWsScreenDevice(this, aDefaultScreenNumber,aClientScreenDevicePointer);
sl@0: 	CleanupStack::PushL(screenDevice);
sl@0: 	screenDevice->ConstructL();
sl@0: 	CleanupStack::Pop(screenDevice);
sl@0: 	if (iPrimaryScreenDevice==NULL)
sl@0: 		{
sl@0: 		iPrimaryScreenDevice=screenDevice;
sl@0: 		// When client create screen device, change default screen to the one specified.
sl@0: 		// Client should do this immediately after establishing session
sl@0: 		iScreen = iPrimaryScreenDevice->Screen();
sl@0: 		InitialiseScreenDevices();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::InitialiseScreenDevices()
sl@0: 	{
sl@0: 	const TWsObject* ptr = iObjectIndex->FirstObject();
sl@0: 	const TWsObject* end = ptr+iObjectIndex->Length();
sl@0: 	WS_ASSERT_DEBUG(ptr->iObject==NULL, EWsPanicObjectIndexError);
sl@0: 	while(++ptr<end)
sl@0: 		{
sl@0: 		if (ptr->iObject && ptr->iObject->Type()==WS_HANDLE_GROUP_WINDOW)
sl@0: 			{
sl@0: 			CWsWindowGroup* gw = static_cast<CWsWindowGroup*>(ptr->iObject);
sl@0: 			if(!gw->Device())
sl@0: 				gw->SetScreenDevice(iPrimaryScreenDevice);
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CreateNewClickHandlerL(const TUid& aUid)
sl@0: 	{
sl@0: 	CClick* click = new(ELeave) CClick(this);
sl@0: 	CleanupStack::PushL(click);
sl@0: 	click->ConstructL(aUid);
sl@0: 	CleanupStack::Pop(click);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::RequestComplete(TRequestStatus*  &aStatus, TInt aErr)
sl@0: 	{
sl@0: 	Client().RequestComplete(aStatus,aErr);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::PanicCurrentClient(TClientPanic aPanic)
sl@0: 	{
sl@0: 	iCurrentClient->PPanic(aPanic);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::PPanic(TClientPanic aPanic) const
sl@0: //This function is allowed to leave with out the 'L' convention for special reasons
sl@0: 	{
sl@0: 	SessionPanic(aPanic);
sl@0: 	User::Leave(EPanicLeave);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SessionPanic(TClientPanic aReason) const
sl@0: 	{
sl@0: 	if (wsDebugLog)
sl@0: 		wsDebugLog->Panic(iConnectionHandle, aReason);
sl@0: 	
sl@0: 	if (!(iInternalFlags&EPanicClientAsSoonAsPossible)) // keep the first error code
sl@0: 		{
sl@0: 		iInternalFlags |= EPanicClientAsSoonAsPossible;
sl@0: 		iPanicReason = aReason;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SessionTerminate()
sl@0: 	{
sl@0: 	if (wsDebugLog)
sl@0: 		wsDebugLog->Panic(iConnectionHandle, 0);
sl@0: 
sl@0: 	const RThread thread=Client();
sl@0: 	RProcess process;
sl@0: 	if (thread.Process(process)==KErrNone)
sl@0: 		{
sl@0: 		process.Terminate(0);
sl@0: 		process.Close();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**	
sl@0: Returns the remaining space in the descriptor
sl@0: */
sl@0: TInt CWsClient::ReplyBufSpace() 
sl@0: 	{
sl@0: 	const TInt retVal = iCurrentClient->ClientMessage().GetDesLength(KReplyBufferMessageSlot);
sl@0: 	
sl@0: 	if (iReplyOffset>=0 && retVal>=iReplyOffset)
sl@0: 		return retVal-iReplyOffset;
sl@0: 	else
sl@0: 		return (retVal<0 ? retVal : KErrBadDescriptor);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ReplyBuf(const TDesC16 &aDes)	// static
sl@0: 	{
sl@0: 	WS_ASSERT_DEBUG(!iCurrentClient->ClientMessage().IsNull(), EWsPanicInvalidMessageHandle);
sl@0: 	
sl@0: 	if(iCurrentClient->ClientMessage().Write(KReplyBufferMessageSlot,aDes,iReplyOffset) != KErrNone)
sl@0: 		PanicCurrentClient(EWservPanicDescriptor);
sl@0: 	
sl@0: 	iReplyOffset += aDes.Length();
sl@0: 	if (wsDebugLog)
sl@0: 		wsDebugLog->ReplyBuf(aDes);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ReplyBuf(const TDesC8 &aDes)	// static
sl@0: 	{
sl@0: 	WS_ASSERT_DEBUG(!iCurrentClient->ClientMessage().IsNull(), EWsPanicInvalidMessageHandle);
sl@0: 	
sl@0: 	if(iCurrentClient->ClientMessage().Write(KReplyBufferMessageSlot, aDes, iReplyOffset) != KErrNone)
sl@0: 		PanicCurrentClient(EWservPanicDescriptor);
sl@0: 	
sl@0: 	iReplyOffset += aDes.Length();
sl@0: 	if (wsDebugLog)
sl@0: 		wsDebugLog->ReplyBuf(aDes);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ReplyBuf(const TAny* aSource, TInt aLength)	// static
sl@0: //
sl@0: // Send a buffer to the client process.
sl@0: //
sl@0: 	{
sl@0: 	TPtrC8 src(reinterpret_cast<const TUint8*>(aSource),aLength);
sl@0: 	ReplyBuf(src);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ReplySize(const TSize &aSize)	// static
sl@0: 	{
sl@0: 	ReplyBuf(&aSize, sizeof(aSize));
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ReplyPoint(const TPoint &aPoint)	// static
sl@0: 	{
sl@0: 	ReplyBuf(&aPoint, sizeof(aPoint));
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ReplyRect(const TRect &aRect)	// static
sl@0: 	{
sl@0: 	ReplyBuf(&aRect, sizeof(aRect));
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SetReply(TInt reply)
sl@0: 	{
sl@0: 	iReply = reply;
sl@0: 	if (wsDebugLog)
sl@0: 		wsDebugLog->Reply(reply);
sl@0: 	}
sl@0: 
sl@0: const TUint8* CWsClient::EndOfCommandBuffer()
sl@0: 	{
sl@0: 	return(iCmdBuf.Ptr()+iCmdBuf.Size());
sl@0: 	}
sl@0: 
sl@0: const TPtrC CWsClient::BufferTPtr(TText *aStart,TInt aLen)
sl@0: 	{
sl@0: 	TPtrC ptr;
sl@0: 	if (!BufferTPtrGc(aStart,aLen,ptr))
sl@0: 		PanicCurrentClient(EWservPanicBufferPtr);
sl@0: 	return(ptr);
sl@0: 	}
sl@0: 
sl@0: TBool CWsClient::BufferTPtrGc(TText* aStart,TInt aLen, TPtrC& aPtr)
sl@0: 	{
sl@0: 	if (iCurrentCommand.iOpcode>0)
sl@0: 		{
sl@0: 		if ((REINTERPRET_CAST(TUint8*,aStart)<iCmdBuf.Ptr()
sl@0: 										|| REINTERPRET_CAST(TUint8*,aStart+aLen)>(iCmdBuf.Ptr()+iCmdBuf.Size())))
sl@0: 			return(EFalse);
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		if (aLen>=iCurrentCommand.iCmdLength)
sl@0: 			return(EFalse);
sl@0: 		}
sl@0: 	aPtr.Set(aStart,aLen);
sl@0: 	return(ETrue);
sl@0: 	}
sl@0: 
sl@0: const TPtrC8 CWsClient::BufferTPtr8(TUint8* aStart,TInt aLen)
sl@0: 	{
sl@0: 	if (iCurrentCommand.iOpcode>0 && (REINTERPRET_CAST(TUint8*,aStart)<iCmdBuf.Ptr()
sl@0: 										|| REINTERPRET_CAST(TUint8*,aStart+aLen)>(iCmdBuf.Ptr()+iCmdBuf.Size())))
sl@0: 		PanicCurrentClient(EWservPanicBufferPtr);
sl@0: 		
sl@0: 	return(TPtrC8(aStart,aLen));
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Process a command buffer
sl@0: 
sl@0: @internalComponent
sl@0: @released
sl@0: */
sl@0: void CWsClient::DispatchCommandsInBufL()	// (step #4)
sl@0: 	{		
sl@0: 	if (wsDebugLog)
sl@0: 		{
sl@0:  		wsDebugLog->CommandBuf(iConnectionHandle);
sl@0:  		RThread client = Client(); 
sl@0:  		wsDebugLog->MiscMessage(CDebugLogBase::ELogEverything, client.FullName());
sl@0: 		}
sl@0: 	const TUint8* endCmd=iCmdBuf.Ptr()+iCmdBuf.Length();
sl@0: 	do
sl@0: 		{
sl@0: 		const TWsCmdHeader* pCmd=
sl@0: 				reinterpret_cast<const TWsCmdHeader*>(iNextCmd);
sl@0: 		TUint opcode = pCmd->iBase.iOpcode;
sl@0: 		TInt headerLen = sizeof(pCmd->iBase);
sl@0: 		iCurrentCommand = pCmd->iBase;
sl@0: 		
sl@0: 		// For performance reasons the handle is only included
sl@0: 		// if it is different from the previous command. The EWsOpcodeHandle
sl@0: 		// flag indicates whether a new handle has been included in the
sl@0: 		// current command. If not we use the same handle as the previous
sl@0: 		// command.
sl@0: 		if (opcode&EWsOpcodeHandle)
sl@0: 			{
sl@0: 			// Find the WServ object associated with this op code
sl@0: 			opcode &= ~EWsOpcodeHandle;
sl@0: 			iCurrentCommand.iOpcode = reinterpret_cast<TUint16&>(opcode);
sl@0: 			iDestObj=HandleToObjUntyped(pCmd->iDestHandle);
sl@0: 			headerLen = sizeof(*pCmd);
sl@0: 			}
sl@0: 			
sl@0: 		iNextCmd += headerLen;
sl@0: 		const TAny* cmdParams = iNextCmd;
sl@0: 		iNextCmd += pCmd->iBase.iCmdLength;
sl@0: 		if (!iDestObj || iNextCmd>endCmd)		// Invalid handle or Corrupt buffer
sl@0: 			{
sl@0: 			SessionPanic(iDestObj==NULL ? EWservPanicHandle : EWservPanicBuffer);
sl@0: 			iInternalFlags|=EFinishedProcessingCommands;
sl@0: 			break;
sl@0: 			}
sl@0: 
sl@0: 		if (iNextCmd==endCmd)
sl@0: 			iInternalFlags|=EFinishedProcessingCommands;
sl@0: 			
sl@0: 		if (wsDebugLog)
sl@0: 			wsDebugLog->Command(iDestObj->Type(), opcode, cmdParams, iDestObj->LogHandle());
sl@0: 		
sl@0: 		// Dispatch the command to the WServ object that will process it
sl@0: 		iDestObj->CommandL(opcode, cmdParams);	// (call #5)
sl@0: 		} 
sl@0: 	while(iNextCmd<endCmd);
sl@0: 	
sl@0: 	}
sl@0: 
sl@0: void CWsClient::DoServiceCommandBuf() // (step #3.1)
sl@0: 	{
sl@0: 	iCurrentClient=this;
sl@0: 	iInternalFlags&=~EFinishedProcessingCommands;
sl@0: 	TRAPD(err, DispatchCommandsInBufL());	// (call #4)
sl@0: 	
sl@0: #if defined(_DEBUG)
sl@0: 	if (err!=KErrNone && !(iInternalFlags&(EFinishedProcessingCommands|EPanicClientAsSoonAsPossible)))
sl@0: 		SessionPanic(EWservPanicFunctionLeave);
sl@0: #endif
sl@0: 
sl@0: 	if (err<KErrNone)
sl@0: 		SetReply(err);
sl@0: 
sl@0: 	if (iInternalFlags&(EFinishedProcessingCommands|EPanicClientAsSoonAsPossible))
sl@0: 		CompleteMessage(iClientMessage,iReply);	// (finish)
sl@0: 	
sl@0: 	iCurrentClient=NULL;
sl@0: #if defined(_DEBUG)
sl@0: 	User::Heap().Check();
sl@0: #endif
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ExecuteAsyncClientCommandL(TInt aOpcode, const RMessage2& aMessage)	// (step #3.2)
sl@0: 	{
sl@0: 	switch(aOpcode)
sl@0: 		{
sl@0: 		case EWsClOpEventReady:
sl@0: 			EventReady(aMessage);
sl@0: 			break;
sl@0: 		case EWsClOpPriorityKeyReady:
sl@0: 			PriorityKeyEventReady(aMessage);
sl@0: 			break;
sl@0: 		case EWsClOpRedrawReady:
sl@0: 			RedrawEventReady(aMessage);
sl@0: 			break;
sl@0: 		case EWsClOpGraphicMessageReady:
sl@0: 			iGraphicMessageQueue.EventReady(aMessage);
sl@0: 			break;
sl@0: 		default:
sl@0: 			{
sl@0: 			PPanic(EWservPanicOpcode);
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: 
sl@0: 
sl@0: void CWsClient::ExecuteCommandL(TInt aOpcode, const TAny* aCmdData)	// (step #6)
sl@0: 	{
sl@0: 	TWsClCmdUnion pData;
sl@0: 	pData.any=aCmdData;
sl@0: 	switch(aOpcode)
sl@0: 		{
sl@0: 		case EWsClOpCreateWindowGroup:
sl@0: 			CreateNewWindowGroupL(*pData.CreateWindowGroup);
sl@0: 			break;
sl@0: 		case EWsClOpCreateWindow:
sl@0: 			CreateNewWindowL(*pData.CreateWindow);
sl@0: 			break;
sl@0: 		case EWsClOpCreateGc:
sl@0: 			CWsGc::NewL(this);
sl@0: 			break;
sl@0: 		case EWsClOpCreateAnimDll:
sl@0: 			if (!CheckBuffer(pData.LoadAnimDll->length, KMaxFileName))
sl@0: 				PanicCurrentClient(EWservPanicBufferPtr);
sl@0: 			CreateNewAnimDllL(pData);
sl@0: 			break;
sl@0: 		case EWsClOpCreateGraphic:
sl@0: 			CWsGraphicDrawerObject::NewL(this,pData);
sl@0: 			break;
sl@0: 		case EWsClOpCreateScreenDevice:
sl@0: 			{
sl@0: 			const TInt screenNumber = pData.CreateScreenDevice->screenNumber;
sl@0: 			const TUint clientScreenDevicePointer = pData.CreateScreenDevice->clientScreenDevicePointer;
sl@0: 			if (screenNumber<0 || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 				{
sl@0: 				PPanic(EWservPanicScreenNumber);
sl@0: 				}
sl@0: 			else
sl@0: 				{
sl@0: 				CreateNewScreenDeviceL(screenNumber,clientScreenDevicePointer);
sl@0: 				}
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpCreateSprite:
sl@0: 			CreateNewSpriteL(*pData.CreateSprite);
sl@0: 			break;
sl@0: 		case EWsClOpCreatePointerCursor:
sl@0: 			CreateNewPointerCursorL(*pData.CreatePointerCursor);
sl@0: 			break;
sl@0: 		case EWsClOpStartSetCustomTextCursor:
sl@0: 			StartSetCustomTextCursorL(*pData.CustomTextCursorData);
sl@0: 			break;
sl@0: 		case EWsClOpCompleteSetCustomTextCursor:
sl@0: 			CompleteSetCustomTextCursorL(*pData.Int);
sl@0: 			break;
sl@0: 		case EWsClOpCreateBitmap:
sl@0: 			CreateNewBitmapL(*pData.CreateBitmap);
sl@0: 			break;
sl@0: 		case EWsClOpCreateDirectScreenAccess:
sl@0: 			CWsDirectScreenAccess::NewL(this,EFalse);
sl@0: 			break;
sl@0: 		case EWsClOpCreateDirectScreenAccessRegionTrackingOnly:
sl@0: 			CWsDirectScreenAccess::NewL(this,ETrue);	//creates a DSA object that will not draw to the screen, but will use just the region tracking functionality
sl@0: 			break;
sl@0: 		case EWsClOpCreateClick:
sl@0: 			CreateNewClickHandlerL(*pData.Uid);
sl@0: 			break;
sl@0: 		case EWsClOpSetHotKey:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_SwEvent().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetHotKey API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			TWindowServerEvent::SetHotKeyL(*pData.SetHotKey);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpClearHotKeys:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_SwEvent().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::ClearHotKeys API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			TWindowServerEvent::ClearHotKeysL(*pData.UInt);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpRestoreDefaultHotKey:
sl@0: 			TWindowServerEvent::ResetDefaultHotKeyL(*pData.UInt);
sl@0: 			break;
sl@0: 		case EWsClOpSetShadowVector:
sl@0: 			PPanic(EWservPanicOpcode); //this op code is deprecated, should never be generated by the client
sl@0: 			break;
sl@0: 		case EWsClOpShadowVector:
sl@0: 			PPanic(EWservPanicOpcode); //this op code is deprecated, should never be generated by the client
sl@0: 			break;
sl@0: 		case EWsClOpSetKeyboardRepeatRate:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetKeyboardRepeatRate API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			if ((pData.SetKeyboardRepeatRate->initial.Int()<0) || (pData.SetKeyboardRepeatRate->time.Int()<0))
sl@0: 				{
sl@0: 				User::Leave(KErrArgument);
sl@0: 				}
sl@0: 			CKeyboardRepeat::SetRepeatTime(pData.SetKeyboardRepeatRate->initial,pData.SetKeyboardRepeatRate->time);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpGetKeyboardRepeatRate:
sl@0: 			{
sl@0: 			SKeyRepeatSettings settings;
sl@0: 			CKeyboardRepeat::GetRepeatTime(settings.iInitialTime,settings.iTime);
sl@0: 			ReplyBuf(&settings,sizeof(settings));
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSetDoubleClick:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetDoubleClick API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			TWsPointer::SetDoubleClick(pData.SetDoubleClick->interval,pData.SetDoubleClick->distance);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpGetDoubleClickSettings:
sl@0: 			{
sl@0: 			SDoubleClickSettings settings;
sl@0: 			TWsPointer::GetDoubleClickSettings(settings.iInterval,settings.iDistance);
sl@0: 			ReplyBuf(&settings,sizeof(settings));
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpEventReady:
sl@0: 			// No need to do anything
sl@0: 			break;
sl@0: 		case EWsClOpGetEvent:
sl@0: 			HandleClientRequestForEventData();
sl@0: 			// Check flag if the group message queue is overflow and has pended messages  
sl@0: 			if (iInternalFlags & EWgMsgQueueOverflow)
sl@0: 				{
sl@0: 				iInternalFlags &= ~EWgMsgQueueOverflow;
sl@0: 				CWsWindowGroup::ReleasePendedMessagesToAllGroups(this);
sl@0: 				}
sl@0: 			break;
sl@0: 		case EWsClOpPurgePointerEvents:
sl@0: 			PurgePointerEvents();
sl@0: 			break;
sl@0: 		case EWsClOpEventReadyCancel:
sl@0: 			CancelClientRequestForEventData();
sl@0: 			break;
sl@0: 		case EWsClOpRedrawReady:
sl@0: 			iInternalFlags&=~EIsPerformingRedrawEvent;
sl@0: 			break;
sl@0: 		case EWsClOpRedrawReadyCancel:
sl@0: 			CancelClientRequestForRedrawEvent();
sl@0: 			break;
sl@0: 		case EWsClOpGetRedraw:
sl@0: 			HandleClientRequestForRedrawData();
sl@0: 			break;
sl@0: 		case EWsClOpPriorityKeyReady:
sl@0: 			// No need to do anything
sl@0: 			break;
sl@0: 		case EWsClOpPriorityKeyReadyCancel:
sl@0: 			CancelClientRequestForPriorityKeyEvent();
sl@0: 			break;
sl@0: 		case EWsClOpGetPriorityKey:
sl@0: 			HandleClientRequestForPriorityKeyData();
sl@0: 			break;
sl@0: 		case EWsClOpNumWindowGroups:
sl@0: 			SetReply(CWsWindowGroup::NumWindowGroups(EFalse,* pData.Int));
sl@0: 			break;
sl@0: 		case EWsClOpNumWindowGroupsAllPriorities:
sl@0: 			SetReply(CWsWindowGroup::NumWindowGroups(ETrue, 0));
sl@0: 			break;
sl@0: 		case EWsClOpNumWindowGroupsOnScreen:
sl@0: 			{
sl@0: 			const TInt screenNumber=pData.NumWinGroups->screenNumber;
sl@0: 			if (screenNumber<0 || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 				PPanic(EWservPanicScreenNumber);
sl@0: 			else
sl@0: 				SetReply(CWsWindowGroup::NumWindowGroupsOnScreen(CWsTop::Screen(screenNumber)->RootWindow()->Child(),(pData.NumWinGroups->priority==EAllPriorities),pData.NumWinGroups->priority));
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpWindowGroupList:
sl@0: 			{
sl@0: 			const TInt screenNumber=pData.WindowGroupList->screenNumber;
sl@0: 			if (screenNumber<KDummyScreenNumber || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 				PPanic(EWservPanicScreenNumber);
sl@0: 			else
sl@0: 				SetReply(CWsWindowGroup::SendWindowGroupListL(screenNumber,(pData.WindowGroupList->priority==EAllPriorities), pData.WindowGroupList->priority, pData.WindowGroupList->count));
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpWindowGroupListAllPriorities:
sl@0: 			{
sl@0: 			const TInt screenNumber=pData.WindowGroupList->screenNumber;
sl@0: 			if (screenNumber<KDummyScreenNumber || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 				PPanic(EWservPanicScreenNumber);
sl@0: 			else
sl@0: 				SetReply(CWsWindowGroup::SendWindowGroupListL(screenNumber,ETrue, 0, pData.WindowGroupList->count));
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpWindowGroupListAndChain:
sl@0: 			SetReply(CWsWindowGroup::SendWindowGroupListAndChainL(EFalse, pData.WindowGroupList->priority, pData.WindowGroupList->count));
sl@0: 			break;
sl@0: 		case EWsClOpWindowGroupListAndChainAllPriorities:
sl@0: 			SetReply(CWsWindowGroup::SendWindowGroupListAndChainL(ETrue, 0, pData.WindowGroupList->count));
sl@0: 			break;
sl@0: 		case EWsClOpGetDefaultOwningWindow:
sl@0: 			{
sl@0: 			const TInt screenNumber = *pData.Int;
sl@0: 			if (screenNumber<KDummyScreenNumber || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 				PPanic(EWservPanicScreenNumber);
sl@0: 			else
sl@0: 				{
sl@0: 				CScreen* screen = (screenNumber ==KDummyScreenNumber) ? iScreen : CWsTop::Screen(screenNumber);
sl@0: 				SetReply(screen->DefaultOwningWindowGroup() ? screen->DefaultOwningWindowGroup()->Identifier():0);
sl@0: 				}
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpGetFocusWindowGroup:
sl@0: 			{
sl@0: 			const TInt screenNumber = *pData.Int;
sl@0: 			if (screenNumber<KDummyScreenNumber || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 				PPanic(EWservPanicScreenNumber);
sl@0: 			else
sl@0: 				CWsWindowGroup::GetFocusWindowGroupL(screenNumber);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSetWindowGroupOrdinalPosition:
sl@0: 			CWsWindowGroup::WindowGroupFromIdentifierL(pData.SetWindowGroupOrdinalPosition->identifier)->SetOrdinalPosition(pData.SetWindowGroupOrdinalPosition->position);
sl@0: 			break;
sl@0: 		case EWsClOpGetWindowGroupHandle:
sl@0: 			SetReply(CWsWindowGroup::WindowGroupFromIdentifierL(*pData.Int)->ClientHandle());
sl@0: 			break;
sl@0: 		case EWsClOpGetWindowGroupOrdinalPriority:
sl@0: 			SetReply(CWsWindowGroup::WindowGroupFromIdentifierL(*pData.Int)->OrdinalPriority());
sl@0: 			break;
sl@0: 		case EWsClOpGetWindowGroupClientThreadId:
sl@0: 			{
sl@0: 			TThreadId id=CWsWindowGroup::WindowGroupFromIdentifierL(*pData.Int)->WsOwner()->Client().Id();
sl@0: 			ReplyBuf(&id,sizeof(id));
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSendEventToWindowGroup:
sl@0: 			{
sl@0: 			CWsWindowGroup* group=CWsWindowGroup::WindowGroupFromIdentifierL(pData.SendEventToWindowGroup->parameter);
sl@0: 			TWsEvent event=pData.SendEventToWindowGroup->event;
sl@0: 			event.SetHandle(group->ClientHandle());
sl@0: 			// Events in enum TEventCode is protected by capabilities
sl@0: 			if (group->WsOwner()!=this && event.Type()>=EEventNull && event.Type()<EEventUser)
sl@0: 				{
sl@0: 				if (event.Type()<EEventPowerMgmt || event.Type()>=EEventReserved)
sl@0: 					{
sl@0: 					if(!KSecurityPolicy_SwEvent().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SendEventToWindowGroup API")))
sl@0: 						User::Leave(KErrPermissionDenied);
sl@0: 					}
sl@0: 				else
sl@0: 					{
sl@0: 					if (!KSecurityPolicy_PowerMgmt().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SendEventToWindowGroup API")))
sl@0: 						User::Leave(KErrPermissionDenied);
sl@0: 					}
sl@0: 				}
sl@0: 			if (event.Type()==EEventKey && event.Key()->iRepeats!=0)
sl@0: 				CKeyboardRepeat::CancelRepeat(NULL);		//Otherwise we will trip an invarient
sl@0: 			if (!group->EventQueue()->QueueEvent(event))
sl@0: 				User::Leave(KErrNoMemory);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSendEventToAllWindowGroup:
sl@0: 		case EWsClOpSendEventToAllWindowGroupPriority:
sl@0: 		case EWsClOpSendEventToOneWindowGroupPerClient:
sl@0: 			{
sl@0: 			TWsEvent event=pData.SendEventToWindowGroup->event;
sl@0: 			if (event.Type()<0)
sl@0: 				User::Leave(KErrArgument);
sl@0: 			if(event.Type()<EEventUser)
sl@0: 				{
sl@0: 				if (event.Type()<EEventPowerMgmt || event.Type()>=EEventReserved)
sl@0: 					{
sl@0: 					if(!KSecurityPolicy_SwEvent().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SendEventToAllWindowGroup API")))
sl@0: 						User::Leave(KErrPermissionDenied);
sl@0: 					}
sl@0: 				else 
sl@0: 					{
sl@0: 					if (!KSecurityPolicy_PowerMgmt().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SendEventToAllWindowGroup API")))
sl@0: 						User::Leave(KErrPermissionDenied);
sl@0: 					}
sl@0: 				}
sl@0: 			if (!CWsWindowGroup::SendEventToAllGroups(aOpcode!=EWsClOpSendEventToAllWindowGroupPriority
sl@0: 													,aOpcode==EWsClOpSendEventToOneWindowGroupPerClient,*pData.SendEventToWindowGroup))
sl@0: 				User::Leave(KErrNoMemory);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSendMessageToWindowGroup:
sl@0: 			{
sl@0: 			CWsWindowGroup* group=CWsWindowGroup::WindowGroupFromIdentifierL(pData.SendMessageToWindowGroup->identifierOrPriority);
sl@0: 			if (group->WsOwner()!=this)
sl@0: 				{
sl@0: 				if (!KSecurityPolicy_SwEvent().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SendMessageToWindowGroup API")))
sl@0: 					{
sl@0: 					User::Leave(KErrPermissionDenied);
sl@0: 					}
sl@0: 				}
sl@0: 			group->QueueMessageL(pData.SendMessageToWindowGroup->uid, pData.SendMessageToWindowGroup->dataLength,* this);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSendMessageToAllWindowGroups:
sl@0: 		case EWsClOpSendMessageToAllWindowGroupsPriority:
sl@0: 			{
sl@0: 			if ((pData.SendMessageToWindowGroup->dataLength<0) || (pData.SendMessageToWindowGroup->dataLength>=(KMaxTInt/2)))
sl@0: 				{
sl@0: 				User::Leave(KErrArgument);
sl@0: 				}
sl@0: 			CWsWindowGroup::SendMessageToAllGroupsL(*this,aOpcode==EWsClOpSendMessageToAllWindowGroups,*pData.SendMessageToWindowGroup);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpFetchMessage:
sl@0: 			CWsWindowGroup::WindowGroupFromIdentifierL(pData.FetchMessage->windowGroupIdentifier)->FetchMessageL();
sl@0: 			break;
sl@0: 		case EWsClOpGetWindowGroupNameFromIdentifier:
sl@0: 			ReplyGroupName(CWsWindowGroup::WindowGroupFromIdentifierL(pData.GetWindowGroupNameFromIdentifier->identifier)->GroupName(),pData.GetWindowGroupNameFromIdentifier->maxLength);
sl@0: 			break;
sl@0: 		case EWsClOpFindWindowGroupIdentifier:
sl@0: 			{
sl@0: 			if (pData.FindWindowGroupIdentifier->length<0)
sl@0: 				User::Leave(KErrArgument);
sl@0: 			TPtrC ptr(BufferTPtr((TText*)(pData.FindWindowGroupIdentifier+1),pData.FindWindowGroupIdentifier->length));
sl@0: 			SetReply(CWsWindowGroup::FindWindowGroupL(this, pData.FindWindowGroupIdentifier->identifier,
sl@0: 							pData.FindWindowGroupIdentifier->offset,&ptr,NULL)->Identifier());
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpFindWindowGroupIdentifierThread:
sl@0: 			SetReply(CWsWindowGroup::FindWindowGroupL(this, pData.FindWindowGroupIdentifierThread->identifier,0,NULL,
sl@0: 											&pData.FindWindowGroupIdentifierThread->threadId)->Identifier());
sl@0: 			break;
sl@0: 		case EWsClOpSetBackgroundColor:
sl@0: 			for(TInt i=0;i<CWsTop::NumberOfScreens();i++)
sl@0: 				{
sl@0: 				CWsTop::Screen(i)->RootWindow()->SetColor(*pData.rgb);
sl@0: 				}
sl@0: 			break;
sl@0: 		case EWsClOpGetBackgroundColor:
sl@0: 			SetReply(iScreen->RootWindow()->BackColor().Internal());
sl@0: 			break;
sl@0: 		case EWsClOpClaimSystemPointerCursorList:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::ClaimSystemPointerCursorList API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			ClaimSystemPointerCursorListL();
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpFreeSystemPointerCursorList:
sl@0: 			FreeSystemPointerCursorList();
sl@0: 			break;
sl@0: 		case EWsClOpSetSystemPointerCursor:
sl@0: 			{
sl@0: 			CWsObject* pointercursor = NULL;
sl@0: 			if ((pointercursor=HandleToObj(pData.SetSystemPointerCursor->handle, WS_HANDLE_POINTER_CURSOR))==NULL)
sl@0: 				PPanic(EWservPanicSprite);
sl@0: 			
sl@0: 			SetSystemPointerCursorL(pData.SetSystemPointerCursor->number, (CWsPointerCursor* )pointercursor);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpClearSystemPointerCursor:
sl@0: 			ClearSystemPointerCursor(*pData.Int);
sl@0: 			break;
sl@0: 		case EWsClOpSetPointerCursorArea:
sl@0: 			{
sl@0: 			if(KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetPointerCursorArea API")))
sl@0: 				{
sl@0: 				if (!iScreen->IsValidScreenSizeMode(*pData.Int))
sl@0: 					PPanic(EWservPanicScreenModeNumber);
sl@0: 				iScreen->SetPointerCursorArea(pData.SetPointerCursorArea->mode,pData.SetPointerCursorArea->area);
sl@0: 				}
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpPointerCursorArea:
sl@0: 			if (!iScreen->IsValidScreenSizeMode(*pData.Int))
sl@0: 				PPanic(EWservPanicScreenModeNumber);
sl@0: 			
sl@0: 			ReplyRect(iScreen->GetPointerCursorArea(*pData.Int));
sl@0: 			break;
sl@0: 		case EWsClOpSetPointerCursorMode:
sl@0: 			{
sl@0: 			CWsWindowGroup* focusWinGp=CWsTop::FocusWindowGroup();
sl@0: 			if (focusWinGp && focusWinGp->WsOwner()==this)
sl@0: 				{
sl@0: 				TWsPointer::SetPointerCursorMode(*pData.Mode);
sl@0: 				TWsPointer::UpdatePointerCursor();
sl@0: 				}
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSetClientCursorMode :
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetPointerCursorModeIfFocused API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			TWsPointer::SetPointerCursorMode(*pData.Mode);
sl@0: 			TWsPointer::UpdatePointerCursor();
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpPointerCursorMode:
sl@0: 			SetReply(TWsPointer::PointerCursorMode());
sl@0: 			break;
sl@0: 		case EWsClOpSetDefaultSystemPointerCursor:
sl@0: 			SetDefaultSystemPointerCursor(*pData.Int);
sl@0: 			break;
sl@0: 		case EWsClOpClearDefaultSystemPointerCursor:
sl@0: 			SetDefaultSystemPointerCursor(ENoDefaultSystemPointerCursor);
sl@0: 			break;
sl@0: 		case EWsClOpSetPointerCursorPosition:
sl@0: 			{
sl@0: 			CWsWindowGroup* focusWinGp=CWsTop::FocusWindowGroup();
sl@0: 			if ((!focusWinGp || focusWinGp->WsOwner()!=this)&&
sl@0: 				(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetPointerCursorPosition API"))))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			TWsPointer::SetPointerCursorPos(*pData.Point);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpPointerCursorPosition:
sl@0: 			ReplyPoint(TWsPointer::PointerCursorPos());
sl@0: 			break;
sl@0: 		case EWsClOpSetModifierState:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetModifierState API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			TWindowServerEvent::SetModifierState(pData.SetModifierState->modifier,pData.SetModifierState->state);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpGetModifierState:
sl@0: 			SetReply(TWindowServerEvent::GetModifierState());
sl@0: 			break;
sl@0: 		case EWsClOpHeapCount:
sl@0: 			SetReply(CWsMemoryManager::Static()->Count());
sl@0: 			break;
sl@0:  		case EWsClOpDebugInfo:
sl@0: 			DebugInfoL(pData.DebugInfo->iFunction,pData.DebugInfo->iParam,EFalse);
sl@0:  			break;
sl@0:  		case EWsClOpDebugInfoReplyBuf:
sl@0: 			DebugInfoL(pData.DebugInfo->iFunction,pData.DebugInfo->iParam,ETrue);
sl@0:  			break;
sl@0: 		case EWsClOpResourceCount:
sl@0: 			SetReply(iObjectIndex->Count());
sl@0: 			break;
sl@0: 		case EWsClOpHeapSetFail:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::HeapSetFail API")))
sl@0: 				{
sl@0: 				PPanic(EWservPanicPermissionDenied);
sl@0: 				}
sl@0: #if !defined(_DEBUG)
sl@0: 			if (pData.HeapSetFail->type!=RHeap::ENone)
sl@0: 				TWindowServerEvent::NotifyOom();
sl@0: #endif
sl@0: 			// if there is a memory manager and we are making the allocator fail next or 
sl@0: 			// deteministic we want to make sure we test both when the memory manager
sl@0: 			// succeeds and fails in allocating after freeing up memory. we do that by
sl@0: 			// remapping the rate and explicitly telling the memory manager to fail:
sl@0: 			// requested rate  | fail on retry, actual rate
sl@0: 			//        1        |    true      ,    1
sl@0: 			//        2        |    false     ,    1
sl@0: 			//        3        |    true      ,    2
sl@0: 			CWsMemoryManager* memoryManager = NULL;
sl@0: 			TInt rate = pData.HeapSetFail->value;
sl@0: 			TBool memoryManagerRetryFail = EFalse;
sl@0: 			if((pData.HeapSetFail->type == RAllocator::EFailNext || pData.HeapSetFail->type == RAllocator::EDeterministic))
sl@0: 				{
sl@0: 				memoryManager = CWsMemoryManager::Static();
sl@0: 				if(memoryManager)
sl@0: 					{
sl@0: 					memoryManagerRetryFail = (rate % 2 == 1);
sl@0: 					rate = rate / 2 + (memoryManagerRetryFail ? 1 : 0);
sl@0: 					}
sl@0: 				}
sl@0: 
sl@0: 			switch (pData.HeapSetFail->type)
sl@0: 				{	//This log message means you can safely ignore the allocation failures in between
sl@0: 					//see CWindowServer::ReleaseMemory()
sl@0: 				case RAllocator::ENone:
sl@0: 					RDebug::Printf("WSERV Heap: __DbgSetAllocFail() <<<ENone");
sl@0: 					break;
sl@0: 				case RAllocator::EReset:
sl@0: 					RDebug::Printf("WSERV Heap: __DbgSetAllocFail() <<<EReset");
sl@0: 					break;
sl@0: 				default:	
sl@0: 					if (memoryManagerRetryFail)
sl@0: 						RDebug::Printf("WSERV Heap: Memory Manager set to fail on retry");
sl@0: 					RDebug::Printf("WSERV Heap: __DbgSetAllocFail(EUser,%i,%i)>>>", pData.HeapSetFail->type, rate);
sl@0: 					break;
sl@0: 				}
sl@0: 
sl@0: 			if (memoryManager && memoryManagerRetryFail)
sl@0: 				memoryManager->SetFailNextRetry();
sl@0: 			
sl@0: 			if (pData.HeapSetFail->burst >= 0)
sl@0: 				User::__DbgSetBurstAllocFail(RHeap::EUser, pData.HeapSetFail->type, rate, pData.HeapSetFail->burst);
sl@0: 			else
sl@0: 				User::__DbgSetAllocFail(RHeap::EUser, pData.HeapSetFail->type, rate);
sl@0: 			break;
sl@0: 			}
sl@0: 		case EWsClOpRawEvent:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_SwEvent().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SimulateRawEvent API")))
sl@0: 				{
sl@0: 				PPanic(EWservPanicPermissionDenied);
sl@0: 				}
sl@0: 			TRawEvent event(*pData.RawEvent);
sl@0: 			if (TWsPointer::PreProcessDriverEvent(event))
sl@0: 				TWindowServerEvent::ProcessRawEvent(event);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpKeyEvent:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_SwEvent().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SimulateKeyEvent API")))
sl@0: 				{
sl@0: 				PPanic(EWservPanicPermissionDenied);
sl@0: 				}
sl@0: 			TWindowServerEvent::ProcessKeyEvent(*pData.KeyEvent,0);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpLogMessage:
sl@0: 			if (wsDebugLog)
sl@0: 				{
sl@0: 				if (CheckBuffer(*pData.Int, KLogMessageLength))
sl@0: 					wsDebugLog->MiscMessage(CDebugLogBase::ELogImportant,BufferTPtr((TText* )(pData.Int+1),*pData.Int),0);
sl@0: 				}
sl@0: 			break;
sl@0: 		case EWsClOpPasswordEntered:
sl@0: 			CWsPassword::PasswordEntered(this);
sl@0: 			break;
sl@0: 		case EWsClOpComputeMode:
sl@0: 			SetComputeMode(*pData.ComputeMode);
sl@0: 			break;
sl@0: 		case EWsClOpSendOffEventsToShell:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_PowerMgmt().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::RequestOffEvents API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			SetReply(CWsTop::SetSendOffEventsToShell(this,*pData.OffEventsToShell));
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpGetDefModeMaxNumColors:
sl@0: 			{
sl@0: 			SDefModeMaxNumColors colors;
sl@0: 			const TInt screenNumber = *pData.Int;
sl@0: 			if (screenNumber<KDummyScreenNumber || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 				PPanic(EWservPanicScreenNumber);
sl@0: 			else
sl@0: 				{
sl@0: 				CScreen* screen = (screenNumber==KDummyScreenNumber)?iScreen:CWsTop::Screen(screenNumber);
sl@0: 				screen->MaxNumColors(colors.iColors,colors.iGrays);
sl@0: 				colors.iDisplayMode=screen->FirstDefaultDisplayMode();
sl@0: 				}
sl@0: 			ReplyBuf(&colors,sizeof(colors));
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpGetColorModeList:
sl@0: 			{
sl@0: 			const TInt screenNumber = *pData.Int;
sl@0: 			if (screenNumber<KDummyScreenNumber || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 				PPanic(EWservPanicScreenNumber);
sl@0: 			else
sl@0: 				SetReply((screenNumber==KDummyScreenNumber) ? iScreen->ColorModesFlag() : CWsTop::Screen(screenNumber)->ColorModesFlag());
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSetDefaultFadingParams:
sl@0: 			{
sl@0: 			if(KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetDefaultFadingParameters API")))
sl@0: 				{
sl@0: 				iScreen->SetFadingParams(WservEncoding::ExtractFirst8BitValue(*pData.UInt),WservEncoding::ExtractSecond8BitValue(*pData.UInt));
sl@0: 				}
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpPrepareForSwitchOff:
sl@0: 			{
sl@0: 			if(KSecurityPolicy_PowerMgmt().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::PrepareForSwitchOff API")))
sl@0: 				{
sl@0: 				}
sl@0: 			}
sl@0: 			break;
sl@0: 		case EWsClOpSetFaded:
sl@0: 			{
sl@0: 			// Deprecated - retained for BC with applications that retrieve the fade count
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetSystemFaded API")))
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 
sl@0: 			TUint8 blackMap;
sl@0: 			TUint8 whiteMap;
sl@0: 			if (pData.SetSystemFaded->UseDefaultMap())
sl@0: 				iScreen->GetFadingParams(blackMap,whiteMap);
sl@0: 			else
sl@0: 				pData.SetSystemFaded->GetFadingParams(blackMap,whiteMap);
sl@0: 			
sl@0: 			iScreen->RootWindow()->SetSystemFaded(pData.SetSystemFaded->Faded(),blackMap,whiteMap);
sl@0: 			}
sl@0: 		break;
sl@0: 		case EWsClOpLogCommand:
sl@0: 			CWsTop::LogCommand(*pData.LogCommand);
sl@0: 			break;
sl@0: #if defined(__WINS__)
sl@0: 		case EWsClOpRemoveKeyCode:
sl@0: 			iInternalFlags&=~ERemoveKeyCode;
sl@0: 			if (*pData.Bool)
sl@0: 				iInternalFlags|=ERemoveKeyCode;
sl@0: 			break;
sl@0: 		case EWsClOpSimulateXyInput:
sl@0: 			TWsPointer::SetXyInputType(static_cast<TXYInputType>(*pData.XyInput));
sl@0: 			break;
sl@0: #endif
sl@0: 		case EWsClOpNoFlickerFree:
sl@0: 			PPanic(EWservPanicOpcode); //not supported anymore
sl@0: 			break;
sl@0: 		case EWsClOpSetFocusScreen:
sl@0: 			{
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetFocusScreen API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			TInt focusScreen=*pData.Int;
sl@0: 			if (focusScreen>=0 && focusScreen<CWsTop::NumberOfScreens())
sl@0: 				SetReply(CWsTop::SetCurrentFocusScreen(focusScreen));
sl@0: 			else
sl@0: 				SessionPanic(EWservPanicScreenNumber);
sl@0: 			break;
sl@0: 			}
sl@0: 		case EWsClOpGetFocusScreen:
sl@0: 			SetReply(CWsTop::CurrentFocusScreen()->ScreenNumber());
sl@0: 			break;
sl@0: 		case EWsClOpGetNumberOfScreens:
sl@0: 			SetReply(CWsTop::NumberOfScreens());
sl@0: 			break;
sl@0: 		case EWsClOpClearAllRedrawStores:
sl@0: 			CWsTop::ClearAllRedrawStores();
sl@0: 			break;
sl@0: 		case EWsClOpGetGraphicMessage:
sl@0: 			iGraphicMessageQueue.GetGraphicMessage();
sl@0: 			break;
sl@0: 		case EWsClOpGraphicMessageCancel:
sl@0: 			iGraphicMessageQueue.CancelRead();
sl@0: 			break;
sl@0: 		case EWsClOpGraphicAbortMessage:
sl@0: 			iGraphicMessageQueue.AbortMessage(*pData.Int);
sl@0: 			break;
sl@0: 		case EWsClOpGraphicFetchHeaderMessage:
sl@0: 			SetReply(iGraphicMessageQueue.TopClientHandle());
sl@0: 			break;
sl@0: 		case EWsClOpRegisterSurface:
sl@0: 			SetReply(RegisterSurface(pData));
sl@0: 			break;
sl@0: 		case EWsClOpUnregisterSurface:
sl@0: 			UnregisterSurface(pData);
sl@0: 			break;
sl@0: 		case EWsClOpSetCloseProximityThresholds:
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),
sl@0: 					__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetCloseProximityThresholds")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			SetReply(TWsPointer::SetCloseProximityThresholds(pData.ZThresholdPair->enterThreshold,
sl@0: 															 pData.ZThresholdPair->exitThreshold));
sl@0: 			break;
sl@0: 		case EWsClOpSetHighPressureThresholds:
sl@0: 			if(!KSecurityPolicy_WriteDeviceData().CheckPolicy(ClientMessage(),
sl@0: 					__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::SetHighPressureThresholds")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			SetReply(TWsPointer::SetHighPressureThresholds(pData.ZThresholdPair->enterThreshold,
sl@0: 					 									   pData.ZThresholdPair->exitThreshold));
sl@0: 			break;
sl@0: 		case EWsClOpGetEnterCloseProximityThreshold:
sl@0: 			SetReply(TWsPointer::GetEnterCloseProximityThreshold());
sl@0: 			break;
sl@0: 		case EWsClOpGetExitCloseProximityThreshold:
sl@0: 			SetReply(TWsPointer::GetExitCloseProximityThreshold());
sl@0: 			break;
sl@0: 		case EWsClOpGetEnterHighPressureThreshold:
sl@0: 			SetReply(TWsPointer::GetEnterHighPressureThreshold());
sl@0: 			break;
sl@0: 		case EWsClOpGetExitHighPressureThreshold:
sl@0: 			SetReply(TWsPointer::GetExitHighPressureThreshold());
sl@0: 			break;
sl@0: 		case EWsClOpCreateDrawableSource:
sl@0: 			CreateDrawableSourceL(*pData.CreateDrawableSource);
sl@0: 			break;
sl@0: 		case EWsClOpIndicateAppOrientation:
sl@0: 			IndicateAppOrientation(*pData.Orientation);
sl@0: 			break;
sl@0: 		case EWsClOpUnregisterAllTFXEffect:
sl@0: 			RDebug::Printf("[Bug 3344] OpCode EWsClOpUnregisterAllTFXEffect not supported.");
sl@0: 			break;
sl@0: 		default:
sl@0: 			PPanic(EWservPanicOpcode);
sl@0: 			break;
sl@0: 		}
sl@0: 	}
sl@0: /**	Debug information accessor.
sl@0:  * 	
sl@0:  * 
sl@0:  **/
sl@0: void CWsClient::DebugInfoL(TInt aFunction, TInt aParam, TBool aHasReplyBuf) const
sl@0: 	{
sl@0: 	if (aFunction & EWsDebugClassMask)
sl@0: 		SetReply(DebugInfoClassifiedL(aFunction,aParam,aHasReplyBuf));
sl@0: 	else
sl@0: 		DebugInfoUnclassifiedL(aFunction,aParam,aHasReplyBuf);
sl@0: 	}
sl@0: 
sl@0: /**	A wide variety of generally unconnected debug enquiries.
sl@0:  * 
sl@0:  * 
sl@0:  **/
sl@0: void CWsClient::DebugInfoUnclassifiedL(TInt aFunction, TInt aParam, TBool aHasReplyBuf) const
sl@0: 	{
sl@0: 	switch(aFunction)
sl@0: 		{
sl@0: 		case EWsDebugInfoHeap:
sl@0: 			if (aHasReplyBuf)
sl@0: 				{
sl@0: 				TWsDebugHeapInfo heapInfo;
sl@0: 				RHeap& heap=User::Heap();
sl@0: 				heapInfo.iCount=heap.AllocSize(heapInfo.iTotal);
sl@0: 				heapInfo.iAvailable=heap.Available(heapInfo.iLargestAvailable);
sl@0: 				ReplyBuf(&heapInfo,sizeof(heapInfo));
sl@0: 				}
sl@0: 			SetReply(KErrArgument);
sl@0: 			break;
sl@0: 		case EWsDebugSetCheckHeapOnDisconnectClient:
sl@0: 			if (!KSecurityPolicy_PowerMgmt().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::DebugInfo API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			CWsTop::SetCheckHeapOnDisconnectClient(this);
sl@0: 			break;
sl@0: 		case EWsDebugSetCheckHeapOnDisconnectMode:
sl@0: 			if (!KSecurityPolicy_PowerMgmt().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for RWsSession::DebugInfo API")))
sl@0: 				{
sl@0: 				User::Leave(KErrPermissionDenied);
sl@0: 				}
sl@0: 			CWsTop::SetCheckHeapOnDisconnectMode(STATIC_CAST(TWsCheckHeapOnDisconnectMode,aParam));
sl@0: 			break;
sl@0: 		case EWsDebugFetchCheckHeapResult:
sl@0: 			SetReply(CWsTop::FetchCheckHeapResult());
sl@0: 			break;
sl@0: 		case EWsDebugSetEventQueueTest:
sl@0: 			CWsWindowGroup::SetEventQueueTestState(aParam);
sl@0: 			break;
sl@0: 		default:
sl@0: 			SetReply(KErrNotSupported);
sl@0: 			break;
sl@0: 		}
sl@0: 	}
sl@0: 	
sl@0: /**	Selects a debug function based on the class of debug query.
sl@0:  * 
sl@0:  * 
sl@0:  **/
sl@0: TInt CWsClient::DebugInfoClassifiedL(TInt aFunction, TInt aParam, TBool aHasReplyBuf) const
sl@0: 	{//Duplicating the meanings of Classified... this would be a good place for a security check
sl@0: 	//first part of param is always screen number
sl@0: 	TInt buffSpace=aHasReplyBuf?ReplyBufSpace():0;
sl@0: 	if (buffSpace<0)
sl@0: 		return (buffSpace);
sl@0: 		
sl@0: 	const TInt screenNumber = (aParam&EWsDebugArgScreenMask)>>EWsDebugArgScreenShift;
sl@0: 	const TInt functionClass = (aFunction&EWsDebugClassMask);
sl@0: 	CScreen* screen = NULL;
sl@0: 	if (functionClass<EWsDebugClassNonScreen)
sl@0: 		{
sl@0: 		if (screenNumber<0 || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 			return (KErrArgument);
sl@0: 
sl@0: 		screen = CWsTop::Screen(screenNumber);
sl@0: 		}
sl@0: 	WS_ASSERT_DEBUG(screen, EWsPanicNoScreen);
sl@0: 	switch (aFunction&EWsDebugClassMask)
sl@0: 		{
sl@0: 		case EWsDebugClassScreenUiElement:
sl@0: 			return DebugInfoScreenUiL(aFunction,aParam,buffSpace,*screen);
sl@0: 		case EWsDebugClassScreenElementSet:
sl@0: 			return DebugInfoScreenElementSetL(aFunction, aParam, buffSpace, *screen);
sl@0: 		case EWsDebugClassElementSetWindow:
sl@0: 			return DebugInfoElementSetWindowL(aFunction, aParam, buffSpace, *screen);
sl@0: 		case EWsDebugClassElementSetElement:
sl@0: 			return DebugInfoElementSetElementL(aFunction, aParam, buffSpace, *screen);
sl@0: 
sl@0: 		case EWsDebugClassClientWindow:
sl@0: 		default:
sl@0: 			return (KErrNotSupported);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**	Returns debug info about the UIElement entries for a screen.
sl@0:  * 	This describes the general state or size of the element set.
sl@0:  * 	It is indexed via screen num, and optionally element index.
sl@0:  * 	Element index MUST BE 0 when not required.
sl@0:  * 	@return size of buffer required or error code.
sl@0:  **/
sl@0: TInt CWsClient::DebugInfoScreenUiL(TInt aFunction, TInt /* aParam */, TInt aReplyBufSize, CScreen& aScreen) const
sl@0: 	{
sl@0: 	switch(aFunction)
sl@0: 		{
sl@0: 		case EWsDebugGetFastpathMode:
sl@0: 			{
sl@0: 			// obsolete through preq2669
sl@0:             WS_ASSERT_DEBUG(EFalse, EWsPanicDrawCommandsInvalidState);
sl@0: 			return KErrNotSupported;
sl@0: 			}
sl@0: 			
sl@0: 		case EWsDebugSetFastpathMode:
sl@0: 			{
sl@0:             // obsolete through preq2669
sl@0:             WS_ASSERT_DEBUG(EFalse, EWsPanicDrawCommandsInvalidState);
sl@0:             return KErrNotSupported;
sl@0: 			}
sl@0: 			
sl@0: 		case EWsDebugGetUIElementInfoList:
sl@0: 			{
sl@0:             // obsolete through preq2669
sl@0:             WS_ASSERT_DEBUG(EFalse, EWsPanicDrawCommandsInvalidState);
sl@0:             return KErrNotSupported;
sl@0: 			}
sl@0: 			
sl@0: 		case EWsDebugGetUIElementBase:
sl@0: 			{
sl@0:             // obsolete through preq2669
sl@0:             WS_ASSERT_DEBUG(EFalse, EWsPanicDrawCommandsInvalidState);
sl@0:             return KErrNotSupported;
sl@0: 			}
sl@0: 
sl@0: 		case EWsDebugGetUIElementIds:
sl@0: 			{
sl@0:             // obsolete through preq2669
sl@0:             WS_ASSERT_DEBUG(EFalse, EWsPanicDrawCommandsInvalidState);
sl@0:             return KErrNotSupported;
sl@0: 			}
sl@0: 
sl@0: 		case EWsDebugGetSceneElementIdOrder:
sl@0: 			{
sl@0:             // obsolete through preq2669
sl@0:             WS_ASSERT_DEBUG(EFalse, EWsPanicDrawCommandsInvalidState);
sl@0:             return KErrNotSupported;
sl@0: 			}
sl@0: 		case EWsDebugSetFastpathTestMode:
sl@0: 			{
sl@0:             // obsolete through preq2669
sl@0:             WS_ASSERT_DEBUG(EFalse, EWsPanicDrawCommandsInvalidState);
sl@0:             return KErrNotSupported;
sl@0: 			}
sl@0: 			
sl@0: 		case EWsDebugSetFastpathOomMode:
sl@0: 			{
sl@0:             // obsolete through preq2669
sl@0:             WS_ASSERT_DEBUG(EFalse, EWsPanicDrawCommandsInvalidState);
sl@0:             return KErrNotSupported;
sl@0: 			}
sl@0: 		case EWsDebugGetUIElementConfig:
sl@0: 			{
sl@0: 			return DebugReturnConfig(aReplyBufSize,&aScreen.UiElement(),0);
sl@0: 
sl@0: 			}
sl@0: 		default:
sl@0: 			return (KErrNotSupported);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**	Returns debug info about the CWindowElementSet entry for a screen.
sl@0:  * 	This describes the general state or size of the element set
sl@0:  * 	It is indexed via screen num.
sl@0:  * 	@return size of buffer required or error code.
sl@0:  **/
sl@0: TInt CWsClient::DebugInfoScreenElementSetL(TInt aFunction, TInt /*aParam*/, TInt aReplyBufSize, const CScreen& aScreen) const
sl@0: 	{
sl@0: 	const CWindowElementSet& elementSet = aScreen.WindowElements();
sl@0: 	switch (aFunction)
sl@0: 		{
sl@0: 		case EWsDebugSerialSurfacesUpdated:
sl@0: 			return 0;
sl@0: 
sl@0: 		case EWsDebugSurfaceWindowList:
sl@0: 			{
sl@0: 			TInt outSize = elementSet.Count() * sizeof(TWsDebugWindowId);
sl@0: 			if (outSize<=aReplyBufSize)
sl@0: 				{//can stream, so I shall!
sl@0: 				for (TInt index = 0; index < elementSet.Count(); index++)
sl@0: 					{
sl@0: 					const CWsClientWindow& win = *elementSet.DebugWindowAt(index);
sl@0: 					TWsDebugWindowId id=
sl@0: 						{
sl@0: 						win.ClientHandle(), 0
sl@0: 						};
sl@0: 					if (win.WsOwner()!=this)
sl@0: 						id.iOtherGroupId=win.WinGroup()->Identifier();
sl@0: 					ReplyBuf(&id, sizeof(id));
sl@0: 					}
sl@0: 				}
sl@0: 			return outSize;
sl@0: 			}
sl@0: 		default:
sl@0: 			return (KErrNotSupported);
sl@0: 
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**	Returns debug info about a CWindowElement entry.
sl@0:  * 	This describes the window or the background element(s)
sl@0:  * 	It is indexed via screen num, and index in elementset.
sl@0:  * 	@return size of buffer required or error code.
sl@0:  **/
sl@0: TInt CWsClient::DebugInfoElementSetWindowL(TInt aFunction, TInt aParam,
sl@0: 		TInt aReplyBufSize, const CScreen& aScreen) const
sl@0: 	{
sl@0: 	const CWindowElementSet& elementSet = aScreen.WindowElements();
sl@0: 	TUint winIndex = (aParam & EWsDebugArgWindowMask) >> EWsDebugArgWindowShift;
sl@0: 	const TAttributes* winElement = elementSet.DebugBackgroundAt(winIndex);
sl@0: 	if (winElement == NULL)
sl@0: 		{
sl@0: 		return KErrArgument;
sl@0: 		}
sl@0: 
sl@0: 	MWsElement* backElement = winElement->iElement;
sl@0: 	TInt placedCount = elementSet.DebugPlacedCountAt(winIndex);
sl@0: 	switch (aFunction)
sl@0: 		{
sl@0: 		case EWsDebugElementIdList:
sl@0: 			{
sl@0: 			TInt retVal = (placedCount + 1) * sizeof(MWsElement*);
sl@0: 			if (retVal<aReplyBufSize)
sl@0: 				{
sl@0: 				ReplyBuf(&backElement, sizeof(MWsElement*));
sl@0: 				for (TInt index=0; index<placedCount; index++)
sl@0: 					ReplyBuf(&elementSet.DebugPlacedAt(winIndex, index)->iElement, sizeof(MWsElement*));
sl@0: 				}
sl@0: 			return retVal;
sl@0: 			}
sl@0: 		case EWsDebugBackgroundConfig:
sl@0: 			if (backElement == NULL)
sl@0: 				return KErrNotFound;
sl@0: 			else
sl@0: 				return DebugReturnConfig(aReplyBufSize, backElement,
sl@0: 						winElement->DebugFlags());
sl@0: 		case EWsDebugBackgroundBase:
sl@0: 			if (backElement == NULL)
sl@0: 				return KErrNotFound;
sl@0: 			else
sl@0: 				return DebugReturnBase(aReplyBufSize, backElement);
sl@0: 		case EWsDebugBackgroundFlags:
sl@0: 			return DebugReturnFlags(aReplyBufSize, backElement,
sl@0: 					winElement->DebugFlags());
sl@0: 		default:
sl@0: 			return KErrNotSupported;
sl@0: 		//This method can also be extended to return region and state information from the associated window
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**	Returns debug info about a placed element.
sl@0:  * 	It is indexed via screen num, index in elementset, and index in placed element array.
sl@0:  * 	@return size of buffer required or error code.
sl@0:  **/
sl@0: TInt CWsClient::DebugInfoElementSetElementL(TInt aFunction, TInt aParam,
sl@0: 		TInt aReplyBufSize, const CScreen& aScreen) const
sl@0: 	{
sl@0: 	const CWindowElementSet& elementSet = aScreen.WindowElements();
sl@0: 	TUint winIndex = (aParam & EWsDebugArgWindowMask) >> EWsDebugArgWindowShift;
sl@0: 	TUint placeIndex = (aParam & EWsDebugArgElementMask) >> EWsDebugArgElementShift;
sl@0: 	const TAttributes* placedElement = elementSet.DebugPlacedAt(winIndex, placeIndex);
sl@0: 	if (placedElement == NULL)
sl@0: 		{
sl@0: 		return KErrArgument;
sl@0: 		}
sl@0: 
sl@0: 	MWsElement* element = placedElement->iElement;
sl@0: 	if (element == NULL)
sl@0: 		{
sl@0: 		return KErrNotFound;
sl@0: 		}
sl@0: 
sl@0: 	switch (aFunction)
sl@0: 		{
sl@0: 		case EWsDebugPlacedConfig:
sl@0: 			return DebugReturnConfig(aReplyBufSize, element,
sl@0: 					placedElement->DebugFlags());
sl@0: 		case EWsDebugPlacedBase:
sl@0: 			return DebugReturnBase(aReplyBufSize, element);
sl@0: 		case EWsDebugPlacedFlags:
sl@0: 			return DebugReturnFlags(aReplyBufSize, element,
sl@0: 					placedElement->DebugFlags());
sl@0: 		default:
sl@0: 			return KErrNotSupported;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**	Returns a filled in TSurfaceConfiguration from an MWsElement.
sl@0:  * 	Data is usually copied if the buffer is big enough
sl@0:  * 	@return the size of buffer required, or zero if the buffer is acceptable
sl@0:  **/
sl@0: TInt CWsClient::DebugReturnConfig(TInt aReplyBufSize, MWsElement* aElement, TInt /*aFlags*/) const
sl@0: 	{
sl@0: 	if (aElement == NULL)
sl@0: 		{
sl@0: 		return KErrNotReady;
sl@0: 		}
sl@0: 
sl@0: 	TSurfaceConfiguration config(aReplyBufSize);
sl@0: 	TInt retVal=config.Size();
sl@0: 	if (aReplyBufSize)
sl@0: 		{
sl@0: 		retVal = CWindowElementSet::GetConfiguration(config, *aElement);
sl@0: 		if (retVal==KErrNone)
sl@0: 			{
sl@0: 			ReplyBuf(&config, config.Size()); //return code is 0 = "just right"
sl@0: 			}
sl@0: 		}
sl@0: 	return retVal;
sl@0: 	}
sl@0: 
sl@0: /**	Returns the base region of the element.
sl@0:  * 	This region is element relative. There are a number of ways that this does not match the input region:
sl@0:  * 	First, if no region is specified then the extent rectangle is returned
sl@0:  * 	Any region returned has all negative ordinate values clipped. 
sl@0:  * 	Positive values may exceed the extent, but negative values are never returned. 
sl@0:  *  Internally, a region which is only negative is "remembered illegally", but an empty region is returned.
sl@0:  **/
sl@0: TInt CWsClient::DebugReturnBase(TInt /*aReplyBufSize*/, const MWsElement* /*aElement*/)const
sl@0: 	{
sl@0: 	return KErrNotSupported;
sl@0: 	}
sl@0: 
sl@0: /**	Returns the flags associated with the given element.
sl@0:  * 	2 words are inserted.
sl@0:  * 	One represents the MWsElement flags, the other represents CWindowElement or UIElement flags
sl@0:  * 	@return length of two words
sl@0:  **/
sl@0: TInt CWsClient::DebugReturnFlags(TInt aReplyBufSize, const MWsElement* /*aElement*/, TInt aFlags)const
sl@0: 	{
sl@0: 	const TInt KArraySize=2;
sl@0: 	if (aReplyBufSize>KArraySize*sizeof(TInt))
sl@0: 		{
sl@0: 		// First field is for flags from scene element if any
sl@0: 		TInt returns[KArraySize]=
sl@0: 			{
sl@0: 			0, aFlags
sl@0: 			};
sl@0: 		ReplyBuf(returns,KArraySize*sizeof(TInt));
sl@0: 		}
sl@0: 	return KArraySize*sizeof(TInt);
sl@0: 	}
sl@0: 
sl@0: /**	Packages a region for return ans an array of rectangles.
sl@0:  * 	If the buffer is big enough the data is transferred
sl@0:  * 	@return the buffer size required, or an error code if an empty or null pointer is passed in
sl@0:  **/
sl@0: TInt CWsClient::DebugReturnRegion(TInt aReplyBufSize, const TRegion* aRegion, TInt aErrCodeIfEmpty)const
sl@0: 	{
sl@0: 	if (aRegion==NULL)
sl@0: 		return KErrNotReady;
sl@0: 	
sl@0: 	const TInt returnSize=aRegion->Count()*sizeof(TRect);
sl@0: 	if (returnSize==0)
sl@0: 		return aErrCodeIfEmpty;
sl@0: 	
sl@0: 	if (returnSize<=aReplyBufSize)
sl@0: 		ReplyBuf(aRegion->RectangleList(),returnSize);
sl@0: 	
sl@0: 	return returnSize;
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ReplyGroupName(HBufC* aName, TInt aMaxLength)	// static
sl@0: 	{
sl@0: 	if (aName)
sl@0: 		{
sl@0: 		if (aName->Length()>aMaxLength)
sl@0: 			{
sl@0: 			ReplyBuf(aName->Left(aMaxLength));
sl@0: 			SetReply(KErrOverflow);
sl@0: 			}
sl@0: 		else
sl@0: 			ReplyBuf(*aName);
sl@0: 		}
sl@0: 	else
sl@0: 		ReplyBuf(KNullDesC);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::TriggerRedraw()
sl@0: 	{
sl@0: 	RedrawQueue()->TriggerRedraw();
sl@0: 	}
sl@0: 
sl@0: void CWsClient::UpdateWindowOrdinalPrioritys()
sl@0: 	{
sl@0: 	for(CWsWindowGroup* win=iScreen->RootWindow()->Child();win;win=win->NextSibling())
sl@0: 		{
sl@0: 		if (win->WsOwner()==this)
sl@0: 			win->UpdateOrdinalPriority(ETrue);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::DeleteSystemPointerListEntry(TInt aIndex)
sl@0: 	{
sl@0: 	PointerCursor (aIndex)->Close();
sl@0: 	iSystemPointerCursors->Delete(aIndex);
sl@0: 	}
sl@0: 
sl@0: CWsPointerCursor* CWsClient::SystemPointerCursor(TInt aIndex)
sl@0: 	{
sl@0: 	TInt arrayIndex;
sl@0: 	if (iSystemPointerCursors)
sl@0: 		{
sl@0: 		if (FindCursorArrayItem(iSystemPointerCursors, aIndex, arrayIndex))
sl@0: 			return PointerCursor(arrayIndex);
sl@0: 
sl@0: 		// Cursor not defined so try for default cursor
sl@0: 		if (FindCursorArrayItem(iSystemPointerCursors, 0, arrayIndex))
sl@0: 			return PointerCursor(arrayIndex);
sl@0: 		}
sl@0: 
sl@0: 	// If that fails simply return NULL for no cursor
sl@0: 	return NULL;
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SetSystemPointerCursorL(TInt aIndex, CWsPointerCursor* aCursor)
sl@0: 	{
sl@0: 	if (iSystemPointerCursorListOwner!=this)
sl@0: 		PPanic(EWservPanicNotSystemPointerCursorListOwner);
sl@0: 	
sl@0: 	TInt arrayIndex = KErrNotFound;
sl@0: 	if (FindCursorArrayItem(iSystemPointerCursors, aIndex, arrayIndex))
sl@0: 		{
sl@0: 		PointerCursor(arrayIndex)->Close();
sl@0: 		PointerCursor(arrayIndex) = aCursor;
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		TWsCursorArrayItem entry;
sl@0: 		entry.iIndex=aIndex;
sl@0: 		entry.iCursor=aCursor;
sl@0: 		iSystemPointerCursors->InsertIsqL(entry, iCursorKey);
sl@0: 		}
sl@0: 	
sl@0: 	aCursor->Open();
sl@0: 	if (aIndex==iDefaultSystemPointerCursorIndex)
sl@0: 		iDefaultSystemPointerCursor=aCursor;
sl@0: 	TWsPointer::UpdatePointerCursor();
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ClearSystemPointerCursor(TInt aIndex)
sl@0: 	{
sl@0: 	if (iSystemPointerCursorListOwner!=this)
sl@0: 		PPanic(EWservPanicNotSystemPointerCursorListOwner);
sl@0: 	
sl@0: 	TInt arrayIndex;
sl@0: 	if (FindCursorArrayItem(iSystemPointerCursors, aIndex, arrayIndex))
sl@0: 		{
sl@0: 		DeleteSystemPointerListEntry(arrayIndex);
sl@0: 		if (aIndex==iDefaultSystemPointerCursorIndex)
sl@0: 			iDefaultSystemPointerCursor=NULL;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ClaimSystemPointerCursorListL()
sl@0: 	{
sl@0: 	if (iSystemPointerCursorListOwner)
sl@0: 		User::Leave(KErrInUse);
sl@0: 	
sl@0: 	const TInt systemPointerCursorGranularity = 4;
sl@0: 	iSystemPointerCursors = new(ELeave) CArrayFixFlat<TWsCursorArrayItem> (systemPointerCursorGranularity);
sl@0: 	iSystemPointerCursorListOwner=this;
sl@0: 	}
sl@0: 
sl@0: void CWsClient::FreeSystemPointerCursorList()
sl@0: 	{
sl@0: 	if(iSystemPointerCursorListOwner == this)
sl@0: 		{
sl@0: 		iSystemPointerCursorListOwner = NULL;
sl@0: 		
sl@0: 		while(iSystemPointerCursors->Count()>0)
sl@0: 			DeleteSystemPointerListEntry(0);
sl@0: 		
sl@0: 		iDefaultSystemPointerCursor = NULL;
sl@0: 		iDefaultSystemPointerCursorIndex = 0;
sl@0: 		
sl@0: 		delete iSystemPointerCursors;
sl@0: 		iSystemPointerCursors = NULL;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SetDefaultSystemPointerCursor(TInt aIndex)
sl@0: 	{
sl@0: 	TInt arrayIndex;
sl@0: 	if (iSystemPointerCursorListOwner != this)
sl@0: 		PPanic(EWservPanicNotSystemPointerCursorListOwner);
sl@0: 	
sl@0: 	iDefaultSystemPointerCursorIndex = aIndex;
sl@0: 	iDefaultSystemPointerCursor = NULL;
sl@0: 	
sl@0: 	if (aIndex != ENoDefaultSystemPointerCursor &&
sl@0: 		FindCursorArrayItem(iSystemPointerCursors, aIndex, arrayIndex))
sl@0: 		iDefaultSystemPointerCursor = PointerCursor (arrayIndex);
sl@0: 	else
sl@0: 		iDefaultSystemPointerCursor = NULL;
sl@0: 	
sl@0: 	TWsPointer::UpdatePointerCursor();
sl@0: 	}
sl@0: 
sl@0: TBool CWsClient::FindCursorArrayItem(CArrayFixFlat<TWsCursorArrayItem>* aCursorArray,
sl@0: 									 TInt aIndex,TInt& aPosition)
sl@0: 	{
sl@0: 	if (!aCursorArray)
sl@0: 		return EFalse; // No hit if the array isn't even allocated
sl@0: 
sl@0: 	TWsCursorArrayItem entry;
sl@0: 	entry.iIndex = aIndex;
sl@0: 	return aCursorArray->FindIsq(entry, iCursorKey, aPosition)==KErrNone;
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SetClientPriority()
sl@0: 	{
sl@0: 	if (iComputeMode!=RWsSession::EPriorityControlDisabled)
sl@0: 		{
sl@0: 		Client().SetProcessPriority(
sl@0: 				iComputeMode==RWsSession::EPriorityControlComputeOn 
sl@0: 			||	CWsTop::FocusWindowGroupOwner()!=this
sl@0: 				?	EPriorityBackground
sl@0: 			  	:	EPriorityForeground);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SetComputeMode(RWsSession::TComputeMode aComputeMode)
sl@0: 	{
sl@0: 	if (aComputeMode!=RWsSession::EPriorityControlDisabled 
sl@0: 		&& aComputeMode	!=RWsSession::EPriorityControlComputeOn 
sl@0: 		&& aComputeMode	!=RWsSession::EPriorityControlComputeOff)
sl@0: 		PPanic(EWservPanicSetComputeMode);
sl@0: 	iComputeMode=aComputeMode;
sl@0: 	SetClientPriority();
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CompleteMessage(const RMessage2& aMessage,TInt aReason)
sl@0: 	{
sl@0: 	WS_ASSERT_DEBUG(!aMessage.IsNull(),EWsPanicPanicFlagError);
sl@0: 	if (iInternalFlags&EPanicClientAsSoonAsPossible)
sl@0: 		{
sl@0: 		aMessage.Panic(KWSERVSessionPanicCategory,iPanicReason);
sl@0: 		iInternalFlags&=~EPanicClientAsSoonAsPossible;
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		if(!iResponseHandle)
sl@0: 			aMessage.Complete(aReason);
sl@0: 		else
sl@0: 			{
sl@0: 			aMessage.Complete(*iResponseHandle);
sl@0: 			iResponseHandle=NULL;
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ServiceError(const RMessage2& /*aMessage*/,TInt aError)
sl@0: 	{
sl@0: 	CompleteMessage(iClientMessage,aError);	// (finish)
sl@0: 	}
sl@0: 
sl@0: void CWsClient::ServiceL(const RMessage2 &aMessage)	// (step ##1)
sl@0: //
sl@0: // Handle messages for the window server server.
sl@0: //
sl@0: 	{
sl@0: 	iClientMessage=aMessage; // from now on use always the message stored in the session
sl@0: 	if (iInternalFlags&EPanicClientAsSoonAsPossible)
sl@0: 		{
sl@0: 		iClientMessage.Panic(KWSERVSessionPanicCategory,iPanicReason);
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		iPanicReason=KErrNone;
sl@0: 		iReply=KErrNone;
sl@0: 		TBool completeRequest=ETrue;
sl@0: 		DoServiceL(iClientMessage, completeRequest);	// (call #2)
sl@0: 		if (completeRequest)
sl@0: 			CompleteMessage(iClientMessage,iReply);	// (finish)
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SetResponseHandle(RHandleBase* aHandle)
sl@0: 	{
sl@0: 	iResponseHandle = aHandle;
sl@0: 	}
sl@0: 
sl@0: void CWsClient::DoServiceL(const RMessage2& aMessage, TBool& aCompleteRequest)	// (step #2)
sl@0: 	{
sl@0: 	if (aMessage.IsNull())
sl@0: 		PPanic(EWservPanicNullMessageFromClient);
sl@0: 	
sl@0: 	WS_ASSERT_DEBUG(iInternalFlags&EFinishedProcessingCommands,EWsPanicCommandBufferStillBeingProcessed);
sl@0: 
sl@0: 	const TInt function = aMessage.Function();
sl@0: 	switch (function)
sl@0: 		{
sl@0: 	case EWservMessInit:
sl@0: 		StartInitializationL(iConnectionId++);
sl@0: 		break;
sl@0: 	case EWservMessSyncMsgBuf:
sl@0: 	case EWservMessCommandBuffer:	// Process command buffer containing draw ops
sl@0: 		{
sl@0: 		if (!IsInitialised())			
sl@0: 			PPanic(EWservPanicUninitialisedClient);
sl@0: 			
sl@0: 		const TInt err = aMessage.Read(KBufferMessageSlot, iCmdBuf);
sl@0: 		if (!err)
sl@0: 			{
sl@0: 			iReplyOffset=0;
sl@0: 			iDestObj=NULL;
sl@0: 			iNextCmd=iCmdBuf.Ptr();
sl@0: 			DoServiceCommandBuf();	// (call #3.1)
sl@0: 			}
sl@0: 		else if (err!=KErrDied)
sl@0: 			PPanic(EWservPanicDescriptor);
sl@0: 		
sl@0: 		if(function == EWservMessCommandBuffer && CWsTop::FinishEveryFlush())
sl@0: 			Screen()->DoRedrawNow();
sl@0: 		else
sl@0: 			aCompleteRequest=EFalse;
sl@0: 		}
sl@0: 		break;
sl@0: 	case EWservMessShutdown:
sl@0: 		{
sl@0: 		if(!KSecurityPolicy_PowerMgmt().CheckPolicy(ClientMessage(),__PLATSEC_DIAGNOSTIC_STRING("Capability check failed for EWservMessShutdown message ")))
sl@0: 			PPanic(EWservPanicPermissionDenied);
sl@0: 
sl@0: 		if (aMessage.Int0() == EWservShutdownCheck)
sl@0: 			CWsTop::Exit();
sl@0: 		else
sl@0: 			PPanic(EWservPanicHandle);
sl@0: 		}
sl@0: 		break;
sl@0: 	case EWservMessFinish:
sl@0: 		Screen()->DoRedrawNow();
sl@0: 		break;
sl@0: 	default:
sl@0: 		if (function&EWservMessAsynchronousService)
sl@0: 			{
sl@0: 			TRAPD(err, ExecuteAsyncClientCommandL((function&~EWservMessAsynchronousService), aMessage));	// (call #3.2)
sl@0: 			aCompleteRequest = (err!=KErrNone);
sl@0: 			WS_ASSERT_DEBUG((!(iInternalFlags&EPanicClientAsSoonAsPossible))==(!aCompleteRequest), EWsPanicPanicFlagError);
sl@0: 			}
sl@0: 		else if (function&EWservMessAnimDllAsyncCommand)
sl@0: 			{
sl@0: 			CWsAnimDll* const animDll = static_cast<CWsAnimDll*>(HandleToObj(aMessage.Int0(), WS_HANDLE_ANIM_DLL));
sl@0: 			if (!animDll)
sl@0: 				{
sl@0: 				SessionPanic(EWservPanicHandle);
sl@0: 				break;
sl@0: 				}
sl@0: 				
sl@0: 			// it looks wrong to call CommandReply here (not AsyncCommandReply, or something, which doesn't exist), but basically, we can't add a virtual AsyncCommandReplyL to CAnim to correspond to RAnim::AsyncCommandReply as that would break binary and source compatibility for Anim plug-ins; instead asynchronous commands are done by the plug-in having to complete the RMessagePtr2 returned by iFunctions->Message() (or a copy of of that object) for asynchronous commands only
sl@0: 			TRAPD(err, animDll->AnimObjectL(aMessage.Int1())->CommandReply(function&~EWservMessAnimDllAsyncCommand,NULL));
sl@0: 			aCompleteRequest=(err!=KErrNone);
sl@0: 			WS_ASSERT_DEBUG((!(iInternalFlags&EPanicClientAsSoonAsPossible))==(!aCompleteRequest), EWsPanicPanicFlagError);
sl@0: 			}
sl@0: 		else
sl@0: 			SetReply(KErrNotSupported);
sl@0: 		}
sl@0: 	}
sl@0: void CWsClient::RemoteRead(TDes16& aDes, TInt aOffset)
sl@0: 	{
sl@0: 	if (iClientMessage.Read(KRemoteBufferMessageSlot,aDes,aOffset)!=KErrNone)
sl@0: 		SessionPanic(EWservPanicDescriptor);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::RemoteRead(TDes8& aDes, TInt aOffset)
sl@0: 	{
sl@0: 	if (iClientMessage.Read(KRemoteBufferMessageSlot,aDes,aOffset)!=KErrNone)
sl@0: 		SessionPanic(EWservPanicDescriptor);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::RemoteReadL(TDes16& aDes, TInt aOffset)
sl@0: 	{
sl@0: 	iClientMessage.ReadL(KRemoteBufferMessageSlot,aDes,aOffset);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::RemoteReadL(TDes8& aDes, TInt aOffset)
sl@0: 	{
sl@0: 	iClientMessage.ReadL(KRemoteBufferMessageSlot,aDes,aOffset);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::InitStaticsL()
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: void CWsClient::DeleteStatics()
sl@0: 	{
sl@0: 	if (iTextCursorArray)
sl@0: 		{
sl@0: 		const TInt count = iTextCursorArray->Count();
sl@0: 		for (TInt index=0;index<count;index++)
sl@0: 			delete iTextCursorArray->At(index).iCursor;
sl@0: 
sl@0: 		delete iTextCursorArray;
sl@0: 		iTextCursorArray = NULL;
sl@0: 		}
sl@0: 
sl@0: 	// coverity[extend_simple_error] 
sl@0: 	}
sl@0: 		
sl@0: /* CWsClient implementing MWsClient */
sl@0: 
sl@0: TBool CWsClient::HasCapability(TCapability aCapability) const
sl@0: 	{
sl@0: 	return iClient.HasCapability(aCapability);
sl@0: 	}
sl@0: 
sl@0: TSecureId CWsClient::SecureId() const
sl@0: 	{
sl@0: 	return iClient.SecureId();
sl@0: 	}
sl@0: 
sl@0: TVendorId CWsClient::VendorId() const
sl@0: 	{
sl@0: 	return iClient.VendorId();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Makes a new copy of the aData. so it could be deleted after this call.
sl@0: */
sl@0: TInt CWsClient::SendMessage(const CWsGraphicDrawer* aOnBehalfOf,const TDesC8& aData)
sl@0: 	{
sl@0: 	CWsGraphicMessageQueue::CMessage* msg = CWsGraphicMessageQueue::CMessage::New(aData);
sl@0: 	if(msg)
sl@0: 		return SendMessage(aOnBehalfOf, *msg);
sl@0: 	
sl@0: 	return KErrGeneral;
sl@0: 	}
sl@0: 
sl@0: /** adds a message to the message queue
sl@0: @return a postive number to uniquely identify the message
sl@0: */
sl@0: TInt CWsClient::SendMessage(const CWsGraphicDrawer* aOnBehalfOf,CWsMessageData& aData)
sl@0: 	{
sl@0: 	WS_ASSERT_DEBUG(aData.Data().Size(), EWsPanicWsGraphic);
sl@0: 	const CWsGraphicDrawerObject* obj = DrawerObject(aOnBehalfOf);
sl@0: 	WS_ASSERT_DEBUG(obj, EWsPanicWsGraphic);
sl@0: 	if(obj)
sl@0: 		{
sl@0: 		// assign message id
sl@0: 		if(iMessageIdSeq == KMaxTInt) // Wrap if iMessageIdSeq has reached KMaxTInt
sl@0: 			iMessageIdSeq = 0;
sl@0: 		
sl@0: 		iMessageIdSeq++;
sl@0: 		// correct other handles
sl@0: 		aData.iClientHandle = (obj->ClientHandle() | (EWsGraphMessageTypeUser & 0x03));
sl@0: 		aData.iDrawer = obj->Drawer();
sl@0: 		aData.iId = iMessageIdSeq;
sl@0: 		iGraphicMessageQueue.Queue(&aData);
sl@0: 		return iMessageIdSeq;
sl@0: 		}
sl@0: 
sl@0: 	return KErrGeneral;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: CWsGraphicDrawerObject* CWsClient::DrawerObject(const CWsGraphicDrawer* aDrawer)
sl@0: 	{
sl@0: 	const TInt count = ObjectIndex()->Length();
sl@0: 	for(TInt i=0; i<count; i++)
sl@0: 		{
sl@0: 		CWsObject* obj = const_cast<CWsObject*>(ObjectIndex()->At(i));
sl@0: 		if(obj && (WS_HANDLE_GRAPHIC_DRAWER == obj->Type()))
sl@0: 			{
sl@0: 			CWsGraphicDrawerObject* candidate = static_cast<CWsGraphicDrawerObject*>(obj);
sl@0: 			if(candidate->Drawer() == aDrawer)
sl@0: 				return candidate;
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	return NULL;
sl@0: 	}
sl@0: 
sl@0: const CWsGraphicDrawerObject* CWsClient::DrawerObject(const CWsGraphicDrawer* aDrawer) const
sl@0: 	{
sl@0: 	CWsObjectIx* objectIndex = const_cast<CWsClient*>(this)->ObjectIndex();
sl@0: 	const TInt count = objectIndex->Length();
sl@0: 	for(TInt i=0; i<count; i++)
sl@0: 		{
sl@0: 		CWsObject* obj = const_cast<CWsObject*>(objectIndex->At(i));
sl@0: 		if(obj && (WS_HANDLE_GRAPHIC_DRAWER == obj->Type()))
sl@0: 			{
sl@0: 			const CWsGraphicDrawerObject* candidate = static_cast<CWsGraphicDrawerObject*>(obj);
sl@0: 			if(candidate->Drawer() == aDrawer)
sl@0: 				return candidate;
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	return NULL;
sl@0: 	}
sl@0: 
sl@0: TInt CWsClient::RegisterSurface(const TWsClCmdUnion& pData)
sl@0: 	{
sl@0: 	TInt screenNumber = pData.SurfaceRegister->screenNumber;
sl@0: 	if (screenNumber<0 || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 		{
sl@0: 		PPanic(EWservPanicScreenNumber);
sl@0: 		}
sl@0: 	if (pData.SurfaceRegister->surfaceId.Type() == TSurfaceId::EScreenSurface
sl@0: 			|| pData.SurfaceRegister->surfaceId.IsNull())
sl@0: 		{
sl@0: 		PPanic(EWservPanicInvalidSurface);
sl@0: 		}
sl@0: 
sl@0: 	CRegisteredSurfaceMap* surfaceMap = CWsTop::Screen(screenNumber)->SurfaceMap();
sl@0: 	const TSurfaceId& surfaceId = pData.SurfaceRegister->surfaceId;
sl@0: 	TInt err = surfaceMap->Add(*this,surfaceId);
sl@0: 
sl@0: 	switch(err)
sl@0: 		{
sl@0: 	case KErrNone:
sl@0: 	case KErrNoMemory:
sl@0: 	case KErrInUse:
sl@0: 	case KErrArgument:
sl@0: 		break;
sl@0: 	default:
sl@0: 		PPanic(EWservPanicInvalidSurface);
sl@0: 		}
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: void CWsClient::UnregisterSurface(const TWsClCmdUnion& pData)
sl@0: 	{
sl@0: 	TInt screenNumber = pData.SurfaceRegister->screenNumber;
sl@0: 	if (screenNumber<0 || screenNumber>=CWsTop::NumberOfScreens())
sl@0: 		{
sl@0: 		PPanic(EWservPanicScreenNumber);
sl@0: 		}
sl@0: 	TInt err = CWsTop::Screen(screenNumber)->SurfaceMap()->Remove(*this,pData.SurfaceRegister->surfaceId);
sl@0: 	WS_ASSERT_DEBUG((err==KErrNone||err==KErrNotFound), EWsPanicSurfaceMapError);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::CreateDrawableSourceL(const TWsClCmdCreateDrawableSource& aDrawableSourceData)
sl@0: 	{
sl@0: 	CWsDrawableSource* drawableSource = new(ELeave) CWsDrawableSource(this);
sl@0: 	CleanupStack::PushL(drawableSource);
sl@0: 	drawableSource->ConstructL(aDrawableSourceData);
sl@0: 	CleanupStack::Pop();
sl@0: 	}
sl@0: 	
sl@0: void CWsClient::IndicateAppOrientation(TRenderOrientation aOrientation)
sl@0: 	{
sl@0: 	iIndicatedAppOrientation = aOrientation;
sl@0: 	CWsTop::CheckRenderOrientation();
sl@0: 	}
sl@0: 
sl@0: TInt CWsClient::GetIndicatedAppOrientation()
sl@0: 	{
sl@0: 	return iIndicatedAppOrientation;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // class CWsCliObj
sl@0: //
sl@0: 
sl@0: CWsCliObj* CWsCliObj::NewL(CWsClient* aOwner)
sl@0: 	{
sl@0: 	CWsCliObj* self = new(ELeave) CWsCliObj(aOwner);
sl@0: 	CleanupStack::PushL(self);
sl@0: 	self->ConstructL();
sl@0: 	CleanupStack::Pop(self);
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: CWsCliObj::CWsCliObj(CWsClient *aOwner) :
sl@0: 	CWsObject(aOwner, WS_HANDLE_CLIENT)
sl@0: 	{
sl@0: 	}
sl@0: 	
sl@0: void CWsCliObj::ConstructL()
sl@0: 	{
sl@0: 	NewObjL();	
sl@0: 	}
sl@0: 
sl@0: void CWsCliObj::CommandL(TInt aOpcode, const TAny* aCmdData)	// (step #5)
sl@0: 	{
sl@0: 	iWsOwner->ExecuteCommandL(aOpcode,aCmdData);	// (call #6)
sl@0: 	}
sl@0: 
sl@0: CWsObject* CWsClient::HandleToObjUntyped(TInt aHandle)
sl@0: 	{
sl@0: 	return iObjectIndex->HandleToObject(aHandle);
sl@0: 	}
sl@0: 
sl@0: const CWsObject* CWsClient::HandleToObjUntyped(TInt aHandle) const
sl@0: 	{
sl@0: 	return const_cast<CWsClient*>(this)->HandleToObjUntyped(aHandle);
sl@0: 	}
sl@0: 
sl@0: CWsObject* CWsClient::HandleToObj(TInt aHandle, WH_HANDLES aType)
sl@0: 	{
sl@0: 	CWsObject* object = HandleToObjUntyped(aHandle);
sl@0: 	return (object && object->Type() == aType) ? object : NULL;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: const CWsObject* CWsClient::HandleToObj(TInt aHandle, WH_HANDLES aType) const
sl@0: 	{
sl@0: 	return const_cast<CWsClient*>(this)->HandleToObj(aHandle, aType);
sl@0: 	}
sl@0: 
sl@0: void CWsClient::SetRetryFlag(TEventCode aEventCode)
sl@0: 	{
sl@0: 	switch(aEventCode)
sl@0: 		{
sl@0: 		//To be expanded
sl@0: 		case EEventDisplayChanged:
sl@0: 			{
sl@0: 			iInternalFlags |= ERetryDisplayEvent;
sl@0: 			}
sl@0: 		break;
sl@0: 		
sl@0: 		}
sl@0: 	}
sl@0: TBool CWsClient::RetryEvent(TEventCode aEventCode)
sl@0: 	{
sl@0: 	switch(aEventCode)
sl@0: 		{//To be expanded
sl@0: 		case EEventDisplayChanged:
sl@0: 			{
sl@0: 			return (iInternalFlags & ERetryDisplayEvent);
sl@0: 			}
sl@0: 		}
sl@0: 	return EFalse;
sl@0: 	}
sl@0: 
sl@0: void CWsClient::RemoveRetryFlag(TEventCode aEventCode)
sl@0: 	{
sl@0: 	switch(aEventCode)
sl@0: 		{//To be expanded
sl@0: 		case EEventDisplayChanged:
sl@0: 			{
sl@0: 			iInternalFlags &= ~ERetryDisplayEvent;
sl@0: 			}
sl@0: 		break;
sl@0: 		}
sl@0: 	}
sl@0: