// 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:

// Test of the ESTW32 facilities for accessing Win32 stdin/stdout/stderr

// 

//

#include <e32std.h>

#include <e32base.h>

#include <e32svr.h>

#include <estw32.h>

void failed(int line, TInt aExpected, TInt aResult)

	{

	TBuf<80> buf;

	buf.Format(_L("Failed line %d: expected %d, got %d"), line, aExpected, aResult);

	for(;;)

		{

		User::InfoPrint(buf);

		User::After(5*1000000);	// 5 seconds

		}

	}

#define test(err,expected)			if (err!=expected) failed(__LINE__,expected,err)

#define test_status(status,expected)	if (status.Int()!=expected) failed(__LINE__,expected,status.Int())

/**

@SYMTestCaseID          SYSLIB-STDLIB-CT-1042

@SYMTestCaseDesc	    Tests for the ESTW32 facilities for accessing Win32 stdin/stdout/stderr

@SYMTestPriority 	    High

@SYMTestActions  	    Open RWin32Stream::stdin,stdout,stderr and test writing to these streams.

                        Check for KErrNone flag

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

void DoTest()

	{

	RWin32Stream::StartServer();

	RWin32Stream stdin;

	RWin32Stream stdout;

	RWin32Stream stderr;

	TRequestStatus status;

	TInt err;

	err=stdin.Open(Kstdin);

	test(err,KErrNone);

	err=stdout.Open(Kstdout);

	test(err,KErrNone);

	err=stderr.Open(Kstderr);

	test(err,KErrNone);

	TBuf8<80> outbuf;

	// stderr

	outbuf=_L8("Writing to stderr\n");

	stderr.Write(status,outbuf);

	User::WaitForRequest(status);

	test_status(status,KErrNone);

	outbuf=_L8("1234XXX89");

	stderr.Write(status,outbuf,4);

	User::WaitForRequest(status);

	test_status(status,KErrNone);

	// stdout

	outbuf=_L8("Writing to stdout\n");

	stdout.Write(status,outbuf);

	User::WaitForRequest(status);

	test_status(status,KErrNone);

	outbuf=_L8("1234XXX89");

	stdout.Write(status,outbuf,4);

	User::WaitForRequest(status);

	test_status(status,KErrNone);

	FOREVER

		{

		stdin.Read(status,outbuf);

		User::WaitForRequest(status);

		TRequestStatus outStatus;

		TBuf8<80> commentary;

		commentary.Format(_L8("\nread %d, status %d\n"), outbuf.Length(), status.Int());

		stderr.Write(outStatus,commentary);

		User::WaitForRequest(outStatus);

		test_status(outStatus,KErrNone);

		if (status.Int()==KErrEof)

			break;

		stdout.Write(outStatus,outbuf);

		User::WaitForRequest(outStatus);

		test_status(outStatus,KErrNone);

		}

	outbuf=_L8("Stdin closed\n");

	stderr.Write(status,outbuf);

	User::WaitForRequest(status);

	test_status(status,KErrNone);

	}

IMPORT_C void RegisterWsExe(const TDesC &aName);

GLDEF_C TInt E32Main()

	{     

	CTrapCleanup* TheTrapCleanup=CTrapCleanup::New();

#ifdef USE_FULL_GRAPHICAL_ENVIRONMENT

	// Cause the Eikon environment to come into existence

	RSemaphore sem;

	sem.CreateGlobal(_L("WsExeSem"),0);

	RegisterWsExe(sem.FullName());

	DoTest();

	User::InfoPrint(_L("Test passed"));

	sem.Wait();	// continue running Eikon until that exits as well

#else

	DoTest();

	User::InfoPrint(_L("Test passed"));

#endif

	return(KErrNone);

	}