OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/indexed_db_dispatcher.h" | 5 #include "content/renderer/indexed_db_dispatcher.h" |
6 | 6 |
7 #include "content/common/indexed_db_messages.h" | 7 #include "content/common/indexed_db_messages.h" |
8 #include "content/renderer/render_thread_impl.h" | 8 #include "content/renderer/render_thread_impl.h" |
9 #include "content/renderer/render_view_impl.h" | 9 #include "content/renderer/render_view_impl.h" |
10 #include "content/renderer/renderer_webidbcursor_impl.h" | 10 #include "content/renderer/renderer_webidbcursor_impl.h" |
(...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
113 WebFrame* web_frame) { | 113 WebFrame* web_frame) { |
114 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | 114 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); |
115 | 115 |
116 if (!web_frame) | 116 if (!web_frame) |
117 return; // We must be shutting down. | 117 return; // We must be shutting down. |
118 RenderViewImpl* render_view = RenderViewImpl::FromWebView(web_frame->view()); | 118 RenderViewImpl* render_view = RenderViewImpl::FromWebView(web_frame->view()); |
119 if (!render_view) | 119 if (!render_view) |
120 return; // We must be shutting down. | 120 return; // We must be shutting down. |
121 | 121 |
122 IndexedDBHostMsg_FactoryOpen_Params params; | 122 IndexedDBHostMsg_FactoryOpen_Params params; |
123 params.routing_id = render_view->routing_id(); | |
124 params.response_id = pending_callbacks_.Add(callbacks.release()); | 123 params.response_id = pending_callbacks_.Add(callbacks.release()); |
125 params.origin = origin; | 124 params.origin = origin; |
126 params.name = name; | 125 params.name = name; |
127 RenderThreadImpl::current()->Send(new IndexedDBHostMsg_FactoryOpen(params)); | 126 RenderThreadImpl::current()->Send(new IndexedDBHostMsg_FactoryOpen(params)); |
128 } | 127 } |
129 | 128 |
130 void IndexedDBDispatcher::RequestIDBFactoryGetDatabaseNames( | 129 void IndexedDBDispatcher::RequestIDBFactoryGetDatabaseNames( |
131 WebIDBCallbacks* callbacks_ptr, | 130 WebIDBCallbacks* callbacks_ptr, |
132 const string16& origin, | 131 const string16& origin, |
133 WebFrame* web_frame) { | 132 WebFrame* web_frame) { |
134 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | 133 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); |
135 | 134 |
136 if (!web_frame) | 135 if (!web_frame) |
137 return; // We must be shutting down. | 136 return; // We must be shutting down. |
138 RenderViewImpl* render_view = RenderViewImpl::FromWebView(web_frame->view()); | 137 RenderViewImpl* render_view = RenderViewImpl::FromWebView(web_frame->view()); |
139 if (!render_view) | 138 if (!render_view) |
140 return; // We must be shutting down. | 139 return; // We must be shutting down. |
141 | 140 |
142 IndexedDBHostMsg_FactoryGetDatabaseNames_Params params; | 141 IndexedDBHostMsg_FactoryGetDatabaseNames_Params params; |
143 params.routing_id = render_view->routing_id(); | |
144 params.response_id = pending_callbacks_.Add(callbacks.release()); | 142 params.response_id = pending_callbacks_.Add(callbacks.release()); |
145 params.origin = origin; | 143 params.origin = origin; |
146 RenderThreadImpl::current()->Send( | 144 RenderThreadImpl::current()->Send( |
147 new IndexedDBHostMsg_FactoryGetDatabaseNames(params)); | 145 new IndexedDBHostMsg_FactoryGetDatabaseNames(params)); |
148 } | 146 } |
149 | 147 |
150 void IndexedDBDispatcher::RequestIDBFactoryDeleteDatabase( | 148 void IndexedDBDispatcher::RequestIDBFactoryDeleteDatabase( |
151 const string16& name, | 149 const string16& name, |
152 WebIDBCallbacks* callbacks_ptr, | 150 WebIDBCallbacks* callbacks_ptr, |
153 const string16& origin, | 151 const string16& origin, |
154 WebFrame* web_frame) { | 152 WebFrame* web_frame) { |
155 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | 153 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); |
156 | 154 |
157 if (!web_frame) | 155 if (!web_frame) |
158 return; // We must be shutting down. | 156 return; // We must be shutting down. |
159 RenderViewImpl* render_view = RenderViewImpl::FromWebView(web_frame->view()); | 157 RenderViewImpl* render_view = RenderViewImpl::FromWebView(web_frame->view()); |
160 if (!render_view) | 158 if (!render_view) |
161 return; // We must be shutting down. | 159 return; // We must be shutting down. |
162 | 160 |
163 IndexedDBHostMsg_FactoryDeleteDatabase_Params params; | 161 IndexedDBHostMsg_FactoryDeleteDatabase_Params params; |
164 params.routing_id = render_view->routing_id(); | |
165 params.response_id = pending_callbacks_.Add(callbacks.release()); | 162 params.response_id = pending_callbacks_.Add(callbacks.release()); |
166 params.origin = origin; | 163 params.origin = origin; |
167 params.name = name; | 164 params.name = name; |
168 RenderThreadImpl::current()->Send( | 165 RenderThreadImpl::current()->Send( |
169 new IndexedDBHostMsg_FactoryDeleteDatabase(params)); | 166 new IndexedDBHostMsg_FactoryDeleteDatabase(params)); |
170 } | 167 } |
171 | 168 |
172 void IndexedDBDispatcher::RequestIDBDatabaseClose(int32 idb_database_id) { | 169 void IndexedDBDispatcher::RequestIDBDatabaseClose(int32 idb_database_id) { |
173 RenderThreadImpl::current()->Send( | 170 RenderThreadImpl::current()->Send( |
174 new IndexedDBHostMsg_DatabaseClose(idb_database_id)); | 171 new IndexedDBHostMsg_DatabaseClose(idb_database_id)); |
(...skipping 314 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
489 | 486 |
490 void IndexedDBDispatcher::OnVersionChange(int32 database_id, | 487 void IndexedDBDispatcher::OnVersionChange(int32 database_id, |
491 const string16& newVersion) { | 488 const string16& newVersion) { |
492 WebIDBDatabaseCallbacks* callbacks = | 489 WebIDBDatabaseCallbacks* callbacks = |
493 pending_database_callbacks_.Lookup(database_id); | 490 pending_database_callbacks_.Lookup(database_id); |
494 // callbacks would be NULL if a versionchange event is received after close | 491 // callbacks would be NULL if a versionchange event is received after close |
495 // has been called. | 492 // has been called. |
496 if (callbacks) | 493 if (callbacks) |
497 callbacks->onVersionChange(newVersion); | 494 callbacks->onVersionChange(newVersion); |
498 } | 495 } |
OLD | NEW |