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

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

Issue 1945903006: Motown: Move responsibility for binding to MediaFactoryService::Product (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: Change per feedback - rename Abort to UnbindAndReleaseFromOwner Created 4 years, 7 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_demux_impl.cc
diff --git a/services/media/factory_service/media_demux_impl.cc b/services/media/factory_service/media_demux_impl.cc
index e53ab44ae1baa4ac90e570d544485d28eb968589..37478e46172b56c1769d0e0d26a71358f8d620e0 100644
--- a/services/media/factory_service/media_demux_impl.cc
+++ b/services/media/factory_service/media_demux_impl.cc
@@ -26,7 +26,7 @@ std::shared_ptr<MediaDemuxImpl> MediaDemuxImpl::Create(
MediaDemuxImpl::MediaDemuxImpl(InterfaceHandle<SeekingReader> reader,
InterfaceRequest<MediaDemux> request,
MediaFactoryService* owner)
- : MediaFactoryService::Product(owner), binding_(this, request.Pass()) {
+ : MediaFactoryService::Product<MediaDemux>(this, request.Pass(), owner) {
DCHECK(reader);
task_runner_ = base::MessageLoop::current()->task_runner();
@@ -38,9 +38,6 @@ MediaDemuxImpl::MediaDemuxImpl(InterfaceHandle<SeekingReader> reader,
: nullptr);
});
- // Go away when the client is no longer connected.
- binding_.set_connection_error_handler([this]() { ReleaseFromOwner(); });
-
std::shared_ptr<Reader> reader_ptr = MojoReader::Create(reader.Pass());
if (!reader_ptr) {
NOTREACHED() << "couldn't create reader";
@@ -101,7 +98,7 @@ void MediaDemuxImpl::Describe(const DescribeCallback& callback) {
void MediaDemuxImpl::GetProducer(uint32_t stream_index,
InterfaceRequest<MediaProducer> producer) {
- DCHECK(init_complete_.occurred());
+ RCHECK(init_complete_.occurred());
if (stream_index >= streams_.size()) {
return;
@@ -116,7 +113,7 @@ void MediaDemuxImpl::GetMetadata(uint64_t version_last_seen,
}
void MediaDemuxImpl::Prime(const PrimeCallback& callback) {
- DCHECK(init_complete_.occurred());
+ RCHECK(init_complete_.occurred());
std::shared_ptr<CallbackJoiner> callback_joiner = CallbackJoiner::Create();
@@ -128,7 +125,7 @@ void MediaDemuxImpl::Prime(const PrimeCallback& callback) {
}
void MediaDemuxImpl::Flush(const FlushCallback& callback) {
- DCHECK(init_complete_.occurred());
+ RCHECK(init_complete_.occurred());
graph_.FlushAllOutputs(demux_part_);
@@ -142,7 +139,7 @@ void MediaDemuxImpl::Flush(const FlushCallback& callback) {
}
void MediaDemuxImpl::Seek(int64_t position, const SeekCallback& callback) {
- DCHECK(init_complete_.occurred());
+ RCHECK(init_complete_.occurred());
demux_->Seek(position, [this, callback]() {
task_runner_->PostTask(FROM_HERE, base::Bind(&RunSeekCallback, callback));
« no previous file with comments | « services/media/factory_service/media_demux_impl.h ('k') | services/media/factory_service/media_player_impl.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698