// 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;

	}