summaryrefslogtreecommitdiff
path: root/libavcodec/libstagefright.cpp
diff options
context:
space:
mode:
authorMichael Niedermayer <michaelni@gmx.at>2011-10-13 17:54:22 +0200
committerMichael Niedermayer <michaelni@gmx.at>2011-10-13 18:04:02 +0200
commit072a62b50ab4e54ee55585dc06a8e313d713b39f (patch)
tree5c0783e7bc4d63936a17d12989edd1e2daf341c3 /libavcodec/libstagefright.cpp
parent40963ea9e9f8fbc178673c963f1d9662f3f20cfb (diff)
parente82cbb69a768205d0bea2fc5b97377dff35d5e72 (diff)
Merge remote-tracking branch 'hexene/stagefright'
* hexene/stagefright: tools/build_libstagefright: fetch android system headers and libraries libstagefright: reindent after previous commit Merged-by: Michael Niedermayer <michaelni@gmx.at>
Diffstat (limited to 'libavcodec/libstagefright.cpp')
-rw-r--r--libavcodec/libstagefright.cpp68
1 files changed, 34 insertions, 34 deletions
diff --git a/libavcodec/libstagefright.cpp b/libavcodec/libstagefright.cpp
index caaf6f4590..e29a377311 100644
--- a/libavcodec/libstagefright.cpp
+++ b/libavcodec/libstagefright.cpp
@@ -445,49 +445,49 @@ static av_cold int Stagefright_close(AVCodecContext *avctx)
Frame *frame;
if (s->thread_started) {
- if (!s->thread_exited) {
- s->stop_decode = 1;
+ if (!s->thread_exited) {
+ s->stop_decode = 1;
- // Make sure decode_thread() doesn't get stuck
- pthread_mutex_lock(&s->out_mutex);
- while (!s->out_queue->empty()) {
- frame = *s->out_queue->begin();
- s->out_queue->erase(s->out_queue->begin());
- if (frame->size)
- frame->mbuffer->release();
- av_freep(&frame);
- }
- pthread_mutex_unlock(&s->out_mutex);
+ // Make sure decode_thread() doesn't get stuck
+ pthread_mutex_lock(&s->out_mutex);
+ while (!s->out_queue->empty()) {
+ frame = *s->out_queue->begin();
+ s->out_queue->erase(s->out_queue->begin());
+ if (frame->size)
+ frame->mbuffer->release();
+ av_freep(&frame);
+ }
+ pthread_mutex_unlock(&s->out_mutex);
+
+ // Feed a dummy frame prior to signalling EOF.
+ // This is required to terminate the decoder(OMX.SEC)
+ // when only one frame is read during stream info detection.
+ if (s->dummy_buf && (frame = (Frame*)av_mallocz(sizeof(Frame)))) {
+ frame->status = OK;
+ frame->size = s->dummy_bufsize;
+ frame->key = 1;
+ frame->buffer = s->dummy_buf;
+ pthread_mutex_lock(&s->in_mutex);
+ s->in_queue->push_back(frame);
+ pthread_cond_signal(&s->condition);
+ pthread_mutex_unlock(&s->in_mutex);
+ s->dummy_buf = NULL;
+ }
- // Feed a dummy frame prior to signalling EOF.
- // This is required to terminate the decoder(OMX.SEC)
- // when only one frame is read during stream info detection.
- if (s->dummy_buf && (frame = (Frame*)av_mallocz(sizeof(Frame)))) {
- frame->status = OK;
- frame->size = s->dummy_bufsize;
- frame->key = 1;
- frame->buffer = s->dummy_buf;
pthread_mutex_lock(&s->in_mutex);
- s->in_queue->push_back(frame);
+ s->end_frame->status = ERROR_END_OF_STREAM;
+ s->in_queue->push_back(s->end_frame);
pthread_cond_signal(&s->condition);
pthread_mutex_unlock(&s->in_mutex);
- s->dummy_buf = NULL;
+ s->end_frame = NULL;
}
- pthread_mutex_lock(&s->in_mutex);
- s->end_frame->status = ERROR_END_OF_STREAM;
- s->in_queue->push_back(s->end_frame);
- pthread_cond_signal(&s->condition);
- pthread_mutex_unlock(&s->in_mutex);
- s->end_frame = NULL;
- }
-
- pthread_join(s->decode_thread_id, NULL);
+ pthread_join(s->decode_thread_id, NULL);
- if (s->ret_frame.data[0])
- avctx->release_buffer(avctx, &s->ret_frame);
+ if (s->ret_frame.data[0])
+ avctx->release_buffer(avctx, &s->ret_frame);
- s->thread_started = false;
+ s->thread_started = false;
}
while (!s->in_queue->empty()) {