native-media-jni.c revision ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6
197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten/* 297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * Copyright (C) 2010 The Android Open Source Project 397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * 497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * Licensed under the Apache License, Version 2.0 (the "License"); 597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * you may not use this file except in compliance with the License. 697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * You may obtain a copy of the License at 797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * 897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * http://www.apache.org/licenses/LICENSE-2.0 997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * 1097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * Unless required by applicable law or agreed to in writing, software 1197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * distributed under the License is distributed on an "AS IS" BASIS, 1297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * See the License for the specific language governing permissions and 1497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten * limitations under the License. 1597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten */ 1697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 1797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten#include <assert.h> 1897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten#include <jni.h> 1997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten#include <pthread.h> 2097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten#include <string.h> 21ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten//#define LOG_NDEBUG 0 2297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten#define LOG_TAG "NativeMedia" 2397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten#include <utils/Log.h> 24f183d0fd23f1c0f45ceaf280d404f1b0709a699aJean-Michel Trivi 25c6853892c94800e72c0bd676d5d2136d48cea76eGlenn Kasten#include <OMXAL/OpenMAXAL.h> 26c6853892c94800e72c0bd676d5d2136d48cea76eGlenn Kasten#include <OMXAL/OpenMAXAL_Android.h> 27f183d0fd23f1c0f45ceaf280d404f1b0709a699aJean-Michel Trivi 28295395c087000a9d804f8d12d58dea4cd9e7d26aJean-Michel Trivi#include <android/native_window_jni.h> 2997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 3097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten// engine interfaces 3197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kastenstatic XAObjectItf engineObject = NULL; 32ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenstatic XAEngineItf engineEngine = NULL; 3397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 3497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten// output mix interfaces 3597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kastenstatic XAObjectItf outputMixObject = NULL; 3697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 3797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten// streaming media player interfaces 38eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivistatic XAObjectItf playerObj = NULL; 39eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivistatic XAPlayItf playerPlayItf = NULL; 40eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivistatic XAAndroidBufferQueueItf playerBQItf = NULL; 4137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivistatic XAStreamInformationItf playerStreamInfoItf = NULL; 42ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenstatic XAVolumeItf playerVolItf = NULL; 43ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 44d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi// number of required interfaces for the MediaPlayer creation 4537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi#define NB_MAXAL_INTERFACES 3 // XAAndroidBufferQueueItf, XAStreamInformationItf and XAPlayItf 4697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 4739310fca2e30101fa6e5168da443581cc60c20bfGlenn Kasten// video sink for the player 48295395c087000a9d804f8d12d58dea4cd9e7d26aJean-Michel Trivistatic ANativeWindow* theNativeWindow; 4997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 50ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten// number of buffers in our buffer queue, an arbitrary number 51d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi#define NB_BUFFERS 16 52ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 53d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi// we're streaming MPEG-2 transport stream data, operate on transport stream block size 54d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi#define MPEG2_TS_BLOCK_SIZE 188 55ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 56ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten// number of MPEG-2 transport stream blocks per buffer, an arbitrary number 57ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten#define BLOCKS_PER_BUFFER 20 58ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 59d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi// determines how much memory we're dedicating to memory caching 60ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten#define BUFFER_SIZE (BLOCKS_PER_BUFFER*MPEG2_TS_BLOCK_SIZE) 61d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi 62d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi// where we cache in memory the data to play 63ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten// note this memory is re-used by the buffer queue callback 64d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivichar dataCache[BUFFER_SIZE * NB_BUFFERS]; 65ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 66eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi// handle of the file to play 67eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel TriviFILE *file; 68ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 6970c49ae2867094072a4365423417ea452bf82231Jean-Michel Trivi// has the app reached the end of the file 70ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenjboolean reachedEof = JNI_FALSE; 71ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 72ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten// for mutual exclusion between callback thread and application thread(s) 73ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenpthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; 74ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenpthread_cond_t cond = PTHREAD_COND_INITIALIZER; 75ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 76ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten// whether a discontinuity is in progress 77ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenjboolean discontinuity = JNI_FALSE; 78ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 79ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenstatic jboolean enqueueInitialBuffers(jboolean discontinuity); 80eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 81eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi// AndroidBufferQueueItf callback for an audio player 82eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel TriviXAresult AndroidBufferQueueCallback( 83eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi XAAndroidBufferQueueItf caller, 8437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi void *pCallbackContext, /* input */ 8537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi void *pBufferContext, /* input */ 8637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi void *pBufferData, /* input */ 87d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi XAuint32 dataSize, /* input */ 88d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi XAuint32 dataUsed, /* input */ 89d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi const XAAndroidBufferItem *pItems,/* input */ 90d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi XAuint32 itemsLength /* input */) 91eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi{ 92ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten XAresult res; 93ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten int ok; 94ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 95ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // pCallbackContext was specified as NULL at RegisterCallback and is unused here 96ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(NULL == pCallbackContext); 97ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 98ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // note there is never any contention on this mutex unless a discontinuity request is active 99ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten ok = pthread_mutex_lock(&mutex); 100ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(0 == ok); 101ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 102ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // was a discontinuity requested? 103ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten if (discontinuity) { 104ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // FIXME sorry, can't rewind after EOS 105ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten if (!reachedEof) { 106ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // clear the buffer queue 107ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten res = (*playerBQItf)->Clear(playerBQItf); 108ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(XA_RESULT_SUCCESS == res); 109ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // rewind the data source so we are guaranteed to be at an appropriate point 110ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten rewind(file); 111ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // Enqueue the initial buffers, with a discontinuity indicator on first buffer 112ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten (void) enqueueInitialBuffers(JNI_TRUE); 113ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } 114ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // acknowledge the discontinuity request 115ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten discontinuity = JNI_FALSE; 116ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten ok = pthread_cond_signal(&cond); 117ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(0 == ok); 118ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten goto exit; 119ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } 120ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 12137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi if (pBufferData == NULL) { 12237dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // this is the case when our buffer with the EOS message has been consumed 123ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(0 == dataSize); 124ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten goto exit; 12537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi } 12637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 127ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // pBufferData is a pointer to a buffer that we previously Enqueued 128ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(BUFFER_SIZE == dataSize); 129ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(dataCache <= (char *) pBufferData && (char *) pBufferData < 130ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten &dataCache[BUFFER_SIZE * NB_BUFFERS]); 131ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(0 == (((char *) pBufferData - dataCache) % BUFFER_SIZE)); 132ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 13337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi#if 0 13437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // sample code to use the XAVolumeItf 13537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi XAAndroidBufferQueueState state; 13637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*caller)->GetState(caller, &state); 13737dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi switch (state.index) { 13837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi case 300: 13937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*playerVolItf)->SetVolumeLevel(playerVolItf, -600); // -6dB 14037dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi LOGV("setting volume to -6dB"); 14137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi break; 14237dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi case 400: 14337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*playerVolItf)->SetVolumeLevel(playerVolItf, -1200); // -12dB 14437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi LOGV("setting volume to -12dB"); 14537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi break; 14637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi case 500: 14737dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*playerVolItf)->SetVolumeLevel(playerVolItf, 0); // full volume 14837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi LOGV("setting volume to 0dB (full volume)"); 14937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi break; 15037dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi case 600: 15137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*playerVolItf)->SetMute(playerVolItf, XA_BOOLEAN_TRUE); // mute 15237dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi LOGV("muting player"); 15337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi break; 15437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi case 700: 15537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*playerVolItf)->SetMute(playerVolItf, XA_BOOLEAN_FALSE); // unmute 15637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi LOGV("unmuting player"); 15737dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi break; 15837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi case 800: 15937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*playerVolItf)->SetStereoPosition(playerVolItf, -1000); 16037dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*playerVolItf)->EnableStereoPosition(playerVolItf, XA_BOOLEAN_TRUE); 16137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi LOGV("pan sound to the left (hard-left)"); 16237dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi break; 16337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi case 900: 16437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi (*playerVolItf)->EnableStereoPosition(playerVolItf, XA_BOOLEAN_FALSE); 16537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi LOGV("disabling stereo position"); 16637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi break; 16737dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi default: 16837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi break; 16937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi } 17037dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi#endif 17137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 172ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // don't bother trying to read more data once we've hit EOF 173ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten if (reachedEof) { 174ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten goto exit; 175ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } 176ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 177ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten size_t nbRead; 178ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // note we do call fread from multiple threads, but never concurrently 179ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten nbRead = fread(pBufferData, BUFFER_SIZE, 1, file); 180ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten if (nbRead > 0) { 181ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(1 == nbRead); 182ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten res = (*caller)->Enqueue(caller, NULL /*pBufferContext*/, 183d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi pBufferData /*pData*/, 184ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten nbRead * BUFFER_SIZE /*dataLength*/, 185d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi NULL /*pMsg*/, 186d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi 0 /*msgLength*/); 187ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(XA_RESULT_SUCCESS == res); 188ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } else { 189d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi // signal EOS 190ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten XAAndroidBufferItem msgEos[1]; 191ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten msgEos[0].itemKey = XA_ANDROID_ITEMKEY_EOS; 192ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten msgEos[0].itemSize = 0; 193d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi // EOS message has no parameters, so the total size of the message is the size of the key 194d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi // plus the size if itemSize, both XAuint32 195ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten res = (*caller)->Enqueue(caller, NULL /*pBufferContext*/, 19637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi NULL /*pData*/, 0 /*dataLength*/, 197ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten msgEos /*pMsg*/, 198ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // FIXME == sizeof(BufferItem)? */ 19937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi sizeof(XAuint32)*2 /*msgLength*/); 200ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(XA_RESULT_SUCCESS == res); 201ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten reachedEof = JNI_TRUE; 202eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi } 203eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 204ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenexit: 205ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten ok = pthread_mutex_unlock(&mutex); 206ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(0 == ok); 207eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi return XA_RESULT_SUCCESS; 208eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi} 209eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 210eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 21137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivivoid StreamChangeCallback (XAStreamInformationItf caller, 21237dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi XAuint32 eventId, 21337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi XAuint32 streamIndex, 21437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi void * pEventData, 21537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi void * pContext ) 21637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi{ 217ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten LOGV("StreamChangeCallback called for stream %u", streamIndex); 218ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // pContext was specified as NULL at RegisterStreamChangeCallback and is unused here 219ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(NULL == pContext); 220ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten switch (eventId) { 221ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten case XA_STREAMCBEVENT_PROPERTYCHANGE: { 222ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten /** From spec 1.0.1: 223ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten "This event indicates that stream property change has occurred. 224ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten The streamIndex parameter identifies the stream with the property change. 225ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten The pEventData parameter for this event is not used and shall be ignored." 226ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten */ 227ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 228ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten XAresult res; 22937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi XAuint32 domain; 230ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten res = (*caller)->QueryStreamType(caller, streamIndex, &domain); 231ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(XA_RESULT_SUCCESS == res); 232ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten switch (domain) { 233ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten case XA_DOMAINTYPE_VIDEO: { 234ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten XAVideoStreamInformation videoInfo; 235ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten res = (*caller)->QueryStreamInformation(caller, streamIndex, &videoInfo); 236ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(XA_RESULT_SUCCESS == res); 237ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten LOGI("Found video size %u x %u, codec ID=%u, frameRate=%u, bitRate=%u, duration=%u ms", 238ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten videoInfo.width, videoInfo.height, videoInfo.codecId, videoInfo.frameRate, 239ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten videoInfo.bitRate, videoInfo.duration); 240ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } break; 241ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten default: 242ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten fprintf(stderr, "Unexpected domain %u\n", domain); 243ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten break; 24437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi } 245ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } break; 246ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten default: 247ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten fprintf(stderr, "Unexpected stream event ID %u\n", eventId); 248ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten break; 24937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi } 25037dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi} 25137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 25237dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 25397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten// create the engine and output mix objects 25497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kastenvoid Java_com_example_nativemedia_NativeMedia_createEngine(JNIEnv* env, jclass clazz) 25597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten{ 256eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi XAresult res; 25797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 25897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // create engine 259eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = xaCreateEngine(&engineObject, 0, NULL, 0, NULL, NULL); 260eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 26197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 26297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // realize the engine 263eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*engineObject)->Realize(engineObject, XA_BOOLEAN_FALSE); 264eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 26597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 26697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // get the engine interface, which is needed in order to create other objects 267eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*engineObject)->GetInterface(engineObject, XA_IID_ENGINE, &engineEngine); 268eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 26997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 27097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // create output mix 271eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*engineEngine)->CreateOutputMix(engineEngine, &outputMixObject, 0, NULL, NULL); 272eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 27397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 27497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // realize the output mix 275eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*outputMixObject)->Realize(outputMixObject, XA_BOOLEAN_FALSE); 276eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 27797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 27897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten} 27997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 28097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 281ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten// Enqueue the initial buffers, and optionally signal a discontinuity in the first buffer 282ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenstatic jboolean enqueueInitialBuffers(jboolean discontinuity) 283ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten{ 284ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 285ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten /* Fill our cache */ 286ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten size_t nbRead; 287ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten nbRead = fread(dataCache, BUFFER_SIZE, NB_BUFFERS, file); 288ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten if (nbRead <= 0) { 289ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // could be premature EOF or I/O error 290ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten LOGE("Error filling cache, exiting\n"); 291ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten return JNI_FALSE; 292ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } 293ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(1 <= nbRead && nbRead <= NB_BUFFERS); 294ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten LOGV("Initially queueing %u buffers of %u bytes each", nbRead, BUFFER_SIZE); 295ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 296ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten /* Enqueue the content of our cache before starting to play, 297ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten we don't want to starve the player */ 298ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten size_t i; 299ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten for (i = 0; i < nbRead; i++) { 300ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten XAresult res; 301ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten if (discontinuity) { 302ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // signal discontinuity 303ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten XAAndroidBufferItem items[1]; 304ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten items[0].itemKey = XA_ANDROID_ITEMKEY_DISCONTINUITY; 305ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten items[0].itemSize = 0; 306ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // DISCONTINUITY message has no parameters, 307ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // so the total size of the message is the size of the key 308ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // plus the size if itemSize, both XAuint32 309ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten res = (*playerBQItf)->Enqueue(playerBQItf, NULL /*pBufferContext*/, 310ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten dataCache + i*BUFFER_SIZE, BUFFER_SIZE, items /*pMsg*/, 311ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // FIXME == sizeof(BufferItem)? */ 312ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten sizeof(XAuint32)*2 /*msgLength*/); 313ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten discontinuity = JNI_FALSE; 314ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } else { 315ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten res = (*playerBQItf)->Enqueue(playerBQItf, NULL /*pBufferContext*/, 316ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten dataCache + i*BUFFER_SIZE, BUFFER_SIZE, NULL, 0); 317ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } 318ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(XA_RESULT_SUCCESS == res); 319ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } 320ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 321ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten return JNI_TRUE; 322ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten} 323ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 324ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 32597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten// create streaming media player 32697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kastenjboolean Java_com_example_nativemedia_NativeMedia_createStreamingMediaPlayer(JNIEnv* env, 32797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten jclass clazz, jstring filename) 32897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten{ 329eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi XAresult res; 33097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 33197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // convert Java string to UTF-8 33297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten const char *utf8 = (*env)->GetStringUTFChars(env, filename, NULL); 33397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten assert(NULL != utf8); 33497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 335eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi // open the file to play 336eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi file = fopen(utf8, "rb"); 337eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi if (file == NULL) { 338eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi LOGE("Failed to open %s", utf8); 339eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi return JNI_FALSE; 340eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi } 341eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 342eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi // configure data source 343d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi XADataLocator_AndroidBufferQueue loc_abq = { XA_DATALOCATOR_ANDROIDBUFFERQUEUE, NB_BUFFERS }; 344d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi XADataFormat_MIME format_mime = { 345d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi XA_DATAFORMAT_MIME, (XAchar *)"video/mp2ts", XA_CONTAINERTYPE_MPEG_TS }; 346eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi XADataSource dataSrc = {&loc_abq, &format_mime}; 34797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 34897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // configure audio sink 349d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi XADataLocator_OutputMix loc_outmix = { XA_DATALOCATOR_OUTPUTMIX, outputMixObject }; 350d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi XADataSink audioSnk = { &loc_outmix, NULL }; 35197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 35297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // configure image video sink 353295395c087000a9d804f8d12d58dea4cd9e7d26aJean-Michel Trivi XADataLocator_NativeDisplay loc_nd = { 354ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten XA_DATALOCATOR_NATIVEDISPLAY, // locatorType 35539310fca2e30101fa6e5168da443581cc60c20bfGlenn Kasten // the video sink must be an ANativeWindow created from a Surface or SurfaceTexture 356ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten (void*)theNativeWindow, // hWindow 357ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten // must be NULL 358ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten NULL // hDisplay 359ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten }; 36097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten XADataSink imageVideoSink = {&loc_nd, NULL}; 36197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 362eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi // declare interfaces to use 36337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi XAboolean required[NB_MAXAL_INTERFACES] 36437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi = {XA_BOOLEAN_TRUE, XA_BOOLEAN_TRUE, XA_BOOLEAN_TRUE}; 36537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi XAInterfaceID iidArray[NB_MAXAL_INTERFACES] 36637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi = {XA_IID_PLAY, XA_IID_ANDROIDBUFFERQUEUE, XA_IID_STREAMINFORMATION}; 36737dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 368eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 36997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // create media player 370eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*engineEngine)->CreateMediaPlayer(engineEngine, &playerObj, &dataSrc, 371eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi NULL, &audioSnk, &imageVideoSink, NULL, NULL, 372d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi NB_MAXAL_INTERFACES /*XAuint32 numInterfaces*/, 373eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi iidArray /*const XAInterfaceID *pInterfaceIds*/, 374eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi required /*const XAboolean *pInterfaceRequired*/); 375eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 37697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 37797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // release the Java string and UTF-8 37897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten (*env)->ReleaseStringUTFChars(env, filename, utf8); 37997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 38097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // realize the player 381eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*playerObj)->Realize(playerObj, XA_BOOLEAN_FALSE); 382eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 38397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 38497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // get the play interface 385eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*playerObj)->GetInterface(playerObj, XA_IID_PLAY, &playerPlayItf); 386eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 387eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 38837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // get the stream information interface (for video size) 38937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi res = (*playerObj)->GetInterface(playerObj, XA_IID_STREAMINFORMATION, &playerStreamInfoItf); 39037dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 39137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 39237dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // get the volume interface 39337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi res = (*playerObj)->GetInterface(playerObj, XA_IID_VOLUME, &playerVolItf); 39437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 39537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 396eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi // get the Android buffer queue interface 397eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*playerObj)->GetInterface(playerObj, XA_IID_ANDROIDBUFFERQUEUE, &playerBQItf); 398eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 399eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 400ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // specify which events we want to be notified of 401ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten res = (*playerBQItf)->SetCallbackEventsMask(playerBQItf, XA_ANDROIDBUFFERQUEUEEVENT_PROCESSED); 402ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 403eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi // register the callback from which OpenMAX AL can retrieve the data to play 404d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi res = (*playerBQItf)->RegisterCallback(playerBQItf, AndroidBufferQueueCallback, NULL); 40537dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 40637dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 40737dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // we want to be notified of the video size once it's found, so we register a callback for that 40837dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi res = (*playerStreamInfoItf)->RegisterStreamChangeCallback(playerStreamInfoItf, 40937dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi StreamChangeCallback, NULL); 410d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi 411ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // enqueue the initial buffers 412ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten if (!enqueueInitialBuffers(JNI_FALSE)) { 413d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi return JNI_FALSE; 414d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi } 415d158d31a6bbb06426b71c3d097b7768bc3fb79a3Jean-Michel Trivi 416eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi // prepare the player 417eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*playerPlayItf)->SetPlayState(playerPlayItf, XA_PLAYSTATE_PAUSED); 418eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 419eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi 42037dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // set the volume 42137dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi res = (*playerVolItf)->SetVolumeLevel(playerVolItf, 0);//-300); 42237dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 42337dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi 42437dc2fccf3f122b79ebd554de209d0a3c94ae161Jean-Michel Trivi // start the playback 425eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*playerPlayItf)->SetPlayState(playerPlayItf, XA_PLAYSTATE_PLAYING); 426eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 42797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 42897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten return JNI_TRUE; 42997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten} 43097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 43197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 43297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten// set the playing state for the streaming media player 43397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kastenvoid Java_com_example_nativemedia_NativeMedia_setPlayingStreamingMediaPlayer(JNIEnv* env, 43497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten jclass clazz, jboolean isPlaying) 43597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten{ 436eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi XAresult res; 43797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 43897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // make sure the streaming media player was created 439eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi if (NULL != playerPlayItf) { 44097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 44197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // set the player's state 442eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi res = (*playerPlayItf)->SetPlayState(playerPlayItf, isPlaying ? 44397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten XA_PLAYSTATE_PLAYING : XA_PLAYSTATE_PAUSED); 444eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi assert(XA_RESULT_SUCCESS == res); 44597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 44697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten } 44797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 44897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten} 44997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 45097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 45197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten// shut down the native media system 45297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kastenvoid Java_com_example_nativemedia_NativeMedia_shutdown(JNIEnv* env, jclass clazz) 45397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten{ 45497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // destroy streaming media player object, and invalidate all associated interfaces 455eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi if (playerObj != NULL) { 456eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi (*playerObj)->Destroy(playerObj); 457eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi playerObj = NULL; 458eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi playerPlayItf = NULL; 459eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi playerBQItf = NULL; 460ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten playerStreamInfoItf = NULL; 461ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten playerVolItf = NULL; 46297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten } 46397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 46497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // destroy output mix object, and invalidate all associated interfaces 46597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten if (outputMixObject != NULL) { 46697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten (*outputMixObject)->Destroy(outputMixObject); 46797bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten outputMixObject = NULL; 46897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten } 46997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 47097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten // destroy engine object, and invalidate all associated interfaces 47197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten if (engineObject != NULL) { 47297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten (*engineObject)->Destroy(engineObject); 47397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten engineObject = NULL; 47497bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten engineEngine = NULL; 47597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten } 47697bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 477eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi // close the file 478eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi if (file != NULL) { 479eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi fclose(file); 480b66b0745d45f4c0c7620749185f7fb3306804ce3Glenn Kasten file = NULL; 481eae4df541ba1d46f65d37e959baf2127aa632c93Jean-Michel Trivi } 482295395c087000a9d804f8d12d58dea4cd9e7d26aJean-Michel Trivi 483295395c087000a9d804f8d12d58dea4cd9e7d26aJean-Michel Trivi // make sure we don't leak native windows 484ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten if (theNativeWindow != NULL) { 485ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten ANativeWindow_release(theNativeWindow); 486b66b0745d45f4c0c7620749185f7fb3306804ce3Glenn Kasten theNativeWindow = NULL; 487ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten } 48897bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten} 48997bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 49097bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten 49197bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten// set the surface 49297bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kastenvoid Java_com_example_nativemedia_NativeMedia_setSurface(JNIEnv *env, jclass clazz, jobject surface) 49397bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten{ 494295395c087000a9d804f8d12d58dea4cd9e7d26aJean-Michel Trivi // obtain a native window from a Java surface 495295395c087000a9d804f8d12d58dea4cd9e7d26aJean-Michel Trivi theNativeWindow = ANativeWindow_fromSurface(env, surface); 496ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten} 497ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten 498ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten 499ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten// set the surface texture 500ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kastenvoid Java_com_example_nativemedia_NativeMedia_setSurfaceTexture(JNIEnv *env, jclass clazz, 501ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten jobject surfaceTexture) 502ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten{ 503ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten // obtain a native window from a Java surface texture 504ad1ab1d13a9b043202b9d5cdc1d8c4ef66cbbca8Glenn Kasten theNativeWindow = ANativeWindow_fromSurfaceTexture(env, surfaceTexture); 50597bdbe13fc48640babe6c1ce270660476f04c3dfGlenn Kasten} 506ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 507ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 508ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten// rewind the streaming media player 509ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kastenvoid Java_com_example_nativemedia_NativeMedia_rewindStreamingMediaPlayer(JNIEnv *env, jclass clazz) 510ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten{ 511ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten XAresult res; 512ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 513ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // make sure the streaming media player was created 514ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten if (NULL != playerBQItf && NULL != file) { 515ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // first wait for buffers currently in queue to be drained 516ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten int ok; 517ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten ok = pthread_mutex_lock(&mutex); 518ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(0 == ok); 519ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten discontinuity = JNI_TRUE; 520ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // wait for discontinuity request to be observed by buffer queue callback 521ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten // FIXME sorry, can't rewind after EOS 522ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten while (discontinuity && !reachedEof) { 523ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten ok = pthread_cond_wait(&cond, &mutex); 524ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(0 == ok); 525ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } 526ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten ok = pthread_mutex_unlock(&mutex); 527ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten assert(0 == ok); 528ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten } 529ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten 530ac8c7318e1d7ec1358bbf924e1bc2cee45b44fc6Glenn Kasten} 531