| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "content/renderer/pepper/host_var_tracker.h" | 5 #include "content/renderer/pepper/host_var_tracker.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "content/renderer/pepper/host_array_buffer_var.h" | 8 #include "content/renderer/pepper/host_array_buffer_var.h" |
| 9 #include "content/renderer/pepper/host_globals.h" |
| 9 #include "content/renderer/pepper/host_resource_var.h" | 10 #include "content/renderer/pepper/host_resource_var.h" |
| 10 #include "content/renderer/pepper/npobject_var.h" | |
| 11 #include "content/renderer/pepper/pepper_plugin_instance_impl.h" | 11 #include "content/renderer/pepper/pepper_plugin_instance_impl.h" |
| 12 #include "content/renderer/pepper/v8object_var.h" |
| 12 #include "ppapi/c/pp_var.h" | 13 #include "ppapi/c/pp_var.h" |
| 13 | 14 |
| 14 using ppapi::ArrayBufferVar; | 15 using ppapi::ArrayBufferVar; |
| 15 using ppapi::NPObjectVar; | 16 using ppapi::V8ObjectVar; |
| 16 | 17 |
| 17 namespace content { | 18 namespace content { |
| 18 | 19 |
| 20 HostVarTracker::V8ObjectVarKey::V8ObjectVarKey(V8ObjectVar* object_var) |
| 21 : instance(object_var->instance()->pp_instance()) { |
| 22 v8::Local<v8::Object> object = object_var->GetHandle(); |
| 23 hash = object.IsEmpty() ? 0 : object->GetIdentityHash(); |
| 24 } |
| 25 |
| 26 HostVarTracker::V8ObjectVarKey::V8ObjectVarKey(PP_Instance instance, |
| 27 v8::Handle<v8::Object> object) |
| 28 : instance(instance), |
| 29 hash(object.IsEmpty() ? 0 : object->GetIdentityHash()) {} |
| 30 |
| 31 HostVarTracker::V8ObjectVarKey::~V8ObjectVarKey() {} |
| 32 |
| 33 bool HostVarTracker::V8ObjectVarKey::operator<( |
| 34 const V8ObjectVarKey& other) const { |
| 35 if (instance == other.instance) |
| 36 return hash < other.hash; |
| 37 return instance < other.instance; |
| 38 } |
| 39 |
| 19 HostVarTracker::HostVarTracker() | 40 HostVarTracker::HostVarTracker() |
| 20 : VarTracker(SINGLE_THREADED), last_shared_memory_map_id_(0) {} | 41 : VarTracker(SINGLE_THREADED), last_shared_memory_map_id_(0) {} |
| 21 | 42 |
| 22 HostVarTracker::~HostVarTracker() {} | 43 HostVarTracker::~HostVarTracker() {} |
| 23 | 44 |
| 24 ArrayBufferVar* HostVarTracker::CreateArrayBuffer(uint32 size_in_bytes) { | 45 ArrayBufferVar* HostVarTracker::CreateArrayBuffer(uint32 size_in_bytes) { |
| 25 return new HostArrayBufferVar(size_in_bytes); | 46 return new HostArrayBufferVar(size_in_bytes); |
| 26 } | 47 } |
| 27 | 48 |
| 28 ArrayBufferVar* HostVarTracker::CreateShmArrayBuffer( | 49 ArrayBufferVar* HostVarTracker::CreateShmArrayBuffer( |
| 29 uint32 size_in_bytes, | 50 uint32 size_in_bytes, |
| 30 base::SharedMemoryHandle handle) { | 51 base::SharedMemoryHandle handle) { |
| 31 return new HostArrayBufferVar(size_in_bytes, handle); | 52 return new HostArrayBufferVar(size_in_bytes, handle); |
| 32 } | 53 } |
| 33 | 54 |
| 34 void HostVarTracker::AddNPObjectVar(NPObjectVar* object_var) { | 55 void HostVarTracker::AddV8ObjectVar(V8ObjectVar* object_var) { |
| 35 CheckThreadingPreconditions(); | 56 CheckThreadingPreconditions(); |
| 36 | 57 v8::HandleScope handle_scope(object_var->instance()->GetIsolate()); |
| 37 InstanceMap::iterator found_instance = | 58 DCHECK(GetForV8Object(object_var->instance()->pp_instance(), |
| 38 instance_map_.find(object_var->pp_instance()); | 59 object_var->GetHandle()) == object_map_.end()); |
| 39 if (found_instance == instance_map_.end()) { | 60 object_map_.insert(std::make_pair(V8ObjectVarKey(object_var), object_var)); |
| 40 // Lazily create the instance map. | |
| 41 DCHECK(object_var->pp_instance() != 0); | |
| 42 found_instance = | |
| 43 instance_map_.insert(std::make_pair( | |
| 44 object_var->pp_instance(), | |
| 45 linked_ptr<NPObjectToNPObjectVarMap>( | |
| 46 new NPObjectToNPObjectVarMap))).first; | |
| 47 } | |
| 48 NPObjectToNPObjectVarMap* np_object_map = found_instance->second.get(); | |
| 49 | |
| 50 DCHECK(np_object_map->find(object_var->np_object()) == np_object_map->end()) | |
| 51 << "NPObjectVar already in map"; | |
| 52 np_object_map->insert(std::make_pair(object_var->np_object(), object_var)); | |
| 53 } | 61 } |
| 54 | 62 |
| 55 void HostVarTracker::RemoveNPObjectVar(NPObjectVar* object_var) { | 63 void HostVarTracker::RemoveV8ObjectVar(V8ObjectVar* object_var) { |
| 56 CheckThreadingPreconditions(); | 64 CheckThreadingPreconditions(); |
| 57 | 65 v8::HandleScope handle_scope(object_var->instance()->GetIsolate()); |
| 58 InstanceMap::iterator found_instance = | 66 ObjectMap::iterator it = GetForV8Object( |
| 59 instance_map_.find(object_var->pp_instance()); | 67 object_var->instance()->pp_instance(), object_var->GetHandle()); |
| 60 if (found_instance == instance_map_.end()) { | 68 DCHECK(it != object_map_.end()); |
| 61 NOTREACHED() << "NPObjectVar has invalid instance."; | 69 object_map_.erase(it); |
| 62 return; | |
| 63 } | |
| 64 NPObjectToNPObjectVarMap* np_object_map = found_instance->second.get(); | |
| 65 | |
| 66 NPObjectToNPObjectVarMap::iterator found_object = | |
| 67 np_object_map->find(object_var->np_object()); | |
| 68 if (found_object == np_object_map->end()) { | |
| 69 NOTREACHED() << "NPObjectVar not registered."; | |
| 70 return; | |
| 71 } | |
| 72 if (found_object->second != object_var) { | |
| 73 NOTREACHED() << "NPObjectVar doesn't match."; | |
| 74 return; | |
| 75 } | |
| 76 np_object_map->erase(found_object); | |
| 77 } | 70 } |
| 78 | 71 |
| 79 NPObjectVar* HostVarTracker::NPObjectVarForNPObject(PP_Instance instance, | 72 PP_Var HostVarTracker::V8ObjectVarForV8Object(PP_Instance instance, |
| 80 NPObject* np_object) { | 73 v8::Handle<v8::Object> object) { |
| 81 CheckThreadingPreconditions(); | 74 CheckThreadingPreconditions(); |
| 82 | 75 ObjectMap::const_iterator it = GetForV8Object(instance, object); |
| 83 InstanceMap::iterator found_instance = instance_map_.find(instance); | 76 if (it == object_map_.end()) |
| 84 if (found_instance == instance_map_.end()) | 77 return (new V8ObjectVar(instance, object))->GetPPVar(); |
| 85 return NULL; // No such instance. | 78 return it->second->GetPPVar(); |
| 86 NPObjectToNPObjectVarMap* np_object_map = found_instance->second.get(); | |
| 87 | |
| 88 NPObjectToNPObjectVarMap::iterator found_object = | |
| 89 np_object_map->find(np_object); | |
| 90 if (found_object == np_object_map->end()) | |
| 91 return NULL; // No such object. | |
| 92 return found_object->second; | |
| 93 } | 79 } |
| 94 | 80 |
| 95 int HostVarTracker::GetLiveNPObjectVarsForInstance(PP_Instance instance) const { | 81 int HostVarTracker::GetLiveV8ObjectVarsForTest(PP_Instance instance) { |
| 96 CheckThreadingPreconditions(); | 82 CheckThreadingPreconditions(); |
| 97 | 83 int count = 0; |
| 98 InstanceMap::const_iterator found = instance_map_.find(instance); | 84 ObjectMap::const_iterator it = object_map_.lower_bound( |
| 99 if (found == instance_map_.end()) | 85 V8ObjectVarKey(instance, v8::Handle<v8::Object>())); |
| 100 return 0; | 86 while (it != object_map_.end() && it->first.instance == instance) { |
| 101 return static_cast<int>(found->second->size()); | 87 ++count; |
| 88 ++it; |
| 89 } |
| 90 return count; |
| 102 } | 91 } |
| 103 | 92 |
| 104 PP_Var HostVarTracker::MakeResourcePPVarFromMessage( | 93 PP_Var HostVarTracker::MakeResourcePPVarFromMessage( |
| 105 PP_Instance instance, | 94 PP_Instance instance, |
| 106 const IPC::Message& creation_message, | 95 const IPC::Message& creation_message, |
| 107 int pending_renderer_id, | 96 int pending_renderer_id, |
| 108 int pending_browser_id) { | 97 int pending_browser_id) { |
| 109 // On the host side, the creation message is ignored when creating a resource. | 98 // On the host side, the creation message is ignored when creating a resource. |
| 110 // Therefore, a call to this function indicates a null resource. Return the | 99 // Therefore, a call to this function indicates a null resource. Return the |
| 111 // resource 0. | 100 // resource 0. |
| 112 return MakeResourcePPVar(0); | 101 return MakeResourcePPVar(0); |
| 113 } | 102 } |
| 114 | 103 |
| 115 ppapi::ResourceVar* HostVarTracker::MakeResourceVar(PP_Resource pp_resource) { | 104 ppapi::ResourceVar* HostVarTracker::MakeResourceVar(PP_Resource pp_resource) { |
| 116 return new HostResourceVar(pp_resource); | 105 return new HostResourceVar(pp_resource); |
| 117 } | 106 } |
| 118 | 107 |
| 119 void HostVarTracker::DidDeleteInstance(PP_Instance instance) { | 108 void HostVarTracker::DidDeleteInstance(PP_Instance pp_instance) { |
| 120 CheckThreadingPreconditions(); | 109 CheckThreadingPreconditions(); |
| 121 | 110 |
| 122 InstanceMap::iterator found_instance = instance_map_.find(instance); | 111 PepperPluginInstanceImpl* instance = |
| 123 if (found_instance == instance_map_.end()) | 112 HostGlobals::Get()->GetInstance(pp_instance); |
| 124 return; // Nothing to do. | 113 v8::HandleScope handle_scope(instance->GetIsolate()); |
| 125 NPObjectToNPObjectVarMap* np_object_map = found_instance->second.get(); | 114 // Force delete all var references. ForceReleaseV8Object() will cause |
| 126 | |
| 127 // Force delete all var references. ForceReleaseNPObject() will cause | |
| 128 // this object, and potentially others it references, to be removed from | 115 // this object, and potentially others it references, to be removed from |
| 129 // |np_object_map|. | 116 // |live_vars_|. |
| 130 while (!np_object_map->empty()) { | 117 ObjectMap::iterator it = object_map_.lower_bound( |
| 131 ForceReleaseNPObject(np_object_map->begin()->second); | 118 V8ObjectVarKey(pp_instance, v8::Handle<v8::Object>())); |
| 119 while (it != object_map_.end() && it->first.instance == pp_instance) { |
| 120 ForceReleaseV8Object(it->second); |
| 121 object_map_.erase(it++); |
| 132 } | 122 } |
| 133 | |
| 134 // Remove the record for this instance since it should be empty. | |
| 135 DCHECK(np_object_map->empty()); | |
| 136 instance_map_.erase(found_instance); | |
| 137 } | 123 } |
| 138 | 124 |
| 139 void HostVarTracker::ForceReleaseNPObject(ppapi::NPObjectVar* object_var) { | 125 void HostVarTracker::ForceReleaseV8Object(ppapi::V8ObjectVar* object_var) { |
| 140 object_var->InstanceDeleted(); | 126 object_var->InstanceDeleted(); |
| 141 VarMap::iterator iter = live_vars_.find(object_var->GetExistingVarID()); | 127 VarMap::iterator iter = live_vars_.find(object_var->GetExistingVarID()); |
| 142 if (iter == live_vars_.end()) { | 128 if (iter == live_vars_.end()) { |
| 143 NOTREACHED(); | 129 NOTREACHED(); |
| 144 return; | 130 return; |
| 145 } | 131 } |
| 146 iter->second.ref_count = 0; | 132 iter->second.ref_count = 0; |
| 147 DCHECK(iter->second.track_with_no_reference_count == 0); | 133 DCHECK(iter->second.track_with_no_reference_count == 0); |
| 148 DeleteObjectInfoIfNecessary(iter); | 134 DeleteObjectInfoIfNecessary(iter); |
| 149 } | 135 } |
| 150 | 136 |
| 137 HostVarTracker::ObjectMap::iterator HostVarTracker::GetForV8Object( |
| 138 PP_Instance instance, |
| 139 v8::Handle<v8::Object> object) { |
| 140 V8ObjectVarKey key(instance, object); |
| 141 ObjectMap::iterator it = object_map_.lower_bound(key); |
| 142 |
| 143 while (it != object_map_.end() && |
| 144 it->first.instance == key.instance && it->first.hash == key.hash) { |
| 145 if (object == it->second->GetHandle()) |
| 146 return it; |
| 147 ++it; |
| 148 } |
| 149 return object_map_.end(); |
| 150 } |
| 151 |
| 151 int HostVarTracker::TrackSharedMemoryHandle(PP_Instance instance, | 152 int HostVarTracker::TrackSharedMemoryHandle(PP_Instance instance, |
| 152 base::SharedMemoryHandle handle, | 153 base::SharedMemoryHandle handle, |
| 153 uint32 size_in_bytes) { | 154 uint32 size_in_bytes) { |
| 154 SharedMemoryMapEntry entry; | 155 SharedMemoryMapEntry entry; |
| 155 entry.instance = instance; | 156 entry.instance = instance; |
| 156 entry.handle = handle; | 157 entry.handle = handle; |
| 157 entry.size_in_bytes = size_in_bytes; | 158 entry.size_in_bytes = size_in_bytes; |
| 158 | 159 |
| 159 // Find a free id for our map. | 160 // Find a free id for our map. |
| 160 while (shared_memory_map_.find(last_shared_memory_map_id_) != | 161 while (shared_memory_map_.find(last_shared_memory_map_id_) != |
| (...skipping 15 matching lines...) Expand all Loading... |
| 176 if (it->second.instance != instance) | 177 if (it->second.instance != instance) |
| 177 return false; | 178 return false; |
| 178 | 179 |
| 179 *handle = it->second.handle; | 180 *handle = it->second.handle; |
| 180 *size_in_bytes = it->second.size_in_bytes; | 181 *size_in_bytes = it->second.size_in_bytes; |
| 181 shared_memory_map_.erase(it); | 182 shared_memory_map_.erase(it); |
| 182 return true; | 183 return true; |
| 183 } | 184 } |
| 184 | 185 |
| 185 } // namespace content | 186 } // namespace content |
| OLD | NEW |