/*
* Copyright (c) 2004 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:  Symbian OS Server source.
*
*/


#include <f32file.h>
#include <e32math.h>

#include <nsmldebug.h>
#include "nsmlsosserver.h"

GLDEF_C TInt E32Main() // main function called by E32
	{
    return LaunchServer();
	}

// --------------------------------------------------------------------------
// EXPORT_C TInt LaunchServer()
// --------------------------------------------------------------------------
//
TInt LaunchServer()
    {
    // check server not already started
	TFindServer findSOSServer( KSOSServerName );
	TFullName name;
	if ( findSOSServer.Next(name) == KErrNone )
		{ // found server already 
		return KErrGeneral;
		}

	// create server thread
	RSemaphore signal;
    signal.CreateLocal(0);

	// randomize server thread's name
    TName threadName( KSOSServerThread );
    threadName.AppendNum( Math::Random(), EHex );
    
    RThread thread;
	TInt res = thread.Create( threadName, // name of thread
		                      CNSmlSOSServer::ThreadFunction, // thread function
		                      KDefaultStackSize, NULL,
		                      &signal ); // parameter to thread function
		
	if ( res != KErrNone )
		{
		thread.Close();
		return res;
		}
	// start thread
	thread.SetPriority(EPriorityMuchMore); // set priority
	thread.Resume(); 
    thread.Close();
    signal.Wait(); 
    signal.Close();

    return res;
    }

// --------------------------------------------------------------------------
// void CNSmlSOSServer::PanicServer( TNSmlSOSServerPanic aPanic )
// --------------------------------------------------------------------------
//
void CNSmlSOSServer::PanicServer( TNSmlSOSServerPanic aPanic )
    {
	_LIT(KTxtSOSServer,"SOSServer");
	User::Panic(KTxtSOSServer,aPanic);
    }

// --------------------------------------------------------------------------
// TInt CNSmlSOSServer::ThreadFunction(TAny* aStarted)
// --------------------------------------------------------------------------
//
TInt CNSmlSOSServer::ThreadFunction( TAny* aStarted )
	{
#ifdef __CLIENT_API_MT_
    __UHEAP_MARK;
#endif // __CLIENT_API_MT_

	// create cleanup stack
    CTrapCleanup* cleanup = CTrapCleanup::New();
	if ( !cleanup )
	    {
	    PanicServer(ECleanupCreateError);
	    }    
	    
	DBG_BEGIN();
	_DBG_FILE("CNSmlSOSServer::ThreadFunction(): CleanupStack created.");
	    
	// convert argument to semaphore
	RSemaphore& started= *(RSemaphore*) aStarted;
	
	// construct and install active scheduler
	CActiveScheduler* scheduler = new CActiveScheduler;
	__ASSERT_ALWAYS( scheduler,PanicServer(EMainSchedulerError) );
	CActiveScheduler::Install( scheduler );

	// construct server
    CNSmlSOSServer* server = NULL;
    TRAPD( err, server = CNSmlSOSServer::NewL());

	RProcess::Rendezvous( err );

	// start handling requests
	CActiveScheduler::Start();
	
    started.Signal();
	
	_DBG_FILE("CNSmlSOSServer::ThreadFunction(): CActiveScheduler stopped");

    delete server;
    delete scheduler;    
    delete cleanup;

#ifdef __CLIENT_API_MT_
    __UHEAP_MARKEND;
#endif // __CLIENT_API_MT_
	
    return err;
	}

// --------------------------------------------------------------------------
// CNSmlSOSServer* CNSmlSOSServer::NewL()
// --------------------------------------------------------------------------
//
CNSmlSOSServer* CNSmlSOSServer::NewL()
	{
	_DBG_FILE("CNSmlSOSServer::NewL(): begin");
	
	CNSmlSOSServer* self = new (ELeave) CNSmlSOSServer();
	CleanupStack::PushL(self);
    self->ConstructL();
	self->StartL(KSOSServerName);
    CleanupStack::Pop(); // self

	_DBG_FILE("CNSmlSOSServer::NewL(): end");
	
	return self;
	}

// --------------------------------------------------------------------------
// CNSmlSOSServer::CNSmlSOSServer()
// --------------------------------------------------------------------------
//
CNSmlSOSServer::CNSmlSOSServer() : CServer2(EPriorityStandard, ESharableSessions)
	{
	}

// --------------------------------------------------------------------------
// void CNSmlSOSServer::ConstructL()
// --------------------------------------------------------------------------
//
void CNSmlSOSServer::ConstructL()
    {
    iHandler = CNSmlSOSHandler::NewL();
    iBackup = CNSmlSOSBackup::NewL(iHandler);
    iObjConIndex = CObjectConIx::NewL();
    }

// --------------------------------------------------------------------------
// CNSmlSOSServer::~CNSmlSOSServer()
// --------------------------------------------------------------------------
//
CNSmlSOSServer::~CNSmlSOSServer()
	{
    delete iBackup;
    delete iHandler;
    delete iObjConIndex;
    }

// --------------------------------------------------------------------------
// CSession2* CNSmlSOSServer::NewSessionL( const TVersion& aVersion, const RMessage2& aMessage ) const
// --------------------------------------------------------------------------
//
CSession2* CNSmlSOSServer::NewSessionL( const TVersion& aVersion, const RMessage2& /*aMessage*/ ) const
	{
	_DBG_FILE("CNSmlSOSServer::NewSessionL(): begin");
	TVersion v(KNSmlSOSServerVersionMajor, KNSmlSOSServerVersionMinor, 0);
	if( !User::QueryVersionSupported(v,aVersion) )
		{
		User::Leave(KErrNotSupported);
		}

    iBackup->Subscribe();
    
    _DBG_FILE("CNSmlSOSServer::NewSessionL(): end");
	return CNSmlSOSSession::NewL( (CNSmlSOSServer*)this, iHandler ); 
	}

// --------------------------------------------------------------------------
// CObjectCon* CNSmlSOSServer::NewContainerL()
// --------------------------------------------------------------------------
//
CObjectCon* CNSmlSOSServer::NewContainerL()
    {
    return iObjConIndex->CreateL();
    }

//End of File