diff -r 000000000000 -r 3e07fef1e154 testexecfw/tef/workshop/demoipsuite/src/tcpstep.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/testexecfw/tef/workshop/demoipsuite/src/tcpstep.cpp	Mon Mar 08 15:03:44 2010 +0800
@@ -0,0 +1,102 @@
+/*
+* Copyright (c) 2005-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:  
+* Example CTestStep derived implementation
+*
+*/
+
+
+
+/**
+ @file TCPStep.cpp
+*/
+#include "TCPStep.h"
+#include "IPSuiteDefs.h"
+
+CTCPStep::~CTCPStep()
+/**
+ * Destructor
+ */
+	{
+	}
+
+CTCPStep::CTCPStep()
+/**
+ * Constructor
+ */
+	{
+	// **MUST** call SetTestStepName in the constructor as the controlling
+	// framework uses the test step name immediately following construction to set
+	// up the step's unique logging ID.
+	SetTestStepName(KDemoTCPStep);
+	}
+
+TVerdict CTCPStep::doTestStepL()
+/**
+ * @return - TVerdict code
+ * Override of base class pure virtual
+ * Our implementation only gets called if the base class doTestStepPreambleL() did
+ * not leave. That being the case, the current test result value will be EPass.
+ */
+	{
+	RSocket socket;
+	User::LeaveIfError(socket.Open(iServer, KAfInet, KSockStream, KProtocolInetTcp));
+	CleanupClosePushL(socket);
+
+	TRequestStatus status;
+	socket.Connect(iDestAddr,status);
+	User::WaitForRequest(status);
+	User::LeaveIfError(status.Int());
+	
+	TBuf<50> IPAddrBuf;
+	iDestAddr.Output(IPAddrBuf);
+	_LIT(KSendDataMessage,"Send Data to %S Port = %d Length = %d");
+	INFO_PRINTF4(KSendDataMessage,&IPAddrBuf,iDestAddr.Port(),iWriteData->Des().Length());
+	
+	TPtr8 writeDataDes(iWriteData->Des());
+	socket.Write(writeDataDes,status);
+	User::WaitForRequest(status);
+	User::LeaveIfError(status.Int());
+
+	// For TCP only. We can check to see if the server has the ACK'd the data using
+	// an Ioctl on the socket
+	socket.Ioctl(KIoctlTcpNotifyDataSent,status, 0, KSolInetTcp);
+	User::WaitForRequest(status);
+	User::LeaveIfError(status.Int());
+
+	_LIT(KSentDataMessage,"Data Sent");
+	INFO_PRINTF1(KSentDataMessage);
+
+	// Use Recv in this case
+	// The status is not completed until the descriptor is full
+	// or there is a socket error/timeout -22
+	TPtr8 readDataDes(iReadData->Des());
+	socket.Recv(readDataDes,0,status);
+	User::WaitForRequest(status);
+	User::LeaveIfError(status.Int());
+
+	_LIT(KRecvDataMessage,"Data Received Length = %d");
+	INFO_PRINTF2(KRecvDataMessage,readDataDes.Length());
+
+	// The receive data should always match the sent
+	// Try deliberately corrupting the send or receive descriptor and
+	// the panic will be picked up in the script engine
+	__ASSERT_ALWAYS(readDataDes == writeDataDes,User::Panic(KDemoIPSuitePanic,ETCPDataCorrupt));
+
+	socket.Close();
+
+	CleanupStack::Pop(1);			// Server and Socket Handles
+	
+	return TestStepResult();
+	}