blob: 95afb1d8cf599d4e42810e540fa5a78f9874001d [file] [log] [blame]
Andreas Huber20111aa2009-07-14 16:56:47 -07001/*
2 * Copyright (C) 2009 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
James Dongc32cd792010-04-26 17:48:26 -070017//#define LOG_NDEBUG 0
18#define LOG_TAG "CameraSource"
19#include <utils/Log.h>
Andreas Huber20111aa2009-07-14 16:56:47 -070020
Andreas Huber20111aa2009-07-14 16:56:47 -070021#include <OMX_Component.h>
James Dong9d7f58a2010-06-09 15:57:48 -070022#include <binder/IPCThreadState.h>
Andreas Huber20111aa2009-07-14 16:56:47 -070023#include <media/stagefright/CameraSource.h>
Andreas Huber0c891992009-08-26 14:48:20 -070024#include <media/stagefright/MediaDebug.h>
Andreas Huberbe5c74f2009-10-13 17:08:31 -070025#include <media/stagefright/MediaDefs.h>
Andreas Huber20111aa2009-07-14 16:56:47 -070026#include <media/stagefright/MediaErrors.h>
27#include <media/stagefright/MetaData.h>
Mathias Agopian3cf61352010-02-09 17:46:37 -080028#include <camera/Camera.h>
29#include <camera/CameraParameters.h>
James Dong54ff19a2010-10-08 11:59:32 -070030#include <surfaceflinger/Surface.h>
Andreas Huberbe5c74f2009-10-13 17:08:31 -070031#include <utils/String8.h>
James Dong365a9632010-06-04 13:59:27 -070032#include <cutils/properties.h>
Andreas Huber20111aa2009-07-14 16:56:47 -070033
34namespace android {
35
Andreas Huberbe5c74f2009-10-13 17:08:31 -070036struct CameraSourceListener : public CameraListener {
37 CameraSourceListener(const sp<CameraSource> &source);
38
39 virtual void notify(int32_t msgType, int32_t ext1, int32_t ext2);
40 virtual void postData(int32_t msgType, const sp<IMemory> &dataPtr);
41
42 virtual void postDataTimestamp(
43 nsecs_t timestamp, int32_t msgType, const sp<IMemory>& dataPtr);
44
45protected:
46 virtual ~CameraSourceListener();
47
48private:
49 wp<CameraSource> mSource;
50
51 CameraSourceListener(const CameraSourceListener &);
52 CameraSourceListener &operator=(const CameraSourceListener &);
53};
54
55CameraSourceListener::CameraSourceListener(const sp<CameraSource> &source)
56 : mSource(source) {
57}
58
59CameraSourceListener::~CameraSourceListener() {
60}
61
62void CameraSourceListener::notify(int32_t msgType, int32_t ext1, int32_t ext2) {
63 LOGV("notify(%d, %d, %d)", msgType, ext1, ext2);
64}
65
66void CameraSourceListener::postData(int32_t msgType, const sp<IMemory> &dataPtr) {
67 LOGV("postData(%d, ptr:%p, size:%d)",
68 msgType, dataPtr->pointer(), dataPtr->size());
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -070069
70 sp<CameraSource> source = mSource.promote();
71 if (source.get() != NULL) {
72 source->dataCallback(msgType, dataPtr);
73 }
Andreas Huberbe5c74f2009-10-13 17:08:31 -070074}
75
76void CameraSourceListener::postDataTimestamp(
77 nsecs_t timestamp, int32_t msgType, const sp<IMemory>& dataPtr) {
James Dongc32cd792010-04-26 17:48:26 -070078
79 sp<CameraSource> source = mSource.promote();
80 if (source.get() != NULL) {
81 source->dataCallbackTimestamp(timestamp/1000, msgType, dataPtr);
82 }
Andreas Huberbe5c74f2009-10-13 17:08:31 -070083}
84
James Dong653252b2010-06-03 11:48:31 -070085static int32_t getColorFormat(const char* colorFormat) {
James Donge2d8ba82010-09-15 16:52:51 -070086 if (!strcmp(colorFormat, CameraParameters::PIXEL_FORMAT_YUV420P)) {
87 return OMX_COLOR_FormatYUV420Planar;
88 }
89
James Dong653252b2010-06-03 11:48:31 -070090 if (!strcmp(colorFormat, CameraParameters::PIXEL_FORMAT_YUV422SP)) {
91 return OMX_COLOR_FormatYUV422SemiPlanar;
92 }
93
94 if (!strcmp(colorFormat, CameraParameters::PIXEL_FORMAT_YUV420SP)) {
95 return OMX_COLOR_FormatYUV420SemiPlanar;
96 }
97
98 if (!strcmp(colorFormat, CameraParameters::PIXEL_FORMAT_YUV422I)) {
99 return OMX_COLOR_FormatYCbYCr;
100 }
101
102 if (!strcmp(colorFormat, CameraParameters::PIXEL_FORMAT_RGB565)) {
103 return OMX_COLOR_Format16bitRGB565;
104 }
105
James Donga1abc1a2010-09-13 16:30:51 -0700106 LOGE("Uknown color format (%s), please add it to "
107 "CameraSource::getColorFormat", colorFormat);
108
James Dong653252b2010-06-03 11:48:31 -0700109 CHECK_EQ(0, "Unknown color format");
110}
111
Andreas Huber20111aa2009-07-14 16:56:47 -0700112CameraSource *CameraSource::Create() {
James Dong54ff19a2010-10-08 11:59:32 -0700113 Size size;
114 size.width = -1;
115 size.height = -1;
Andreas Huber20111aa2009-07-14 16:56:47 -0700116
James Dong54ff19a2010-10-08 11:59:32 -0700117 sp<ICamera> camera;
James Dong5c952312010-10-18 21:42:27 -0700118 return new CameraSource(camera, 0, size, -1, NULL, false);
Andreas Huber20111aa2009-07-14 16:56:47 -0700119}
120
Andreas Huber30ab6622009-11-16 15:43:38 -0800121// static
James Dong54ff19a2010-10-08 11:59:32 -0700122CameraSource *CameraSource::CreateFromCamera(
123 const sp<ICamera>& camera,
124 int32_t cameraId,
125 Size videoSize,
126 int32_t frameRate,
James Dong5c952312010-10-18 21:42:27 -0700127 const sp<Surface>& surface,
128 bool storeMetaDataInVideoBuffers) {
Andreas Huber30ab6622009-11-16 15:43:38 -0800129
James Dong54ff19a2010-10-08 11:59:32 -0700130 CameraSource *source = new CameraSource(camera, cameraId,
James Dong5c952312010-10-18 21:42:27 -0700131 videoSize, frameRate, surface,
132 storeMetaDataInVideoBuffers);
James Dong54ff19a2010-10-08 11:59:32 -0700133
134 if (source != NULL) {
135 if (source->initCheck() != OK) {
136 delete source;
137 return NULL;
138 }
139 }
140 return source;
Andreas Huber30ab6622009-11-16 15:43:38 -0800141}
142
James Dong54ff19a2010-10-08 11:59:32 -0700143CameraSource::CameraSource(
144 const sp<ICamera>& camera,
145 int32_t cameraId,
146 Size videoSize,
147 int32_t frameRate,
James Dong5c952312010-10-18 21:42:27 -0700148 const sp<Surface>& surface,
149 bool storeMetaDataInVideoBuffers)
James Dong54ff19a2010-10-08 11:59:32 -0700150 : mCameraFlags(0),
151 mVideoFrameRate(-1),
152 mCamera(0),
153 mSurface(surface),
James Dong13aec892010-04-21 16:14:15 -0700154 mNumFramesReceived(0),
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700155 mLastFrameTimestampUs(0),
156 mStarted(false),
157 mFirstFrameTimeUs(0),
James Dong13aec892010-04-21 16:14:15 -0700158 mNumFramesEncoded(0),
159 mNumFramesDropped(0),
James Dongf60cafe2010-06-19 09:04:18 -0700160 mNumGlitches(0),
161 mGlitchDurationThresholdUs(200000),
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700162 mCollectStats(false) {
James Dong9d7f58a2010-06-09 15:57:48 -0700163
James Dong54ff19a2010-10-08 11:59:32 -0700164 mVideoSize.width = -1;
165 mVideoSize.height = -1;
166
James Dong5c952312010-10-18 21:42:27 -0700167 mInitCheck = init(camera, cameraId,
168 videoSize, frameRate,
169 storeMetaDataInVideoBuffers);
James Dong54ff19a2010-10-08 11:59:32 -0700170}
171
172status_t CameraSource::initCheck() const {
173 return mInitCheck;
174}
175
176status_t CameraSource::isCameraAvailable(
177 const sp<ICamera>& camera, int32_t cameraId) {
178
179 if (camera == 0) {
180 mCamera = Camera::connect(cameraId);
181 mCameraFlags &= ~FLAGS_HOT_CAMERA;
182 } else {
183 mCamera = Camera::create(camera);
184 mCameraFlags |= FLAGS_HOT_CAMERA;
185 }
186
187 // Is camera available?
188 if (mCamera == 0) {
189 LOGE("Camera connection could not be established.");
190 return -EBUSY;
191 }
192 if (!(mCameraFlags & FLAGS_HOT_CAMERA)) {
193 mCamera->lock();
194 }
195 return OK;
196}
197
198
199/*
200 * Check to see whether the requested video width and height is one
201 * of the supported sizes.
202 * @param width the video frame width in pixels
203 * @param height the video frame height in pixels
204 * @param suppportedSizes the vector of sizes that we check against
205 * @return true if the dimension (width and height) is supported.
206 */
207static bool isVideoSizeSupported(
208 int32_t width, int32_t height,
209 const Vector<Size>& supportedSizes) {
210
211 LOGV("isVideoSizeSupported");
212 for (size_t i = 0; i < supportedSizes.size(); ++i) {
213 if (width == supportedSizes[i].width &&
214 height == supportedSizes[i].height) {
215 return true;
216 }
217 }
218 return false;
219}
220
221/*
222 * If the preview and video output is separate, we only set the
223 * the video size, and applications should set the preview size
224 * to some proper value, and the recording framework will not
225 * change the preview size; otherwise, if the video and preview
226 * output is the same, we need to set the preview to be the same
227 * as the requested video size.
228 *
229 */
230/*
231 * Query the camera to retrieve the supported video frame sizes
232 * and also to see whether CameraParameters::setVideoSize()
233 * is supported or not.
234 * @param params CameraParameters to retrieve the information
235 * @@param isSetVideoSizeSupported retunrs whether method
236 * CameraParameters::setVideoSize() is supported or not.
237 * @param sizes returns the vector of Size objects for the
238 * supported video frame sizes advertised by the camera.
239 */
240static void getSupportedVideoSizes(
241 const CameraParameters& params,
242 bool *isSetVideoSizeSupported,
243 Vector<Size>& sizes) {
244
245 *isSetVideoSizeSupported = true;
246 params.getSupportedVideoSizes(sizes);
247 if (sizes.size() == 0) {
248 LOGD("Camera does not support setVideoSize()");
249 params.getSupportedPreviewSizes(sizes);
250 *isSetVideoSizeSupported = false;
251 }
252}
253
254/*
255 * Check whether the camera has the supported color format
256 * @param params CameraParameters to retrieve the information
257 * @return OK if no error.
258 */
259status_t CameraSource::isCameraColorFormatSupported(
260 const CameraParameters& params) {
261 mColorFormat = getColorFormat(params.get(
262 CameraParameters::KEY_VIDEO_FRAME_FORMAT));
263 if (mColorFormat == -1) {
264 return BAD_VALUE;
265 }
266 return OK;
267}
268
269/*
270 * Configure the camera to use the requested video size
271 * (width and height) and/or frame rate. If both width and
272 * height are -1, configuration on the video size is skipped.
273 * if frameRate is -1, configuration on the frame rate
274 * is skipped. Skipping the configuration allows one to
275 * use the current camera setting without the need to
276 * actually know the specific values (see Create() method).
277 *
278 * @param params the CameraParameters to be configured
279 * @param width the target video frame width in pixels
280 * @param height the target video frame height in pixels
281 * @param frameRate the target frame rate in frames per second.
282 * @return OK if no error.
283 */
284status_t CameraSource::configureCamera(
285 CameraParameters* params,
286 int32_t width, int32_t height,
287 int32_t frameRate) {
288
289 Vector<Size> sizes;
290 bool isSetVideoSizeSupportedByCamera = true;
291 getSupportedVideoSizes(*params, &isSetVideoSizeSupportedByCamera, sizes);
292 bool isCameraParamChanged = false;
293 if (width != -1 && height != -1) {
294 if (!isVideoSizeSupported(width, height, sizes)) {
295 LOGE("Video dimension (%dx%d) is unsupported", width, height);
296 return BAD_VALUE;
297 }
298 if (isSetVideoSizeSupportedByCamera) {
299 params->setVideoSize(width, height);
300 } else {
301 params->setPreviewSize(width, height);
302 }
303 isCameraParamChanged = true;
304 } else if ((width == -1 && height != -1) ||
305 (width != -1 && height == -1)) {
306 // If one and only one of the width and height is -1
307 // we reject such a request.
308 LOGE("Requested video size (%dx%d) is not supported", width, height);
309 return BAD_VALUE;
310 } else { // width == -1 && height == -1
311 // Do not configure the camera.
312 // Use the current width and height value setting from the camera.
313 }
314
315 if (frameRate != -1) {
316 params->setPreviewFrameRate(frameRate);
317 isCameraParamChanged = true;
318 } else { // frameRate == -1
319 // Do not configure the camera.
320 // Use the current frame rate value setting from the camera
321 }
322
323 if (isCameraParamChanged) {
324 // Either frame rate or frame size needs to be changed.
325 String8 s = params->flatten();
326 if (OK != mCamera->setParameters(s)) {
327 LOGE("Could not change settings."
328 " Someone else is using camera %p?", mCamera.get());
329 return -EBUSY;
330 }
331 }
332 return OK;
333}
334
335/*
336 * Check whether the requested video frame size
337 * has been successfully configured or not. If both width and height
338 * are -1, check on the current width and height value setting
339 * is performed.
340 *
341 * @param params CameraParameters to retrieve the information
342 * @param the target video frame width in pixels to check against
343 * @param the target video frame height in pixels to check against
344 * @return OK if no error
345 */
346status_t CameraSource::checkVideoSize(
347 const CameraParameters& params,
348 int32_t width, int32_t height) {
349
James Dongf96c9d12010-10-20 11:41:33 -0700350 // The actual video size is the same as the preview size
351 // if the camera hal does not support separate video and
352 // preview output. In this case, we retrieve the video
353 // size from preview.
James Dong54ff19a2010-10-08 11:59:32 -0700354 int32_t frameWidthActual = -1;
355 int32_t frameHeightActual = -1;
James Dongf96c9d12010-10-20 11:41:33 -0700356 Vector<Size> sizes;
357 params.getSupportedVideoSizes(sizes);
358 if (sizes.size() == 0) {
359 // video size is the same as preview size
360 params.getPreviewSize(&frameWidthActual, &frameHeightActual);
361 } else {
362 // video size may not be the same as preview
363 params.getVideoSize(&frameWidthActual, &frameHeightActual);
364 }
James Dong54ff19a2010-10-08 11:59:32 -0700365 if (frameWidthActual < 0 || frameHeightActual < 0) {
366 LOGE("Failed to retrieve video frame size (%dx%d)",
367 frameWidthActual, frameHeightActual);
368 return UNKNOWN_ERROR;
369 }
370
371 // Check the actual video frame size against the target/requested
372 // video frame size.
373 if (width != -1 && height != -1) {
374 if (frameWidthActual != width || frameHeightActual != height) {
375 LOGE("Failed to set video frame size to %dx%d. "
376 "The actual video size is %dx%d ", width, height,
377 frameWidthActual, frameHeightActual);
378 return UNKNOWN_ERROR;
379 }
380 }
381
382 // Good now.
383 mVideoSize.width = frameWidthActual;
384 mVideoSize.height = frameHeightActual;
385 return OK;
386}
387
388/*
389 * Check the requested frame rate has been successfully configured or not.
390 * If the target frameRate is -1, check on the current frame rate value
391 * setting is performed.
392 *
393 * @param params CameraParameters to retrieve the information
394 * @param the target video frame rate to check against
395 * @return OK if no error.
396 */
397status_t CameraSource::checkFrameRate(
398 const CameraParameters& params,
399 int32_t frameRate) {
400
401 int32_t frameRateActual = params.getPreviewFrameRate();
402 if (frameRateActual < 0) {
403 LOGE("Failed to retrieve preview frame rate (%d)", frameRateActual);
404 return UNKNOWN_ERROR;
405 }
406
407 // Check the actual video frame rate against the target/requested
408 // video frame rate.
409 if (frameRate != -1 && (frameRateActual - frameRate) != 0) {
410 LOGE("Failed to set preview frame rate to %d fps. The actual "
411 "frame rate is %d", frameRate, frameRateActual);
412 return UNKNOWN_ERROR;
413 }
414
415 // Good now.
416 mVideoFrameRate = frameRateActual;
417 return OK;
418}
419
420/*
421 * Initialize the CameraSource to so that it becomes
422 * ready for providing the video input streams as requested.
423 * @param camera the camera object used for the video source
424 * @param cameraId if camera == 0, use camera with this id
425 * as the video source
426 * @param videoSize the target video frame size. If both
427 * width and height in videoSize is -1, use the current
428 * width and heigth settings by the camera
429 * @param frameRate the target frame rate in frames per second.
430 * if it is -1, use the current camera frame rate setting.
James Dong5c952312010-10-18 21:42:27 -0700431 * @param storeMetaDataInVideoBuffers request to store meta
432 * data or real YUV data in video buffers. Request to
433 * store meta data in video buffers may not be honored
434 * if the source does not support this feature.
435 *
James Dong54ff19a2010-10-08 11:59:32 -0700436 * @return OK if no error.
437 */
438status_t CameraSource::init(
439 const sp<ICamera>& camera,
440 int32_t cameraId,
441 Size videoSize,
James Dong5c952312010-10-18 21:42:27 -0700442 int32_t frameRate,
443 bool storeMetaDataInVideoBuffers) {
James Dong54ff19a2010-10-08 11:59:32 -0700444
445 status_t err = OK;
James Dong9d7f58a2010-06-09 15:57:48 -0700446 int64_t token = IPCThreadState::self()->clearCallingIdentity();
James Dong54ff19a2010-10-08 11:59:32 -0700447
448 if ((err = isCameraAvailable(camera, cameraId)) != OK) {
449 return err;
450 }
451 CameraParameters params(mCamera->getParameters());
452 if ((err = isCameraColorFormatSupported(params)) != OK) {
453 return err;
454 }
455
456 // Set the camera to use the requested video frame size
457 // and/or frame rate.
458 if ((err = configureCamera(&params,
459 videoSize.width, videoSize.height,
460 frameRate))) {
461 return err;
462 }
463
464 // Check on video frame size and frame rate.
465 CameraParameters newCameraParams(mCamera->getParameters());
466 if ((err = checkVideoSize(newCameraParams,
467 videoSize.width, videoSize.height)) != OK) {
468 return err;
469 }
470 if ((err = checkFrameRate(newCameraParams, frameRate)) != OK) {
471 return err;
472 }
473
474 // This CHECK is good, since we just passed the lock/unlock
475 // check earlier by calling mCamera->setParameters().
476 CHECK_EQ(OK, mCamera->setPreviewDisplay(mSurface));
James Dong2b37ced2010-10-09 01:16:58 -0700477
James Dong5c952312010-10-18 21:42:27 -0700478 mIsMetaDataStoredInVideoBuffers = false;
479 if (storeMetaDataInVideoBuffers &&
480 OK == mCamera->storeMetaDataInBuffers(true)) {
481 mIsMetaDataStoredInVideoBuffers = true;
482 }
483
James Dong2b37ced2010-10-09 01:16:58 -0700484 /*
485 * mCamera->startRecording() signals camera hal to make
486 * available the video buffers (for instance, allocation
487 * of the video buffers may be triggered when camera hal's
488 * startRecording() method is called). Making available these
489 * video buffers earlier (before calling start()) is critical,
490 * if one wants to configure omx video encoders to use these
491 * buffers for passing video frame data during video recording
492 * without the need to memcpy the video frame data stored
493 * in these buffers. Eliminating memcpy for video frame data
494 * is crucial in performance for HD quality video recording
495 * applications.
496 *
497 * Based on OMX IL spec, configuring the omx video encoders
498 * must occur in loaded state. When start() is called, omx
499 * video encoders are already in idle state, which is too
500 * late. Thus, we must call mCamera->startRecording() earlier.
501 */
502 startCameraRecording();
503
James Dong9d7f58a2010-06-09 15:57:48 -0700504 IPCThreadState::self()->restoreCallingIdentity(token);
505
James Dong54ff19a2010-10-08 11:59:32 -0700506 int64_t glitchDurationUs = (1000000LL / mVideoFrameRate);
James Dongf60cafe2010-06-19 09:04:18 -0700507 if (glitchDurationUs > mGlitchDurationThresholdUs) {
508 mGlitchDurationThresholdUs = glitchDurationUs;
509 }
510
James Dongddcc4a62010-06-08 11:58:53 -0700511 // XXX: query camera for the stride and slice height
512 // when the capability becomes available.
James Dong653252b2010-06-03 11:48:31 -0700513 mMeta = new MetaData;
James Dong54ff19a2010-10-08 11:59:32 -0700514 mMeta->setCString(kKeyMIMEType, MEDIA_MIMETYPE_VIDEO_RAW);
515 mMeta->setInt32(kKeyColorFormat, mColorFormat);
516 mMeta->setInt32(kKeyWidth, mVideoSize.width);
517 mMeta->setInt32(kKeyHeight, mVideoSize.height);
518 mMeta->setInt32(kKeyStride, mVideoSize.width);
519 mMeta->setInt32(kKeySliceHeight, mVideoSize.height);
520 return OK;
Andreas Huber20111aa2009-07-14 16:56:47 -0700521}
522
523CameraSource::~CameraSource() {
524 if (mStarted) {
525 stop();
526 }
Andreas Huber20111aa2009-07-14 16:56:47 -0700527}
528
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700529void CameraSource::startCameraRecording() {
530 CHECK_EQ(OK, mCamera->startRecording());
James Dong2b37ced2010-10-09 01:16:58 -0700531 CHECK(mCamera->recordingEnabled());
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700532}
533
James Dongf60cafe2010-06-19 09:04:18 -0700534status_t CameraSource::start(MetaData *meta) {
Andreas Huber0c891992009-08-26 14:48:20 -0700535 CHECK(!mStarted);
James Dong54ff19a2010-10-08 11:59:32 -0700536 if (mInitCheck != OK) {
537 LOGE("CameraSource is not initialized yet");
538 return mInitCheck;
539 }
Andreas Huber20111aa2009-07-14 16:56:47 -0700540
James Dong365a9632010-06-04 13:59:27 -0700541 char value[PROPERTY_VALUE_MAX];
542 if (property_get("media.stagefright.record-stats", value, NULL)
543 && (!strcmp(value, "1") || !strcasecmp(value, "true"))) {
544 mCollectStats = true;
545 }
James Dong9d7f58a2010-06-09 15:57:48 -0700546
James Dongf60cafe2010-06-19 09:04:18 -0700547 mStartTimeUs = 0;
548 int64_t startTimeUs;
549 if (meta && meta->findInt64(kKeyTime, &startTimeUs)) {
550 mStartTimeUs = startTimeUs;
551 }
552
James Dong9d7f58a2010-06-09 15:57:48 -0700553 int64_t token = IPCThreadState::self()->clearCallingIdentity();
Andreas Huberbe5c74f2009-10-13 17:08:31 -0700554 mCamera->setListener(new CameraSourceListener(this));
James Dong9d7f58a2010-06-09 15:57:48 -0700555 IPCThreadState::self()->restoreCallingIdentity(token);
Andreas Huber20111aa2009-07-14 16:56:47 -0700556
557 mStarted = true;
Andreas Huber20111aa2009-07-14 16:56:47 -0700558 return OK;
559}
560
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700561void CameraSource::stopCameraRecording() {
Nipun Kwatra78eff722010-09-15 15:08:49 -0700562 mCamera->setListener(NULL);
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700563 mCamera->stopRecording();
564}
565
Andreas Huber20111aa2009-07-14 16:56:47 -0700566status_t CameraSource::stop() {
James Dongc32cd792010-04-26 17:48:26 -0700567 LOGV("stop");
568 Mutex::Autolock autoLock(mLock);
Andreas Huber20111aa2009-07-14 16:56:47 -0700569 mStarted = false;
James Dongc32cd792010-04-26 17:48:26 -0700570 mFrameAvailableCondition.signal();
James Dong365a9632010-06-04 13:59:27 -0700571
James Dong9d7f58a2010-06-09 15:57:48 -0700572 int64_t token = IPCThreadState::self()->clearCallingIdentity();
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700573 stopCameraRecording();
James Dongc32cd792010-04-26 17:48:26 -0700574 releaseQueuedFrames();
James Dong7278cf32010-05-27 16:05:58 -0700575 while (!mFramesBeingEncoded.empty()) {
James Dong365a9632010-06-04 13:59:27 -0700576 LOGI("Waiting for outstanding frames being encoded: %d",
577 mFramesBeingEncoded.size());
James Dong7278cf32010-05-27 16:05:58 -0700578 mFrameCompleteCondition.wait(mLock);
579 }
James Dong54ff19a2010-10-08 11:59:32 -0700580
581 LOGV("Disconnect camera");
582 if ((mCameraFlags & FLAGS_HOT_CAMERA) == 0) {
583 LOGV("Camera was cold when we started, stopping preview");
584 mCamera->stopPreview();
585 }
586 mCamera->unlock();
587 mCamera.clear();
588 mCamera = 0;
589 mCameraFlags = 0;
James Dong9d7f58a2010-06-09 15:57:48 -0700590 IPCThreadState::self()->restoreCallingIdentity(token);
James Dong7278cf32010-05-27 16:05:58 -0700591
James Dong365a9632010-06-04 13:59:27 -0700592 if (mCollectStats) {
593 LOGI("Frames received/encoded/dropped: %d/%d/%d in %lld us",
594 mNumFramesReceived, mNumFramesEncoded, mNumFramesDropped,
595 mLastFrameTimestampUs - mFirstFrameTimeUs);
596 }
James Dong13aec892010-04-21 16:14:15 -0700597
598 CHECK_EQ(mNumFramesReceived, mNumFramesEncoded + mNumFramesDropped);
Andreas Huber20111aa2009-07-14 16:56:47 -0700599 return OK;
600}
601
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700602void CameraSource::releaseRecordingFrame(const sp<IMemory>& frame) {
603 mCamera->releaseRecordingFrame(frame);
604}
605
James Dongc32cd792010-04-26 17:48:26 -0700606void CameraSource::releaseQueuedFrames() {
607 List<sp<IMemory> >::iterator it;
James Dong7278cf32010-05-27 16:05:58 -0700608 while (!mFramesReceived.empty()) {
609 it = mFramesReceived.begin();
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700610 releaseRecordingFrame(*it);
James Dong7278cf32010-05-27 16:05:58 -0700611 mFramesReceived.erase(it);
James Dong13aec892010-04-21 16:14:15 -0700612 ++mNumFramesDropped;
James Dongc32cd792010-04-26 17:48:26 -0700613 }
614}
615
Andreas Huber20111aa2009-07-14 16:56:47 -0700616sp<MetaData> CameraSource::getFormat() {
James Dong653252b2010-06-03 11:48:31 -0700617 return mMeta;
Andreas Huber20111aa2009-07-14 16:56:47 -0700618}
619
James Dongf60cafe2010-06-19 09:04:18 -0700620void CameraSource::releaseOneRecordingFrame(const sp<IMemory>& frame) {
621 int64_t token = IPCThreadState::self()->clearCallingIdentity();
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700622 releaseRecordingFrame(frame);
James Dongf60cafe2010-06-19 09:04:18 -0700623 IPCThreadState::self()->restoreCallingIdentity(token);
624}
625
James Dong7278cf32010-05-27 16:05:58 -0700626void CameraSource::signalBufferReturned(MediaBuffer *buffer) {
627 LOGV("signalBufferReturned: %p", buffer->data());
Andreas Huber56223b92010-08-11 12:34:32 -0700628 Mutex::Autolock autoLock(mLock);
James Dong7278cf32010-05-27 16:05:58 -0700629 for (List<sp<IMemory> >::iterator it = mFramesBeingEncoded.begin();
630 it != mFramesBeingEncoded.end(); ++it) {
631 if ((*it)->pointer() == buffer->data()) {
James Dongf60cafe2010-06-19 09:04:18 -0700632 releaseOneRecordingFrame((*it));
James Dong7278cf32010-05-27 16:05:58 -0700633 mFramesBeingEncoded.erase(it);
634 ++mNumFramesEncoded;
635 buffer->setObserver(0);
636 buffer->release();
637 mFrameCompleteCondition.signal();
638 return;
639 }
640 }
641 CHECK_EQ(0, "signalBufferReturned: bogus buffer");
642}
643
Andreas Huber20111aa2009-07-14 16:56:47 -0700644status_t CameraSource::read(
645 MediaBuffer **buffer, const ReadOptions *options) {
James Dongc32cd792010-04-26 17:48:26 -0700646 LOGV("read");
Andreas Huber20111aa2009-07-14 16:56:47 -0700647
648 *buffer = NULL;
649
650 int64_t seekTimeUs;
Andreas Huberabd1f4f2010-07-20 15:04:28 -0700651 ReadOptions::SeekMode mode;
652 if (options && options->getSeekTo(&seekTimeUs, &mode)) {
Andreas Huber20111aa2009-07-14 16:56:47 -0700653 return ERROR_UNSUPPORTED;
654 }
655
656 sp<IMemory> frame;
Andreas Huberbe5c74f2009-10-13 17:08:31 -0700657 int64_t frameTime;
Andreas Huber20111aa2009-07-14 16:56:47 -0700658
659 {
660 Mutex::Autolock autoLock(mLock);
James Dong542db5d2010-07-21 14:51:35 -0700661 while (mStarted) {
662 while(mFramesReceived.empty()) {
663 mFrameAvailableCondition.wait(mLock);
664 }
Andreas Huberbe5c74f2009-10-13 17:08:31 -0700665
James Dong542db5d2010-07-21 14:51:35 -0700666 if (!mStarted) {
667 return OK;
668 }
James Dong7278cf32010-05-27 16:05:58 -0700669
James Dong542db5d2010-07-21 14:51:35 -0700670 frame = *mFramesReceived.begin();
671 mFramesReceived.erase(mFramesReceived.begin());
672
673 frameTime = *mFrameTimes.begin();
674 mFrameTimes.erase(mFrameTimes.begin());
675 int64_t skipTimeUs;
676 if (!options || !options->getSkipFrame(&skipTimeUs)) {
677 skipTimeUs = frameTime;
678 }
679 if (skipTimeUs > frameTime) {
680 LOGV("skipTimeUs: %lld us > frameTime: %lld us",
681 skipTimeUs, frameTime);
682 releaseOneRecordingFrame(frame);
683 ++mNumFramesDropped;
684 // Safeguard against the abuse of the kSkipFrame_Option.
685 if (skipTimeUs - frameTime >= 1E6) {
686 LOGE("Frame skipping requested is way too long: %lld us",
687 skipTimeUs - frameTime);
688 return UNKNOWN_ERROR;
689 }
690 } else {
691 mFramesBeingEncoded.push_back(frame);
692 *buffer = new MediaBuffer(frame->pointer(), frame->size());
693 (*buffer)->setObserver(this);
694 (*buffer)->add_ref();
695 (*buffer)->meta_data()->setInt64(kKeyTime, frameTime);
Andreas Huber56223b92010-08-11 12:34:32 -0700696
James Dong542db5d2010-07-21 14:51:35 -0700697 return OK;
698 }
699 }
Andreas Huber20111aa2009-07-14 16:56:47 -0700700 }
Andreas Huber20111aa2009-07-14 16:56:47 -0700701 return OK;
702}
703
James Dongc32cd792010-04-26 17:48:26 -0700704void CameraSource::dataCallbackTimestamp(int64_t timestampUs,
705 int32_t msgType, const sp<IMemory> &data) {
706 LOGV("dataCallbackTimestamp: timestamp %lld us", timestampUs);
Andreas Huber20111aa2009-07-14 16:56:47 -0700707 Mutex::Autolock autoLock(mLock);
James Dongc32cd792010-04-26 17:48:26 -0700708 if (!mStarted) {
James Dongf60cafe2010-06-19 09:04:18 -0700709 releaseOneRecordingFrame(data);
James Dong13aec892010-04-21 16:14:15 -0700710 ++mNumFramesReceived;
711 ++mNumFramesDropped;
James Dongc32cd792010-04-26 17:48:26 -0700712 return;
713 }
Andreas Huber20111aa2009-07-14 16:56:47 -0700714
James Dongf60cafe2010-06-19 09:04:18 -0700715 if (mNumFramesReceived > 0 &&
716 timestampUs - mLastFrameTimestampUs > mGlitchDurationThresholdUs) {
717 if (mNumGlitches % 10 == 0) { // Don't spam the log
718 LOGW("Long delay detected in video recording");
719 }
720 ++mNumGlitches;
721 }
722
Nipun Kwatra65e7e6f2010-07-12 09:17:14 -0700723 // May need to skip frame or modify timestamp. Currently implemented
724 // by the subclass CameraSourceTimeLapse.
725 if(skipCurrentFrame(timestampUs)) {
726 releaseOneRecordingFrame(data);
727 return;
Nipun Kwatrafc20aab2010-06-30 18:51:31 -0700728 }
729
James Dong365a9632010-06-04 13:59:27 -0700730 mLastFrameTimestampUs = timestampUs;
James Dong13aec892010-04-21 16:14:15 -0700731 if (mNumFramesReceived == 0) {
James Dongc32cd792010-04-26 17:48:26 -0700732 mFirstFrameTimeUs = timestampUs;
James Dongf60cafe2010-06-19 09:04:18 -0700733 // Initial delay
734 if (mStartTimeUs > 0) {
735 if (timestampUs < mStartTimeUs) {
736 // Frame was captured before recording was started
737 // Drop it without updating the statistical data.
738 releaseOneRecordingFrame(data);
739 return;
740 }
741 mStartTimeUs = timestampUs - mStartTimeUs;
742 }
Andreas Huberbe5c74f2009-10-13 17:08:31 -0700743 }
James Dong13aec892010-04-21 16:14:15 -0700744 ++mNumFramesReceived;
Andreas Huberbe5c74f2009-10-13 17:08:31 -0700745
James Dong7278cf32010-05-27 16:05:58 -0700746 mFramesReceived.push_back(data);
James Dongf60cafe2010-06-19 09:04:18 -0700747 int64_t timeUs = mStartTimeUs + (timestampUs - mFirstFrameTimeUs);
748 mFrameTimes.push_back(timeUs);
749 LOGV("initial delay: %lld, current time stamp: %lld",
750 mStartTimeUs, timeUs);
Andreas Huber20111aa2009-07-14 16:56:47 -0700751 mFrameAvailableCondition.signal();
752}
753
James Dong5c952312010-10-18 21:42:27 -0700754size_t CameraSource::getNumberOfVideoBuffers() const {
755 LOGV("getNumberOfVideoBuffers");
756 size_t nBuffers = 0;
757 int64_t token = IPCThreadState::self()->clearCallingIdentity();
758 if (mInitCheck == OK && mCamera != 0) {
759 nBuffers = mCamera->getNumberOfVideoBuffers();
760 }
761 IPCThreadState::self()->restoreCallingIdentity(token);
762 return nBuffers;
763}
764
765sp<IMemory> CameraSource::getVideoBuffer(size_t index) const {
766 LOGV("getVideoBuffer: %d", index);
767 sp<IMemory> buffer = 0;
768 int64_t token = IPCThreadState::self()->clearCallingIdentity();
769 if (mInitCheck == OK && mCamera != 0) {
770 buffer = mCamera->getVideoBuffer(index);
771 }
772 IPCThreadState::self()->restoreCallingIdentity(token);
773 return buffer;
774}
775
776bool CameraSource::isMetaDataStoredInVideoBuffers() const {
777 LOGV("isMetaDataStoredInVideoBuffers");
778 return mIsMetaDataStoredInVideoBuffers;
779}
780
Andreas Huber20111aa2009-07-14 16:56:47 -0700781} // namespace android