// Copyright (c) 2010 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 steps

//

/**

 @file

 @internalComponent

*/

#include <stdlib.h>

#include <string.h>

//#include <profiler.h>

#include <test/testexecutelog.h>

#include <in_sock.h>

#include "te_mbufgobblertest.h"

#include "mbufgobblertestflags.h"

CMbufGobblerStartupTest::CMbufGobblerStartupTest(CMbufGobblerTestServer* /*aOwner*/)

	{

	SetTestStepName(KTestMbufGobblerStartupTest);

	}

CMbufGobblerStartupTest::~CMbufGobblerStartupTest()

	{

	}

TVerdict CMbufGobblerStartupTest::doTestStepL()

	{

#ifdef _DEBUG

    SetTestStepResult( EFail );    

    User::LeaveIfError(MbufGobblerTestFlags::ActivateTestFlags());

	INFO_PRINTF1(_L("  .. opening socket server.."));

	RSocketServ sockServ;

    User::LeaveIfError(sockServ.Connect());

    CleanupClosePushL(sockServ);

	INFO_PRINTF1(_L("  .. opening connection.."));

	RConnection conn;

    User::LeaveIfError(conn.Open(sockServ));

    CleanupClosePushL(conn);

    User::LeaveIfError(conn.Start()); // start default connection (defined in commsdat)

	INFO_PRINTF1(_L("Checking Tier up.."));

    TInt result = MbufGobblerTestFlags::GetResult(MbufGobblerTestFlags::KTierUp);

    User::LeaveIfError(result);

	INFO_PRINTF2(_L("Tier started ok [%d]."),result);

	INFO_PRINTF1(_L("Checking MCPr up.."));

    result = MbufGobblerTestFlags::GetResult(MbufGobblerTestFlags::KMCPrUp);

    User::LeaveIfError(result);

	INFO_PRINTF2(_L("MCPr started ok [%d]."),result);

	INFO_PRINTF1(_L("Checking CPr up.."));

    result = MbufGobblerTestFlags::GetResult(MbufGobblerTestFlags::KCPrUp);

    User::LeaveIfError(result);

	INFO_PRINTF2(_L("CPr started ok [%d]."),result);

	INFO_PRINTF1(_L("Checking SCPr up.."));

    result = MbufGobblerTestFlags::GetResult(MbufGobblerTestFlags::KSCPrUp);

    User::LeaveIfError(result);

	INFO_PRINTF2(_L("SCPr started ok [%d]."),result);

	INFO_PRINTF1(_L("Checking Binder up.."));

    result = MbufGobblerTestFlags::GetResult(MbufGobblerTestFlags::KBind);

    User::LeaveIfError(result);

	INFO_PRINTF2(_L("Binder up ok [%d]."),result);

	INFO_PRINTF1(_L("  .. opening socket.."));

    RSocket sock;

	User::LeaveIfError(sock.Open(sockServ,KAfInet,KSockDatagram,KProtocolInetUdp,conn));

    CleanupClosePushL(sock);

	INFO_PRINTF1(_L("  .. sending a packet.."));

	TBuf8<128> pkt;

	pkt.SetLength(128);

	TInetAddr dest;

	dest.Input(_L("11.22.33.44"));

	dest.SetPort(100);

	TRequestStatus status;

	sock.SendTo(pkt,dest,0,status);

	User::WaitForRequest(status);

	User::LeaveIfError(status.Int());

	INFO_PRINTF1(_L("Checking Send occurred.."));

    result = MbufGobblerTestFlags::GetResult(MbufGobblerTestFlags::KBinderSend);

    User::LeaveIfError(result);

	INFO_PRINTF2(_L("Send occurred ok [%d]."),result);

	INFO_PRINTF1(_L("Checking Receive occurred.."));

    result = MbufGobblerTestFlags::GetResult(MbufGobblerTestFlags::KBinderReceive);

    User::LeaveIfError(result);

	INFO_PRINTF2(_L("Receive occurred ok [%d]."),result);

	// Remove this call if its high capability requirement is a problem

	INFO_PRINTF1(_L("  .. stopping connection.."));

	User::LeaveIfError(conn.Stop());

    CleanupStack::Pop(); // RSocket close

    CleanupStack::Pop(); // RConnection close

    CleanupStack::Pop(); // RSocketServ close

	// return success / failure

    SetTestStepResult( EPass );

#else // _DEBUG

    SetTestStepResult( EPass );    

	INFO_PRINTF1(_L("  .. results for this component only useful in UDEB mode."));

#endif    

	return TestStepResult();

	}