/*

* 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:  This class has JNI wrappers for CMMASourceStream

*

*/

//#include "jutils.h"

//#include "mmapiutils.h"

#include "com_nokia_microedition_media_protocol_SourceStreamReader.h"

#include "cmmasourcestream.h"

#include "mmafunctionserver.h"

// If eventsource is already disposed, then do nothing

#define CHECK_HANDLE(x, j) { if ( !( x ) || ( ( x )->Players().Count() == 0 ) ) { return ( j ); } }

LOCAL_C void WriteDataL(TInt aSourceStream,

                        TInt aPlayer,

                        MMAFunctionServer* aEventSource,

                        const TUint8* aData,

                        TInt aLength,

                        TInt aState)

{

    if (!aEventSource->FindPlayer(aPlayer))

    {

        // Native object was already deleted

        User::Leave(KErrBadHandle);

    }

    CMMASourceStream* sourceStream =

    	reinterpret_cast< CMMASourceStream *>(aSourceStream);

    sourceStream->WriteL(aData, aLength, aState);

    LOG( EJavaMMAPI, EInfo, "jni SourceStreamReader.cpp: WriteDataL() -");

}

JNIEXPORT jint JNICALL Java_com_nokia_microedition_media_protocol_SourceStreamReader__1write

(JNIEnv* aJni, jclass, jint aSourceStream, jint aEventSource,

 jbyteArray aData, jint aLength, jint aState, jint aPlayerHandle)

{

	 LOG( EJavaMMAPI, EInfo, "SourceStreamReaderjni_write");

    MMAFunctionServer* eventSource =

		reinterpret_cast< MMAFunctionServer* >(aEventSource);

    CHECK_HANDLE(eventSource, KErrNone);

    jbyte* data = aJni->GetByteArrayElements(aData, NULL);

	LOG2( EJavaMMAPI, EInfo, "SourceStreamReaderjni_write , length = %d,state = %d",(TInt)aLength,(TInt)aState);

    TInt err = eventSource->ExecuteTrap(&WriteDataL,

                                        aSourceStream,

                                        aPlayerHandle,

                                        eventSource,

                                        (const TUint8*)data,

                                        aLength,

                                        aState);

    ELOG1( EJavaMMAPI, "SourceStreamReaderjni_write , err = %d",err);

    aJni->ReleaseByteArrayElements(aData, data, JNI_ABORT);

    return err;

}

// END OF FILE