// Copyright (c) 2002-2009 Nokia Corporation and/or its subsidiary(-ies).
// All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the License "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:
// e32test\debug\T_TRACEREDIRECT.cpp
// Print out RDebug::Prints captured by the 'trace redirection' LDD
// 
//

#include <e32cmn.h>
#include <e32cmn_private.h>
#include "d_traceredirect.h"
#include <e32debug.h>
#include <e32test.h>

RTest test(_L("T_TRACEREDIRECT"));

RTraceRedirect ldd;


TInt noisythreadfn(TAny *)
	{

	for (TInt i=0; i<12; i++)
		{

		User::After(700000); // 2+1/2 a second
		RDebug::Print(_L("Noisy thread 1 @ %lx"), User::TickCount());
		}
	RDebug::Print(_L("END"));
	return KErrNone;
	}

TInt noisythreadfn2(TAny *)
	{

	for (TInt i=0; i<20; i++)
		{

		User::After(300000); // 2+1/2 a second
		RDebug::Print(_L("Noisy thread 2 @ %lx"), User::TickCount());
		}
	return KErrNone;
	}

GLDEF_C TInt E32Main()
    {
	test.Title();
	TInt r;
	
	test.Start(_L("Loading LDD"));
	r = User::LoadLogicalDevice(_L("D_TRACEREDIRECT"));
	test(r==KErrNone || r==KErrAlreadyExists);

	TBool logged=test.Logged();
	test.SetLogged(EFalse);
	test.Next(_L("Open channel to LDD"));
	r = ldd.Open();
	test(r==KErrNone);


	test.Next(_L("Setup noisy thread"));
	RThread thread;
	TRequestStatus threadstat;
	r=thread.Create(KNullDesC,noisythreadfn,KDefaultStackSize,&User::Allocator(),NULL);
	test(r==KErrNone);
	thread.Logon(threadstat);
	thread.Resume();
	RThread thread2;
	TRequestStatus threadstat2;
	r=thread2.Create(KNullDesC,noisythreadfn2,KDefaultStackSize,&User::Allocator(),NULL);
	test(r==KErrNone);
	thread2.Logon(threadstat2);
	thread2.Resume();

	test.Next(_L("Capture RDebug::Prints until 'END' is captured"));
	TBuf8<256> buf;
	TBuf16<256> buf16;
	FOREVER
		{
		test(ldd.NextTrace(buf) == KErrNone);
		buf16.Copy(buf);
		if (buf16!=_L(""))
			test.Printf(_L("Captured: '%S'\n"),&buf16);
		if (buf16==_L("END"))
			break;
		buf=_L8("");
		User::After(250000); // poll every half a second
		}
	test.SetLogged(logged);

	test.Next(_L("Wait for noisy thread to die"));
	User::WaitForRequest(threadstat);
	User::WaitForRequest(threadstat2);
	test(threadstat==KErrNone);

	test.Next(_L("Closing ldd"));
	ldd.Close();
	
	test.End();

	return(0);
    }