/*
* Copyright (c) 2002 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: 
*    Implementation for the RDosServer class.
*
*/


#include <e32svr.h>
#include "DosSvrServices.h"
#include "dosclientserver.h"
#include "dosserver.h"
#include "dos_debug.h"

// CONSTANTS
const TUid KDosServerUid = {0x101f6efa};
const TInt KConnectionTries = 5;
#if defined(__WINS__)
_LIT( KDosSrvLibName, "DosSrv.dll" );
const TInt KDosSrvThreadStartPos = 103;
#endif

// ================= MEMBER FUNCTIONS =======================

// -----------------------------------------------------------------------------
// RDosServer::StartServer
// Creates the server thread/process
// -----------------------------------------------------------------------------
EXPORT_C TInt RDosServer::StartServer() const
{
    API_TRACE_( "[DOSSERVER] RDosServer::StartServer()" );

    TInt ret(KErrNone);
	TRequestStatus status;
    // IPCv2: TSignal no longer used, but still passed to threadfunction as 
	// otherwise API change would be required.
	CDosServer::TSignal signal( status );

	// Create startup semaphore
	RSemaphore startupSemaphore;
	ret = startupSemaphore.CreateGlobal( KServerStartupSemaphoreName, 0 );

	if ( ret == KErrAlreadyExists )
		{
		// The server is starting up, but has not yet started 
		startupSemaphore.OpenGlobal( KServerStartupSemaphoreName );
		startupSemaphore.Wait(); // wait until the server has started up.
		startupSemaphore.Close();
		return ret;
		}

	// launch server thread (emulator) or process (Target platform)

	RProcess server;

	ret = server.Create( KDosServerExe, signal.Get(),
                       TUidType( KNullUid, KNullUid, KDosServerUid ),
                       EOwnerThread );

	if ( ret )
	{
		startupSemaphore.Close();
		return ret;
	}

	server.SetPriority(EPriorityHigh);

	server.Resume();
	server.Close();

	startupSemaphore.Wait();
	startupSemaphore.Close();

	return KErrNone;
}

// -----------------------------------------------------------------------------
// RDosServer::Connect
// -----------------------------------------------------------------------------
EXPORT_C TInt RDosServer::Connect()
{
    API_TRACE_( "[DOSSERVER] RDosServer::Connect()" );

    TInt err( KErrNone );

    for ( TInt tries = 0; tries < KConnectionTries ; tries++ )
    {
    COM_TRACE_1( "[DOSSERVER]\t RDosServer::Connect() tries: %d", tries );

        err = CreateSession( KDosServerName, TVersion(1,0,0));
        COM_TRACE_1( "[DOSSERVER]\t RDosServer::Connect()-CreateSession err: %d", err );

        // Break if connected to existing server or if the problem is
        // other than missing server.

        if ( err == KErrNone || 
           ( err != KErrNotFound && err != KErrServerTerminated ) )
        {
            break;
        }

        // do not try to start server on last round (since if it failed before with KErrNone
        // (i.e. failure in server side on launch),
        // it is likely to fail again and reset the error code to KErrNone)
        if ( tries < (KConnectionTries - 1) )
		{
	        err = StartServer();    // try start a new server
            COM_TRACE_1( "[DOSSERVER]\t RDosServer::Connect()-StartServer err: %d", err );

			// If server launched ok or someone else got to launch it first,
			// try connect again.

			if ( err != KErrNone && err != KErrAlreadyExists )
			{
				break; // server not launched: don't cycle round again
			}
		}
    }

    return err;
}

// FLAGS STRUCTURE (It always goes in the third (2) position of the parameter array)
//
// KAutoComplete:
// 
// Position: 0 0 0 0 0 0 0 x
// Values:	0 -> AutoComplete is not active.
//			1 -> AutoComplete is active.


// -----------------------------------------------------------------------------
// RDosServer::Close()
// Closes the session.
// -----------------------------------------------------------------------------

EXPORT_C void RDosServer::Close() 
{
    API_TRACE_( "[DOSSERVER] RDosServer::Close()" );

    RSessionBase::Close();  // deletes session object
}


// -----------------------------------------------------------------------------
// RDosServer::ServerShutdown()
// Shutdowns the server
// -----------------------------------------------------------------------------

EXPORT_C void RDosServer::ServerShutdown() const
{
    API_TRACE_( "[DOSSERVER] RDosServer::ServerShutdown()" );

    Send(EServerShutdown, TIpcArgs(TIpcArgs::ENothing, TIpcArgs::ENothing, KAutoComplete));
}