OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/bind.h" | 5 #include "base/bind.h" |
6 #include "base/callback.h" | 6 #include "base/callback.h" |
7 #include "base/threading/platform_thread.h" | 7 #include "base/threading/platform_thread.h" |
8 #include "media/base/buffers.h" | 8 #include "media/base/buffers.h" |
9 #include "media/base/filter_host.h" | 9 #include "media/base/filter_host.h" |
10 #include "media/base/limits.h" | 10 #include "media/base/limits.h" |
(...skipping 359 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
370 // Discard frames until we reach our desired seek timestamp. | 370 // Discard frames until we reach our desired seek timestamp. |
371 if (state_ == kSeeking && !frame->IsEndOfStream() && | 371 if (state_ == kSeeking && !frame->IsEndOfStream() && |
372 (frame->GetTimestamp() + frame->GetDuration()) <= seek_timestamp_) { | 372 (frame->GetTimestamp() + frame->GetDuration()) <= seek_timestamp_) { |
373 AttemptRead_Locked(); | 373 AttemptRead_Locked(); |
374 return; | 374 return; |
375 } | 375 } |
376 | 376 |
377 // This one's a keeper! Place it in the ready queue. | 377 // This one's a keeper! Place it in the ready queue. |
378 frames_queue_ready_.push_back(frame); | 378 frames_queue_ready_.push_back(frame); |
379 DCHECK_LE(frames_queue_ready_.size(), | 379 DCHECK_LE(frames_queue_ready_.size(), |
380 static_cast<size_t>(Limits::kMaxVideoFrames)); | 380 static_cast<size_t>(limits::kMaxVideoFrames)); |
381 frame_available_.Signal(); | 381 frame_available_.Signal(); |
382 | 382 |
383 PipelineStatistics statistics; | 383 PipelineStatistics statistics; |
384 statistics.video_frames_decoded = 1; | 384 statistics.video_frames_decoded = 1; |
385 statistics_callback_.Run(statistics); | 385 statistics_callback_.Run(statistics); |
386 | 386 |
387 // Always request more decoded video if we have capacity. This serves two | 387 // Always request more decoded video if we have capacity. This serves two |
388 // purposes: | 388 // purposes: |
389 // 1) Prerolling while paused | 389 // 1) Prerolling while paused |
390 // 2) Keeps decoding going if video rendering thread starts falling behind | 390 // 2) Keeps decoding going if video rendering thread starts falling behind |
391 if (frames_queue_ready_.size() < Limits::kMaxVideoFrames && | 391 if (frames_queue_ready_.size() < limits::kMaxVideoFrames && |
392 !frame->IsEndOfStream()) { | 392 !frame->IsEndOfStream()) { |
393 AttemptRead_Locked(); | 393 AttemptRead_Locked(); |
394 return; | 394 return; |
395 } | 395 } |
396 | 396 |
397 // If we're at capacity or end of stream while seeking we need to transition | 397 // If we're at capacity or end of stream while seeking we need to transition |
398 // to prerolled. | 398 // to prerolled. |
399 if (state_ == kSeeking) { | 399 if (state_ == kSeeking) { |
400 state_ = kPrerolled; | 400 state_ = kPrerolled; |
401 | 401 |
(...skipping 11 matching lines...) Expand all Loading... |
413 | 413 |
414 base::AutoUnlock ul(lock_); | 414 base::AutoUnlock ul(lock_); |
415 OnFrameAvailable(); | 415 OnFrameAvailable(); |
416 } | 416 } |
417 } | 417 } |
418 | 418 |
419 void VideoRendererBase::AttemptRead_Locked() { | 419 void VideoRendererBase::AttemptRead_Locked() { |
420 lock_.AssertAcquired(); | 420 lock_.AssertAcquired(); |
421 DCHECK_NE(kEnded, state_); | 421 DCHECK_NE(kEnded, state_); |
422 | 422 |
423 if (pending_read_ || frames_queue_ready_.size() == Limits::kMaxVideoFrames) { | 423 if (pending_read_ || frames_queue_ready_.size() == limits::kMaxVideoFrames) { |
424 return; | 424 return; |
425 } | 425 } |
426 | 426 |
427 pending_read_ = true; | 427 pending_read_ = true; |
428 decoder_->Read(read_cb_); | 428 decoder_->Read(read_cb_); |
429 } | 429 } |
430 | 430 |
431 void VideoRendererBase::AttemptFlush_Locked() { | 431 void VideoRendererBase::AttemptFlush_Locked() { |
432 lock_.AssertAcquired(); | 432 lock_.AssertAcquired(); |
433 DCHECK_EQ(kFlushing, state_); | 433 DCHECK_EQ(kFlushing, state_); |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
476 void VideoRendererBase::DoStopOrError_Locked() { | 476 void VideoRendererBase::DoStopOrError_Locked() { |
477 DCHECK(!pending_paint_); | 477 DCHECK(!pending_paint_); |
478 DCHECK(!pending_paint_with_last_available_); | 478 DCHECK(!pending_paint_with_last_available_); |
479 lock_.AssertAcquired(); | 479 lock_.AssertAcquired(); |
480 current_frame_ = NULL; | 480 current_frame_ = NULL; |
481 last_available_frame_ = NULL; | 481 last_available_frame_ = NULL; |
482 DCHECK(!pending_read_); | 482 DCHECK(!pending_read_); |
483 } | 483 } |
484 | 484 |
485 } // namespace media | 485 } // namespace media |
OLD | NEW |