OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 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 | 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 "media/mojo/services/mojo_cdm_service.h" | 5 #include "media/mojo/services/mojo_cdm_service.h" |
6 | 6 |
7 #include <map> | 7 #include <map> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
11 #include "base/lazy_instance.h" | |
12 #include "base/macros.h" | 11 #include "base/macros.h" |
13 #include "base/memory/ptr_util.h" | 12 #include "base/memory/ptr_util.h" |
14 #include "base/synchronization/lock.h" | 13 #include "base/synchronization/lock.h" |
15 #include "media/base/cdm_config.h" | 14 #include "media/base/cdm_config.h" |
16 #include "media/base/cdm_context.h" | 15 #include "media/base/cdm_context.h" |
17 #include "media/base/cdm_factory.h" | 16 #include "media/base/cdm_factory.h" |
18 #include "media/base/cdm_key_information.h" | 17 #include "media/base/cdm_key_information.h" |
19 #include "media/base/key_systems.h" | 18 #include "media/base/key_systems.h" |
20 #include "media/mojo/common/media_type_converters.h" | 19 #include "media/mojo/common/media_type_converters.h" |
21 #include "media/mojo/services/mojo_cdm_service_context.h" | 20 #include "media/mojo/services/mojo_cdm_service_context.h" |
22 #include "url/gurl.h" | 21 #include "url/gurl.h" |
23 | 22 |
24 namespace media { | 23 namespace media { |
25 | 24 |
26 namespace { | 25 namespace { |
27 | 26 |
28 // Manages all CDMs created by MojoCdmService. Can only have one instance per | 27 // Manages all CDMs created by MojoCdmService. Can only have one instance per |
29 // process so use a LazyInstance to ensure this. | 28 // process, so we use a thread-safe static to achieve this. |
30 class CdmManager { | 29 class CdmManager { |
31 public: | 30 public: |
32 CdmManager() {} | 31 CdmManager() {} |
33 ~CdmManager() {} | 32 ~CdmManager() {} |
34 | 33 |
35 // Returns the CDM associated with |cdm_id|. Can be called on any thread. | 34 // Returns the CDM associated with |cdm_id|. Can be called on any thread. |
36 scoped_refptr<ContentDecryptionModule> GetCdm(int cdm_id) { | 35 scoped_refptr<ContentDecryptionModule> GetCdm(int cdm_id) { |
37 base::AutoLock lock(lock_); | 36 base::AutoLock lock(lock_); |
38 auto iter = cdm_map_.find(cdm_id); | 37 auto iter = cdm_map_.find(cdm_id); |
39 return iter == cdm_map_.end() ? nullptr : iter->second; | 38 return iter == cdm_map_.end() ? nullptr : iter->second; |
(...skipping 15 matching lines...) Expand all Loading... |
55 } | 54 } |
56 | 55 |
57 private: | 56 private: |
58 // Lock to protect |cdm_map_|. | 57 // Lock to protect |cdm_map_|. |
59 base::Lock lock_; | 58 base::Lock lock_; |
60 std::map<int, scoped_refptr<ContentDecryptionModule>> cdm_map_; | 59 std::map<int, scoped_refptr<ContentDecryptionModule>> cdm_map_; |
61 | 60 |
62 DISALLOW_COPY_AND_ASSIGN(CdmManager); | 61 DISALLOW_COPY_AND_ASSIGN(CdmManager); |
63 }; | 62 }; |
64 | 63 |
65 base::LazyInstance<CdmManager>::Leaky g_cdm_manager = LAZY_INSTANCE_INITIALIZER; | 64 CdmManager* GetManager() { |
| 65 static CdmManager* manager = new CdmManager(); |
| 66 return manager; |
| 67 } |
66 | 68 |
67 } // namespace | 69 } // namespace |
68 | 70 |
69 using SimpleMojoCdmPromise = MojoCdmPromise<>; | 71 using SimpleMojoCdmPromise = MojoCdmPromise<>; |
70 using NewSessionMojoCdmPromise = MojoCdmPromise<std::string>; | 72 using NewSessionMojoCdmPromise = MojoCdmPromise<std::string>; |
71 | 73 |
72 int MojoCdmService::next_cdm_id_ = CdmContext::kInvalidCdmId + 1; | 74 int MojoCdmService::next_cdm_id_ = CdmContext::kInvalidCdmId + 1; |
73 | 75 |
74 // static | 76 // static |
75 scoped_refptr<ContentDecryptionModule> MojoCdmService::LegacyGetCdm( | 77 scoped_refptr<ContentDecryptionModule> MojoCdmService::LegacyGetCdm( |
76 int cdm_id) { | 78 int cdm_id) { |
77 DVLOG(1) << __func__ << ": " << cdm_id; | 79 DVLOG(1) << __func__ << ": " << cdm_id; |
78 return g_cdm_manager.Get().GetCdm(cdm_id); | 80 return GetManager()->GetCdm(cdm_id); |
79 } | 81 } |
80 | 82 |
81 MojoCdmService::MojoCdmService(base::WeakPtr<MojoCdmServiceContext> context, | 83 MojoCdmService::MojoCdmService(base::WeakPtr<MojoCdmServiceContext> context, |
82 CdmFactory* cdm_factory) | 84 CdmFactory* cdm_factory) |
83 : context_(context), | 85 : context_(context), |
84 cdm_factory_(cdm_factory), | 86 cdm_factory_(cdm_factory), |
85 cdm_id_(CdmContext::kInvalidCdmId), | 87 cdm_id_(CdmContext::kInvalidCdmId), |
86 weak_factory_(this) { | 88 weak_factory_(this) { |
87 DCHECK(context_); | 89 DCHECK(context_); |
88 DCHECK(cdm_factory_); | 90 DCHECK(cdm_factory_); |
89 } | 91 } |
90 | 92 |
91 MojoCdmService::~MojoCdmService() { | 93 MojoCdmService::~MojoCdmService() { |
92 if (cdm_id_ == CdmContext::kInvalidCdmId) | 94 if (cdm_id_ == CdmContext::kInvalidCdmId) |
93 return; | 95 return; |
94 | 96 |
95 g_cdm_manager.Get().UnregisterCdm(cdm_id_); | 97 GetManager()->UnregisterCdm(cdm_id_); |
96 | 98 |
97 if (context_) | 99 if (context_) |
98 context_->UnregisterCdm(cdm_id_); | 100 context_->UnregisterCdm(cdm_id_); |
99 } | 101 } |
100 | 102 |
101 void MojoCdmService::SetClient(mojom::ContentDecryptionModuleClientPtr client) { | 103 void MojoCdmService::SetClient(mojom::ContentDecryptionModuleClientPtr client) { |
102 client_ = std::move(client); | 104 client_ = std::move(client); |
103 } | 105 } |
104 | 106 |
105 void MojoCdmService::Initialize(const std::string& key_system, | 107 void MojoCdmService::Initialize(const std::string& key_system, |
(...skipping 81 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
187 cdm_promise_result->system_code = 0; | 189 cdm_promise_result->system_code = 0; |
188 cdm_promise_result->error_message = error_message; | 190 cdm_promise_result->error_message = error_message; |
189 callback.Run(std::move(cdm_promise_result), 0, nullptr); | 191 callback.Run(std::move(cdm_promise_result), 0, nullptr); |
190 return; | 192 return; |
191 } | 193 } |
192 | 194 |
193 cdm_ = cdm; | 195 cdm_ = cdm; |
194 cdm_id_ = next_cdm_id_++; | 196 cdm_id_ = next_cdm_id_++; |
195 | 197 |
196 context_->RegisterCdm(cdm_id_, this); | 198 context_->RegisterCdm(cdm_id_, this); |
197 g_cdm_manager.Get().RegisterCdm(cdm_id_, cdm); | 199 GetManager()->RegisterCdm(cdm_id_, cdm); |
198 | 200 |
199 // If |cdm| has a decryptor, create the MojoDecryptorService | 201 // If |cdm| has a decryptor, create the MojoDecryptorService |
200 // and pass the connection back to the client. | 202 // and pass the connection back to the client. |
201 mojom::DecryptorPtr decryptor_service; | 203 mojom::DecryptorPtr decryptor_service; |
202 CdmContext* const cdm_context = cdm_->GetCdmContext(); | 204 CdmContext* const cdm_context = cdm_->GetCdmContext(); |
203 if (cdm_context && cdm_context->GetDecryptor()) { | 205 if (cdm_context && cdm_context->GetDecryptor()) { |
204 // MojoDecryptorService takes a reference to the CDM, but it is still owned | 206 // MojoDecryptorService takes a reference to the CDM, but it is still owned |
205 // by |this|. | 207 // by |this|. |
206 decryptor_.reset(new MojoDecryptorService( | 208 decryptor_.reset(new MojoDecryptorService( |
207 cdm_, MakeRequest(&decryptor_service), | 209 cdm_, MakeRequest(&decryptor_service), |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
249 | 251 |
250 void MojoCdmService::OnDecryptorConnectionError() { | 252 void MojoCdmService::OnDecryptorConnectionError() { |
251 DVLOG(2) << __func__; | 253 DVLOG(2) << __func__; |
252 | 254 |
253 // MojoDecryptorService has lost connectivity to it's client, so it can be | 255 // MojoDecryptorService has lost connectivity to it's client, so it can be |
254 // freed. | 256 // freed. |
255 decryptor_.reset(); | 257 decryptor_.reset(); |
256 } | 258 } |
257 | 259 |
258 } // namespace media | 260 } // namespace media |
OLD | NEW |