--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/commsprocess/commsrootserverconfig/TE_rootserver/testcpm/testcpm.cpp	Mon Sep 06 13:49:23 2010 +0100
@@ -0,0 +1,374 @@
+// 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;
+	}
+
+