/*

* 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 "cmmaeventsource.h"

#include "cmmadatasourcestream.h"

#include "mmmasourcestreamlistener.h"

#include "cmmastreamrequest.h"

#include "cmmasourcestreamevent.h"

// CONSTRUCTION

CMMADataSourceStream* CMMADataSourceStream::NewLC(JNIEnv* aJNIEnv,

        MMMAEventPoster* aEventPoster,

        jobject aJavaSourceStream,

        MMMASourceStreamListener* aListener

                                                 )

{

    CMMADataSourceStream* self = new(ELeave) CMMADataSourceStream(aEventPoster,

            aListener);

    CleanupStack::PushL(self);

    self->ConstructL(aJNIEnv, aJavaSourceStream);

    return self;

}

CMMADataSourceStream::~CMMADataSourceStream()

{

    DEBUG("MMA::CMMADataSourceStream::~");

}

// Default constructor

CMMADataSourceStream::CMMADataSourceStream(MMMAEventPoster* aEventPoster,

        MMMASourceStreamListener* aListener):

        CMMASourceStream(aEventPoster, aListener)

{

}

inline void CMMADataSourceStream::ConstructL(JNIEnv* aJNIEnv,

        jobject aJavaSourceStream)

{

    CMMASourceStream::ConstructL(aJNIEnv, aJavaSourceStream);

    CreateDataBufferL(KMMAStreamRequestBufferSize);

}

void CMMADataSourceStream::WriteL(const TUint8* aData,

                                  TInt aLength,

                                  TInt aState)

{

    DEBUG_INT("MMA::CMMADataSourceStream::WriteL data length %d", aLength);

    DEBUG_INT("MMA::CMMADataSourceStream::WriteL state %d", aState);

    if (!iRequest)

    {

        // there is no request to write

        return;

    }

    if (aState >= KErrNone)

    {

        if ((aState == CMMASourceStream::ECompleted) &&

                aLength == -1)

        {

            // Stream ended

            iRequest->RequestBuffer() = 1;

        }

        else if ((iData->Length() == 0) &&

                 (iRequest->DataPtr().Length() == 0))

        {

            iRequest->DataPtr().Append(aData, aLength);

            // read next

            iEventPoster->PostEvent(iReadEvent,

                                    CMMAEvent::ENotifyPriority);

            return;

        }

        else if (iData->Length() == 0)

        {

            iData->Des().Append(aData, aLength);

        }

    }

    // complete read operation

    CMMAStreamRequest* r = iRequest;

    iRequest = NULL;

    r->CompleteRead(aState);

    DEBUG("MMA::CMMADataSourceStream::WriteL completed");

}

void CMMADataSourceStream::ResetData()

{

    DEBUG("MMA::CMMADataSourceStream::ResetData");

}

CMMAStreamRequest* CMMADataSourceStream::Request()

{

    return iRequest;

}

void CMMADataSourceStream::Read(CMMAStreamRequest* aRequest)

{

    // Setting NULL, means that all read completes are ignored

    if (!aRequest)

    {

        iRequest = NULL;

        return;

    }

    if (!iRequest)

    {

        iRequest = aRequest;

        iRequest->RequestBuffer() = 0;

        iReadEvent->SetLength(aRequest->DataPtr().MaxLength());

        if (iData->Length() > 0)

        {

            // Previous read buffered data

            iRequest->DataPtr().Append(*iData);

            // re-use buffer

            iData->Des().SetLength(0);

        }

        // data has been requested, note will be sent

        iEventPoster->PostEvent(iReadEvent, CMMAEvent::ENotifyPriority);

    }

    // else java is already reading

}

//  END OF FILE