diff -r 000000000000 -r 7f656887cf89 plugins/networking/tcpcsy/src/reader.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/plugins/networking/tcpcsy/src/reader.cpp	Wed Jun 23 15:52:26 2010 +0100
@@ -0,0 +1,116 @@
+// reader.cpp
+// 
+// Copyright (c) 2008 - 2010 Accenture. All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of the "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:
+// Accenture - Initial contribution
+//
+
+#include "reader.h"
+#include "panic.h"
+
+
+CReader* CReader::NewL(RSocket& aSocket, MReaderObserver& aObserver)
+	{
+	return new(ELeave) CReader(aSocket, aObserver);
+	}
+
+CReader::~CReader()
+	{
+	Cancel();
+	iBuffer.Close();
+	}
+
+void CReader::StartRead(TInt aLength, TReadMode aMode)
+	{
+	__ASSERT_DEBUG(!IsActive() && (iPendingLength == 0), Panic(EPanicReadAlreadyPending));
+
+	if (iBuffer.MaxLength() < aLength)
+		{
+		TInt err = iBuffer.ReAlloc(aLength);
+		if (err)
+			{
+			iObserver.ReadError(err);
+			return;
+			}
+		}
+
+	if (Connected())
+		{
+		iBuffer.Zero();
+
+		switch (aMode)
+			{
+			case EFull:
+				{
+				iSocket.Recv(iBuffer, 0, iStatus);
+				break;
+				}
+			case EOneOrMore:
+				{
+				iSocket.RecvOneOrMore(iBuffer, 0, iStatus, iXfrLength);
+				break;
+				}
+			default:
+				{
+				__ASSERT_DEBUG(EFalse, Panic(EPanicInvalidReadMode));
+				}
+			};
+
+		SetActive();
+		}
+	else
+		{
+		iPendingLength = aLength;
+		iPendingMode = aMode;
+		}
+	}
+
+void CReader::GetBufferLength(TInt& aLength)
+	{
+	aLength = iBuffer.Length();
+	}
+
+void CReader::Abort()
+	{
+	iPendingLength = 0;
+	Cancel();
+	}
+
+void CReader::HandleSocketConnected()
+	{
+	if (iPendingLength > 0)
+		{
+		TInt pendingLength = iPendingLength;
+		iPendingLength = 0;
+		StartRead(pendingLength, iPendingMode);
+		}
+	}
+
+CReader::CReader(RSocket& aSocket, MReaderObserver& aObserver)
+	: CSocketUser(aSocket), iObserver(aObserver)
+	{
+	CActiveScheduler::Add(this);
+	}
+
+void CReader::RunL()
+	{
+	if (iStatus.Int())
+		{
+		iObserver.ReadError(iStatus.Int());
+		}
+	else
+		{
+		iObserver.ReadComplete(iBuffer);
+		}
+	}
+
+void CReader::DoCancel()
+	{
+	iSocket.CancelRecv();
+	}
+