// reader.cpp
// 
// Copyright (c) 2008 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

#include "reader.h"
#include "panic.h"


CReader* CReader::NewL(RSocket& aSocket, MReaderObserver& aObserver)
	{
	return new(ELeave) CReader(aSocket, aObserver);
	}

CReader::~CReader()
	{
	Cancel();
	iBuffer.Close();
	}

void CReader::StartRead(TInt aLength, TReadMode aMode)
	{
	__ASSERT_DEBUG(!IsActive() && (iPendingLength == 0), Panic(EPanicReadAlreadyPending));

	if (iBuffer.MaxLength() < aLength)
		{
		TInt err = iBuffer.ReAlloc(aLength);
		if (err)
			{
			iObserver.ReadError(err);
			return;
			}
		}

	if (Connected())
		{
		iBuffer.Zero();

		switch (aMode)
			{
			case EFull:
				{
				iSocket.Recv(iBuffer, 0, iStatus);
				break;
				}
			case EOneOrMore:
				{
				iSocket.RecvOneOrMore(iBuffer, 0, iStatus, iXfrLength);
				break;
				}
			default:
				{
				__ASSERT_DEBUG(EFalse, Panic(EPanicInvalidReadMode));
				}
			};

		SetActive();
		}
	else
		{
		iPendingLength = aLength;
		iPendingMode = aMode;
		}
	}

void CReader::GetBufferLength(TInt& aLength)
	{
	aLength = iBuffer.Length();
	}

void CReader::Abort()
	{
	iPendingLength = 0;
	Cancel();
	}

void CReader::HandleSocketConnected()
	{
	if (iPendingLength > 0)
		{
		TInt pendingLength = iPendingLength;
		iPendingLength = 0;
		StartRead(pendingLength, iPendingMode);
		}
	}

CReader::CReader(RSocket& aSocket, MReaderObserver& aObserver)
	: CSocketUser(aSocket), iObserver(aObserver)
	{
	CActiveScheduler::Add(this);
	}

void CReader::RunL()
	{
	if (iStatus.Int())
		{
		iObserver.ReadError(iStatus.Int());
		}
	else
		{
		iObserver.ReadComplete(iBuffer);
		}
	}

void CReader::DoCancel()
	{
	iSocket.CancelRecv();
	}