media/base/fake_text_track_stream.cc

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "media/base/fake_text_track_stream.h"
   6
   7 #include "base/bind.h"
   8 #include "base/callback_helpers.h"
   9 #include "base/single_thread_task_runner.h"
  10 #include "base/thread_task_runner_handle.h"
  11 #include "media/base/decoder_buffer.h"
  12 #include "media/filters/webvtt_util.h"
  13
  14 namespace media {
  15
  16 FakeTextTrackStream::FakeTextTrackStream()
  17     : task_runner_(base::ThreadTaskRunnerHandle::Get()),
  18       stopping_(false) {
  19 }
  20
  21 FakeTextTrackStream::~FakeTextTrackStream() {
  22   DCHECK(read_cb_.is_null());
  23 }
  24
  25 void FakeTextTrackStream::Read(const ReadCB& read_cb) {
  26   DCHECK(!read_cb.is_null());
  27   DCHECK(read_cb_.is_null());
  28   OnRead();
  29   read_cb_ = read_cb;
  30
  31   if (stopping_) {
  32     task_runner_->PostTask(FROM_HERE, base::Bind(
  33         &FakeTextTrackStream::AbortPendingRead, base::Unretained(this)));
  34   }
  35 }
  36
  37 DemuxerStream::Type FakeTextTrackStream::type() const {
  38   return DemuxerStream::TEXT;
  39 }
  40
  41 bool FakeTextTrackStream::SupportsConfigChanges() { return false; }
  42
  43 VideoRotation FakeTextTrackStream::video_rotation() {
  44   return VIDEO_ROTATION_0;
  45 }
  46
  47 void FakeTextTrackStream::SatisfyPendingRead(
  48     const base::TimeDelta& start,
  49     const base::TimeDelta& duration,
  50     const std::string& id,
  51     const std::string& content,
  52     const std::string& settings) {
  53   DCHECK(!read_cb_.is_null());
  54
  55   const uint8* const data_buf = reinterpret_cast<const uint8*>(content.data());
  56   const int data_len = static_cast<int>(content.size());
  57
  58   std::vector<uint8> side_data;
  59   MakeSideData(id.begin(), id.end(),
  60                 settings.begin(), settings.end(),
  61                 &side_data);
  62
  63   const uint8* const sd_buf = &side_data[0];
  64   const int sd_len = static_cast<int>(side_data.size());
  65
  66   scoped_refptr<DecoderBuffer> buffer;
  67   buffer = DecoderBuffer::CopyFrom(data_buf, data_len, sd_buf, sd_len);
  68
  69   buffer->set_timestamp(start);
  70   buffer->set_duration(duration);
  71
  72   // Assume all fake text buffers are keyframes.
  73   buffer->set_is_key_frame(true);
  74
  75   base::ResetAndReturn(&read_cb_).Run(kOk, buffer);
  76 }
  77
  78 void FakeTextTrackStream::AbortPendingRead() {
  79   DCHECK(!read_cb_.is_null());
  80   base::ResetAndReturn(&read_cb_).Run(kAborted, NULL);
  81 }
  82
  83 void FakeTextTrackStream::SendEosNotification() {
  84   DCHECK(!read_cb_.is_null());
  85   base::ResetAndReturn(&read_cb_).Run(kOk, DecoderBuffer::CreateEOSBuffer());
  86 }
  87
  88 void FakeTextTrackStream::Stop() {
  89   stopping_ = true;
  90   if (!read_cb_.is_null())
  91     AbortPendingRead();
  92 }
  93
  94 }  // namespace media