// Copyright (c) 2003-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 "chttpcontentreader.h"
#include "mhttpdatasender.h"

const TInt KFileReadSize = 16 * 1024;

CHttpFileReader* CHttpFileReader::New(RFile aFile, MHttpDataSender& aReceiver)
    {
    CHttpFileReader* self = new CHttpFileReader(aFile, aReceiver);
    if(self)
        {
        if(self->Construct() != KErrNone)
            {
            delete self;
            self = NULL;
            }
        }
    return self;
    }

TInt CHttpFileReader::Construct()
    {   
    iFile.Size(iTotalSize);
    return iContentBuffer.Create(KFileReadSize);
    }

CHttpFileReader::CHttpFileReader(RFile aFile, MHttpDataSender& aReceiver)
: CActive(EPriorityStandard),
iFile(aFile),
iDataSender(aReceiver)
    {
    CActiveScheduler::Add(this);
    }
CHttpFileReader::~CHttpFileReader()
    {
    Cancel();
    iContentBuffer.Close();
    }

void CHttpFileReader::Read()
    {
    iContentBuffer.Zero();
    iFile.Read(iContentBuffer, iStatus);
    SetActive();
    }

// From CActive
void CHttpFileReader::RunL()
    {
    User::LeaveIfError(iStatus.Int());
    iReadBytes += iContentBuffer.Length();
    iDataSender.Notify(iContentBuffer, iReadBytes == iTotalSize);
    }

void CHttpFileReader::DoCancel()
    {
    iFile.ReadCancel(iStatus);
    }

TInt CHttpFileReader::RunError(TInt aError)
    {
    iDataSender.Error(aError);
    return KErrNone;
    }