分析下系统Camera和MediaRecorder（libstagefright中MPEG4Writer以及CameraSource的关系）。

  首先，通过图示、看看Android系统Camera录像时的调用时序：

1.录像命令时序

2.录像数据回调时序

一、应用部分

1.主Activity启动

packages/apps/Camera/src/com/android/camera/CameraActivity.java

[java]  

1. public void onCreate(Bundle state)   
2. {  
3.   mCurrentModule.init(this, mFrame, true);  
4. }  

2.录像Activity初始化

packages/apps/Camera/src/com/android/camera/VideoModule.java

[java]  

1. public void init(CameraActivity activity, View root, boolean reuseScreenNail) {  
2. {  
3.   CameraOpenThread cameraOpenThread = new CameraOpenThread();  
4.   /* 
5.   protected class CameraOpenThread extends Thread { 
6.      
7.     public void run() { 
8.       openCamera(); 
9.     } 
10.   } 
11.   */  
12. }  

3.开始录制和停止录制

[java]  

1. //当用户点击录像后调用  
2. public void onShutterButtonClick()   
3. {  
4.   startVideoRecording();  
5. }  
6. private void startVideoRecording()   
7. {  
8.   initializeRecorder();  
9.   /* 
10.   private void initializeRecorder()    
11.   { 
12.     mMediaRecorder = new MediaRecorder(); 
13.     //调用至frameworks/av/media/libmediaplayerservice/StagefrightRecorder.cpp 
14.     /* 
15.     status_t StagefrightRecorder::setCamera(const sp<ICamera> &camera, 
16.                                         const sp<ICameraRecordingProxy> &proxy) { 
17.       mCamera = camera; 
18.     } 
19.     */  
20.     mMediaRecorder.setCamera(mActivity.mCameraDevice.getCamera());   
21.     mMediaRecorder.setAudioSource(MediaRecorder.AudioSource.CAMCORDER);  
22.     mMediaRecorder.setVideoSource(MediaRecorder.VideoSource.CAMERA);  
23.     mMediaRecorder.setProfile(mProfile);  
24.     mMediaRecorder.setMaxDuration(mMaxVideoDurationInMs);  
25.     mMediaRecorder.setOutputFile(mVideoFilename);  
26.   }  
27.   */  
28.   mMediaRecorder.start();  
29. }  
30. //当用户点击停止录制后调用  
31. public void onShutterButtonClick() {  
32.   public void onShutterButtonClick() {  
33. }  
34. private void onStopVideoRecording() {  
35.   stopVideoRecording();  
36. }  
37. private boolean stopVideoRecording() {  
38.   mMediaRecorder.setOnErrorListener(null);  
39.   mMediaRecorder.setOnInfoListener(null);  
40.   mMediaRecorder.stop();  
41.   closeCamera(closeEffects);  
42. }  

二、框架部分

1.MediaRecorder的API部分

frameworks/base/media/java/android/media/MediaRecorder.java

[java]  

1. public native void start() throws IllegalStateException;  
2. public native void stop() throws IllegalStateException;  

2.Native部分

frameworks/base/media/jni/android_media_MediaRecorder.cpp

[cpp]  

1. static JNINativeMethod gMethods[] = {  
2.   {"start",  "()V",   (void *)android_media_MediaRecorder_start},  
3.   {"stop",  "()V",   (void *)android_media_MediaRecorder_stop},  
4. }  
5. static void  
6. android_media_MediaRecorder_start(JNIEnv *env, jobject thiz)  
7. {  
8.   ALOGV("start");  
9.   sp<MediaRecorder> mr = getMediaRecorder(env, thiz);  
10.   process_media_recorder_call(env, mr->start(), "java/lang/RuntimeException", "start failed.");  
11. }  
12. static void  
13. android_media_MediaRecorder_stop(JNIEnv *env, jobject thiz)  
14. {  
15.   ALOGV("stop");  
16.   sp<MediaRecorder> mr = getMediaRecorder(env, thiz);  
17.   process_media_recorder_call(env, mr->stop(), "java/lang/RuntimeException", "stop failed.");  
18. }  

3.C++部分

frameworks/av/media/libmedia/MediaRecorder.cpp

[cpp]  

1. status_t MediaRecorder::start()  
2. {  
3.   status_t ret = mMediaRecorder->start();  
4.   /* 
5.   MediaRecorder::MediaRecorder() : mSurfaceMediaSource(NULL) 
6.   { 
7.     const sp<IMediaPlayerService>& service(getMediaPlayerService()); 
8.     mMediaRecorder = service->createMediaRecorder(getpid()); 
9.     //frameworks/av/media/libmediaplayerservice/MediaPlayerService.cpp 
10.     //sp<IMediaRecorder> MediaPlayerService::createMediaRecorder(pid_t pid) 
11.     //{ 
12.     //  sp<MediaRecorderClient> recorder = new MediaRecorderClient(this, pid); 
13.     //  return recorder; 
14.     //} 
15.   } 
16.   */  
17. }  

 

4.服务端（Android的Binder）

frameworks/av/media/libmediaplayerservice/MediaRecorderClient.cpp

[cpp]  

1. MediaRecorderClient::MediaRecorderClient(const sp<MediaPlayerService>& service, pid_t pid)  
2. {  
3.   ALOGV("Client constructor");  
4.   mPid = pid;  
5.   mRecorder = new StagefrightRecorder;  
6.   mMediaPlayerService = service;  
7. }  
8. status_t MediaRecorderClient::start()  
9. {  
10.   return mRecorder->start();  
11. }  

Android4.2多媒体使用Stagefright架构

frameworks/av/media/libmediaplayerservice/StagefrightRecorder.cpp

[cpp]  

1. status_t StagefrightRecorder::start() {  
2.   switch (mOutputFormat) {  
3.     case OUTPUT_FORMAT_MPEG_4:  
4.       status = startMPEG4Recording();  
5.       break;  
6.     case OUTPUT_FORMAT_AMR_WB:  
7.       status = startAMRRecording();  
8.       break;  
9.     case OUTPUT_FORMAT_AAC_ADTS:  
10.       status = startAACRecording();      
11.       break;  
12.     case OUTPUT_FORMAT_RTP_AVP:    
13.       status = startRTPRecording();  
14.       break;  
15.     case OUTPUT_FORMAT_MPEG2TS:  
16.       status = startMPEG2TSRecording();  
17.       break;  
18.   }  
19. }  
20. status_t StagefrightRecorder::startMPEG4Recording() {  
21.   status_t err = setupMPEG4Recording(  
22.             mOutputFd, mVideoWidth, mVideoHeight,  
23.             mVideoBitRate, &totalBitRate, &mWriter);  
24.   /* 
25.   status_t StagefrightRecorder::setupMPEG4Recording( 
26.         int outputFd, 
27.         int32_t videoWidth, int32_t videoHeight, 
28.         int32_t videoBitRate, 
29.         int32_t *totalBitRate, 
30.         sp<MediaWriter> *mediaWriter) { 
31.     sp<MediaWriter> writer = new MPEG4Writer(outputFd); 
32.     if (mVideoSource < VIDEO_SOURCE_LIST_END) { 
33.       sp<MediaSource> mediaSource; 
34.       //创建CameraSource: 
35.       //这步使用mCamera，mMediaRecorder.setCamera(mActivity.mCameraDevice.getCamera())应用设置过来的 
36.       err = setupMediaSource(&mediaSource);  
37.       sp<MediaSource> encoder; 
38.       //重要！！！！！设置输入类型，如：YUV420SP等 
39.       err = setupVideoEncoder(mediaSource, videoBitRate, &encoder);  
40.       //sp<MetaData> meta = cameraSource->getFormat(); 
41.       //CameraSource.cpp 
42.       mColorFormat = getColorFormat(params.get(CameraParameters::KEY_VIDEO_FRAME_FORMAT)); 
43.       //CameraHal.cpp: 
44.       p.set(CameraParameters::KEY_VIDEO_FRAME_FORMAT, (const char *) CameraParameters::PIXEL_FORMAT_YUV420SP); 
45.       //setVideoInputFormat(mMIME, meta); 
46.       //setVideoPortFormatType 
47.       writer->addSource(encoder); 
48.     } 
49.     if (!mCaptureTimeLapse && (mAudioSource != AUDIO_SOURCE_CNT)) { 
50.       //创建AudioSource；这步使用new AudioRecord 
51.       err = setupAudioEncoder(writer);  
52.       if (err != OK) return err; 
53.       *totalBitRate += mAudioBitRate; 
54.     } 
55.   } 
56.   */    
57.   err = mWriter->start(meta.get());  
58. }  

MPEG4编码器部分

frameworks/av/media/libstagefright/MPEG4Writer.cpp

[cpp]  

1. status_t MPEG4Writer::Track::start(MetaData *params) {  
2.   pthread_create(&mThread, &attr, ThreadWrapper, this);  
3.   /* 
4.   void *MPEG4Writer::Track::ThreadWrapper(void *me) { 
5.     Track *track = static_cast<Track *>(me); 
6.     status_t err = track->threadEntry(); 
7.     return (void *) err; 
8.   } 
9.   status_t MPEG4Writer::Track::threadEntry() { 
10.     while (!mDone && (err = mSource->read(&buffer)) == OK) { 
11.       //如上read即是frameworks/av/media/libstagefright/CameraSource.cpp的read 
12.     } 
13.   } 
14.   */    
15. }  
16. status_t MPEG4Writer::Track::stop() {  
17.   mDone = true;  
18.   void *dummy;  
19.   pthread_join(mThread, &dummy); //等待刚才的主线程退出  
20. }  

当有数据来时CameraSource的dataCallbackTimestamp函数会被调用，如此、完成视频录制。

三、分析问题

  我们的问题就出在直接拔掉Camera时；应用程序调用mMediaRecorder.stop()超时卡死；经分析是上述框架部分“Camera拔出时录制的主线程不能退出、导致接口阻塞”。后调试发现：mDone变量并不能在两个线程间传参数；后打入之前一个patcher（see bug 4724339），修改了主线程中的mSource->read、并在相应的while循环中做判断，问题解决。

frameworks/av/media/libstagefright/CameraSource.cpp

 

[cpp]  

1. status_t CameraSource::read(  
2.         MediaBuffer **buffer, const ReadOptions *options) {  
3.   ALOGW("Timed out waiting for incoming camera video frames: %lld us",  
4.                     mLastFrameTimestampUs);  
5.   //add by tankai  
6.   // For funtion OMXCodec::read timeout return in writer, then Writer (e.g. VECaptureWriter) thread can exit  when  
7.   // media recorder stop  
8.   // reason: when media recorder start with no frame send to OMXCodec(with camera source),  
9.   // media recorder can not stop always (because writer can't exit)  
10.   // this change impact cameras: vecapture fake camera and Webcam  
11.   return ERROR_END_OF_STREAM;  
12.   //end tankai  
13. }  

 

四、补充，分析MPEG4中Audio流程；接分析二中的实现

1.Audio录音

frameworks/av/media/libmediaplayerservice/StagefrightRecorder.cpp

[cpp]  

1. status_t StagefrightRecorder::setupAudioEncoder(const sp<MediaWriter>& writer) {() {  
2.   sp<MediaSource> audioEncoder = createAudioSource();  
3.   writer->addSource(audioEncoder);  
4. }  
5. sp<MediaSource> StagefrightRecorder::createAudioSource() {  
6.   sp<AudioSource> audioSource =  
7.         new AudioSource(  
8.                 mAudioSource,  
9.                 mSampleRate,  
10.                 mAudioChannels);  
11. }  

frameworks/av/media/libstagefright/AudioSource.cpp

[cpp]  

1. AudioSource::AudioSource(  
2.         audio_source_t inputSource, uint32_t sampleRate, uint32_t channelCount)  
3.     : mRecord(NULL),  
4.       mStarted(false),  
5.       mSampleRate(sampleRate),  
6.       mPrevSampleTimeUs(0),  
7.       mNumFramesReceived(0),  
8.       mNumClientOwnedBuffers(0) {  
9.   mRecord = new AudioRecord(  
10.                     inputSource, sampleRate, AUDIO_FORMAT_PCM_16_BIT,  
11.                     audio_channel_in_mask_from_count(channelCount),  
12.                     bufCount * frameCount,  
13.                     AudioRecordCallbackFunction,  
14.                     this,  
15.                     frameCount);  
16. }  

 

至此，MediaRecorder与AudioFlinger建立联系。

2.Audio放音

MediaPlayer播放音频服务端（后边有时间在具体分析应用程序/客户端流程）：

frameworks/av/media/libmediaplayerservice/MediaPlayerService.cpp

[cpp]  

1. status_t MediaPlayerService::AudioOutput::open(  
2.         uint32_t sampleRate, int channelCount, audio_channel_mask_t channelMask,  
3.         audio_format_t format, int bufferCount,  
4.         AudioCallback cb, void *cookie,  
5.         audio_output_flags_t flags)  
6. {  
7.   AudioTrack *t;  
8.   //最终放声音使用AudioTrack  
9.   t = new AudioTrack(  
10.                 mStreamType,  
11.                 sampleRate,  
12.                 format,  
13.                 channelMask,  
14.                 frameCount,  
15.                 flags,  
16.                 CallbackWrapper,  
17.                 newcbd,  
18.                 0,  // notification frames  
19.                 mSessionId);  
20. }