// Copyright (c) 2005-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:
//

/**
 @file
 @internalComponent - Internal Symbian test code 
*/




#include "messageservserver.h"
#include "messageservsession.h"


/**
   Constructor
 */
CMessageServServer::CMessageServServer(TInt aPriority)
	: CServer2(aPriority)
	{
	__DECLARE_NAME(_S("CMessageServServer"));
	}


/**
   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL
  
   The method creates and start a the message server by invoking
   CServer::Start().
  
 */
void CMessageServServer::New(MMessageProvider *aMessageProvider)
	{
	CMessageServServer *pS=new CMessageServServer(EPriority);
	__ASSERT_ALWAYS(pS!=NULL,PanicServer(ESvrCreateServer));
	HBufC *pN=(&KMessageServerName)->Alloc();
	__ASSERT_ALWAYS(pN!=NULL,PanicServer(ESvrCreateServer));
	
	pS->iMessageProvider = aMessageProvider;
	
	TInt r=pS->Start(*pN);
	__ASSERT_ALWAYS(r==KErrNone,PanicServer(ESvrStartServer));
	}


/**
   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL.
 
   This method identifies the client thread. It then creates an returns a server
   session for the client. The new server session is created by calling 
   CMessageServSession::NewL().
 
*/
CSession2 *CMessageServServer::NewSessionL(const TVersion &aVersion, const RMessage2& ) const
	{
	// check we're the right version
	TVersion v(KMessageServMajorVersionNumber,KMessageServMinorVersionNumber,KMessageServBuildVersionNumber);
	if (!User::QueryVersionSupported(v,aVersion))
		User::Leave(KErrNotSupported);
	// make new session
	//RThread thread;// = Message().Client();
	//aMessage.Client(thread);

	return CMessageServSession::NewL((CMessageServServer*)this);
	}
	
/**
  
   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL
  
   The method creates & installs an active scheduler for the server thread. It
   then creates & a message server instance by calling CMessageServServer::New().
   The message server is then set ready to run by invoking RSemaphore::Signal().
  
 */
EXPORT_C TInt CMessageServServer::ThreadFunction(TAny* anArg)
	{
	MMessageProvider *theProvider = (MMessageProvider*) anArg;

	// convert argument into semaphore reference
	RSemaphore& semaphore= theProvider->Semaphore();

	// start scheduler and server
	CActiveScheduler *pA=new CActiveScheduler;
	__ASSERT_ALWAYS(pA!=NULL,PanicServer(EMainSchedulerError));
	CActiveScheduler::Install(pA);
	CMessageServServer::New(theProvider);
	// signal that we've started
	semaphore.Signal();
	// start fielding requests from clients
	CActiveScheduler::Start();
	// finished
	
	//Adding a delay here seems to fix the crash on multicore SMP naviengine
	User::After(200000);
	
	return(KErrNone);
	}
	
/**
   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL
  
   This method is used to panic the server thread.
  
 */
GLDEF_C void PanicServer(TMessageServPanic aPanic)
	{
	_LIT(KTxtServerPanic,"server panic");
	User::Panic(KTxtServerPanic,aPanic);
	}