| 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 |