Index: media/mojo/services/demuxer_stream_provider_shim.cc |
diff --git a/media/mojo/services/demuxer_stream_provider_shim.cc b/media/mojo/services/demuxer_stream_provider_shim.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..6620e6ae665429e9b0ddd0c3d8e2166d9bc16a08 |
--- /dev/null |
+++ b/media/mojo/services/demuxer_stream_provider_shim.cc |
@@ -0,0 +1,62 @@ |
+// Copyright 2014 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+#include "media/mojo/services/demuxer_stream_provider_shim.h" |
+ |
+#include "base/bind.h" |
+#include "base/bind_helpers.h" |
+#include "base/callback_helpers.h" |
+ |
+namespace media { |
+ |
+DemuxerStreamProviderShim::DemuxerStreamProviderShim( |
+ mojo::DemuxerStreamPtr audio, |
+ mojo::DemuxerStreamPtr video, |
+ const base::Closure& demuxer_ready_cb) |
+ : demuxer_ready_cb_(demuxer_ready_cb), |
+ streams_ready_(0), |
+ weak_factory_(this) { |
+ DCHECK(audio || video); |
+ DCHECK(!demuxer_ready_cb_.is_null()); |
+ |
+ if (audio) { |
+ streams_.push_back(new MojoDemuxerStreamAdapter( |
+ audio.Pass(), |
+ base::Bind(&DemuxerStreamProviderShim::OnStreamReady, |
+ weak_factory_.GetWeakPtr()))); |
+ } |
+ |
+ if (video) { |
+ streams_.push_back(new MojoDemuxerStreamAdapter( |
+ video.Pass(), |
+ base::Bind(&DemuxerStreamProviderShim::OnStreamReady, |
+ weak_factory_.GetWeakPtr()))); |
+ } |
+} |
+ |
+DemuxerStreamProviderShim::~DemuxerStreamProviderShim() { |
+} |
+ |
+DemuxerStream* DemuxerStreamProviderShim::GetStream(DemuxerStream::Type type) { |
+ DCHECK(demuxer_ready_cb_.is_null()); |
+ for (auto* stream : streams_) { |
+ if (stream->type() == type) |
+ return stream; |
+ } |
+ |
+ return nullptr; |
+} |
+ |
+DemuxerStreamProvider::Liveness DemuxerStreamProviderShim::GetLiveness() const { |
+ // TODO(dalecurtis): This should be removed once liveness lives elsewhere, see |
+ // http://crbug.com/420025 |
+ return DemuxerStreamProvider::LIVENESS_UNKNOWN; |
+} |
+ |
+void DemuxerStreamProviderShim::OnStreamReady() { |
+ if (++streams_ready_ == streams_.size()) |
+ base::ResetAndReturn(&demuxer_ready_cb_).Run(); |
+} |
+ |
+} // namespace media |