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

	}