Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1183)

Unified Diff: services/media/factory_service/media_source_impl.cc

Issue 2097953002: Motown: Rename MediaProducer/Consumer to MediaPacketProducer/Consumer (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: Fixed #ifndef guards Created 4 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: services/media/factory_service/media_source_impl.cc
diff --git a/services/media/factory_service/media_source_impl.cc b/services/media/factory_service/media_source_impl.cc
index c2e38db7a5edd131ba8b9694c92ebd682e8d54e4..57d4fd5994ffed71a8f639c3c7b8958881107bd3 100644
--- a/services/media/factory_service/media_source_impl.cc
+++ b/services/media/factory_service/media_source_impl.cc
@@ -102,27 +102,16 @@ void MediaSourceImpl::GetStreams(const GetStreamsCallback& callback) {
});
}
-void MediaSourceImpl::GetProducer(uint32_t stream_index,
- InterfaceRequest<MediaProducer> producer) {
- RCHECK(init_complete_.occurred());
-
- if (stream_index >= streams_.size()) {
- return;
- }
-
- streams_[stream_index]->GetProducer(producer.Pass());
-}
-
-void MediaSourceImpl::GetPullModeProducer(
+void MediaSourceImpl::GetPacketProducer(
uint32_t stream_index,
- InterfaceRequest<MediaPullModeProducer> producer) {
+ InterfaceRequest<MediaPacketProducer> producer) {
RCHECK(init_complete_.occurred());
if (stream_index >= streams_.size()) {
return;
}
- streams_[stream_index]->GetPullModeProducer(producer.Pass());
+ streams_[stream_index]->GetPacketProducer(producer.Pass());
}
void MediaSourceImpl::GetStatus(uint64_t version_last_seen,
@@ -215,45 +204,25 @@ MediaTypePtr MediaSourceImpl::Stream::original_media_type() const {
return MediaType::From(original_stream_type_);
}
-void MediaSourceImpl::Stream::GetProducer(
- InterfaceRequest<MediaProducer> producer) {
- if (pull_mode_producer_) {
- // Can't have both push mode and pull mode producers.
- return;
- }
-
+void MediaSourceImpl::Stream::GetPacketProducer(
+ InterfaceRequest<MediaPacketProducer> producer) {
if (!producer_) {
- producer_ = MojoProducer::Create();
+ producer_ = MojoPacketProducer::Create();
graph_->ConnectOutputToPart(output_, graph_->Add(producer_));
}
producer_->AddBinding(producer.Pass());
}
-void MediaSourceImpl::Stream::GetPullModeProducer(
- InterfaceRequest<MediaPullModeProducer> producer) {
- if (producer_) {
- // Can't have both push mode and pull mode producers.
- return;
- }
-
- if (!pull_mode_producer_) {
- pull_mode_producer_ = MojoPullModeProducer::Create();
- graph_->ConnectOutputToPart(output_, graph_->Add(pull_mode_producer_));
- }
-
- pull_mode_producer_->AddBinding(producer.Pass());
-}
-
void MediaSourceImpl::Stream::EnsureSink() {
- if (producer_ == nullptr && pull_mode_producer_ == nullptr) {
+ if (producer_ == nullptr) {
null_sink_ = NullSink::Create();
graph_->ConnectOutputToPart(output_, graph_->Add(null_sink_));
}
}
void MediaSourceImpl::Stream::PrimeConnection(
- const MojoProducer::PrimeConnectionCallback callback) {
+ const MojoPacketProducer::PrimeConnectionCallback callback) {
if (producer_ != nullptr) {
producer_->PrimeConnection(callback);
} else {
@@ -262,7 +231,7 @@ void MediaSourceImpl::Stream::PrimeConnection(
}
void MediaSourceImpl::Stream::FlushConnection(
- const MojoProducer::FlushConnectionCallback callback) {
+ const MojoPacketProducer::FlushConnectionCallback callback) {
if (producer_ != nullptr) {
producer_->FlushConnection(callback);
} else {
« no previous file with comments | « services/media/factory_service/media_source_impl.h ('k') | services/media/factory_service/media_timeline_controller_impl.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698