OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "base/logging.h" | 5 #include "base/logging.h" |
6 #include "mojo/public/cpp/application/connect.h" | 6 #include "mojo/public/cpp/application/connect.h" |
7 #include "services/media/factory_service/media_player_impl.h" | 7 #include "services/media/factory_service/media_player_impl.h" |
8 #include "services/media/framework/parts/reader.h" | 8 #include "services/media/framework/parts/reader.h" |
9 #include "services/media/framework/util/callback_joiner.h" | 9 #include "services/media/framework/util/callback_joiner.h" |
10 | 10 |
11 namespace mojo { | 11 namespace mojo { |
12 namespace media { | 12 namespace media { |
13 | 13 |
14 // static | 14 // static |
15 std::shared_ptr<MediaPlayerImpl> MediaPlayerImpl::Create( | 15 std::shared_ptr<MediaPlayerImpl> MediaPlayerImpl::Create( |
16 InterfaceHandle<SeekingReader> reader, | 16 InterfaceHandle<SeekingReader> reader, |
17 InterfaceRequest<MediaPlayer> request, | 17 InterfaceRequest<MediaPlayer> request, |
18 MediaFactoryService* owner) { | 18 MediaFactoryService* owner) { |
19 return std::shared_ptr<MediaPlayerImpl>( | 19 return std::shared_ptr<MediaPlayerImpl>( |
20 new MediaPlayerImpl(reader.Pass(), request.Pass(), owner)); | 20 new MediaPlayerImpl(reader.Pass(), request.Pass(), owner)); |
21 } | 21 } |
22 | 22 |
23 MediaPlayerImpl::MediaPlayerImpl(InterfaceHandle<SeekingReader> reader, | 23 MediaPlayerImpl::MediaPlayerImpl(InterfaceHandle<SeekingReader> reader, |
24 InterfaceRequest<MediaPlayer> request, | 24 InterfaceRequest<MediaPlayer> request, |
25 MediaFactoryService* owner) | 25 MediaFactoryService* owner) |
26 : MediaFactoryService::Product(owner), binding_(this, request.Pass()) { | 26 : MediaFactoryService::Product<MediaPlayer>(this, request.Pass(), owner) { |
27 DCHECK(reader); | 27 DCHECK(reader); |
28 | 28 |
29 status_publisher_.SetCallbackRunner( | 29 status_publisher_.SetCallbackRunner( |
30 [this](const GetStatusCallback& callback, uint64_t version) { | 30 [this](const GetStatusCallback& callback, uint64_t version) { |
31 MediaPlayerStatusPtr status = MediaPlayerStatus::New(); | 31 MediaPlayerStatusPtr status = MediaPlayerStatus::New(); |
32 status->state = reported_media_state_; | 32 status->state = reported_media_state_; |
33 status->timeline_transform = transform_.Clone(); | 33 status->timeline_transform = transform_.Clone(); |
34 status->metadata = metadata_.Clone(); | 34 status->metadata = metadata_.Clone(); |
35 callback.Run(version, status.Pass()); | 35 callback.Run(version, status.Pass()); |
36 }); | 36 }); |
37 | 37 |
38 state_ = State::kWaiting; | 38 state_ = State::kWaiting; |
39 | 39 |
40 // Go away when the client is no longer connected. | |
41 binding_.set_connection_error_handler([this]() { ReleaseFromOwner(); }); | |
42 | |
43 ConnectToService(app()->shell(), "mojo:media_factory", GetProxy(&factory_)); | 40 ConnectToService(app()->shell(), "mojo:media_factory", GetProxy(&factory_)); |
44 | 41 |
45 factory_->CreateDemux(reader.Pass(), GetProxy(&demux_)); | 42 factory_->CreateDemux(reader.Pass(), GetProxy(&demux_)); |
46 | 43 |
47 HandleDemuxMetadataUpdates(); | 44 HandleDemuxMetadataUpdates(); |
48 | 45 |
49 demux_->Describe([this](mojo::Array<MediaTypePtr> stream_types) { | 46 demux_->Describe([this](mojo::Array<MediaTypePtr> stream_types) { |
50 // Populate streams_ and enable the streams we want. | 47 // Populate streams_ and enable the streams we want. |
51 std::shared_ptr<CallbackJoiner> callback_joiner = CallbackJoiner::Create(); | 48 std::shared_ptr<CallbackJoiner> callback_joiner = CallbackJoiner::Create(); |
52 | 49 |
(...skipping 305 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
358 }); | 355 }); |
359 } | 356 } |
360 | 357 |
361 MediaPlayerImpl::Stream::Stream(size_t index, MediaTypePtr media_type) | 358 MediaPlayerImpl::Stream::Stream(size_t index, MediaTypePtr media_type) |
362 : index_(index), media_type_(media_type.Pass()) {} | 359 : index_(index), media_type_(media_type.Pass()) {} |
363 | 360 |
364 MediaPlayerImpl::Stream::~Stream() {} | 361 MediaPlayerImpl::Stream::~Stream() {} |
365 | 362 |
366 } // namespace media | 363 } // namespace media |
367 } // namespace mojo | 364 } // namespace mojo |
OLD | NEW |