| 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));
|
|
|