/*
* Copyright (c) 2004-2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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: 
* tocsp.cpp
*
*/


#include "log.h"
#include "tocspserver.h"
#include "tocspclientserver.h"

using Swi::Test::COcspServer;
using Swi::Test::COcspSession;
using Swi::Test::COcspServerShutdown;

static void PanicClient(const RMessagePtr2& aMessage, 
						Swi::Test::TOcspServerPanic aPanic)
	{
	aMessage.Panic(Swi::Test::KOcspServerName, aPanic);
	}

/////
///// TOCSP Server
/////

/*static*/ COcspServer* COcspServer::NewLC()
	{
	COcspServer* self = new(ELeave) COcspServer();
	CleanupStack::PushL(self);
	self->ConstructL();
	return self;
	}
	
void COcspServer::AddSession()
	{
	FLOG(_L("Console Server added session"));
	++iSessionCount;
	iShutdown->Cancel();
	}
	
void COcspServer::DropSession()
	{
	FLOG(_L("Console Server dropped session"));
	if (--iSessionCount==0)
		{
		iShutdown->Start();
		FLOG(_L("Console Server shutting down"))
		}
	}

COcspServer::~COcspServer()
	{
	delete iShutdown;
	delete iConsole;
	FLOG(_L("Console Server destructor"))
	}

COcspServer::COcspServer() : CServer2(EPriorityNormal, ESharableSessions)
	{
	}

void COcspServer::ConstructL()
	{
	StartL(Swi::Test::KConsoleServerName);
	iConsole = Console::NewL(_L("SWI Console Server Test"), TSize(KDefaultConsWidth, KDefaultConsHeight));
	iShutdown = COcspServerShutdown::NewL();
	// Ensure that the server still exits even if the 1st client fails to
	// connect
	iShutdown->Start();
	}

CSession2* COcspServer::NewSessionL(const TVersion& /*aVersion*/, 
									   const RMessage2& /*aMessage*/) const
	{
	return new(ELeave) COcspSession(*iConsole);
	}

void COcspSession::CreateL()
	{
	Server().AddSession();
	}

COcspSession::COcspSession(CConsoleBase& aConsole) : CSession2(), iConsole(aConsole)
	{
	}

COcspSession::~COcspSession()
	{
	Server().DropSession();
	}

COcspServer& COcspSession::Server()
	{
	return *static_cast<COcspServer*>(
		const_cast<CServer2*>(CSession2::Server()));
	}

/////
///// COcspSession		
/////
	
void COcspSession::ServiceL(const RMessage2& aMessage)
	{
	switch (aMessage.Function())
		{
		/*case EPrint:
		{
		FLOG(_L("COcspSession::ServiceL(EPrint)"));
		TInt length = User::LeaveIfError(aMessage.GetDesMaxLength(0));
		HBufC* string = HBufC::NewMaxLC(length);
		TPtr stringBuffer(string->Des());
		aMessage.Read(0, stringBuffer);
		iConsole.Printf(*string); 
		aMessage.Complete(KErrNone);
		break;
		}
	case EGet:
		{
		FLOG(_L("COcspSession::ServiceL(EGet)"));
		aMessage.Complete(iConsole.Getch());
		break;
		}*/
	default:
		{
		FLOG(_L("COcspSession::ServiceL(): unknown function"));
		PanicClient(aMessage, Swi::Test::EPanicOcspServerIllegalFunction);
		break;
		}
		}
	}

void COcspSession::ServiceError(const RMessage2& aMessage, TInt aError)
	{
	if (aError==KErrBadDescriptor)
		{
		PanicClient(aMessage, Swi::Test::EPanicConsoleServerBadDescriptor);
		}
	CSession2::ServiceError(aMessage, aError);
	}

/////
///// CInstallServerShutdown
/////
		
inline COcspServerShutdown::COcspServerShutdown() : CTimer(-1)
	{
	CActiveScheduler::Add(this);
	}

inline void COcspServerShutdown::ConstructL()
	{
	CTimer::ConstructL();
	}

inline void COcspServerShutdown::Start()
	{
	After(KShutdownDelay);
	}

/*static*/ COcspServerShutdown* COcspServerShutdown::NewL()
	{
	COcspServerShutdown* self = new(ELeave) COcspServerShutdown();
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

// Initiate server exit when the timer expires
void COcspServerShutdown::RunL()
	{
	FLOG(_L("COcspServerShutdown::RunL(): stopping Test Console Server"));
	CActiveScheduler::Stop();
	}