// Copyright (c) 2001-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:
// This contains ESock Test cases from section 5
// EPOC includes
// 
//

#include <e32base.h>
#include <in_sock.h>
#include <e32math.h>

//anonymous namespace
namespace
    {
    //once the aRefBoolFlag set to false it never gets set again...
    void setResultFlagBool(const TBool aFlag, TBool& aRefBoolFlag)
        {
        if (aRefBoolFlag)
            {
            aRefBoolFlag = aFlag;
            }
        }
    
    //once the aRefBoolFlag set to false it never gets set again...
     void setResultFlagInt(const TInt aFlag, TBool& aRefBoolFlag)
        {
        if (aRefBoolFlag)
            {
            if (aFlag != KErrNone)
                {
                    aRefBoolFlag = EFalse;
                }
            }
        }
        
        const TUint KMaxTestStepCounter = 5;
    }
// Test system includes
#include "EsockTestSection5.h"

// Test step SendData
// this test is used by the integration test scripts
// and is based on esock test 5.3
// This test step sends TCP and UDP (if enabled in ini file) data
const TDesC& CEsockSendData::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"SendData");
	
	return ret;
	}

CEsockSendData::~CEsockSendData()
	{
	}

enum TVerdict CEsockSendData::easyTestStepL()
	{
	TInetAddr addrRemote, addr;
	TRequestStatus stat(KErrNone);
	TInt connectTimer, Port;
	TBool UdpEnable;
	
	TInt testStepCounter = 0;
	TBool testStepResult;
	TBool socketConnected = EFalse;
	TBool udpBindOK = EFalse;
	
	do
	    {
	    testStepResult = ETrue;
	    
    	// get ip address to connect to (on echo port)
    	TESTL(GetIpAddressFromConfig(_L("Test_Common"), _L("ipAddress"), addrRemote));
    	
    	// get the port number
    	TESTL(GetIntFromConfig(_L("SendData"), _L("Port"), Port));
    	addrRemote.SetPort(Port);
    	
    	// format for display 
    	TBuf<39> AddrBuf;
    	addrRemote.OutputWithScope(AddrBuf);
    	
    	// check if UDP test enabled
    	TBool res = GetBoolFromConfig(_L("SendData"), _L("UdpEnable"), UdpEnable );
    	
    	if (( res == EFalse ) || ( UdpEnable == EFalse ))
    		{
    		Logger().WriteFormat( _L("UDP test disabled"));
    		UdpEnable = EFalse;
    		}
    	
    	// get a value for the connection guard timer 
    	TESTL(GetIntFromConfig(_L("SendData"), _L("connectTimer"), connectTimer));
    	
    	// create timer to use as a guard timer
    	RTimer GuardTimer;
    	GuardTimer.CreateLocal();			// for this thread
    	TRequestStatus TimerStatus;			// status to monitor timer
    	TInt RepeatCount = 0;				// repeat counter 
    	TInt WaitTimeout = 5000000;

        if (!socketConnected)
            {
        	// try 5 times (sometimes it fails because of test network)
        	for(RepeatCount=0; RepeatCount <=5;  RepeatCount++)
        		{
        		// connect
        		(iEsockSuite->GetSocketHandle(1)).Connect(addrRemote, stat);
        		
        		// start timer
        		GuardTimer.After(TimerStatus,connectTimer * 1000000); 
        		
        		// wait for either timer or connect
        		User::WaitForRequest(stat, TimerStatus);
        		GuardTimer.Cancel();
        		User::WaitForAnyRequest();
        		
        		// check connect result
        		if (stat.Int() == KRequestPending)
        			{
        			(iEsockSuite->GetSocketHandle(1)).CancelConnect();
        			Logger().WriteFormat( _L("Socket connect to %S port %d has not completed within %d seconds (connectTimer from ini) "), 
        				&AddrBuf,
        				Port,
        				connectTimer ); 
        			User::After(WaitTimeout);
        			continue; // next attempt
        			}
        		else if(stat.Int() != KErrNone)
        			{
        			Logger().WriteFormat( _L("Socket connect failed with error %d"), stat.Int());
        			if(RepeatCount <= 5)
        				{
        				Logger().WriteFormat( _L("Try to reconnect. RepeatCount %d"), RepeatCount);
        				User::After(WaitTimeout);
        				continue; // next attempt
        				}
        		    else
        		        {
        		        setResultFlagInt(stat.Int(), testStepResult);
        		        }
        			}
        		else
        		    {
        		    socketConnected = ETrue;
        		    }
        		
        		break; // exit "for"
        		}
        	
        	TESTEL((stat.Int()==KErrNone),stat.Int());
            }
    	
    	// get number of packets and size of packets 
    	TInt PacketSize = 0;
    	TESTL(GetIntFromConfig(_L("SendData"), _L("PacketSize"), PacketSize));
    	TInt NoPackets = 0;
    	TESTL(GetIntFromConfig(_L("SendData"), _L("NoPackets"), NoPackets));
    	Logger().WriteFormat( _L("Sending to %S port %d TCP data %d packets of %d bytes = %d"), 
    		&AddrBuf, Port, NoPackets, PacketSize, NoPackets * PacketSize);
    	
    	// set up data buffers
    	HBufC8 * writebuf = HBufC8::NewMaxLC( PacketSize );
    	HBufC8 * readbuf  = HBufC8::NewMaxLC( PacketSize );
    	TPtr8 ptrWritebuf = writebuf->Des();
    	TPtr8 ptrReadbuf = readbuf->Des();
    	
    	// small buffer for data pattern to be sent
    	TBuf8<50> Data;
    	
    	// send data (NoPackets packets of PacketSize bytes)
    	TInt recvCount = 0;
    	for (TInt i = 0; i < NoPackets; i++)
    		{
    		// initialise data
    		Data.Format(_L8("TCP-packet:%d helloworld"),i);
    		ptrWritebuf.Repeat( Data );
    		
    		// write data 
    		GuardTimer.After(TimerStatus,connectTimer * 1000000); 
    		(iEsockSuite->GetSocketHandle(1)).Write(ptrWritebuf, stat);
    		User::WaitForRequest(stat, TimerStatus);
    		GuardTimer.Cancel();
    		User::WaitForAnyRequest();
    		
    		if (stat == KRequestPending)
    			{
    			(iEsockSuite->GetSocketHandle(1)).CancelWrite();
    			Logger().WriteFormat(_L("Timeout on Tcp Send packet %d after %d seconds"), i, connectTimer);
    			setResultFlagInt(stat.Int(), testStepResult);
    			}
    		else if (stat != KErrNone)
    			{
    			Logger().WriteFormat(_L("Tcp Send packet %d failed with error %d"), i, stat.Int());
    			setResultFlagInt(stat.Int(), testStepResult);
    			}
    		TESTEL( stat == KErrNone, stat.Int() );
    		
    		// read data (from echo server)
    		GuardTimer.After(TimerStatus,connectTimer * 1000000); 
    		(iEsockSuite->GetSocketHandle(1)).Read(ptrReadbuf, stat);
    		User::WaitForRequest(stat, TimerStatus);
    		GuardTimer.Cancel();
    		User::WaitForAnyRequest();
    		
    		TESTE( stat == KErrNone, stat.Int() );
    		if (stat == KRequestPending)
    			{
    			(iEsockSuite->GetSocketHandle(1)).CancelRead();
    			Logger().WriteFormat(_L("Timeout on Tcp Recv packet %d after %d seconds"), i, connectTimer);
    			setResultFlagInt(stat.Int(), testStepResult);
    			}
    		else if (stat != KErrNone)
    			{
    			Logger().WriteFormat(_L("Tcp Recv packet %d failed with error %d"), i, stat.Int());
    			setResultFlagInt(stat.Int(), testStepResult);
    			}
    		else
    			{
    			// compare the data
    			TEST( ptrWritebuf.Compare( ptrReadbuf ) == 0);
    			recvCount+=ptrReadbuf.Length();
    			}
    		}
    	
    	// check the total received.
    	TEST(recvCount==(NoPackets*PacketSize));
    	
    	//** UDP STARTS HERE
    	// test UDP if required
    	if ( UdpEnable )
    		{
    		TESTL(GetIntFromConfig(_L("SendData"), _L("UdpPacketSize"), PacketSize));
    		
    		// get the port number
    		// Can't send back on Echo port as it would enter an infinite loop
    		if (!GetIntFromConfig(_L("SendData"), _L("UdpPort"), Port))
    			// use default
    			Port = 9200;
    		
    		Logger().WriteFormat( _L("Sending to %S Port %d UDP data %d packets of %d bytes = %d"), 
    			&AddrBuf, Port, NoPackets, PacketSize, NoPackets * PacketSize);
    		
    		
    		// and make some new buffers the correct size
    		HBufC8 * UdpWritebuf = HBufC8::NewMaxLC( PacketSize );
    		HBufC8 * UdpReadbuf  = HBufC8::NewMaxLC( PacketSize );
    		TPtr8 ptrUdpWritebuf = UdpWritebuf->Des();
    		TPtr8 ptrUdpReadbuf = UdpReadbuf->Des();
    		
    		// open a udp socket
    		RSocket UdpSock;
    		TInt nRet = UdpSock.Open(iEsockSuite->iSocketServer, KAfInet, KSockDatagram, KProtocolInetUdp);
    		if (nRet != KErrNone)
    			{
    			Logger().WriteFormat(_L("Failed to open socket: return value = <%d>"), nRet);
    			setResultFlagBool(EFail, testStepResult);
    			//return EFail;  
    			}
    		
    		if (testStepResult)
    		    {
            		addr.SetPort(Port);
            		
            		// Bind
            		TInt result = UdpSock.SetOpt(KSoUdpSynchronousSend, KSolInetUdp, 1 );
            		
            		UdpSock.SetOpt(KSoReuseAddr, KSolInetIp, KMaxTestStepCounter);
            		
            		TESTEL( KErrNone ==result,result);
            		
            		if (!udpBindOK)
            		    {
                		result = UdpSock.Bind(addr);
                		TESTEL( KErrNone ==result,result);
                		udpBindOK = ETrue;
            		    }
            		
            		
            		// write & read back the data
            		recvCount = 0;
            		for (TInt j = 0; j < NoPackets; j++)
            			{
            			// initialise data
            			Data.Format(_L8("UDP-packet:%d helloworld"),j);
            			ptrUdpWritebuf.Repeat( Data );
            			
            			// write data 
            			GuardTimer.After(TimerStatus,connectTimer * 1000000); 
            			UdpSock.SendTo(ptrUdpWritebuf, addrRemote, 0, stat);
            			User::WaitForRequest(stat, TimerStatus);
            			GuardTimer.Cancel();
            			User::WaitForAnyRequest();
            			
            			if (stat == KRequestPending)
            				{
            				UdpSock.CancelSend();
            				Logger().WriteFormat(_L("Timeout on Udp Send packet %d after %d seconds"), j, connectTimer);
            				setResultFlagInt(stat.Int(), testStepResult);
                            
            				}
            			else if (stat != KErrNone)
            				{
            				Logger().WriteFormat(_L("Udp Send packet %d failed with error %d"), j, stat.Int());
            				setResultFlagInt(stat.Int(), testStepResult);
            				}
            			
            			// read data (from echo server)
            			GuardTimer.After(TimerStatus,connectTimer * 1000000); 
            			UdpSock.RecvFrom(ptrUdpReadbuf, addr, 0, stat);
            			User::WaitForRequest(stat, TimerStatus);
            			GuardTimer.Cancel();
            			User::WaitForAnyRequest();
            			
            			if (stat == KRequestPending)
            				{
            				UdpSock.CancelRecv();
            				Logger().WriteFormat(_L("Timeout on Udp Recv packet %d after %d seconds"), j, connectTimer);
            				setResultFlagInt(stat.Int(), testStepResult);
            				}
            			else if (stat.Int() != KErrNone) 
            				{
            				Logger().WriteFormat(_L("Udp Recv packet %d failed with error %d"), j, stat.Int());
            				setResultFlagInt(stat.Int(), testStepResult);
            				}
            			//TEST( stat == KErrNone );  ** We could have packet loss with UDP in real life
            			else
            				{
            				// compare the data
            				TEST( ptrUdpWritebuf.Compare( ptrUdpReadbuf ) == 0);
            				recvCount += ptrUdpReadbuf.Length();
            				}
            			}
            		
            		Logger().WriteFormat(_L("Udp data sent %d bytes, data received %d bytes"),(NoPackets*PacketSize),recvCount);
            		
            		// check the total received (95 per cent is allowable for us)
            		//TESTE( recvCount >= (NoPackets*PacketSize), (NoPackets*PacketSize) );
            				
            		// close the UDP socket
                    UdpSock.Close();
    		    }
            
    		// get rid of the old buffers 
    		CleanupStack::PopAndDestroy();	//	UdpWritebuf;
    		CleanupStack::PopAndDestroy();	//	UdpReadbuf;
    		}
    		
    	CleanupStack::PopAndDestroy();	//	writebuf;
    	CleanupStack::PopAndDestroy();	//	readbuf;
    	
    	
    	if (!testStepResult)
    	    {
    	    Logger().WriteFormat(_L("TestStep failed %d time(s) from %d. Trying further..."), testStepCounter, KMaxTestStepCounter);
    	    
    	    ++testStepCounter;
    	    }
    	
	    }
	    while ( (testStepCounter < KMaxTestStepCounter) &&
	          (!testStepResult) ); //big while...
         

    if ( testStepResult )
        {
	    return EPass;
        }
    else
        {
        return EFail;
        }
	}
	
	
// Test step SendTcpData
// this test is used by the integration test scripts
// and is based on esock test 5.3
// This test step sends TCP data only
const TDesC& CEsockSendTcpData::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"SendTcpData");
	
	return ret;
	}

CEsockSendTcpData::~CEsockSendTcpData()
	{
	}

enum TVerdict CEsockSendTcpData::easyTestStepL()
	{
	TInetAddr addrRemote;
	TRequestStatus stat;
	TInt connectTimer, Port;
	
	// get ip address to connect to (on echo port)
	TESTL(GetIpAddressFromConfig(_L("Test_Common"), _L("ipAddress"), addrRemote));
	
	// get the port number
	TESTL(GetIntFromConfig(_L("SendData"), _L("Port"), Port));
	addrRemote.SetPort(Port);
	
	// format for display 
	TBuf<39> AddrBuf;
	addrRemote.OutputWithScope(AddrBuf);
	
	// get a value for the connection guard timer 
	TESTL(GetIntFromConfig(_L("SendData"), _L("connectTimer"), connectTimer));
	
	// create timer to use as a guard timer
	RTimer GuardTimer;
	GuardTimer.CreateLocal();			// for this thread
	TRequestStatus TimerStatus;			// status to monitor timer
	
    // connect
    (iEsockSuite->GetSocketHandle(1)).Connect(addrRemote, stat);
	
	// start timer
	GuardTimer.After(TimerStatus,connectTimer * 1000000); 
	
	// wait for either timer or connect
	User::WaitForRequest(stat, TimerStatus);
	GuardTimer.Cancel();
	User::WaitForAnyRequest();
	
	// check connect result
	if (stat!=KErrNone)
		{
		// either connect failed or timer expired
		// because it may be the timer cancel connect
		(iEsockSuite->GetSocketHandle(1)).CancelConnect();
		
		Logger().WriteFormat( _L("Socket connect has not completed within %d seconds (connectTimer from ini) "), connectTimer ); 
		
		// report this failure and leave
		TESTL((stat==KErrNone));
		}
	
	// get number of packets and size of packets 
	TInt PacketSize = 0;
	TESTL(GetIntFromConfig(_L("SendData"), _L("PacketSize"), PacketSize));
	TInt NoPackets = 0;
	TESTL(GetIntFromConfig(_L("SendData"), _L("NoPackets"), NoPackets));
	Logger().WriteFormat( _L("Sending to %S TCP data %d packets of %d bytes = %d"), 
		&AddrBuf, NoPackets, PacketSize, NoPackets * PacketSize);
	
	// set up data buffers
	HBufC8 * writebuf = HBufC8::NewMaxLC( PacketSize );
	HBufC8 * readbuf  = HBufC8::NewMaxLC( PacketSize );
	TPtr8 ptrWritebuf = writebuf->Des();
	TPtr8 ptrReadbuf = readbuf->Des();
	
	// initialise data
	TBuf8<50> Data;
	
	// send data (NoPackets packets of PacketSize bytes)
	TInt recvCount = 0;
	for (TInt i = 0; i < NoPackets; i++)
		{
		// initialise data
		Data.Format(_L8("TCP-packet:%d helloworld"),i);
		ptrWritebuf.Repeat( Data );
		
		// write data 
		GuardTimer.After(TimerStatus,connectTimer * 1000000); 
		(iEsockSuite->GetSocketHandle(1)).Write(ptrWritebuf, stat);
		User::WaitForRequest(stat, TimerStatus);
		GuardTimer.Cancel();
		User::WaitForAnyRequest();
		
		if (stat != KErrNone) Logger().WriteFormat(_L("Timeout on Tcp Send after %d seconds"), connectTimer);
		TESTL( stat == KErrNone );
		
		// read data (from echo server)
		GuardTimer.After(TimerStatus,connectTimer * 1000000); 
		(iEsockSuite->GetSocketHandle(1)).Read(ptrReadbuf, stat);
		User::WaitForRequest(stat, TimerStatus);
		GuardTimer.Cancel();
		User::WaitForAnyRequest();
		
		if (stat != KErrNone) Logger().WriteFormat(_L("Timeout on Tcp Recv after %d seconds"), connectTimer);
		TESTL( stat == KErrNone );
		
		// compare the data
		TESTL( ptrWritebuf.Compare( ptrReadbuf ) == 0);
		
		recvCount+=ptrReadbuf.Length();
		}
	
	// check the total received.
	TESTL(recvCount==(NoPackets*PacketSize));
	
	CleanupStack::PopAndDestroy();	//	writebuf;
	CleanupStack::PopAndDestroy();	//	readbuf;
	
	return EPass;
	}
	
// Open Udp Socket
const TDesC& CEsockOpenUdpSocket::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"OpenUdpSocket");
	
	return ret;
	}

CEsockOpenUdpSocket::~CEsockOpenUdpSocket()
	{
	}

enum TVerdict CEsockOpenUdpSocket::easyTestStepL()
	{
	TInt nRet;
	TInt nSockets; // number of sockets to open
	TInetAddr addr;
	TBuf<32> buf;
	TInt i;
	
	RSocket sock;
	
	// get number of sockets from script
	TESTL(GetIntFromConfig(SectionName(_L("Test_1.2")), _L("numSockets"), nSockets));
	
	Logger().WriteFormat(_L("Open <%d> UDP socket(s)"), nSockets);
	for (i = 0; i < nSockets; i++)
		{
		
		// open a UDP socket
		nRet = sock.Open(iEsockSuite->iSocketServer, KAfInet, KSockDatagram, KProtocolInetUdp);
		
		if (nRet != KErrNone)
			{
			
			Logger().WriteFormat(_L("Failed to open socket: return value = <%d>"), nRet);
			return EFail;  // do not try to open more sockets
			}
		
		// store socket handle
		iEsockSuite->AddSocketToListL(sock);
		}
	
	for (i = 0; i < nSockets; i++)
		{
		// Get local address of the socket (Empty)
		(iEsockSuite->GetSocketHandle(i + 1)).LocalName(addr);
		
		// Check length of buffer, should be set to (Zero)
		addr.OutputWithScope(buf);
		TESTL(buf.Length() == 0);
		}
	
	return EPass;
	}

// send Udp Data
const TDesC& CEsockSendUdpData::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"SendUdpData");
	
	return ret;
	}

CEsockSendUdpData::~CEsockSendUdpData()
	{
	}

enum TVerdict CEsockSendUdpData::easyTestStepL()
	{
	TInt testStepCounter = 0;
	TBool bindIsOK = EFalse;
	TBool testStepResult;
	
	TInetAddr addrRemote, addr;
	TRequestStatus stat;
	TInt connectTimer, Port;
	TInt result;
	
	do
	    {
	    testStepResult = ETrue;
	    
    	// get ip address to connect to (on echo port)
    	TESTL(GetIpAddressFromConfig(_L("Test_Common"), _L("ipAddress"), addrRemote));
    	
    	// get the port number
    	TESTL(GetIntFromConfig(_L("SendData"), _L("Port"), Port));
    	addrRemote.SetPort(Port);
    	
    	// get the port number
    	if(!GetIntFromConfig(_L("SendData"), _L("UdpPort"), Port))
    		Port = 9200;  // WAP UDP by default
    	
    	// Can't send back on Echo port as it would enter an infinite loop
    	addr.SetPort(Port);
    	
    	// format for display 
    	TBuf<39> AddrBuf;
    	addrRemote.OutputWithScope(AddrBuf);
    	
    	// get a value for the connection guard timer 
    	TESTL(GetIntFromConfig(_L("SendData"), _L("connectTimer"), connectTimer));
    	
    	// create timer to use as a guard timer
    	RTimer GuardTimer;
    	GuardTimer.CreateLocal();			// for this thread
    	TRequestStatus TimerStatus;			// status to monitor timer
    	
    	// get number of packets and size of packets 
    	TInt PacketSize = 0;
    	TESTL(GetIntFromConfig(_L("SendData"), _L("UdpPacketSize"), PacketSize));
    	TInt NoPackets = 0;
    	TESTL(GetIntFromConfig(_L("SendData"), _L("NoPackets"), NoPackets));
    	Logger().WriteFormat( _L("Send Udp Data to %S port %d in %d packets of %d bytes = %d"), 
    		&AddrBuf, Port, NoPackets, PacketSize, NoPackets * PacketSize);
    	
    	// and make some new buffers the correct size
    	HBufC8 * UdpWritebuf = HBufC8::NewMaxLC( PacketSize );
    	HBufC8 * UdpReadbuf  = HBufC8::NewMaxLC( PacketSize );
    	TPtr8 ptrUdpWritebuf = UdpWritebuf->Des();
    	TPtr8 ptrUdpReadbuf = UdpReadbuf->Des();
    	
    	result = (iEsockSuite->GetSocketHandle(1)).SetOpt(KSoUdpSynchronousSend, KSolInetUdp, 1 );
    	
    	// Bind
    	if (!bindIsOK)
    	    {
    	    result = (iEsockSuite->GetSocketHandle(1)).Bind(addr);
    	    TESTEL( KErrNone ==result,result);
    	    bindIsOK = ETrue;
    	    }
    	
    	TBuf8<50> Data;
    	
    	// write & read back the data
    	TInt recvCount = 0;
    	for (TInt i = 0; i < NoPackets; i++)
    		{
    		// initialise data
    		Data.Format(_L8("UDP-packet:%d helloworld"),i);
    		ptrUdpWritebuf.Repeat( Data );
    		
    		// write data 
    		GuardTimer.After(TimerStatus,connectTimer * 1000000); 
    		(iEsockSuite->GetSocketHandle(1)).SendTo(ptrUdpWritebuf, addrRemote, 0, stat);
    		User::WaitForRequest(stat, TimerStatus);
    		GuardTimer.Cancel();
    		User::WaitForAnyRequest();
    		
    		if (stat.Int() != KErrNone)
    		    {
    			Logger().WriteFormat(_L("Error on Udp Send after %d seconds, reason"), connectTimer, stat.Int());
    			setResultFlagInt(stat.Int(), testStepResult);
    		    }
    		
    		//TESTE( stat.Int() == KErrNone, stat.Int() );
    		
    		// read data (from echo server)
    		GuardTimer.After(TimerStatus,connectTimer * 1000000); 
    		(iEsockSuite->GetSocketHandle(1)).RecvFrom(ptrUdpReadbuf, addr, 0, stat);
    		User::WaitForRequest(stat, TimerStatus);
    		GuardTimer.Cancel();
    		User::WaitForAnyRequest();
    		
    		if (stat.Int() != KErrNone) 
    			{
    			Logger().WriteFormat(_L("Error on Udp Recv (packet %d) after %d seconds, reason %d"), i, connectTimer, stat.Int());
    			(iEsockSuite->GetSocketHandle(1)).CancelRecv();
    			setResultFlagInt(stat.Int(), testStepResult);
    			//TESTE( (stat.Int() == KErrNone), stat.Int() );  ** this is UDP, packet loss possible
    			}
    		else
    			{
    			// compare the data
    			TEST( ptrUdpWritebuf.Compare( ptrUdpReadbuf ) == 0 );
    			recvCount += ptrUdpReadbuf.Length();
    			}
    		
    		}
    	// Log what the % of the data was received!
    	Logger().WriteFormat(_L("Number of UDP packets sent %d, Number received %d"),NoPackets,recvCount);
    	
    	
    	// get rid of the old buffers 
    	CleanupStack::PopAndDestroy();	//	UdpWritebuf;
    	CleanupStack::PopAndDestroy();	//	UdpReadbuf;
    	
    	
	    if (!testStepResult)
    	    {
    	    Logger().WriteFormat(_L("TestStep failed %d time(s) from %d. Trying further..."), testStepCounter, KMaxTestStepCounter);
    	    
    	    ++testStepCounter;
    	    }
    	    
	    }
	    while ( (testStepCounter < KMaxTestStepCounter) &&
	          (!testStepResult) ); //big while...
     

    if ( testStepResult )
        {
	    return EPass;
        }
    else
        {
        return EFail;
        }
	}
	
	
// Test step 5.1
const TDesC& CEsockTest5_1::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test5.1");
	
	return ret;
	}

CEsockTest5_1::~CEsockTest5_1()
	{
	}

enum TVerdict CEsockTest5_1::easyTestStepPreambleL()
	{
	TInt connections;
	TRAPD(ret, connections = OpenConnectionsL(_L("Test_5.1"), iSockIndex2, iSockIndex3));
	if (KErrNone != ret)
		{
		return EFail;
		}
	if (0 >= connections)
		{
		return EFail;
		}

	return EPass;
	}

enum TVerdict CEsockTest5_1::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	// set up data buffers
	TBuf8<100> wbuf, rbuf1;
	TBuf8<20> rbuf2;
	wbuf.SetLength(20);
	StripeDes(wbuf, 0, wbuf.Length(), '@', 'Z');
	
	// for each pair of connected sockets
	TRequestStatus stat;
	TInt i;
	for (i = 0; i < iNumSockets; i++)
		{
		// send data from client to server (20 bytes)
		iEsockSuite->GetSocketHandle(iSockIndex2 + (i*2)).Write(wbuf, stat);
		User::WaitForRequest(stat);
		TESTEL(stat==KErrNone, stat.Int());
		
		// read data (server)
		iEsockSuite->GetSocketHandle(iSockIndex3 + (i*2)).Read(rbuf2, stat);
		User::WaitForRequest(stat);
		TESTEL(stat==KErrNone, stat.Int());
		TESTL(rbuf2==wbuf);
		}
	
	// send data from server to client (100 bytes)
	wbuf.SetMax();
	StripeDes(wbuf, 0, wbuf.Length(), '@', 'Z');
	
	// for each pair of connected sockets
	for (i = 0; i < iNumSockets; i++)
		{
		// send data from server to client
		(iEsockSuite->GetSocketHandle(iSockIndex2 + (i*2))).Write(wbuf, stat);
		User::WaitForRequest(stat);
		TESTEL(stat==KErrNone, stat.Int());
		
		// read data (client)
		(iEsockSuite->GetSocketHandle(iSockIndex3 + (i*2))).Read(rbuf1, stat);
		User::WaitForRequest(stat);
		TESTEL(stat==KErrNone, stat.Int());
		
		// check received data
		TESTL(rbuf1==wbuf);
		}
	
	return EPass;
	}


// Test step 5.2
const TDesC& CEsockTest5_2::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test5.2");
	
	return ret;
	}

CEsockTest5_2::~CEsockTest5_2()
	{
	}

enum TVerdict CEsockTest5_2::easyTestStepPreambleL()
	{
	TInt connections;
	TRAPD(ret, connections = OpenConnectionsL(_L("Test_5.2"), iSockIndex2, iSockIndex3));
	if (KErrNone != ret)
		{
		return EFail;
		}
	if (0 >= connections)
		{
		return EFail;
		}

	return EPass;
	}

enum TVerdict CEsockTest5_2::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	// set up data buffers
	TBuf8<1024> wbuf;
	
	StripeDes(wbuf, 0, wbuf.MaxLength(), '@', 'Z');
	wbuf.SetLength(20);
	
	// send data from client to server (20 bytes)
	TRequestStatus stat;
	iEsockSuite->GetSocketHandle(iSockIndex2).Send(wbuf, 0, stat);
	User::WaitForRequest(stat);
	TESTEL(stat==KErrNone, stat.Int());
	
	// read data 
	TBuf8<20> rbuf2;
	iEsockSuite->GetSocketHandle(iSockIndex3).Recv(rbuf2, 0, stat);
	User::WaitForRequest(stat);
	TESTEL(stat==KErrNone, stat.Int());
	
	TESTL(wbuf==rbuf2);
	
	// send data from server to client (20 packets of 1024 bytes)
	wbuf.SetLength(1024);
	TInt recvCount = 0;
	TBuf8<1024> rbuf1;
	for (TInt i = 0; i < 20; i++)
		{
		iEsockSuite->GetSocketHandle(iSockIndex3).Send(wbuf, 0, stat);
		User::WaitForRequest(stat);
		TESTL(stat==KErrNone);
		
		iEsockSuite->GetSocketHandle(iSockIndex2).Recv(rbuf1, 0, stat);
		User::WaitForRequest(stat);
		TESTEL(stat==KErrNone, stat.Int());
		
		recvCount+=rbuf1.Length();
		}
	
	// check number of bytes received
	TESTL(recvCount==(20*1024));
	
	// send data from client to server (20 packets of 512 bytes)
	wbuf.SetLength(512);
	recvCount = 0;
	TBuf8<512> rbuf3;
	for (TInt ii = 0; ii < 20; ii++)
		{
		iEsockSuite->GetSocketHandle(iSockIndex2).Send(wbuf, 0, stat);
		User::WaitForRequest(stat);
		TESTL(stat==KErrNone);
		
		iEsockSuite->GetSocketHandle(iSockIndex3).Recv(rbuf3, 0, stat);
		User::WaitForRequest(stat);
		TESTEL(stat==KErrNone, stat.Int());
		
		recvCount+=rbuf3.Length();
		}
	
	// check number of bytes received
	TESTL(recvCount==(20*512));
	
	return EPass;
	}


// Test step 5.3
const TDesC& CEsockTest5_3::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test5.3");
	
	return ret;
	}

CEsockTest5_3::~CEsockTest5_3()
	{
	}

enum TVerdict CEsockTest5_3::easyTestStepPreambleL()
	{
	CloseSockets();
	if (KErrNone != OpenMinSockets(_L("Test_5.3"),KAfInet, KSockStream, KProtocolInetTcp))
		{
		return EFail;
		}

	// get ip address to connect to (on echo port)
	TInetAddr addrRemote;
	if (!GetIpAddressFromConfig(_L("Test_Common"), _L("ipAddress"), addrRemote))
		{
		return EFail;
		}
	addrRemote.SetPort(7);
	
	// get log level
	if (!GetIntFromConfig(_L("Test_5.3"), _L("logLevel"), iLogLevel))
		{
		iLogLevel = 0;
		}

	// connect
	if (iLogLevel > 0)
		{
		Logger().Write(_L("Connect to remote host..."));
		}
	TRequestStatus stat;
	(iEsockSuite->GetSocketHandle(1)).Connect(addrRemote, stat);
	User::WaitForRequest(stat);
	if (KErrNone != stat.Int())
		{
		Logger().WriteFormat(_L("Connect returned %d"), stat.Int());
		return EFail;
		}
	if (iLogLevel > 0)
		{
		Logger().Write(_L("completed"));
		}

	return EPass;
	}

enum TVerdict CEsockTest5_3::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	// set up data buffers
	TBuf8<512> wbuf;
	StripeDes(wbuf, 0, wbuf.MaxLength(), '@', 'Z');
	
	// send data (20 bytes)
	wbuf.SetLength(20);
	TRequestStatus stat;
	if (iLogLevel > 0)
		{
		Logger().Write(_L("Sending..."));
		}
	RSocket& sock = iEsockSuite->GetSocketHandle(1);
	sock.Write(wbuf, stat);
	User::WaitForRequest(stat);
	TInt ret = stat.Int();
	TESTEL(KErrNone == ret, ret);
	
	// read data (from echo server)
	if (iLogLevel > 0)
		{
		Logger().Write(_L("Receiving..."));
		}
	TBuf8<20> rbuf2;
	sock.Read(rbuf2, stat);
	User::WaitForRequest(stat);
	ret = stat.Int();
	TESTEL(KErrNone == ret, ret);
	
	TESTL(rbuf2==wbuf);
	
	// send data (20 packets of 512 bytes)
	wbuf.SetMax();
	TInt sendCount = 0;

	if (iLogLevel > 0)
		{
		Logger().Write(_L("Send loop..."));
		}
	for (TInt i = 0; i < 20; i++)
		{
		sock.Write(wbuf, stat);
		User::WaitForRequest(stat);
		ret = stat.Int();
		TESTEL(KErrNone == ret, ret);
		sendCount += wbuf.Length();
		}

	TBuf8<128> rbuf1;
	TInt recvCount = 0;
	ret = KErrNone;
	while (recvCount < sendCount)
		{
		sock.Read(rbuf1, stat);
		User::WaitForRequest(stat);
		ret = stat.Int();
		
		if (KErrNone != ret)
			{
			break;
			}
		
		recvCount += rbuf1.Length();
		if (iLogLevel > 0)
			{
			Logger().WriteFormat(_L("Received %d octets"), rbuf1.Length());
			}
		}
	TESTEL(sendCount == recvCount, recvCount);
	
	if (iLogLevel > 0)
		{
		Logger().Write(_L("End Test 5.3"));
		}
	
	return EPass;
	}


// Test step 5.4
const TDesC& CEsockTest5_4::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test5.4");
	
	return ret;
	}

CEsockTest5_4::~CEsockTest5_4()
	{
	}

enum TVerdict CEsockTest5_4::easyTestStepPreambleL()
	{
	CloseSockets();
	if (KErrNone != OpenMinSockets(_L("Test_5.4"),KAfInet, KSockStream, KProtocolInetTcp))
		{
		return EFail;
		}

	// get ip address to connect to (on echo port)
	TInetAddr addrRemote;
	if (!GetIpAddressFromConfig(_L("Test_Common"), _L("ipAddress"), addrRemote))
		{
		return EFail;
		}
	addrRemote.SetPort(7);
	
	// get log level
	if (!GetIntFromConfig(_L("Test_5.4"), _L("logLevel"), iLogLevel))
		{
		iLogLevel = 0;
		}

	// connect
	if (iLogLevel > 0)
		{
		Logger().Write(_L("Connect to remote host..."));
		}
	TRequestStatus stat;
	(iEsockSuite->GetSocketHandle(1)).Connect(addrRemote, stat);
	User::WaitForRequest(stat);
	if (KErrNone != stat.Int())
		{
		Logger().WriteFormat(_L("Connect returned %d"), stat.Int());
		return EFail;
		}
	if (iLogLevel > 0)
		{
		Logger().Write(_L("completed"));
		}
	return EPass;
	}

enum TVerdict CEsockTest5_4::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	// set up data buffers
	TBuf8<512> wbuf;
	TBuf8<128> rbuf;
	StripeDes(wbuf, 0, wbuf.MaxLength(), '@', 'Z');
	
	// send data (30 bytes)
	wbuf.SetLength(30);
	TRequestStatus stat;
	if (iLogLevel > 0)
		{
		Logger().Write(_L("Sending..."));
		}
	RSocket& sock = iEsockSuite->GetSocketHandle(1);
	sock.Send(wbuf, 0, stat);
	User::WaitForRequest(stat);
	TInt ret = stat.Int();
	TESTEL(KErrNone == ret, ret);
	
	// read data (from echo server)
	if (iLogLevel > 0)
		{
		Logger().Write(_L("Receiving..."));
		}
	TSockXfrLength xfrLen;
	sock.RecvOneOrMore(rbuf, 0, stat, xfrLen);
	User::WaitForRequest(stat);
	ret = stat.Int();
	TESTEL(KErrNone == ret, ret);
	TInt len = xfrLen();
	TESTEL(30 == len, len);
	
	TESTL(rbuf==wbuf);
	
	// send data (20 packets of 512 bytes)
	wbuf.SetMax();
	TInt sendCount = 0;

	if (iLogLevel > 0)
		{
		Logger().Write(_L("Send loop..."));
		}
	for (TInt i = 0; i < 20; i++)
		{
		sock.Send(wbuf, 0, stat);
		User::WaitForRequest(stat);
		ret = stat.Int();
		TESTEL(KErrNone == ret, ret);
		sendCount += wbuf.Length();
		}

	TInt recvCount = 0;
	while (recvCount < sendCount)
		{
		sock.RecvOneOrMore(rbuf, 0, stat, xfrLen);
		User::WaitForRequest(stat);
		ret = stat.Int();

		if (KErrNone != ret)
			{
			break;
			}

		recvCount += xfrLen();
		if (iLogLevel > 0)
			{
			Logger().WriteFormat(_L("Received %d octets"), xfrLen());
			}
		}
	TESTEL(sendCount == recvCount, recvCount);
	
	if (iLogLevel > 0)
		{
		Logger().Write(_L("End Test 5.4"));
		}
	return EPass;
	}


// Test step 5.5
const TDesC& CEsockTest5_5::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test5.5");
	
	return ret;
	}

CEsockTest5_5::~CEsockTest5_5()
	{
	}

enum TVerdict CEsockTest5_5::easyTestStepPreambleL()
	{
	TInt connections;
	TRAPD(ret, connections = OpenConnectionsL(_L("Test_5.5"), iSockIndex2, iSockIndex3));
	if (KErrNone != ret)
		{
		return EFail;
		}
	if (0 >= connections)
		{
		return EFail;
		}

	return EPass;
	}

enum TVerdict CEsockTest5_5::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	const TInt KBufSize = 15000;
	// Constructs an empty 8 bit modifiable buffer descriptor. It contains no data.
	typedef TBuf8<KBufSize> TBuffer;
	
	TBuffer* wtemp=new (ELeave) TBuffer;
	CleanupStack::PushL(wtemp);
	TBuffer& wbuf=*wtemp;
	
	StripeDes(wbuf, 0, wbuf.MaxLength(), '@', 'Z');
	wbuf.SetMax();

	TRequestStatus wstat;
	(iEsockSuite->GetSocketHandle(iSockIndex2)).Write(wbuf, wstat);
	(iEsockSuite->GetSocketHandle(iSockIndex2)).CancelWrite();
	User::WaitForRequest(wstat);
	TESTEL(wstat==KErrNone || wstat==KErrCancel, wstat.Int());
	
	Logger().WriteFormat(_L("wstat =  %d"),wstat.Int());
	
	TBuf8<1024> wbuf2, rbuf;
	
	StripeDes(wbuf2, 0, wbuf2.MaxLength(), '@', 'Z');
	wbuf2.SetMax();
	
	iEsockSuite->GetSocketHandle(iSockIndex2).Write(wbuf2, wstat);
	User::WaitForRequest(wstat);
	TESTL(wstat==KErrNone);

	TRequestStatus rstat;
	iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf, rstat);
	User::WaitForRequest(rstat);	
	TESTEL(rstat==KErrNone, rstat.Int());
	
	TESTL(rbuf==wbuf2);
	
	CleanupStack::PopAndDestroy();
	
	// shutdown the client socket - do not wait for completion
	return EPass;
	}


// Test step 5.6
const TDesC& CEsockTest5_6::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test5.6");
	
	return ret;
	}

CEsockTest5_6::~CEsockTest5_6()
	{
	}

enum TVerdict CEsockTest5_6::easyTestStepPreambleL()
	{
	TInt connections;
	TRAPD(ret, connections = OpenConnectionsL(_L("Test_5.6"), iSockIndex2, iSockIndex3));
	if (KErrNone != ret)
		{
		return EFail;
		}
	if (0 >= connections)
		{
		return EFail;
		}

	return EPass;
	}

enum TVerdict CEsockTest5_6::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	const TInt KBufSize = 15000;
	// Constructs an empty 8 bit modifiable buffer descriptor. It contains no data.
	typedef TBuf8<KBufSize> TBuffer;
	
	TBuffer* wtemp=new (ELeave) TBuffer;
	CleanupStack::PushL(wtemp);
	TBuffer& wbuf=*wtemp;
	
	StripeDes(wbuf, 0, wbuf.MaxLength(), '@', 'Z');
	wbuf.SetMax();
	
	TRequestStatus wstat;
	(iEsockSuite->GetSocketHandle(iSockIndex2)).Send(wbuf, 0, wstat);	
	(iEsockSuite->GetSocketHandle(iSockIndex2)).CancelSend();
	User::WaitForRequest(wstat);
	TESTEL(wstat==KErrNone || wstat==KErrCancel, wstat.Int());
	
	Logger().WriteFormat(_L("wstat =  %d"),wstat.Int());
	
	TBuf8<1024> wbuf2, rbuf;
	
	StripeDes(wbuf2, 0, wbuf2.MaxLength(), '@', 'Z');
	wbuf2.SetMax();
	
	(iEsockSuite->GetSocketHandle(iSockIndex2)).Send(wbuf2, 0, wstat);
	User::WaitForRequest(wstat);
	TESTL(wstat==KErrNone);

	TRequestStatus rstat;
	(iEsockSuite->GetSocketHandle(iSockIndex3)).Recv(rbuf, 0, rstat);
	User::WaitForRequest(rstat);
	TESTEL(rstat==KErrNone, rstat.Int());
	
	TESTL(rbuf==wbuf2);
	
	CleanupStack::PopAndDestroy();
	
	// shutdown the client socket - do not wait for completion
	return EPass;
	}


// Test step 5.7
const TDesC& CEsockTest5_7::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test5.7");
	
	return ret;
	}

CEsockTest5_7::~CEsockTest5_7()
	{
	}

enum TVerdict CEsockTest5_7::easyTestStepPreambleL()
	{
	TInt connections;
	TRAPD(ret, connections = OpenConnectionsL(_L("Test_5.7"), iSockIndex2, iSockIndex3));
	if (KErrNone != ret)
		{
		return EFail;
		}
	if (0 >= connections)
		{
		return EFail;
		}

	return EPass;
	}

enum TVerdict CEsockTest5_7::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	TBuf8<24> wbuf, rbuf;
	StripeDes(wbuf, 0, wbuf.MaxLength(), '1', '9');
	// send data (20 bytes)
	wbuf.SetLength(20);
	
	TRequestStatus wstat;
	iEsockSuite->GetSocketHandle(iSockIndex2).Write(wbuf, wstat);
	User::WaitForRequest(wstat);
	TESTL(wstat==KErrNone);
	
	// read the data - deliberately trying to read more than was sent so as to block indefinitely
	TRequestStatus rstat;
	iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf, rstat);
	User::After(1000000);	// wait a second so that initial 20 bytes can be recv'd
	// cancel read before it completes
	iEsockSuite->GetSocketHandle(iSockIndex3).CancelRead();
	User::WaitForRequest(rstat);
	TESTL(rstat==KErrCancel);
	
	TBuf8<1024> wbuf2, rbuf2;
	StripeDes(wbuf2, 0, wbuf2.MaxLength(), '@', 'Z');
	wbuf2.SetMax();
	
	iEsockSuite->GetSocketHandle(iSockIndex2).Write(wbuf2, wstat);
	User::WaitForRequest(wstat);
	TESTL(wstat==KErrNone);
	iEsockSuite->GetSocketHandle(iSockIndex3).Read(rbuf2, rstat);
	User::WaitForRequest(rstat);
	TESTL(rstat==KErrNone);
	
	TESTL(wbuf2==rbuf2);
	
	// shutdown the client socket - do not wait for completion
	return EPass;
	}


// Test step 5.8
const TDesC& CEsockTest5_8::GetTestName()
	{
	// store the name of this test case
	_LIT(ret,"Test5.8");
	
	return ret;
	}

CEsockTest5_8::~CEsockTest5_8()
	{
	}

enum TVerdict CEsockTest5_8::easyTestStepPreambleL()
	{
	TInt connections;
	TRAPD(ret, connections = OpenConnectionsL(_L("Test_5.8"), iSockIndex2, iSockIndex3));
	if (KErrNone != ret)
		{
		return EFail;
		}
	if (0 >= connections)
		{
		return EFail;
		}

	return EPass;
	}

enum TVerdict CEsockTest5_8::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());

	TBuf8<24> wbuf, rbuf;
	StripeDes(wbuf, 0, wbuf.MaxLength(), '1', '9');
	// send data (20 bytes)
	wbuf.SetLength(20);
	
	TRequestStatus wstat;
	iEsockSuite->GetSocketHandle(iSockIndex2).Send(wbuf, 0, wstat);
	User::WaitForRequest(wstat);
	TESTL(wstat==KErrNone);
	// read the data - deliberately trying to read more than was sent so as to block indefinitely
	
	TRequestStatus rstat;
	iEsockSuite->GetSocketHandle(iSockIndex3).Recv(rbuf, 0, rstat);
	User::After(1000000);	// wait a second so that initial 20 bytes can be recv'd
	// cancel read before it completes
	iEsockSuite->GetSocketHandle(iSockIndex3).CancelRecv();
	User::WaitForRequest(rstat);
	TESTL(rstat==KErrCancel);
	
	TBuf8<1024> wbuf2, rbuf2;
	StripeDes(wbuf2, 0, wbuf2.MaxLength(), '@', 'Z');
	wbuf2.SetMax();
	
	iEsockSuite->GetSocketHandle(iSockIndex2).Send(wbuf2, 0, wstat);
	User::WaitForRequest(wstat);
	TESTL(wstat==KErrNone);
	iEsockSuite->GetSocketHandle(iSockIndex3).Recv(rbuf2, 0, rstat);
	User::WaitForRequest(rstat);
	TESTL(rstat==KErrNone);
	
	TESTL(wbuf2==rbuf2);
	
	// shutdown the client socket - do not wait for completion
	return EPass;
	}

// Test step 5.9
// Open a TCP socket along with a RawIP socket on TCP protocol. Write some data to the 
// TCP socke and perform a read on the RawIP socket, this should not fail.
const TDesC& CEsockTest5_9::GetTestName()
	{		
	// store the name of this test case
	_LIT(ret,"Test5.9");
	
	return ret;
	}

CEsockTest5_9::~CEsockTest5_9()
	{
	}

enum TVerdict CEsockTest5_9::easyTestStepPreambleL()
	{
	CloseSockets();
	if (KErrNone != OpenMinSockets(_L("Test_5.9"),KAfInet, KSockStream, KProtocolInetTcp))
		{
		return EFail;
		}

	TInetAddr addrRemote;
	// get ip address to connect to (on echo port)
	if (!GetIpAddressFromConfig(_L("Test_Common"), _L("ipAddress"), addrRemote))
		{
		return EFail;
		}
	addrRemote.SetPort(7);	
		
	// connect
	TRequestStatus stat;
	(iEsockSuite->GetSocketHandle(1)).Connect(addrRemote, stat);
	User::WaitForRequest(stat);
	TInt ret = stat.Int();
	if (KErrNone != ret)
		{
		Logger().WriteFormat(_L("Connect returned %d"), ret);
		return EFail;
		}

	return EPass;
	}
		
TVerdict CEsockTest5_9::easyTestStepL()
	{
	TESTL(EPass == TestStepResult());
	
	// prepare for test
	// set up data buffers
	TBuf8<512> wbuf;
	StripeDes(wbuf, 0, wbuf.MaxLength(), '@', 'Z');
	
	// setup data (30 bytes) for send
	wbuf.SetLength(30);
	
	// open RawIP socket
	RSocket rawsock;
	CleanupClosePushL(rawsock);
	_LIT(KRawIp, "rawip");
	TInt ret = rawsock.Open(iEsockSuite->iSocketServer, KRawIp);
	TESTEL(KErrNone == ret, ret);
		
	// bind RawIP socket to TCP protocol
	ret = rawsock.SetLocalPort(KProtocolInetTcp);
	TESTEL(KErrNone == ret, ret);
	
	// prepare to receive data
	TBuf8<30> recvBuf;
	recvBuf.Zero();
	TRequestStatus receiveStat;
	rawsock.Read(recvBuf, receiveStat);
	
	// now there is an outstanding receive send to the echo server
	TRequestStatus stat;
	(iEsockSuite->GetSocketHandle(1)).Write(wbuf, stat);
	User::WaitForRequest(stat);
	ret = stat.Int();
	TESTEL(KErrNone == ret, ret);
	
	// check that we have received the echo'ed data
	User::WaitForRequest(receiveStat);
	ret = receiveStat.Int();
	TESTEL(KErrNone == ret, ret);
	TESTL(recvBuf.Length() != 0);
	
	CleanupStack::PopAndDestroy(&rawsock);
	return EPass;
	}