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

// Redirection server for STDLIB test programs

// Implement a redirection server which uses ... a console.

// 

//

#include <e32std.h>

#include <e32cons.h>

#include <redircli.h>

#include <redircliinternal.h>

#include "CTEST.H"

#include "testconsole.h"

_LIT(KReDirServerName,"RedirServer");

struct rendezvous 

	{

	RThread iCaller;

	TRequestStatus* iStatus;

	};

TInt threadFunction(TAny* aPtr)

//

// Create and run an active scheduler containing a RedirectionServer

//

	{

	CTrapCleanup* TheTrapCleanup=CTrapCleanup::New();

	struct rendezvous* rvp = (struct rendezvous *)aPtr;

	TInt ret=KErrNone;

	// start scheduler and server

	CActiveScheduler *pA=new CActiveScheduler;

	if (pA!=NULL) 

		{

		CActiveScheduler::Install(pA);

		// ***** TRAP(ret, CRedirServer::NewL(CTestConsoleFactory::NewL());

		TRAP(ret, CRedirServer2::NewL(CTestConsoleFactory::NewL()));

//		ret=KErrNotSupported;

		}

	// signal to the caller that we've started (or failed!)

	rvp->iCaller.RequestComplete(rvp->iStatus,ret);

	if (ret==KErrNone)

		{

		// start fielding requests from clients

		CActiveScheduler::Start();

		}

	// finished

	delete TheTrapCleanup;

	return(KErrNone);

	}

EXPORT_C int start_redirection_server()

//

// Try to start a redirection server thread, assuming there isn't one already

//

	{

	RRedirSession2 probe;

	TInt err=probe.Connect();

	probe.Close();

	if (err==KErrNone)

		return KErrNone;	// server already exists

	TRequestStatus status(KRequestPending);

	struct rendezvous rv;

	rv.iCaller.Duplicate(RThread(),EOwnerProcess);

	rv.iStatus=&status;

	RThread server;

	err=server.Create(KReDirServerName,threadFunction,0x2000,NULL,&rv);

	if (err==KErrNone) 

		{

		server.Resume();

		User::WaitForRequest(status);

		err=status.Int();

		server.Close();

		}

	rv.iCaller.Close();

	return err;

	}