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

// Contains IPC Test 08

// 

//

// EPOC includes

#include <e32base.h>

// Test system includes

#include "Test08IPCOpenSocketMemoryLeak.h"

const TDesC& CTest08IPCOpenSocketMemoryLeak::GetTestName()

	{

	_LIT(ret,"IPCTest08");

	return ret;

	}

enum TVerdict CTest08IPCOpenSocketMemoryLeak::InternalDoTestStepL()

	{

#if defined (_DEBUG_SOCKET_FUNCTIONS)

	//-------------------substep 00-----------------------------	

	_LIT(aLog00,"00 Open socket server:"); Logger().Write(aLog00);

	TInt err;

	RSocketServ ss;

	CleanupClosePushL(ss);

	if ( (err = OptimalConnect(ss)) != KErrNone )

		{

		Logger().WriteFormat(_L("Connecting to socket server failed with %d"), err);

		User::Leave(EFail);

		}

	//-------------------substep 01-----------------------------	

	Logger().Write(_L("01 Set heap to fails after N=0 allocations..."));

	Logger().Write(_L("   ...Try to Open a socket. If it returns error, check memory leak."));

	Logger().Write(_L("   ...Increase N by one and repeat the same untill open-socket returns NoError:"));

	RSocket aSock;

	CleanupClosePushL(aSock);

	RSocket aSockets[16];

	TInt aFailure = 0;

	TInt i;

	for (i=0; i < 16; i++)

		CleanupClosePushL(aSockets[i]);

	for (i=0;i<16;i++)

		{

		if ((err = aSockets[i].Open(ss, iProt)) != KErrNone)

			{

			Logger().WriteFormat(_L("Error: Open socket error %d"), err);

			User::Leave(EFail);

			}

		}

	CleanupStack::Pop(&aSockets[15]);

	for (i=14; i >= 0; i--)	

		{

		CleanupStack::PopAndDestroy(&aSockets[i]);

		}

	do 

		{

		ss.__DbgFailNext(aFailure);

		ss.__DbgMarkHeap();

		err = aSock.Open(ss, iProt);

		if (err != KErrNone)     

			{

			ss.__DbgMarkEnd(0);

			}

		aFailure++;

		} while  (err != KErrNone);

		// To flush the hanging __DbgFailNext

		ss.__DbgFailNext(-1);

		Logger().WriteFormat(_L("Info: Loop has passed %d times"), aFailure - 1);

		aSockets[15].Close();

		//-------------------substep 02-----------------------------	

		Logger().WriteFormat(_L("02 Close the socket & socket server"));

		CleanupStack::PopAndDestroy(2, &ss);

		return EPass;

#else

		Logger().WriteFormat(_L("Info: Test Disabled on release build"));

		return EPass;	

#endif

	}