--- a/commsprocess/commsrootserverconfig/ts_rootserver/testcpm/testcpm.cpp	Tue Aug 24 14:43:02 2010 +0100
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,376 +0,0 @@
-// Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).
-// All rights reserved.
-// This component and the accompanying materials are made available
-// under the terms of "Eclipse Public License v1.0"
-// which accompanies this distribution, and is available
-// at the URL "http://www.eclipse.org/legal/epl-v10.html".
-//
-// Initial Contributors:
-// Nokia Corporation - initial contribution.
-//
-// Contributors:
-//
-// Description:
-//
-
-#include <cflog.h>
-#include <cfshared.h>
-using namespace CommsFW;
-#include <cfmsgs.h>
-#include <rsshared.h>
-#include "../RootServerTest.h"
-
-__CFLOG_STMT(_LIT8(KLogTestCPM, "TestCPM");) // subsystem name
-_LIT( KTestCpmPanic, "TestCpm" );
-const TText8* const KSubModules[] = { _S8("Test Protocol1"), _S8("Test Protocol2"), _S8("Test Protocol3") };
-
-
-class CDeathTimer : public CTimer
-	{
-public:
-	static CDeathTimer* NewL(TInt aAfter)
-		{
-		CDeathTimer* self = new(ELeave) CDeathTimer;
-		CleanupStack::PushL(self);
-		self->ConstructL();
-		CleanupStack::Pop(self);
-		CActiveScheduler::Add(self);
-		self->After(aAfter);
-		return self;
-		}
-protected:
-	CDeathTimer() : CTimer(EPriorityStandard)
-		{
-		}
-	void RunL()
-		{
-		// Go not gracefully into that good night
-		User::Invariant();
-		}
-	};
-
-class CChannelHandler;
-class CTestModule : public CBase
-	{
-public:
-	enum {EPriority=1000}; //< priority of this Active Object
-public:
-	~CTestModule();
-	void CFMessageReceived(TCFMessage& aMsg);
-	static CTestModule* NewL(TCFModuleInfo* aStartupArgs);
-	void ConstructL(TCFModuleInfo* aStartupArgs);
-	void LoggedAfter(TInt aAfterMS, const TDesC8& aDescription);
-private:
-	CChannelHandler* iChannelHandler;
-	TTestModuleIniDataContainer iDelayTimes;
-	TInt iDiscoverPos;
-	CDeathTimer* iDeathTimer;
-	};
-
-class CChannelHandler:public CActive
-	{
-public:
-	static CChannelHandler* NewL(RCFChannel::TMsgQueues aRxQueues, 
-									RCFChannel::TMsgQueues aTxQueues, CTestModule* aModule);
-	void RunL();
-	TInt Send(TCFMessage);
-	~CChannelHandler();
-protected:
-	virtual void DoCancel();
-private:
-	void ConstructL(RCFChannel::TMsgQueues aRxQueues, 
-					RCFChannel::TMsgQueues aTxQueues, CTestModule* aModule);
-	CChannelHandler();
-private:
-	CTestModule* iModule;
-	RCFChannelPair iChannelPair;
-	};
-
-
-//
-// CChannelHandler class definitions
-//
-
-CChannelHandler::CChannelHandler():CActive(CActive::EPriorityStandard)
-	{
-	CActiveScheduler::Add(this);
-	}
-
-CChannelHandler* CChannelHandler::NewL(RCFChannel::TMsgQueues aRxQueues, 
-									RCFChannel::TMsgQueues aTxQueues, CTestModule* aModule)
-	{
-	CChannelHandler* pHandler = new (ELeave) CChannelHandler;
-	pHandler->ConstructL(aRxQueues, aTxQueues, aModule);
-	return pHandler;
-	}
-
-void CChannelHandler::ConstructL(RCFChannel::TMsgQueues aRxQueues, 
-									RCFChannel::TMsgQueues aTxQueues, CTestModule* aModule)
-	{
-	iModule = aModule;
-	iChannelPair.CreateSend(aTxQueues);
-	iChannelPair.CreateRecv(aRxQueues);
-	SetActive();
-	iChannelPair.NotifyDataAvailable(*this);
-	}
-
-void CChannelHandler::DoCancel(void)
-	{
-	iChannelPair.CancelDataAvailable();
-	}
-
-TInt CChannelHandler::Send(TCFMessage aMsg)
-	{
-	TRequestStatus status;
-	iChannelPair.NotifySpaceAvailable(*this);
-	User::WaitForRequest(status);
-	return iChannelPair.Send(aMsg);
-	}
-
-void CChannelHandler::RunL()
-	{
-
-	if (iStatus != KErrNone)
-		{
-		User::Invariant();
-		}
-
-	// No error. Take the message from the channel.
-	TCFMessage msg;
-	TInt err = iChannelPair.Receive(msg);
-	if (KErrNone == err)
-		{
-		//Pass the message
-		iModule->CFMessageReceived(msg);
-		//Pend again
-		SetActive();
-		iChannelPair.NotifyDataAvailable(*this);
-		}
-	else
-		{
-		User::Invariant();
-		}
-	}
-
-CChannelHandler::~CChannelHandler()
-	{
-	if(IsActive())
-		Cancel();
-	iChannelPair.CloseNonGracefully();
-	}	
-
-
-//
-// implementation of CTestServer
-//
-
-CTestModule* CTestModule::NewL(TCFModuleInfo* aStartupArgs)
-/**
- * Create a new CCommServer.
- *
- * This is not a normal 2 phase contruction. If the allocation of the object
- * fails we will panic with -4 which means that something is very wrong.
- */
-	{
-	CTestModule* pS;
-	CleanupStack::PushL(pS = new CTestModule);
-	__ASSERT_ALWAYS(pS!=NULL, User::Panic( KTestCpmPanic, KErrNoMemory));
-#ifdef SYMBIAN_C32ROOT_API_V3
-	pS->ConstructL(aStartupArgs);
-#else
-	TRAPD(r, pS->ConstructL(aStartupArgs));
-	__ASSERT_ALWAYS(r==KErrNone, User::Panic( KTestCpmPanic, KErrNoMemory));
-#endif
-	CleanupStack::Pop(pS);
-	return pS;
-	}
-
-
-void CTestModule::ConstructL(TCFModuleInfo* aStartupArgs)
-	{
-	if (aStartupArgs->iIniData != NULL)
-		{
-		if (aStartupArgs->iIniData->Length() == sizeof(iDelayTimes))
-			{
-			TTestModuleIniData pkg;
-			pkg.Copy(*(aStartupArgs->iIniData));
-#if defined(SYMBIAN_C32ROOT_API_V3)
-			delete aStartupArgs->iIniData;
-#endif
-
-			iDelayTimes = pkg.iParams;
-
-			if(iDelayTimes.iInitDelay == EXIT_BEFORE_RENDEZVOUS)
-				User::Leave(KErrGeneral);
-			else if(iDelayTimes.iInitDelay > 0)
-				LoggedAfter(iDelayTimes.iInitDelay, _L8("Init"));
-			else if(iDelayTimes.iInitDelay == PANIC_BEFORE_RENDEZVOUS)
-				User::Panic(_L("TESTCPM"), 1);
-
-			__CFLOG_5( KLogTestCPM, KLogCode, 
-				_L8("TestCpm[%LU] - iIniData delays (msec): discoveryDelay %d bindDelay %d unbindDelay %d shutdownDelay %d"), 
-						 RThread().Id().Id(), iDelayTimes.iDiscoveryDelay, iDelayTimes.iBindDelay,
-						 iDelayTimes.iUnbindDelay, iDelayTimes.iShutdownDelay);
-
-			iChannelHandler = CChannelHandler::NewL(aStartupArgs->iRxQueues, aStartupArgs->iTxQueues, this);
-
-			RThread::Rendezvous(KErrNone);
-
-			if(iDelayTimes.iInitDelay == PANIC_AFTER_RENDEZVOUS)
-				User::Panic(_L("TESTCPM"), 1);
-
-			}
-		else
-			{
-			__CFLOG_1( KLogTestCPM, KLogCode, _L("TestCpm[%LU] - iIniData mismatched"), RThread().Id().Id() );
-#if defined(SYMBIAN_C32ROOT_API_V3)
-			delete aStartupArgs->iIniData;
-#endif
-			ASSERT(0);
-			}
-		}
-	else
-		{
-		__CFLOG_1( KLogTestCPM, KLogCode, _L("TestCpm[%LU] - No iIniData"), RThread().Id().Id() );
-		ASSERT(0);
-		}
-	}
-
-void CTestModule::CFMessageReceived(TCFMessage& aMsg)
-	{
-	
-	//It is called when a new message arrives from incomming channel
-	switch (aMsg.Code())
-		{
-		case TCFCommsMessage::ECodeDiscover:
-			{
-			// now wait for delay
-			__CFLOG(KLogTestCPM, KLogCode, _L("TestCpm Discover message received"));
-
-			LoggedAfter(iDelayTimes.iDiscoveryDelay, _L8("Discovery"));
-			const TCFDiscoverMsg& msg = reinterpret_cast<const TCFDiscoverMsg&>(aMsg);
-			// we return our sub-modules one at a time to make sure the RootServer copes with iterative discovery
-			const TInt numSubModules = sizeof(KSubModules) / sizeof(KSubModules[0]);
-			ASSERT(msg.Size() > 0);
-			ASSERT(iDiscoverPos < numSubModules);
-			if(msg.Reset())
-				iDiscoverPos = 0;
-			TCFSubModuleName name;
-			const TText8* subMod = KSubModules[iDiscoverPos++];
-			name.Copy(subMod);
-			msg.SubModuleNames()[0] = name;
-			TBool discoveryEnded = (iDiscoverPos == numSubModules);
-			TCFDiscoverRespMsg diskresp(msg.Identifier(), 1, !discoveryEnded);
-			TInt err = iChannelHandler->Send(diskresp);
-			if(KErrNone != err)
-				{
-       		    User::Invariant();
-				}
-			if(discoveryEnded && iDelayTimes.iDeathDelay != NO_PREMATURE_DEATH)
-				{
-				TRAP(err, iDeathTimer = CDeathTimer::NewL(iDelayTimes.iDeathDelay * 1000));
-				ASSERT(iDeathTimer);
-				}
-				
-			}
-			break;
-
-		case TCFCommsMessage::ECodeBind:
-			{
-			__CFLOG(KLogTestCPM, KLogCode, _L("TestCpm Bind message received"));
-			// now wait for delay
-			LoggedAfter(iDelayTimes.iBindDelay, _L8("Bind"));
-			const TCFBindMsg& msg = reinterpret_cast<const TCFBindMsg&>(aMsg);
-			TCFBindCompleteMsg resp(msg.Identifier(), KErrNone);
-			TInt err = iChannelHandler->Send(resp);
-			if(KErrNone != err)
-				{
-				User::Invariant();
-				}
-			}
-			break;
-
-		case TCFCommsMessage::ECodeUnbind: 
-			{
-			__CFLOG(KLogTestCPM, KLogCode, _L("TestCpm UnBind message received"));
-			// now wait for delay
-			LoggedAfter(iDelayTimes.iUnbindDelay, _L8("Unbind"));
-			const TCFUnbindMsg& msg = reinterpret_cast<const TCFUnbindMsg&>(aMsg);
-			TCFUnbindCompleteMsg resp(msg.Identifier(), KErrNone);
-			TInt err = iChannelHandler->Send(resp);
-			if(KErrNone != err)
-				{
-				User::Invariant();
-				}
-			}
-			break;
-
-		case TCFCommsMessage::ECodeShutdown:
-			// now wait for delay
-			__CFLOG(KLogTestCPM, KLogCode, _L("TestCpm Shutdown message received"));
-			LoggedAfter(iDelayTimes.iShutdownDelay, _L8("Shutdown"));
-
-			CActiveScheduler::Stop();
-			break;
-		default:;
-			User::Invariant();
-		}
-	}
-
-	
-CTestModule::~CTestModule()
-	{
-	delete iChannelHandler;
-	delete iDeathTimer;
-	}
-
-void CTestModule::LoggedAfter(TInt aAfterMS, const TDesC8& aDescription)
-	{ 
-	(void) aDescription;
-	__CFLOG_2(KLogTestCPM, KLogCode, _L8("TestCpm: %d ms %S pause"), aAfterMS, &aDescription);
-	User::After(aAfterMS * 1000);
-	__CFLOG_1(KLogTestCPM, KLogCode, _L8("TestCpm: %S pause complete"), &aDescription);
-	}
-
-
-//---------------
-
-void DoModuleThreadL(TAny * aArg)
-	{
-	TCFModuleInfo* args = reinterpret_cast<TCFModuleInfo*>(aArg);
-	
-	CActiveScheduler*  scheduler = new (ELeave) CActiveScheduler;
-	CleanupStack::PushL(scheduler);
-	CActiveScheduler::Install(scheduler); 
-
-	CTestModule *pTm = CTestModule::NewL(args);
-
-    __CFLOG_1( KLogTestCPM, KLogCode, _L("TestCpm[%LU] - Completed rendezvous."), RThread().Id().Id() );
-
-	CActiveScheduler::Start();
-
-	__CFLOG_1( KLogTestCPM, KLogCode, _L("TestCpm[%LU] - Exiting thread function"), RThread().Id().Id() );
-
-	delete pTm;
-	CActiveScheduler::Install(NULL);
-	CleanupStack::PopAndDestroy(scheduler);
-	}
-
-EXPORT_C TInt ModuleThread(TAny * aArg)
-	{
-	CTrapCleanup* cleanup = CTrapCleanup::New();
-	if(!cleanup)
-		return KErrNoMemory;	
-
-	TRAPD(ret, DoModuleThreadL(aArg))
-	if (ret!=KErrNone)
-		{
-		__CFLOG(KLogTestCPM, KLogCode, _L("ModuleThread failed to create TestCpm"));
-		}
-
-	delete cleanup;
-	return ret;
-	}
-
-
-