/*
|
* Copyright (C) 2010 The Android Open Source Project
|
*
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
* you may not use this file except in compliance with the License.
|
* You may obtain a copy of the License at
|
*
|
* http://www.apache.org/licenses/LICENSE-2.0
|
*
|
* Unless required by applicable law or agreed to in writing, software
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
* See the License for the specific language governing permissions and
|
* limitations under the License.
|
*/
|
|
#include <media/IStreamSource.h>
|
#include <binder/IServiceManager.h>
|
#include "android/android_GenericMediaPlayer.h"
|
|
// number of SLuint32 fields to store a buffer event message in an item, by mapping each
|
// to the item key (SLuint32), the item size (SLuint32), and the item data (mask on SLuint32)
|
#define NB_BUFFEREVENT_ITEM_FIELDS 3
|
|
//--------------------------------------------------------------------------------------------------
|
namespace android {
|
|
//--------------------------------------------------------------------------------------------------
|
class StreamPlayer;
|
|
class StreamSourceAppProxy : public BnStreamSource {
|
public:
|
StreamSourceAppProxy(
|
IAndroidBufferQueue *androidBufferQueue,
|
const sp<CallbackProtector> &callbackProtector,
|
StreamPlayer *player);
|
virtual ~StreamSourceAppProxy();
|
|
// store an item structure to indicate a processed buffer
|
static const SLuint32 kItemProcessed[NB_BUFFEREVENT_ITEM_FIELDS];
|
|
// IStreamSource implementation
|
virtual void setListener(const sp<IStreamListener> &listener); // mediaserver calls exactly once
|
virtual void setBuffers(const Vector<sp<IMemory> > &buffers); // mediaserver calls exactly once
|
virtual void onBufferAvailable(size_t index);
|
|
// Consumption from ABQ
|
void pullFromBuffQueue();
|
|
private:
|
void receivedCmd_l(IStreamListener::Command cmd, const sp<AMessage> &msg = NULL);
|
void receivedBuffer_l(size_t buffIndex, size_t buffLength);
|
|
public:
|
// Call at least once prior to releasing the last strong reference to this object. It causes
|
// the player to release all of its resources, similar to android.media.MediaPlayer disconnect.
|
void disconnect();
|
|
private:
|
// protects mListener, mBuffers, mBuffersHasBeenSet, and mAvailableBuffers
|
Mutex mLock;
|
|
sp<IStreamListener> mListener;
|
// array of shared memory buffers
|
Vector<sp<IMemory> > mBuffers;
|
bool mBuffersHasBeenSet;
|
// list of available buffers in shared memory, identified by their index
|
List<size_t> mAvailableBuffers;
|
|
// the Android Buffer Queue from which data is consumed and written to shared memory
|
IAndroidBufferQueue* const mAndroidBufferQueue;
|
|
const sp<CallbackProtector> mCallbackProtector;
|
const wp<StreamPlayer> mPlayer;
|
|
DISALLOW_EVIL_CONSTRUCTORS(StreamSourceAppProxy);
|
};
|
|
|
//--------------------------------------------------------------------------------------------------
|
class StreamPlayer : public GenericMediaPlayer
|
{
|
public:
|
StreamPlayer(const AudioPlayback_Parameters* params, bool hasVideo,
|
IAndroidBufferQueue *androidBufferQueue, const sp<CallbackProtector> &callbackProtector);
|
virtual ~StreamPlayer();
|
|
// overridden from GenericPlayer
|
virtual void onMessageReceived(const sp<AMessage> &msg);
|
virtual void preDestroy();
|
|
void queueRefilled();
|
// Called after AndroidBufferQueue::Clear.
|
// The "_l" indicates the caller still has it's (now empty) AndroidBufferQueue locked.
|
void appClear_l();
|
|
protected:
|
|
enum {
|
// message to asynchronously notify mAppProxy it should try to pull from the Android
|
// Buffer Queue and push to shared memory (media server), either because the buffer queue
|
// was refilled, or because during playback, the shared memory buffers should remain
|
// filled to prevent it from draining (this can happen if the ABQ is not ready
|
// whenever a shared memory buffer becomes available)
|
kWhatPullFromAbq = 'plfq',
|
kWhatStopForDestroy = 's4ds'
|
};
|
|
const sp<StreamSourceAppProxy> mAppProxy; // application proxy for the shared memory source
|
|
// overridden from GenericMediaPlayer
|
virtual void onPrepare();
|
virtual void onPlay();
|
|
void onPullFromAndroidBufferQueue();
|
|
private:
|
void onStopForDestroy();
|
|
Mutex mStopForDestroyLock;
|
Condition mStopForDestroyCondition;
|
bool mStopForDestroyCompleted;
|
|
DISALLOW_EVIL_CONSTRUCTORS(StreamPlayer);
|
};
|
|
} // namespace android
|
