1 /*

     2 * Copyright (c) 2002-2007 Nokia Corporation and/or its subsidiary(-ies).

     3 * All rights reserved.

     4 * This component and the accompanying materials are made available

     5 * under the terms of "Eclipse Public License v1.0"

     6 * which accompanies this distribution, and is available

     7 * at the URL "http://www.eclipse.org/legal/epl-v10.html".

     8 *

     9 * Initial Contributors:

    10 * Nokia Corporation - initial contribution.

    11 *

    12 * Contributors:

    13 *

    14 * Description:  Class for reading data from Java SourceStream to native side

    15 *

    16 */

    17 

    18 #include <jdebug.h>

    19 #include <JniEnvWrapper.h>

    20 

    21 #include "cmmaeventsource.h"

    22 #include "cmmasourcestream.h"

    23 #include "cmmasourcestreamevent.h"

    24 #include "mmmasourcestreamlistener.h"

    25 

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

    27 

    28 // CONSTRUCTION

    29 CMMASourceStream* CMMASourceStream::NewL(JNIEnv* aJNIEnv,

    30         MMMAEventPoster* aEventPoster,

    31         jobject aJavaSourceStream,

    32         MMMASourceStreamListener* aListener

    33                                         )

    34 {

    35     CMMASourceStream* self = CMMASourceStream::NewLC(aJNIEnv,

    36                              aEventPoster,

    37                              aJavaSourceStream,

    38                              aListener);

    39     CleanupStack::Pop();

    40     return self;

    41 }

    42 

    43 

    44 CMMASourceStream* CMMASourceStream::NewLC(JNIEnv* aJNIEnv,

    45         MMMAEventPoster* aEventPoster,

    46         jobject aJavaSourceStream,

    47         MMMASourceStreamListener* aListener

    48                                          )

    49 {

    50     CMMASourceStream* self = new(ELeave) CMMASourceStream(aEventPoster,

    51             aListener);

    52     CleanupStack::PushL(self);

    53     self->ConstructL(aJNIEnv, aJavaSourceStream);

    54     return self;

    55 }

    56 

    57 

    58 CMMASourceStream::~CMMASourceStream()

    59 {

    60     DEBUG("MMA::CMMASourceStream::~");

    61     delete iData;

    62     delete iReadEvent;

    63 }

    64 

    65 

    66 // Default constructor

    67 CMMASourceStream::CMMASourceStream(MMMAEventPoster* aEventPoster,

    68                                    MMMASourceStreamListener* aListener)

    69         : iEventPoster(aEventPoster), iListener(aListener)

    70 {

    71 }

    72 

    73 

    74 void CMMASourceStream::ConstructL(JNIEnv* aJNIEnv,

    75                                   jobject aJavaSourceStream)

    76 {

    77     // JNI interface pointer can't be passed to different thread, so

    78     // it is needed to get valid JNI interface pointer for Event Server thread

    79     aJNIEnv = JniEnvWrapper::GetValidJniRef();

    80     jmethodID classMethodID =

    81         aJNIEnv->GetMethodID(aJNIEnv->GetObjectClass(aJavaSourceStream),

    82                              "read",

    83                              "(II)V");

    84     if (!classMethodID)

    85     {

    86         User::Leave(KErrNoMemory);

    87     }

    88 

    89     iReadEvent = new(ELeave) CMMASourceStreamEvent(classMethodID,

    90             aJavaSourceStream);

    91 }

    92 

    93 

    94 void CMMASourceStream::WriteL(const TUint8* aData,

    95                               TInt aLength,

    96                               TInt aState)

    97 {

    98     if (aState < KErrNone)

    99     {

   100         // Inform listener on error case

   101         iListener->ReadCompletedL(aState, KNullDesC8());

   102         return;

   103     }

   104 

   105 

   106     if ((iData->Size() + aLength) > iData->Des().MaxSize())

   107     {

   108         // if data doesn't fit, reallocate more

   109         HBufC8* reallocated = iData->ReAlloc(iData->Des().MaxSize() + KBufferSize);

   110         if (!reallocated)  // realloc failed

   111         {

   112             // probably too much data read, so freeing used memory

   113             delete iData;

   114             iData = NULL;

   115             iListener->ReadCompletedL(KErrNoMemory, KNullDesC8());

   116             return;

   117         }

   118         iData = reallocated;

   119     }

   120 

   121     // java returns length -1 when completed

   122     if (aLength > 0)

   123     {

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

   125     }

   126 

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

   128 

   129     if ((aState == ECompleted) ||

   130             (currentRead == iReadLength))

   131     {

   132         if (iReadLength == KMMAReadAllData)

   133         {

   134             iListener->ReadCompletedL(aState, *iData);

   135         }

   136         else

   137         {

   138             TPtrC8 data = iData->Mid(iBufferPosition, currentRead);

   139             iListener->ReadCompletedL(aState, data);

   140         }

   141     }

   142     else

   143     {

   144         // phase ready, inform the Player

   145         if (iReadLength == KMMAReadAllData)

   146         {

   147             iReadEvent->SetLength(KBufferSize);

   148         }

   149         else

   150         {

   151             iReadEvent->SetLength(iReadLength - currentRead);

   152         }

   153 

   154         // data has been requested, note will be sent

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

   156     }

   157 

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

   159 }

   160 

   161 void CMMASourceStream::ReadL(TInt aLength)

   162 {

   163     DEBUG_INT("MMA::CMMASourceStream::ReadL(%d)", aLength);

   164 

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

   166 

   167     PrepareReadL();

   168 

   169     iBufferPosition = iData->Size();

   170     iReadLength = aLength;

   171 

   172     iReadEvent->SetLength(aLength);

   173 

   174     // data has been requested, note will be sent

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

   176 }

   177 

   178 

   179 void CMMASourceStream::ReadAllL()

   180 {

   181     // not reading again if iData already has data

   182     if (iData == NULL)

   183     {

   184         DEBUG("CMMASourceStream::ReadAllL: Buffer empty, reading from java");

   185         CreateDataBufferL(KBufferSize);

   186         ReadL(KMMAReadAllData);

   187     }

   188     else

   189     {

   190         DEBUG("CMMASourceStream::ReadAllL: Buffer not empty, ->ReadCompleteL");

   191         iListener->ReadCompletedL(ECompleted, *iData);

   192     }

   193 }

   194 

   195 void CMMASourceStream::PrepareReadL()

   196 {

   197 }

   198 

   199 void CMMASourceStream::ResetData()

   200 {

   201     delete iData;

   202     iData = NULL;

   203 }

   204 

   205 void CMMASourceStream::CreateDataBufferL(TInt aBufferSize)

   206 {

   207     DEBUG("CMMASourceStream::CreateDataBufferL +");

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

   209 

   210     iData = HBufC8::NewL(aBufferSize);

   211 }

   212 

   213 //  END OF FILE