/*
* Copyright (c) 2002-2007 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:  Class for reading data from Java SourceStream to native side
*
*/

#include <jdebug.h>
#include <JniEnvWrapper.h>

#include "cmmaeventsource.h"
#include "cmmasourcestream.h"
#include "cmmasourcestreamevent.h"
#include "mmmasourcestreamlistener.h"

const TInt KBufferSize = 4096; // data is read from java in 4k pieces

// CONSTRUCTION
CMMASourceStream* CMMASourceStream::NewL(JNIEnv* aJNIEnv,
        MMMAEventPoster* aEventPoster,
        jobject aJavaSourceStream,
        MMMASourceStreamListener* aListener
                                        )
{
    CMMASourceStream* self = CMMASourceStream::NewLC(aJNIEnv,
                             aEventPoster,
                             aJavaSourceStream,
                             aListener);
    CleanupStack::Pop();
    return self;
}


CMMASourceStream* CMMASourceStream::NewLC(JNIEnv* aJNIEnv,
        MMMAEventPoster* aEventPoster,
        jobject aJavaSourceStream,
        MMMASourceStreamListener* aListener
                                         )
{
    CMMASourceStream* self = new(ELeave) CMMASourceStream(aEventPoster,
            aListener);
    CleanupStack::PushL(self);
    self->ConstructL(aJNIEnv, aJavaSourceStream);
    return self;
}


CMMASourceStream::~CMMASourceStream()
{
    DEBUG("MMA::CMMASourceStream::~");
    delete iData;
    delete iReadEvent;
}


// Default constructor
CMMASourceStream::CMMASourceStream(MMMAEventPoster* aEventPoster,
                                   MMMASourceStreamListener* aListener)
        : iEventPoster(aEventPoster), iListener(aListener)
{
}


void CMMASourceStream::ConstructL(JNIEnv* aJNIEnv,
                                  jobject aJavaSourceStream)
{
    // JNI interface pointer can't be passed to different thread, so
    // it is needed to get valid JNI interface pointer for Event Server thread
    aJNIEnv = JniEnvWrapper::GetValidJniRef();
    jmethodID classMethodID =
        aJNIEnv->GetMethodID(aJNIEnv->GetObjectClass(aJavaSourceStream),
                             "read",
                             "(II)V");
    if (!classMethodID)
    {
        User::Leave(KErrNoMemory);
    }

    iReadEvent = new(ELeave) CMMASourceStreamEvent(classMethodID,
            aJavaSourceStream);
}


void CMMASourceStream::WriteL(const TUint8* aData,
                              TInt aLength,
                              TInt aState)
{
    if (aState < KErrNone)
    {
        // Inform listener on error case
        iListener->ReadCompletedL(aState, KNullDesC8());
        return;
    }


    if ((iData->Size() + aLength) > iData->Des().MaxSize())
    {
        // if data doesn't fit, reallocate more
        HBufC8* reallocated = iData->ReAlloc(iData->Des().MaxSize() + KBufferSize);
        if (!reallocated)  // realloc failed
        {
            // probably too much data read, so freeing used memory
            delete iData;
            iData = NULL;
            iListener->ReadCompletedL(KErrNoMemory, KNullDesC8());
            return;
        }
        iData = reallocated;
    }

    // java returns length -1 when completed
    if (aLength > 0)
    {
        iData->Des().Append(aData, aLength);
    }

    TInt currentRead = iData->Size() - iBufferPosition;

    if ((aState == ECompleted) ||
            (currentRead == iReadLength))
    {
        if (iReadLength == KMMAReadAllData)
        {
            iListener->ReadCompletedL(aState, *iData);
        }
        else
        {
            TPtrC8 data = iData->Mid(iBufferPosition, currentRead);
            iListener->ReadCompletedL(aState, data);
        }
    }
    else
    {
        // phase ready, inform the Player
        if (iReadLength == KMMAReadAllData)
        {
            iReadEvent->SetLength(KBufferSize);
        }
        else
        {
            iReadEvent->SetLength(iReadLength - currentRead);
        }

        // data has been requested, note will be sent
        iEventPoster->PostEvent(iReadEvent, CMMAEvent::ENotifyPriority);
    }

    DEBUG("MMA::CMMASourceStream::WriteL completed");
}

void CMMASourceStream::ReadL(TInt aLength)
{
    DEBUG_INT("MMA::CMMASourceStream::ReadL(%d)", aLength);

    __ASSERT_DEBUG(iData != NULL, User::Invariant());

    PrepareReadL();

    iBufferPosition = iData->Size();
    iReadLength = aLength;

    iReadEvent->SetLength(aLength);

    // data has been requested, note will be sent
    iEventPoster->PostEvent(iReadEvent, CMMAEvent::ENotifyPriority);
}


void CMMASourceStream::ReadAllL()
{
    // not reading again if iData already has data
    if (iData == NULL)
    {
        DEBUG("CMMASourceStream::ReadAllL: Buffer empty, reading from java");
        CreateDataBufferL(KBufferSize);
        ReadL(KMMAReadAllData);
    }
    else
    {
        DEBUG("CMMASourceStream::ReadAllL: Buffer not empty, ->ReadCompleteL");
        iListener->ReadCompletedL(ECompleted, *iData);
    }
}

void CMMASourceStream::PrepareReadL()
{
}

void CMMASourceStream::ResetData()
{
    delete iData;
    iData = NULL;
}

void CMMASourceStream::CreateDataBufferL(TInt aBufferSize)
{
    DEBUG("CMMASourceStream::CreateDataBufferL +");
    __ASSERT_DEBUG(iData == NULL, User::Invariant());

    iData = HBufC8::NewL(aBufferSize);
}

//  END OF FILE