diff -r 4dc88a4ac6f4 -r f6055a57ae18 obex/obexprotocol/obextransport/src/obexactivereader.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/obex/obexprotocol/obextransport/src/obexactivereader.cpp	Tue Oct 19 11:00:12 2010 +0800
@@ -0,0 +1,113 @@
+// Copyright (c) 1997-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:
+//
+
+#include <obex/transport/obexactivereader.h>
+#include <es_sock.h>
+#include "logger.h"
+
+#ifdef __FLOG_ACTIVE
+_LIT8(KLogComponent, "OBEXCT");
+#endif
+
+/**
+Factory function.
+@param  aOwner the owner of this 
+@param aSocket  a socket for reading and writing
+@param aInfo connection information
+@return Ownership of a new active reader.
+*/
+EXPORT_C CObexActiveReader* CObexActiveReader::NewL(MObexTransportNotify& aOwner, RSocket& aSocket, TObexConnectionInfo& aInfo)
+	{
+	CObexActiveReader* self = new(ELeave) CObexActiveReader(aOwner, aSocket, aInfo);
+	CleanupStack::PushL(self);
+	self->BaseConstructL();
+	CleanupStack::Pop(self);
+	return self;
+	}
+
+/**
+Constructor
+@param  aOwner the owner of this 
+@param aSocket  a socket for reading and writing
+@param aInfo connection information
+*/
+CObexActiveReader::CObexActiveReader (MObexTransportNotify& aOwner, RSocket& aSocket, TObexConnectionInfo& aInfo)
+	: CObexReaderBase (EPriorityStandard, aOwner, aInfo),
+	iSocket(aSocket)
+	{
+	LOG_LINE
+	LOG_FUNC
+	}
+
+/**
+Destructor
+*/
+EXPORT_C CObexActiveReader::~CObexActiveReader ()
+	{
+	LOG_LINE
+	LOG_FUNC
+
+	Cancel ();
+	}
+
+/**
+Called to actually transfer some data into iLocation 
+*/
+void CObexActiveReader::DoTransfer ()
+	{
+	LOG_FUNC
+
+	iSocket.Recv(iLocation, KSockReadContinuation, iStatus);
+	SetActive ();
+	}
+
+/**
+Return the maximum packet size
+@return TInt the maximum packet size for this transport
+*/
+TInt CObexActiveReader::GetMaxPacketSize()
+	{
+	LOG_FUNC
+
+	// Some slightly dubious logic here...
+	// IrDA has a degenerate case when running over a 256 byte transport layer link, we claim
+	// to support <255 bytes. The Obex spec says that all stations must be able to handle
+	// 255 bytes, so some stacks may ignore our limit.
+	// Thus we compare against the actual buffer size, rather than what we told the remote end
+	// we could handle, so we *may* be able to handle being sent a few bytes more than expected...
+
+	TInt ret = GetObexPacketBufferSize();
+	LOG1(_L8("\tret = %d"), ret);
+	return ret;
+	}
+
+/**
+Returns a initial packet size when the packet size of iPacket is not know.  This is used
+when determining the remaining bytes to be read.  
+@return TInt the initial packet size
+*/
+TInt CObexActiveReader::GetInitialPacketSize ()
+	{
+	LOG_FUNC
+
+	return GetObexPacketHeaderSize();
+	}
+
+void CObexActiveReader::DoCancel ()
+	{
+	LOG_FUNC
+
+	iSocket.CancelRecv ();
+	}