// 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 ();+
−
	}+
−