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.
4
5 #include "content/renderer/media/crypto/renderer_cdm_manager.h"
6
7 #include "base/stl_util.h"
8 #include "content/common/media/cdm_messages.h"
9 #include "content/renderer/media/crypto/proxy_media_keys.h"
10
11 namespace content {
12
13 // Maximum sizes for various EME API parameters. These are checks to prevent
14 // unnecessarily large messages from being passed around, and the sizes
15 // are somewhat arbitrary as the EME spec doesn't specify any limits.
16 const size_t kMaxWebSessionIdLength = 512;
17 const size_t kMaxSessionMessageLength = 10240; // 10 KB
18
RendererCdmManager(RenderFrame * render_frame)19 RendererCdmManager::RendererCdmManager(RenderFrame* render_frame)
20 : RenderFrameObserver(render_frame),
21 next_cdm_id_(kInvalidCdmId + 1) {
22 }
23
~RendererCdmManager()24 RendererCdmManager::~RendererCdmManager() {
25 DCHECK(proxy_media_keys_map_.empty())
26 << "RendererCdmManager is owned by RenderFrameImpl and is destroyed only "
27 "after all ProxyMediaKeys are destroyed and unregistered.";
28 }
29
OnMessageReceived(const IPC::Message & msg)30 bool RendererCdmManager::OnMessageReceived(const IPC::Message& msg) {
31 bool handled = true;
32 IPC_BEGIN_MESSAGE_MAP(RendererCdmManager, msg)
33 IPC_MESSAGE_HANDLER(CdmMsg_SessionCreated, OnSessionCreated)
34 IPC_MESSAGE_HANDLER(CdmMsg_SessionMessage, OnSessionMessage)
35 IPC_MESSAGE_HANDLER(CdmMsg_SessionReady, OnSessionReady)
36 IPC_MESSAGE_HANDLER(CdmMsg_SessionClosed, OnSessionClosed)
37 IPC_MESSAGE_HANDLER(CdmMsg_SessionError, OnSessionError)
38 IPC_MESSAGE_UNHANDLED(handled = false)
39 IPC_END_MESSAGE_MAP()
40 return handled;
41 }
42
InitializeCdm(int cdm_id,ProxyMediaKeys * media_keys,const std::string & key_system,const GURL & security_origin)43 void RendererCdmManager::InitializeCdm(int cdm_id,
44 ProxyMediaKeys* media_keys,
45 const std::string& key_system,
46 const GURL& security_origin) {
47 DCHECK(GetMediaKeys(cdm_id)) << "|cdm_id| not registered.";
48 Send(new CdmHostMsg_InitializeCdm(
49 routing_id(), cdm_id, key_system, security_origin));
50 }
51
CreateSession(int cdm_id,uint32 session_id,CdmHostMsg_CreateSession_ContentType content_type,const std::vector<uint8> & init_data)52 void RendererCdmManager::CreateSession(
53 int cdm_id,
54 uint32 session_id,
55 CdmHostMsg_CreateSession_ContentType content_type,
56 const std::vector<uint8>& init_data) {
57 DCHECK(GetMediaKeys(cdm_id)) << "|cdm_id| not registered.";
58 Send(new CdmHostMsg_CreateSession(
59 routing_id(), cdm_id, session_id, content_type, init_data));
60 }
61
UpdateSession(int cdm_id,uint32 session_id,const std::vector<uint8> & response)62 void RendererCdmManager::UpdateSession(int cdm_id,
63 uint32 session_id,
64 const std::vector<uint8>& response) {
65 DCHECK(GetMediaKeys(cdm_id)) << "|cdm_id| not registered.";
66 Send(
67 new CdmHostMsg_UpdateSession(routing_id(), cdm_id, session_id, response));
68 }
69
ReleaseSession(int cdm_id,uint32 session_id)70 void RendererCdmManager::ReleaseSession(int cdm_id, uint32 session_id) {
71 DCHECK(GetMediaKeys(cdm_id)) << "|cdm_id| not registered.";
72 Send(new CdmHostMsg_ReleaseSession(routing_id(), cdm_id, session_id));
73 }
74
DestroyCdm(int cdm_id)75 void RendererCdmManager::DestroyCdm(int cdm_id) {
76 DCHECK(GetMediaKeys(cdm_id)) << "|cdm_id| not registered.";
77 Send(new CdmHostMsg_DestroyCdm(routing_id(), cdm_id));
78 }
79
OnSessionCreated(int cdm_id,uint32 session_id,const std::string & web_session_id)80 void RendererCdmManager::OnSessionCreated(int cdm_id,
81 uint32 session_id,
82 const std::string& web_session_id) {
83 if (web_session_id.length() > kMaxWebSessionIdLength) {
84 OnSessionError(cdm_id, session_id, media::MediaKeys::kUnknownError, 0);
85 return;
86 }
87
88 ProxyMediaKeys* media_keys = GetMediaKeys(cdm_id);
89 if (media_keys)
90 media_keys->OnSessionCreated(session_id, web_session_id);
91 }
92
OnSessionMessage(int cdm_id,uint32 session_id,const std::vector<uint8> & message,const GURL & destination_url)93 void RendererCdmManager::OnSessionMessage(int cdm_id,
94 uint32 session_id,
95 const std::vector<uint8>& message,
96 const GURL& destination_url) {
97 if (message.size() > kMaxSessionMessageLength) {
98 OnSessionError(cdm_id, session_id, media::MediaKeys::kUnknownError, 0);
99 return;
100 }
101
102 ProxyMediaKeys* media_keys = GetMediaKeys(cdm_id);
103 if (media_keys)
104 media_keys->OnSessionMessage(session_id, message, destination_url);
105 }
106
OnSessionReady(int cdm_id,uint32 session_id)107 void RendererCdmManager::OnSessionReady(int cdm_id, uint32 session_id) {
108 ProxyMediaKeys* media_keys = GetMediaKeys(cdm_id);
109 if (media_keys)
110 media_keys->OnSessionReady(session_id);
111 }
112
OnSessionClosed(int cdm_id,uint32 session_id)113 void RendererCdmManager::OnSessionClosed(int cdm_id, uint32 session_id) {
114 ProxyMediaKeys* media_keys = GetMediaKeys(cdm_id);
115 if (media_keys)
116 media_keys->OnSessionClosed(session_id);
117 }
118
OnSessionError(int cdm_id,uint32 session_id,media::MediaKeys::KeyError error_code,uint32 system_code)119 void RendererCdmManager::OnSessionError(int cdm_id,
120 uint32 session_id,
121 media::MediaKeys::KeyError error_code,
122 uint32 system_code) {
123 ProxyMediaKeys* media_keys = GetMediaKeys(cdm_id);
124 if (media_keys)
125 media_keys->OnSessionError(session_id, error_code, system_code);
126 }
127
RegisterMediaKeys(ProxyMediaKeys * media_keys)128 int RendererCdmManager::RegisterMediaKeys(ProxyMediaKeys* media_keys) {
129 int cdm_id = next_cdm_id_++;
130 DCHECK_NE(cdm_id, kInvalidCdmId);
131 DCHECK(!ContainsKey(proxy_media_keys_map_, cdm_id));
132 proxy_media_keys_map_[cdm_id] = media_keys;
133 return cdm_id;
134 }
135
UnregisterMediaKeys(int cdm_id)136 void RendererCdmManager::UnregisterMediaKeys(int cdm_id) {
137 DCHECK(ContainsKey(proxy_media_keys_map_, cdm_id));
138 proxy_media_keys_map_.erase(cdm_id);
139 }
140
GetMediaKeys(int cdm_id)141 ProxyMediaKeys* RendererCdmManager::GetMediaKeys(int cdm_id) {
142 std::map<int, ProxyMediaKeys*>::iterator iter =
143 proxy_media_keys_map_.find(cdm_id);
144 return (iter != proxy_media_keys_map_.end()) ? iter->second : NULL;
145 }
146
147 } // namespace content
148