1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #ifndef MEDIA_MOJO_SERVICES_MOJO_RENDERER_IMPL_H_
6 #define MEDIA_MOJO_SERVICES_MOJO_RENDERER_IMPL_H_
8 #include "base/macros.h"
9 #include "base/memory/weak_ptr.h"
10 #include "media/base/renderer.h"
11 #include "media/mojo/interfaces/media_renderer.mojom.h"
14 class SingleThreadTaskRunner;
18 class ServiceProvider;
22 class DemuxerStreamProvider;
24 // A media::Renderer that proxies to a mojo::MediaRenderer. That
25 // mojo::MediaRenderer proxies back to the MojoRendererImpl via the
26 // mojo::MediaRendererClient interface.
28 // MojoRendererImpl implements media::Renderer for use as either an audio
31 // TODO(tim): Only audio is currently supported. http://crbug.com/410451.
32 class MojoRendererImpl : public Renderer, public mojo::MediaRendererClient {
34 // |task_runner| is the TaskRunner on which all methods are invoked.
35 // |audio_renderer_provider| is a ServiceProvider from a connected
36 // Application that is hosting a mojo::MediaRenderer.
38 const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
39 mojo::ServiceProvider* audio_renderer_provider);
40 ~MojoRendererImpl() override;
42 // Renderer implementation.
43 void Initialize(DemuxerStreamProvider* demuxer_stream_provider,
44 const base::Closure& init_cb,
45 const StatisticsCB& statistics_cb,
46 const base::Closure& ended_cb,
47 const PipelineStatusCB& error_cb,
48 const BufferingStateCB& buffering_state_cb) override;
49 void Flush(const base::Closure& flush_cb) override;
50 void StartPlayingFrom(base::TimeDelta time) override;
51 void SetPlaybackRate(float playback_rate) override;
52 void SetVolume(float volume) override;
53 base::TimeDelta GetMediaTime() override;
54 bool HasAudio() override;
55 bool HasVideo() override;
56 void SetCdm(MediaKeys* cdm) override;
58 // mojo::MediaRendererClient implementation.
59 void OnTimeUpdate(int64_t time_usec, int64_t max_time_usec) override;
60 void OnBufferingStateChange(mojo::BufferingState state) override;
61 void OnEnded() override;
62 void OnError() override;
65 // Called when |remote_audio_renderer_| has finished initializing.
68 // Task runner used to execute pipeline tasks.
69 scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
71 DemuxerStreamProvider* demuxer_stream_provider_;
72 mojo::MediaRendererPtr remote_audio_renderer_;
74 // Callbacks passed to Initialize() that we forward messages from
75 // |remote_audio_renderer_| through.
76 base::Closure init_cb_;
77 base::Closure ended_cb_;
78 PipelineStatusCB error_cb_;
79 BufferingStateCB buffering_state_cb_;
81 // Lock used to serialize access for the following data members.
82 mutable base::Lock lock_;
84 base::TimeDelta time_;
85 // TODO(xhwang): It seems we don't need |max_time_| now. Drop it!
86 base::TimeDelta max_time_;
88 base::WeakPtrFactory<MojoRendererImpl> weak_factory_;
90 DISALLOW_COPY_AND_ASSIGN(MojoRendererImpl);
95 #endif // MEDIA_MOJO_SERVICES_MOJO_RENDERER_IMPL_H_