// 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/obexactivewriter.h>+
−
#include <obex/internal/obexpacket.h>+
−
#include <es_sock.h>+
−
#include <obex/transport/mobextransportnotify.h>+
−
#include "ObexTransportUtil.h"+
−
#include "logger.h"+
−
+
−
#ifdef __FLOG_ACTIVE+
−
_LIT8(KLogComponent, "OBEXCT");+
−
#endif+
−
+
−
EXPORT_C CObexActiveWriter* CObexActiveWriter::NewL(MObexTransportNotify& aOwner, RSocket& aSocket, TObexConnectionInfo& aInfo)+
−
	{+
−
	CObexActiveWriter* self = new(ELeave) CObexActiveWriter(aOwner, aSocket, aInfo);+
−
	CleanupStack::PushL(self);+
−
	self->BaseConstructL();+
−
	CleanupStack::Pop(self);+
−
	return self;+
−
	}+
−
+
−
CObexActiveWriter::CObexActiveWriter (MObexTransportNotify& aOwner, RSocket& aSocket, TObexConnectionInfo& aInfo)+
−
 :	CObexWriterBase (EPriorityHigh, aOwner, aInfo),+
−
	iInfo ( aInfo ),+
−
	iSocket(aSocket)+
−
	{+
−
	LOG_LINE+
−
	LOG_FUNC+
−
	}+
−
+
−
EXPORT_C CObexActiveWriter::~CObexActiveWriter ()+
−
	{+
−
	LOG_LINE+
−
	LOG_FUNC+
−
+
−
	Cancel ();+
−
	}+
−
+
−
/**+
−
Start transfer.+
−
Calls into CObexActiveRW, which eventaully queues a write which is limited by +
−
the smaller of iInfo's max send size and aPacket's data limit+
−
+
−
@param aPacket The Obex packet to write+
−
*/+
−
void CObexActiveWriter::StartTransfer (CObexPacket& aPacket)+
−
	{+
−
	LOG_FUNC+
−
+
−
	// Find out how much we can write to the remote end per transfer+
−
	iTransportWriteLimit = Min(iInfo.iMaxSendSize, aPacket.DataLimit());+
−
	LOG1(_L8("\tiTransportWriteLimit = %d"), iTransportWriteLimit);+
−
	CObexWriterBase::StartTransfer(aPacket);+
−
	}+
−
	+
−
+
−
// Called to actually transfer some data out from iLocation +
−
void CObexActiveWriter::DoTransfer ()+
−
	{+
−
	LOG_FUNC+
−
+
−
	// Send the biggest chunk we can over the transport+
−
	if (iPacketBased && (iLocation.MaxLength () > iTransportWriteLimit))+
−
		{+
−
		iLocation.SetLength (iTransportWriteLimit);+
−
		}+
−
	else+
−
		{+
−
		iLocation.SetMax ();+
−
		}+
−
+
−
	iSocket.Write (iLocation, iStatus);+
−
	SetActive ();+
−
	}+
−
+
−
void CObexActiveWriter::DoCancel ()+
−
	{+
−
	LOG_FUNC+
−
+
−
	iSocket.CancelSend ();+
−
	}+
−