// 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:

//

#include <obex/internal/obexactiverw.h>

#include <obex/internal/obexpacket.h>

#include <obex/transport/mobextransportnotify.h>

#include <obex/transport/obexconnector.h>

#include "ObexTransportUtil.h"

#include "logger.h"

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, "OBEXCT");

#endif

/**

Constructor

@param aPriority a priority

@param aOwner the owner 

@param aInfo connection information

*/

CObexActiveRW::CObexActiveRW(TPriority aPriority,

							 MObexTransportNotify& aOwner,

							 TObexConnectionInfo& aInfo)

 :	CActive (aPriority), 

	iOwner(aOwner), 

	iLocation (NULL, 0)

	{

	LOG_LINE

	LOG_FUNC

	CActiveScheduler::Add (this);

	iPacketBased = aInfo.iSocketType==TObexConnectionInfo::ESocketPacket ? ETrue : EFalse;

	}

/**

Destructor

*/

CObexActiveRW::~CObexActiveRW()

	{

	LOG_LINE

	LOG_FUNC

	Cancel();

	}

/**

Start a new write or read

Reset the pointer descriptor to the start of the buffer and make the call to 

start the transfer

@param aPacket the obex packet to read or write

*/

void CObexActiveRW::NewRequest(CObexPacket& aPacket)

	{

	LOG_FUNC

	iPacket = &aPacket;

	iCount = 0;

	// Set descriptor to start of buffer

	// Size pointer according to either the number of bytes remaining in packet

	// OR maximum number of bytes we can receive (see Remaining())

	iLocation.Set(iPacket->iBuffer, 0, Remaining ());

	DoTransfer();

	}

/*

Non-virtual method calling virtual method StartTransfer. BC protection.

@param aPacket  the obex packet to transfer

*/

void CObexActiveRW::Transfer(CObexPacket& aPacket)

	{

	LOG_FUNC

	StartTransfer(aPacket);

	}

/**

RunL called after a read/write has completed

Check to see if we need to issue another request, otherwise process the 

complete packet

*/

EXPORT_C void CObexActiveRW::RunL()

	{

	LOG_LINE

	LOG_FUNC

	LOG1(_L8("\tiStatus = %d"), iStatus.Int());

/*

	TBuf<256> hexBuf;

	FTRACE(FPrint(_L("CObexActiveRW::RunL iLocation.Length() = %d"), iLocation.Length()));

	for (TInt i = 0; i < iLocation.Length(); i++)

		{

		hexBuf.AppendFormat(_L("%02X "), iLocation[i]);

		if ((i % 16) == 15)

			{

			FLOG(hexBuf);

			hexBuf = KNullDesC;

			}

		}

	FLOG(hexBuf);

*/

	// Check the request completed OK

	if ( iStatus != KErrNone )

		{

		iOwner.Error(iStatus.Int());

		return;

		}

	// Update the byte count and check to see if the transfer is complete

	iCount += iLocation.Size();

	if ( CompleteTransfer() )

		{

		// Inform interested parties

		OnCompleteTransfer();

		return;

		}

	// Otherwise update the buffer pointer and start another transfer

	LOG1(_L8("CObexActiveRW::RunL Setting location, remaining=%d"), Remaining());

	iLocation.Set (&iPacket->iBuffer[iCount], 0, Remaining());

	if ( iLocation.MaxLength() > 0 )

		{

		DoTransfer();

		}

	}