--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/test/CapTests/RConnServ/Common/CStep.cpp	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,393 @@
+// Copyright (c) 1997-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:
+// PARAM_MESS_NAME_CStep.CPP
+// 
+//
+
+
+
+//Test Step header
+#include "PARAM_MESS_NAME_CStep.h"
+
+
+//TO BE SAFE
+IMPORT_C TInt StartDialogThread();
+
+CPARAM_MESS_NAMEStep::CPARAM_MESS_NAMEStep()
+/** Each test step initialises it's own name
+*/
+	{
+	// store the name of this test case
+	// this is the name that is used by the script file
+	//DEF iTestStepName = _L("CPARAM_MESS_NAMEStep");
+
+	//The server name and IPC number is obtained and all messages are checked Sync
+	SR_ServerName		= _L("PARAM_SVR_NAME");
+	SR_MESSAGE_TYPE		=	2;
+	SR_MESSAGE_ID		= PARAM_MESS_VALUE;
+	SR_MESSAGE_MASK		= PARAM_MESS_CAPMASK;
+
+	//The iServer_Panic is a unique name from Server,but always truncated to KMaxExitCategoryName
+	
+	iServer_Panic		=	_L("PARAM_SVR_T16_PANIC");
+
+	TCapability cap[] = {ECapabilityPARAM_MESS_NAMECAP, ECapability_Limit};
+	
+	TSecurityInfo info;
+	info.Set(RProcess());
+	TBool result = EFalse;
+	
+	for (TInt i = 0; cap[i] != ECapability_Limit; i++) 
+	{
+	
+		if (!(info.iCaps.HasCapability(cap[i])))
+		{
+			result=ETrue;
+		
+		}
+		
+	}
+	
+	iQueryBundle = CConnectionServParameterBundle::NewL();
+	iQueryBuffer.Create(1024);
+	iResultBuffer.Create(1024);
+	iBadBuffer.Create(4);
+	
+	iExpect_Rejection = result;
+	iStepCap			= PARAM_MESS_CAPMASK;
+
+	//Get a unique thread name
+	ChildThread_SR.Format(_L("ChildThread_%S_%d"),&SR_ServerName,SR_MESSAGE_ID);
+
+	}
+
+/*
+Exec_SendReceive():
+	This Fn is called by the Child Thread
+1.	Create a session with the server
+2.	Test an SendReceive call
+3.	Informs the main thread about the status of the call using
+	a.	iSessionCreated, if the a connection is established
+	b.	iResult_Server, holds the return value for connection 
+	c.	iResult_SR, the return value of SendReceive	call
+*/
+TInt CPARAM_MESS_NAMEStep::Exec_SendReceive()
+	{
+	CTrapCleanup* cleanup = CTrapCleanup::New();
+	_LIT(KEsockSessStartMutex,"KESSMTX"); //Keep the descriptor short
+	RMutex mutex;
+	TInt r;
+	// Protect the openning of the session
+	// with a mutex to stop thread collision
+	FOREVER
+		{
+		r = mutex.CreateGlobal(KEsockSessStartMutex());
+		if (r == KErrNone)
+			break;
+		if (r != KErrAlreadyExists)
+			return r;
+		r=mutex.OpenGlobal(KEsockSessStartMutex());
+		if (r == KErrNone)
+			break;
+		if (r != KErrNotFound)
+			return r;
+		}
+	mutex.Wait(); // the exclusion ensures the session is started atomically
+	iResult_Server=CreateSession(SR_ServerName,TVersion(),2);
+	// Because ESock is now loaded by the Comms Root Server which is generally started during
+	// the boot this should commonly succeed; however for test code this is still a possibility
+	// Hence here we try starting it; this is an atomic operation (and cheap if it's already started)
+	if (iResult_Server==KErrNotFound)
+		{
+		r=StartC32();
+		if (r==KErrNone || r==KErrAlreadyExists)
+			{
+			iResult_Server=CreateSession(SR_ServerName,Version(),2);
+			}
+		}
+	
+	mutex.Signal();
+	mutex.Close();
+	
+	if(iResult_Server==KErrNone)
+		{
+		iSessionCreated = ETrue;
+		const TInt test_id = dispatch_num<PARAM_MESS_VALUE>::result;
+		if(SR_MESSAGE_ID >= 0)
+			iResult_SR = do_execute(Int2Type<test_id>());
+		}
+	delete cleanup;
+	return iResult_Server;
+	}
+
+
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMAccessPointStatusQuery_Cancel>)
+// testing the ECMAccessPointStatusQuery_Cancel IPC message
+	{
+	return SendReceive(ECMAccessPointStatusQuery_Cancel,TIpcArgs(0,0,0,0));
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMAccessPointNotification_SetupThenAwaitThenGetResultOrSize>)
+// testing the ECMAccessPointNotification_SetupThenAwaitThenGetResultOrSize IPC message
+	{
+	return SendReceive(ECMAccessPointNotification_SetupThenAwaitThenGetResultOrSize,TIpcArgs(0,0,0,0));
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMAccessPointNotification_AwaitThenGetResultOrSize>)
+// testing the ECMAccessPointNotification_AwaitThenGetResultOrSize IPC message
+	{
+	// connect with server
+	TInt err = ConnectToServer();
+	if(err != KErrNone)
+		{
+		return err; 
+		}
+	TRequestStatus status;
+	// Make Notification Query reques, this is the setup for the ECMAccessPointNotification_AwaitThenGetResultOrSize
+	TRAP(err,NotificationQueryL(status,iResultBuffer, ENotificationStepTwo));
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	User::WaitForRequest(status);
+	if(status.Int() != KErrNone)
+		{
+		return status.Int();		
+		}
+	// load the result buffer
+	TRAP(err, CConnectionServParameterBundle *bundle = CConnectionServParameterBundle::LoadL(iResultBuffer));
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	// make ECMAccessPointNotification_AwaitThenGetResultOrSize request then start a connection in order for request to complete
+    SendReceive(ECMAccessPointNotification_AwaitThenGetResultOrSize,TIpcArgs(0,&iResultBuffer,0,iSessionRef), status);
+	OpenConn();
+	err = iConn.Start();
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	User::WaitForRequest(status);
+	// make ECMAccessPointNotification_AwaitThenGetResultOrSize request then cancel the notification request
+	SendReceive(ECMAccessPointNotification_AwaitThenGetResultOrSize,TIpcArgs(0,&iBadBuffer,0,iSessionRef), status);
+	SendReceive(ECMAccessPointNotification_Cancel,TIpcArgs(0,0,0,iSessionRef), status);
+	User::WaitForRequest(status);
+	return status.Int();
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMAccessPointNotification_GetResult>)
+	{
+	// connect to server 
+	TInt err = ConnectToServer(271064565);
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	TRequestStatus status;
+	// Make Notification Query request, this is the setup for the ECMAccessPointNotification_AwaitThenGetResultOrSize
+	// using result buffer that is too small, will cause error after ECMAccessPointNotification_AwaitThenGetResultOrSize
+	TRAP(err,NotificationQueryL(status,iBadBuffer, ENotificationStepTwo));
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	User::WaitForRequest(status);
+	// make ECMAccessPointNotification_AwaitThenGetResultOrSize request then start a connection in order for request to complete
+	SendReceive(ECMAccessPointNotification_AwaitThenGetResultOrSize,TIpcArgs(0,&iBadBuffer,0,iSessionRef), status);
+	OpenConn();
+	err = iConn.Start();
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	User::WaitForRequest(status);
+	iConn.Stop();
+	// should return an error due to had buffer
+	TRAP(err, CConnectionServParameterBundle *bundle = CConnectionServParameterBundle::LoadL(iResultBuffer));
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	// Now get result with a buffer of correct size
+	SendReceive(ECMAccessPointNotification_GetResult,TIpcArgs(0,&iResultBuffer,0,iSessionRef), status);
+	User::WaitForRequest(status);
+	if(status.Int() != KErrNone )
+		{
+		return status.Int();
+		}
+	// cancel notification request
+	SendReceive(ECMAccessPointNotification_AwaitThenGetResultOrSize,TIpcArgs(0,&iBadBuffer,0,iSessionRef), status);
+	SendReceive(ECMAccessPointNotification_Cancel,TIpcArgs(0,0,0,iSessionRef), status);
+	User::WaitForRequest(status);
+	return status.Int();
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMAccessPointNotification_Cancel>)
+	{
+	// connect to server 
+	TInt err = ConnectToServer();
+	if(err != KErrNone)
+		{
+		return err;	
+		}
+	TRequestStatus status;
+	// Make Notification Query request, this is the setup for the ECMAccessPointNotification_AwaitThenGetResultOrSize
+	TRAP(err, NotificationQueryL(status, iResultBuffer));
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	User::WaitForRequest(status);
+	if(status.Int()!= KErrNone)
+		{
+		return err;	
+		}
+	// cancel the request
+	SendReceive(ECMAccessPointNotification_Cancel,TIpcArgs(0,0,0,iSessionRef), status);
+	User::WaitForRequest(status);
+	return status.Int(); 
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMCreate>)
+// testing the ECMCreate IPC message
+	{
+	return SendReceive(ECMCreate,TIpcArgs(0,0,0,0));
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMClose>)
+// testing the ECMClose IPC message
+	{
+	return SendReceive(ECMClose,TIpcArgs(0,0,0,0));
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMAttachToTierManager>)
+// testing the ECMAttachToTierManager IPC message
+	{
+	return SendReceive(ECMAttachToTierManager,TIpcArgs(0,0,0,0));
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMAccessPointStatusQuery_DoThenGetResultOrSize>)
+// testing the ECMAccessPointStatusQuery_DoThenGetResultOrSize IPC message
+	{ 
+	return SendReceive(ECMAccessPointStatusQuery_DoThenGetResultOrSize,TIpcArgs(0,0,0,0));
+	}
+	
+TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECMAccessPointStatusQuery_GetResult>)
+	{
+	// connect to server with specified tier
+	TInt err = ConnectToServer(271064565);
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	
+	// make an access point query with a buffer that is too small to hold the result
+	TRAP(err, 
+		AccessPointQuery(iBadBuffer);
+		CConnectionServParameterBundle *bundle = CConnectionServParameterBundle::LoadL(iResultBuffer);
+		);
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	TRequestStatus status;
+	// get result with a buffer of sufficient size
+	SendReceive(ECMAccessPointStatusQuery_GetResult,TIpcArgs(&iResultBuffer), status);
+	User::WaitForRequest(status);
+	return status.Int();
+	}
+
+
+TInt CPARAM_MESS_NAMEStep::ConnectToServer(TUint aTierId)
+// connect to the RConnServer with specified Tier Uid
+	{
+	TInt result;
+    TPckgBuf<TInt> session(iSessionRef);
+    result = SendReceive(ECMAttachToTierManager,TIpcArgs(aTierId, &session));
+    iSessionRef = session(); //-- this is the subsession handle
+    return result;
+	}
+	
+TInt CPARAM_MESS_NAMEStep::AccessPointQuery(RBuf8& aBuf)
+// Make access point status query
+	{
+	// build a query
+	TAccessPointStatusFilter filter = BuildQuery();
+	TRAPD(err, AddFilterToQueryL(*iQueryBundle, filter));
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	err = iQueryBundle->Store(iQueryBuffer);
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	
+	TRequestStatus status;
+	SendReceive(ECMAccessPointStatusQuery_DoThenGetResultOrSize, TIpcArgs(&iQueryBuffer,  &aBuf, 0,iSessionRef),status);
+	User::WaitForRequest(status);
+	return status.Int();
+	}
+	
+TAccessPointStatusFilter CPARAM_MESS_NAMEStep::BuildQuery(TFilterType aType)
+// Build a query
+	{
+	TAccessPointStatusFilter filter;
+	switch(aType)
+		{
+		case ENotificationStepTwo :
+			filter.Configured(EAccessPointFlagIgnore);
+			filter.Restricted(EAccessPointFlagIgnore);
+			filter.Available(EAccessPointFlagIgnore);  
+			filter.Started(EAccessPointFlagMatchTrue);
+			break;
+		default :
+			filter.Configured(EAccessPointFlagMatchTrue);
+			filter.Restricted(EAccessPointFlagMatchAny);
+			filter.Available(EAccessPointFlagIgnore);
+			filter.Started(EAccessPointFlagIgnore);
+			break;	
+		};
+	return filter;
+	}
+	
+void CPARAM_MESS_NAMEStep::AddFilterToQueryL(CConnectionServParameterBundle& aBundle,TAccessPointStatusFilter& aFilter )
+// Add a filter to the query
+	{
+	aBundle.AddMatchConditionL(aFilter);
+	aBundle.AddParameterSetToReturnL(XAccessPointGenericParameterSet::Type());
+	}
+	
+void CPARAM_MESS_NAMEStep::NotificationQueryL(TRequestStatus& aStatus, RBuf8& aBuf, TFilterType aFilterType)
+// Make access point Notification query
+	{
+	TAccessPointStatusFilter filter = BuildQuery(aFilterType);
+	AddFilterToQueryL(*iQueryBundle, filter);
+	User::LeaveIfError(iQueryBundle->Store(iQueryBuffer));
+	SendReceive(ECMAccessPointNotification_SetupThenAwaitThenGetResultOrSize, TIpcArgs(&iQueryBuffer,  &aBuf, 0,iSessionRef),aStatus);
+	}
+
+TInt CPARAM_MESS_NAMEStep::OpenConn()
+// Open an rconnection
+	{
+	TInt err = iSockServ.Connect();
+	if(err != KErrNone)
+		{
+		return err;
+		}
+	return iConn.Open(iSockServ);
+	}
+