--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/javauis/mmapi_qt/baseline/src/cmmasourcestream.cpp	Tue May 11 16:07:20 2010 +0300
@@ -0,0 +1,215 @@
+/*
+* 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 <logger.h>
+
+#include <JniEnvWrapper.h>
+
+#include "mmafunctionserver.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()
+{
+    LOG( EJavaMMAPI, EInfo, "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 = iEventPoster->getValidJniEnv();
+    jmethodID classMethodID =
+        aJNIEnv->GetMethodID(aJNIEnv->GetObjectClass(aJavaSourceStream),
+                             "read",
+                             "(II)V");
+    if (!classMethodID)
+    {
+        User::Leave(KErrNoMemory);
+    }
+	LOG( EJavaMMAPI, EInfo, "CMMASourceStream::ConstructL , jmethodId found");  
+	jobject apeer =  aJNIEnv->NewGlobalRef(aJavaSourceStream);  
+    iReadEvent = new(ELeave) CMMASourceStreamEvent(classMethodID,
+            apeer);
+}
+
+
+void CMMASourceStream::WriteL(const TUint8* aData,
+                              TInt aLength,
+                              TInt aState)
+{
+	  LOG1( EJavaMMAPI, EInfo, "MMA::CMMASourceStream::WriteL() %d",aState);
+    if (aState < KErrNone)
+    {
+    	LOG( EJavaMMAPI, EInfo, "MMA::CMMASourceStream::WriteL  : 1");
+        // 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);
+        }
+
+    }
+
+    LOG( EJavaMMAPI, EInfo, "MMA::CMMASourceStream::WriteL completed");
+}
+
+void CMMASourceStream::ReadL(TInt aLength)
+{
+    LOG1( EJavaMMAPI, EInfo, "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)
+    {
+        LOG( EJavaMMAPI, EInfo, "CMMASourceStream::ReadAllL: Buffer empty, reading from java");
+        CreateDataBufferL(KBufferSize);
+        ReadL(KMMAReadAllData);
+    }
+    else
+    {
+        LOG( EJavaMMAPI, EInfo, "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)
+{
+    LOG( EJavaMMAPI, EInfo, "CMMASourceStream::CreateDataBufferL +");
+    __ASSERT_DEBUG(iData == NULL, User::Invariant());
+
+    iData = HBufC8::NewL(aBufferSize);
+}
+
+//  END OF FILE