Mojify demuxers and allow running {Chunk/FFmpeg}Demuxer in a Utility Process

media/mojo/services/mojo_demuxer_service.h

Index: media/mojo/services/mojo_demuxer_service.h
diff --git a/media/mojo/services/mojo_demuxer_service.h b/media/mojo/services/mojo_demuxer_service.h
new file mode 100644
index 0000000000000000000000000000000000000000..2bb6ca795b3664d3c29073b5457088c633c86c4a
--- /dev/null
+++ b/media/mojo/services/mojo_demuxer_service.h
@@ -0,0 +1,94 @@
+// Copyright 2017 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.
+
+#ifndef MEDIA_MOJO_SERVICES_MOJO_DEMUXER_SERVICE_H_
+#define MEDIA_MOJO_SERVICES_MOJO_DEMUXER_SERVICE_H_
+
+#include "media/base/demuxer.h"
+#include "media/mojo/interfaces/data_source.mojom.h"
+#include "media/mojo/interfaces/demuxer.mojom.h"
+#include "media/mojo/services/media_mojo_export.h"
+#include "media/mojo/services/mojo_demuxer_service_context.h"
+
+namespace media {
+
+class DataSource;
+class DemuxerFactory;
+class MediaTracks;
+class SourceBuffer;
+
+// A mojom::Demuxer implementation backed by a
+// media::Demuxer.
+class MEDIA_MOJO_EXPORT MojoDemuxerService
+    : public DemuxerHost,
+      NON_EXPORTED_BASE(public mojom::Demuxer) {
+ public:
+  MojoDemuxerService(base::WeakPtr<MojoDemuxerServiceContext> context,
+                     DemuxerFactory* demuxer_factory);
+
+  ~MojoDemuxerService() final;
+
+  media::Demuxer* GetDemuxerSourceBuffer(
+      media::SourceBuffer** source_buffer_out);
+  media::Demuxer* GetDemuxer(const PipelineStatusCB& demuxer_init_cb);
+
+  void OnEncryptedMediaInitData(EmeInitDataType init_data_type,
+                                const std::vector<uint8_t>& init_data);
+  void OnMediaTracksUpdated(std::unique_ptr<MediaTracks> tracks);
+
+  // DemuxHost implementation.
+  void OnBufferedTimeRangesChanged(const Ranges<base::TimeDelta>& ranges) final;
+  void SetDuration(base::TimeDelta duration) final;
+  void OnDemuxerError(PipelineStatus error) final;
+  void AddTextStream(DemuxerStream* text_stream,
+                     const TextTrackConfig& config) final;
+  void RemoveTextStream(DemuxerStream* text_stream) final;
+
+  // mojom::Demuxer implementation.
+  void Initialize(mojom::DemuxerClientAssociatedPtrInfo client,
+                  int32_t demuxer_id,
+                  media::Demuxer::LoadType load_type,
+                  mojom::DataSourcePtr mojo_data_source,
+                  const InitializeCallback& callback) final;
+  void StartWaitingForSeek(base::TimeDelta seek_time) final;
+  void CancelPendingSeek(base::TimeDelta seek_time) final;
+  void Seek(base::TimeDelta time, const SeekCallback& callback) final;
+  void Stop() final;
+  void AbortPendingReads() final;
+  void GetStartTime(const GetStartTimeCallback& callback) final;
+  void GetTimelineOffset(const GetTimelineOffsetCallback& callback) final;
+  void GetMemoryUsage(const GetMemoryUsageCallback& callback) final;
+  void OnEnabledAudioTracksChanged(const std::vector<MediaTrack::Id>& track_ids,
+                                   base::TimeDelta current_time) final;
+  void OnSelectedVideoTrackChanged(const std::vector<MediaTrack::Id>& track_ids,
+                                   base::TimeDelta current_time) final;
+
+ private:
+  void OnDataSourceReady(const InitializeCallback& callback);
+
+  void OnDemuxerInitialized(PipelineStatus status);
+
+  void OnSeek(const SeekCallback& callback, PipelineStatus status);
+
+  scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
+
+  base::WeakPtr<MojoDemuxerServiceContext> context_;
+  DemuxerFactory* demuxer_factory_;
+
+  mojom::DemuxerClientAssociatedPtr client_;
+
+  std::unique_ptr<media::DataSource> data_source_;
+
+  int32_t demuxer_id_;
+  std::unique_ptr<media::Demuxer> demuxer_;
+  media::SourceBuffer* source_buffer_;
+
+  PipelineStatusCB demuxer_init_cb_;
+
+  base::WeakPtrFactory<MojoDemuxerService> weak_factory_;
+};
+
+}  // namespace media
+
+#endif  // MEDIA_MOJO_SERVICES_MOJO_DEMUXER_SERVICE_H_