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.h" | 8 #include "content/renderer/render_thread.h" |
9 #include "content/renderer/render_view.h" | 9 #include "content/renderer/render_view.h" |
10 #include "content/renderer/renderer_webidbcursor_impl.h" | 10 #include "content/renderer/renderer_webidbcursor_impl.h" |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
98 RenderThread::current()->Send( | 98 RenderThread::current()->Send( |
99 new IndexedDBHostMsg_CursorDelete(idb_cursor_id, response_id, ec)); | 99 new IndexedDBHostMsg_CursorDelete(idb_cursor_id, response_id, ec)); |
100 if (*ec) | 100 if (*ec) |
101 pending_callbacks_.Remove(response_id); | 101 pending_callbacks_.Remove(response_id); |
102 } | 102 } |
103 | 103 |
104 void IndexedDBDispatcher::RequestIDBFactoryOpen( | 104 void IndexedDBDispatcher::RequestIDBFactoryOpen( |
105 const string16& name, | 105 const string16& name, |
106 WebIDBCallbacks* callbacks_ptr, | 106 WebIDBCallbacks* callbacks_ptr, |
107 const string16& origin, | 107 const string16& origin, |
108 WebFrame* web_frame, | 108 WebFrame* web_frame) { |
109 uint64 maximum_size) { | |
110 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | 109 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); |
111 | 110 |
112 if (!web_frame) | 111 if (!web_frame) |
113 return; // We must be shutting down. | 112 return; // We must be shutting down. |
114 RenderView* render_view = RenderView::FromWebView(web_frame->view()); | 113 RenderView* render_view = RenderView::FromWebView(web_frame->view()); |
115 if (!render_view) | 114 if (!render_view) |
116 return; // We must be shutting down. | 115 return; // We must be shutting down. |
117 | 116 |
118 IndexedDBHostMsg_FactoryOpen_Params params; | 117 IndexedDBHostMsg_FactoryOpen_Params params; |
119 params.routing_id = render_view->routing_id(); | 118 params.routing_id = render_view->routing_id(); |
120 params.response_id = pending_callbacks_.Add(callbacks.release()); | 119 params.response_id = pending_callbacks_.Add(callbacks.release()); |
121 params.origin = origin; | 120 params.origin = origin; |
122 params.name = name; | 121 params.name = name; |
123 params.maximum_size = maximum_size; | |
124 RenderThread::current()->Send(new IndexedDBHostMsg_FactoryOpen(params)); | 122 RenderThread::current()->Send(new IndexedDBHostMsg_FactoryOpen(params)); |
125 } | 123 } |
126 | 124 |
127 void IndexedDBDispatcher::RequestIDBFactoryDeleteDatabase( | 125 void IndexedDBDispatcher::RequestIDBFactoryDeleteDatabase( |
128 const string16& name, | 126 const string16& name, |
129 WebIDBCallbacks* callbacks_ptr, | 127 WebIDBCallbacks* callbacks_ptr, |
130 const string16& origin, | 128 const string16& origin, |
131 WebFrame* web_frame) { | 129 WebFrame* web_frame) { |
132 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); | 130 scoped_ptr<WebIDBCallbacks> callbacks(callbacks_ptr); |
133 | 131 |
(...skipping 295 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
429 | 427 |
430 void IndexedDBDispatcher::OnVersionChange(int32 database_id, | 428 void IndexedDBDispatcher::OnVersionChange(int32 database_id, |
431 const string16& newVersion) { | 429 const string16& newVersion) { |
432 WebIDBDatabaseCallbacks* callbacks = | 430 WebIDBDatabaseCallbacks* callbacks = |
433 pending_database_callbacks_.Lookup(database_id); | 431 pending_database_callbacks_.Lookup(database_id); |
434 // callbacks would be NULL if a versionchange event is received after close | 432 // callbacks would be NULL if a versionchange event is received after close |
435 // has been called. | 433 // has been called. |
436 if (callbacks) | 434 if (callbacks) |
437 callbacks->onVersionChange(newVersion); | 435 callbacks->onVersionChange(newVersion); |
438 } | 436 } |
OLD | NEW |