/*

* Copyright (c) 2007-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: 

* Implements CScsServer functionality.  See class and functions definitions

* for more detail.

*

*/

/**

 @file

*/

#include <scs/scsserver.h>

#include "scsserverconstants.h"

static const TInt defaultPolicyRangeCount = 1;

static const TInt defaultPolicyRanges[defaultPolicyRangeCount] = 

				{

				0 // All requests

				};

static const TUint8 defaultPolicyElementsIndex[defaultPolicyRangeCount] = 

				{

				CPolicyServer::EAlwaysPass

				};

static const CPolicyServer::TPolicyElement defaultPolicyPolicyElements[1] = {};

static const CPolicyServer::TPolicy defaultPolicy =

				{

				CPolicyServer::EAlwaysPass, // Allow all connects

				defaultPolicyRangeCount,

				defaultPolicyRanges,

				defaultPolicyElementsIndex,

				defaultPolicyPolicyElements,

				};

EXPORT_C CScsServer::CScsServer(const TVersion& aVersion, CActive::TPriority aPriority)

/**

	Record this server's version so it can be compared against the requested

	version in NewSessionL.

	@param	aVersion		This server's version.	This is compared against each

							client's requested version when the client tries to connect.

	@param	aPriority		This server's active object priority.

 */

	:	CPolicyServer(aPriority, defaultPolicy, ESharableSessions)

	,iVersion(aVersion)

//	,iSessionCount(0)

	{

	// empty.

	}

EXPORT_C CScsServer::CScsServer(const TVersion& aVersion, const CPolicyServer::TPolicy& aPolicy, CActive::TPriority aPriority)

/**

	Record this server's version so it can be compared against the requested

	version in NewSessionL.

	@param	aVersion		This server's version.	This is compared against each

							client's requested version when the client tries to connect.

	@param	aPolicy			Can be used to configure security for server connect and session functions

	@param	aPriority		This server's active object priority.

	Note that aPolicy must be configured to allow all functions

	covered by the KScsFunctionMask mask.

 */

	:	CPolicyServer(aPriority, aPolicy, ESharableSessions)

	,iVersion(aVersion)

//	,iSessionCount(0)

	{

	// empty.

	}

EXPORT_C void CScsServer::ConstructL(TInt aShutdownPeriodUs)

/**

	Second-phase constructor allocates the shutdown timer for this server object.

	If aShutdownPeriodUs is not 0, this function starts the shutdown

	timer because the server starts up with no current sessions.

	If aShutdownPeriodUs is 0, the timer is not started and the server

	will not auto-exit.

	nb. It must be called, even if you do not want a shutdown timer.

	This function does not start the server, i.e. it does not call StartL.	The

	calling function must do this after this function returns.

	@param	aShutdownPeriodUs Shutdown period in microseconds.

 */

	{	

	if(aShutdownPeriodUs > 0)

		{

		iShutdownTimer = CShutdownTimer::NewL(aShutdownPeriodUs);

		iShutdownTimer->Restart();

		}

	iContainerIndex = CObjectConIx::NewL();

	TCallBack cb(RemoveCompletedRequests, this);

	// EPriorityHigh to encourage the active scheduler to action the

	// delete ASAP, in particular ahead of pending or new requests.

	iAsyncCleanup = new(ELeave) CAsyncCallBack(cb, CActive::EPriorityHigh);

	}

EXPORT_C void CScsServer::DisableShutdownTimer()

/**

	The server will no longer shutdown after the last client session closes.

	Client calls to RScsClientBase::ShutdownServer will fail with KErrNotSupported.

*/

	{

	if(iShutdownTimer)

		{

		iShutdownTimer->Cancel();

		}

	delete iShutdownTimer;

	iShutdownTimer = 0;

	}

EXPORT_C void CScsServer::EnableShutdownTimerL(TInt aShutdownPeriodUs)

/**

	Enable shutdown timer support in the server.

	If there are currently no client sessions the timer will be immediately started, otherwise

	it will be started when the last client session closes.

	If the timer expires, before another client creates a session, the server will shutdown.

	The RScsClientBase::ShutdownServer api will now be supported, if called the server timeout

	will effectively be reduced to 0.

*/

	{

	if(aShutdownPeriodUs <= 0)

		{

		return;

		}

	DisableShutdownTimer();

	iShutdownTimer = CShutdownTimer::NewL(aShutdownPeriodUs);

	if(iSessionCount == 0)

		{

		iShutdownTimer->Restart();

		}

	}

EXPORT_C CScsServer::~CScsServer()

/**

	Frees resources used at this level.	 Specifically, frees the

	container index, which is used to generate subsession containers,

	the shutdown timer, and the async request cleanup object.

 */

	{

	__ASSERT_DEBUG(iSessionCount == 0, PanicServer(ESvrRemSessions));

	__ASSERT_DEBUG(iAsyncCleanup == 0 || !iAsyncCleanup->IsActive(), PanicServer(ESvrRemCleanup));

	__ASSERT_DEBUG(iAsyncRequests.Count() == 0, PanicServer(ESvrRemRequests));

	delete iContainerIndex;

	delete iShutdownTimer;

	delete iAsyncCleanup;

	iAsyncRequests.Reset();

	}

// -------- sessions --------

EXPORT_C CSession2* CScsServer::NewSessionL(const TVersion& aVersion, const RMessage2& aMessage) const

/**

	Implement CServer2 by allocating a new session object.	This function

	delegates the actual allocation to the subclass.  Before creating the

	session object, it compares the requested version with its own version.

	After creating the session object, it increments the session count, which

	reset the shutdown timer if it is the only	session.

	@param	aVersion		Version of server which client requires.

	@param	aMessage		Connect message.

	@return					New initialized instance of CSession2 subclass.

 */

	{

	TBool versionOk = User::QueryVersionSupported(/* aCurrent */ iVersion, /* aRequested */ aVersion);

	if (! versionOk)

		User::Leave(KErrNotSupported);

	CScsSession* s = const_cast<CScsServer*>(this)->DoNewSessionL(aMessage);

	return s;

	}

EXPORT_C void CScsServer::DoPreHeapMarkOrCheckL()

	{

	}

EXPORT_C void CScsServer::DoPostHeapMarkOrCheckL()

	{

	}

void CScsServer::IncrementSessionCount()

/**

	Record the fact that another session has been created.	If this new

	session is the only session then cancel the shutdown timer.

 */

	{

	++iSessionCount;

	if (iSessionCount == 1)

		{

		if(iShutdownTimer)

			{

			iShutdownTimer->Cancel();

			}

		}

	}

void CScsServer::DecrementSessionCount()

/**

	Record the fact that a session has been deleted.  If this was the

	only remaining session then start the shutdown timer.

	Note the shutdown timer may be deferred if a request cleanup is

	pending.

 */

	{

	--iSessionCount;

	if (iShutdownTimer && (iSessionCount == 0) && (! iAsyncCleanup->IsActive()))

		{

		iShutdownTimer->Restart();

		}

	}

EXPORT_C void CScsServer::ShutdownWhenIdleL()

	/**

	   Shutdown immediately when server is next idle.  If the server

	   is not transient (ie. has no shutdown timer), this call is

	   prohibited and will leave with KErrNotSupported.

	 */

	{

	if(! iShutdownTimer)

		{

		// We do not allow shutdown of non-transient servers.

		User::Leave(KErrNotSupported);

		}

	// Next time we are idle, shutdown immediately.

	iShutdownTimer->ImmediateTimeoutNextRestart();

	}

// -------- asynchronous requests --------

CAsyncRequest* CScsServer::FindAsyncRequest(

	CScsSession* aSession, CScsSubsession* aSubsession, TInt aFunction)

/**

	Find the outstanding request which matches the supplied criteria.

	@param	aSession		Session which hosts the request.

	@param	aSubsession		Subsession which hosts the request, NULL if

							the request is relative to a session.

	@param	aFunction		The function identifier, without any SCS code.

	@return					The matching asynchronous request, NULL if not

							found.

 */

	{

	TInt reqCount = iAsyncRequests.Count();

	for (TInt i = reqCount - 1; i >= 0; --i)

		{

		CAsyncRequest* req = iAsyncRequests[i];

		if (req->iSession != aSession)

			continue;

		if (req->iSubsession != aSubsession)

			continue;

		if (req->iFunction != aFunction)

			continue;

		return req;

		}

	return 0;				// request not found

	}

void CScsServer::AddAsyncRequestL(CAsyncRequest* aAsyncRequest)

/**

	Add the supplied request to the server's collection.

	@param	aAsyncRequest	Request to add.	 If this function succeeds

							then ownership has been transferred to the

							collection.

 */

	{

	// ensure this session does not already have an outstanding request

	// for the same function

	CAsyncRequest* existReq = FindAsyncRequest(

		aAsyncRequest->iSession, aAsyncRequest->iSubsession,

		aAsyncRequest->iFunction);

	if (existReq != 0)

		User::Leave(KErrScsAsyncAlreadyQueued);

	iAsyncRequests.AppendL(aAsyncRequest);

	}

void CScsServer::CancelAsyncRequest(

	CScsSession* aSession, CScsSubsession* aSubsession, TInt aFunction)

/**

	Cancels a specific (sub)session request in response to a client

	command.  Also completes the client request.

	CancelOutstandingRequest should be called when a (sub)session is closed.

	@param	aSession		Session which hosts the request.

	@param	aSubsession		Subsession which hosts the request, NULL if

							the request is relative to a session.

	@param	aFunction		The function identifier, without any SCS code.

 */

	{

	CAsyncRequest* req = FindAsyncRequest(aSession, aSubsession, aFunction);

	// not an error if the request is not queued; could have been

	// completed before the cancel function was processed.

	if (req != 0)

		req->CancelCompleteAndMarkForDeletion();

	}

void CScsServer::CancelOutstandingRequests(CScsSession* aSession, TBool aCompleteClientRequests)

/**

	Cancels and deletes all outstanding asynchronous requests associated

	with the supplied session or any of its subsessions.  Does not complete

	the associated client requests.

	This function should be called when a session is closed.

	CancelAsyncRequest should be called when a specific request is cancelled.

	@param	aSession		Session which is being closed.

	@param	aCompleteClientRequests Whether to complete the client-side requests

							with KErrCancel.

 */

	{

	CancelOutstandingRequests(aSession, KWildSubsession, aCompleteClientRequests);

	}

void CScsServer::CancelOutstandingRequests(CScsSession* aSession, CScsSubsession* aSubsession, TBool aCompleteClientRequests)

/**

	Cancels and deletes all outstanding asynchronous requests associated

	with the supplied session and subsession.  This should be called when

	a session or subsession is closed.

	As an exception, the user-side request is completed when a subsession is

	closed, else the request would not be completed	until the session itself

	was destroyed.

	CancelAsyncRequest should be called when a specific request is cancelled.

	@param	aSession		Session which is being closed.

	@param	aSubsession		Subsession which is being closed.  If this is

							KWildSubsession then a session is being closed so all of

							its subsession requests should be destroyed as well.

	@param	aCompleteClientRequests Whether to complete the client-side requests

							with KErrCancel.

 */

	{

	TBool wildSubsession = (aSubsession == KWildSubsession);

	TInt reqCount = iAsyncRequests.Count();

	for (TInt i = reqCount - 1; i >= 0; --i)

		{

		CAsyncRequest* req = iAsyncRequests[i];

		TBool sessionMatch = (req->iSession == aSession);

		if (! sessionMatch)

			continue;

		TBool subsessionMatch = wildSubsession || (req->iSubsession == aSubsession);

		if (! subsessionMatch)

			continue;

		if (aCompleteClientRequests)

			req->CancelCompleteAndMarkForDeletion();

		else

			{

			req->DoCleanup();

			req->MarkForDeletion();

			}

		}

	}

TInt CScsServer::RemoveCompletedRequests(TAny* aPtr)

/**

	This static function is called when iAsyncCleanup

	runs.  It interprets its argument as a pointer to

	an instance of CScsServer and removes any asynchronous

	requests which have been completed.

	@param	aPtr			Required callback argument.	 Interpreted

							as a pointer to an instance of CScsServer.

	@return					KErrNone.  Required to satisfy the TCallBack

							function signature.

	@see RemoveCompletedRequests()

 */

	{

	CScsServer* svr = static_cast<CScsServer*>(aPtr);

	svr->RemoveCompletedRequests();

	return KErrNone;

	}

void CScsServer::RemoveCompletedRequests()

/**

	Delete any asynchronous requests which are marked for deletion.

 */

	{

	// The requests have already been completed; they just need to be removed.

	TInt reqCount = iAsyncRequests.Count();

	for (TInt i = reqCount - 1; i >= 0; --i)

		{

		CAsyncRequest* req = iAsyncRequests[i];

		if (req->iSession != 0)		// still outstanding if iSession != 0

			continue;

		delete req;

		iAsyncRequests.Remove(i);

		}

	// if no more outstanding requests then reset array so heap balances

	if (iAsyncRequests.Count() == 0)

		iAsyncRequests.Compress();

	// if the shutdown timer was deferred because of an impending

	// cleanup then launch it now.

	if (iShutdownTimer && (iSessionCount == 0))

		{

		iShutdownTimer->Restart();

		}

	}

// End of file