Symaptic: os/mm/mmtestenv/mmtestfw/Source/SimulProc/SimulProcSession.cpp@bde4ae8d615e (annotated)

sl@0	1	// Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0	2	// All rights reserved.
sl@0	3	// This component and the accompanying materials are made available
sl@0	4	// under the terms of "Eclipse Public License v1.0"
sl@0	5	// which accompanies this distribution, and is available
sl@0	6	// at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0	7	//
sl@0	8	// Initial Contributors:
sl@0	9	// Nokia Corporation - initial contribution.
sl@0	10	//
sl@0	11	// Contributors:
sl@0	12	//
sl@0	13	// Description:
sl@0	14	//
sl@0	15
sl@0	16	#include <simulprocserver.h>
sl@0	17
sl@0	18	EXPORT_C void CSimulProcServer::SessionClosed()
sl@0	19	{
sl@0	20	iSessionCount--;
sl@0	21	if (iSessionCount == 0)
sl@0	22	CActiveScheduler::Stop();
sl@0	23	}
sl@0	24
sl@0	25
sl@0	26	EXPORT_C CSimulProcServer::CSimulProcServer()
sl@0	27	: CServer2(EPriorityNormal)
sl@0	28	{
sl@0	29	}
sl@0	30
sl@0	31
sl@0	32	EXPORT_C CSimulProcServer::~CSimulProcServer()
sl@0	33	{
sl@0	34	}
sl@0	35
sl@0	36
sl@0	37	EXPORT_C CSimulProcSession::CSimulProcSession()
sl@0	38	/**
sl@0	39	* Constructor
sl@0	40	*/
sl@0	41	{
sl@0	42	}
sl@0	43
sl@0	44	EXPORT_C CSimulProcSession::~CSimulProcSession()
sl@0	45	/**
sl@0	46	* Destructor
sl@0	47	*/
sl@0	48	{
sl@0	49	const CSimulProcServer* p=reinterpret_cast<const CSimulProcServer*>(Server());
sl@0	50	// // Shuts Down the server if this is the last open session
sl@0	51	const_cast<CSimulProcServer*>(p)->SessionClosed();
sl@0	52	}
sl@0	53
sl@0	54
sl@0	55
sl@0	56
sl@0	57
sl@0	58	EXPORT_C CSession2* CSimulProcServer::NewSessionL(const TVersion& /aVersion/,const RMessage2& /aMessage/) const
sl@0	59	/**
sl@0	60	* @param RMessage - RMessage for the session open
sl@0	61	* Secure version
sl@0	62	*/
sl@0	63	{
sl@0	64	CSimulProcSession* session = new (ELeave) CSimulProcSession();
sl@0	65	const_cast<CSimulProcServer*>(this)->iSessionCount++;
sl@0	66	return session;
sl@0	67	}
sl@0	68
sl@0	69
sl@0	70
sl@0	71	EXPORT_C void CSimulProcSession::ServiceL(const RMessage2& aMessage)
sl@0	72	/**
sl@0	73	* @param aMessage - Function and data for the session
sl@0	74	* Session was created by pure virtual CTestServer::NewSessionL()
sl@0	75	* Message Functions defined in TestExecuteClient.h
sl@0	76	*
sl@0	77	* EOpenTestStep - Creates a new subsession
sl@0	78	* ERunTestStep - Executes the test step asynchronously
sl@0	79	* EAbortTestStep - Kill()'s the executing test step
sl@0	80	* ECloseTestStep - Free's the resource
sl@0	81	*
sl@0	82	* Secure and non-secure variants
sl@0	83	* There are two modes of operation:
sl@0	84	* Test step is opened with the shared data boolean set to FALSE:
sl@0	85	* Create a new CStepControl instance and hence a new thread in its own heap
sl@0	86	* Consecutive or Concurrent operation
sl@0	87	* Test step is opened with the shared data boolean set to TRUE:
sl@0	88	* Create a CPersistentStepControl and keep reusing it, and its thread
sl@0	89	* Consecutive operation only
sl@0	90	*/
sl@0	91	{
sl@0	92	switch(aMessage.Function())
sl@0	93	{
sl@0	94	case EMMTSOpenTestStep :
sl@0	95	{
sl@0	96	TBuf<256> stepName;
sl@0	97	// Read the step name from the descriptor
sl@0	98	aMessage.ReadL(0,stepName);
sl@0	99	const CSimulProcServer* p=reinterpret_cast<const CSimulProcServer*>(Server());
sl@0	100	iTestStep = p->CreateTestStep(stepName);
sl@0	101	aMessage.Complete(KErrNone);
sl@0	102	}
sl@0	103
sl@0	104	break;
sl@0	105	case EMMTSStartProcessing:
sl@0	106	{
sl@0	107	if (!iTestStep)
sl@0	108	aMessage.Complete(KErrNotReady);
sl@0	109	else
sl@0	110	{
sl@0	111	if (iActiveCallback)
sl@0	112	iActiveCallback->Cancel();
sl@0	113	delete iActiveCallback;
sl@0	114	iActiveCallback = NULL;
sl@0	115	iActiveCallback = new (ELeave) CActiveCallback(aMessage);
sl@0	116	iTestStep->StartProcessing(iActiveCallback->ActiveStatus());
sl@0	117	}
sl@0	118	}
sl@0	119
sl@0	120	break;
sl@0	121	case EMMTSStopProcessing :
sl@0	122	{
sl@0	123	if (!iTestStep)
sl@0	124	aMessage.Complete(KErrNotReady);
sl@0	125	else
sl@0	126	{
sl@0	127	TBuf8<256> message;
sl@0	128	TVerdict verdict = iTestStep->EndProcessingAndReturnResult(message);
sl@0	129	TPckgBuf<TVerdict> v(verdict);
sl@0	130	aMessage.WriteL(0,v);
sl@0	131	aMessage.WriteL(1,message);
sl@0	132	aMessage.Complete(KErrNone);
sl@0	133	}
sl@0	134	break;
sl@0	135	}
sl@0	136	case EMMTSClose :
sl@0	137	{
sl@0	138	aMessage.Complete(KErrNone);
sl@0	139	}
sl@0	140
sl@0	141	break;
sl@0	142	default:
sl@0	143	break;
sl@0	144	}
sl@0	145	}
sl@0	146
sl@0	147	void CSimulProcSession::CActiveCallback::RunL()
sl@0	148	{
sl@0	149	iMessage.Complete(iStatus.Int());
sl@0	150	}
sl@0	151
sl@0	152	void CSimulProcSession::CActiveCallback::DoCancel()
sl@0	153	{
sl@0	154
sl@0	155	}
sl@0	156
sl@0	157	CSimulProcSession::CActiveCallback::CActiveCallback(const RMessage2& aMessage)
sl@0	158	: CActive(EPriorityNormal), iMessage(aMessage)
sl@0	159	{
sl@0	160	CActiveScheduler::Add(this);
sl@0	161	}
sl@0	162
sl@0	163	TRequestStatus& CSimulProcSession::CActiveCallback::ActiveStatus()
sl@0	164	{
sl@0	165	SetActive();
sl@0	166	iStatus = KRequestPending;
sl@0	167	return iStatus;
sl@0	168	}
sl@0	169
sl@0	170
sl@0	171	EXPORT_C CSimulProcTestStep::CSimulProcTestStep()
sl@0	172	{
sl@0	173	}
sl@0	174
sl@0	175	EXPORT_C CSimulProcTestStep::~CSimulProcTestStep()
sl@0	176	{
sl@0	177	}

author	sl@SLION-WIN7.fritz.box
	Fri, 15 Jun 2012 03:10:57 +0200
changeset 0	bde4ae8d615e
permissions	-rw-r--r--