| 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/browser/indexed_db/indexed_db_callbacks.h" | 5 #include "content/browser/indexed_db/indexed_db_callbacks.h" |
| 6 | 6 |
| 7 #include <stddef.h> |
| 8 |
| 7 #include <algorithm> | 9 #include <algorithm> |
| 8 | 10 |
| 9 #include "base/metrics/histogram.h" | 11 #include "base/metrics/histogram.h" |
| 10 #include "base/strings/utf_string_conversions.h" | 12 #include "base/strings/utf_string_conversions.h" |
| 11 #include "base/time/time.h" | 13 #include "base/time/time.h" |
| 12 #include "content/browser/child_process_security_policy_impl.h" | 14 #include "content/browser/child_process_security_policy_impl.h" |
| 13 #include "content/browser/fileapi/fileapi_message_filter.h" | 15 #include "content/browser/fileapi/fileapi_message_filter.h" |
| 14 #include "content/browser/indexed_db/indexed_db_blob_info.h" | 16 #include "content/browser/indexed_db/indexed_db_blob_info.h" |
| 15 #include "content/browser/indexed_db/indexed_db_connection.h" | 17 #include "content/browser/indexed_db/indexed_db_connection.h" |
| 16 #include "content/browser/indexed_db/indexed_db_context_impl.h" | 18 #include "content/browser/indexed_db/indexed_db_context_impl.h" |
| 17 #include "content/browser/indexed_db/indexed_db_cursor.h" | 19 #include "content/browser/indexed_db/indexed_db_cursor.h" |
| 18 #include "content/browser/indexed_db/indexed_db_database_callbacks.h" | 20 #include "content/browser/indexed_db/indexed_db_database_callbacks.h" |
| 19 #include "content/browser/indexed_db/indexed_db_database_error.h" | 21 #include "content/browser/indexed_db/indexed_db_database_error.h" |
| 20 #include "content/browser/indexed_db/indexed_db_metadata.h" | 22 #include "content/browser/indexed_db/indexed_db_metadata.h" |
| 21 #include "content/browser/indexed_db/indexed_db_return_value.h" | 23 #include "content/browser/indexed_db/indexed_db_return_value.h" |
| 22 #include "content/browser/indexed_db/indexed_db_tracing.h" | 24 #include "content/browser/indexed_db/indexed_db_tracing.h" |
| 23 #include "content/browser/indexed_db/indexed_db_value.h" | 25 #include "content/browser/indexed_db/indexed_db_value.h" |
| 24 #include "content/common/indexed_db/indexed_db_constants.h" | 26 #include "content/common/indexed_db/indexed_db_constants.h" |
| 25 #include "content/common/indexed_db/indexed_db_messages.h" | 27 #include "content/common/indexed_db/indexed_db_messages.h" |
| 26 #include "storage/browser/blob/blob_storage_context.h" | 28 #include "storage/browser/blob/blob_storage_context.h" |
| 27 #include "storage/browser/blob/shareable_file_reference.h" | 29 #include "storage/browser/blob/shareable_file_reference.h" |
| 28 #include "storage/browser/quota/quota_manager.h" | 30 #include "storage/browser/quota/quota_manager.h" |
| 29 | 31 |
| 30 using storage::ShareableFileReference; | 32 using storage::ShareableFileReference; |
| 31 | 33 |
| 32 namespace content { | 34 namespace content { |
| 33 | 35 |
| 34 namespace { | 36 namespace { |
| 35 const int32 kNoCursor = -1; | 37 const int32_t kNoCursor = -1; |
| 36 const int32 kNoDatabaseCallbacks = -1; | 38 const int32_t kNoDatabaseCallbacks = -1; |
| 37 const int64 kNoTransaction = -1; | 39 const int64_t kNoTransaction = -1; |
| 38 } | 40 } |
| 39 | 41 |
| 40 IndexedDBCallbacks::IndexedDBCallbacks(IndexedDBDispatcherHost* dispatcher_host, | 42 IndexedDBCallbacks::IndexedDBCallbacks(IndexedDBDispatcherHost* dispatcher_host, |
| 41 int32 ipc_thread_id, | 43 int32_t ipc_thread_id, |
| 42 int32 ipc_callbacks_id) | 44 int32_t ipc_callbacks_id) |
| 43 : dispatcher_host_(dispatcher_host), | 45 : dispatcher_host_(dispatcher_host), |
| 44 ipc_callbacks_id_(ipc_callbacks_id), | 46 ipc_callbacks_id_(ipc_callbacks_id), |
| 45 ipc_thread_id_(ipc_thread_id), | 47 ipc_thread_id_(ipc_thread_id), |
| 46 ipc_cursor_id_(kNoCursor), | 48 ipc_cursor_id_(kNoCursor), |
| 47 host_transaction_id_(kNoTransaction), | 49 host_transaction_id_(kNoTransaction), |
| 48 ipc_database_id_(kNoDatabase), | 50 ipc_database_id_(kNoDatabase), |
| 49 ipc_database_callbacks_id_(kNoDatabaseCallbacks), | 51 ipc_database_callbacks_id_(kNoDatabaseCallbacks), |
| 50 data_loss_(blink::WebIDBDataLossNone), | 52 data_loss_(blink::WebIDBDataLossNone), |
| 51 sent_blocked_(false) { | 53 sent_blocked_(false) {} |
| 52 } | |
| 53 | 54 |
| 54 IndexedDBCallbacks::IndexedDBCallbacks(IndexedDBDispatcherHost* dispatcher_host, | 55 IndexedDBCallbacks::IndexedDBCallbacks(IndexedDBDispatcherHost* dispatcher_host, |
| 55 int32 ipc_thread_id, | 56 int32_t ipc_thread_id, |
| 56 int32 ipc_callbacks_id, | 57 int32_t ipc_callbacks_id, |
| 57 int32 ipc_cursor_id) | 58 int32_t ipc_cursor_id) |
| 58 : dispatcher_host_(dispatcher_host), | 59 : dispatcher_host_(dispatcher_host), |
| 59 ipc_callbacks_id_(ipc_callbacks_id), | 60 ipc_callbacks_id_(ipc_callbacks_id), |
| 60 ipc_thread_id_(ipc_thread_id), | 61 ipc_thread_id_(ipc_thread_id), |
| 61 ipc_cursor_id_(ipc_cursor_id), | 62 ipc_cursor_id_(ipc_cursor_id), |
| 62 host_transaction_id_(kNoTransaction), | 63 host_transaction_id_(kNoTransaction), |
| 63 ipc_database_id_(kNoDatabase), | 64 ipc_database_id_(kNoDatabase), |
| 64 ipc_database_callbacks_id_(kNoDatabaseCallbacks), | 65 ipc_database_callbacks_id_(kNoDatabaseCallbacks), |
| 65 data_loss_(blink::WebIDBDataLossNone), | 66 data_loss_(blink::WebIDBDataLossNone), |
| 66 sent_blocked_(false) { | 67 sent_blocked_(false) {} |
| 67 } | |
| 68 | 68 |
| 69 IndexedDBCallbacks::IndexedDBCallbacks(IndexedDBDispatcherHost* dispatcher_host, | 69 IndexedDBCallbacks::IndexedDBCallbacks(IndexedDBDispatcherHost* dispatcher_host, |
| 70 int32 ipc_thread_id, | 70 int32_t ipc_thread_id, |
| 71 int32 ipc_callbacks_id, | 71 int32_t ipc_callbacks_id, |
| 72 int32 ipc_database_callbacks_id, | 72 int32_t ipc_database_callbacks_id, |
| 73 int64 host_transaction_id, | 73 int64_t host_transaction_id, |
| 74 const GURL& origin_url) | 74 const GURL& origin_url) |
| 75 : dispatcher_host_(dispatcher_host), | 75 : dispatcher_host_(dispatcher_host), |
| 76 ipc_callbacks_id_(ipc_callbacks_id), | 76 ipc_callbacks_id_(ipc_callbacks_id), |
| 77 ipc_thread_id_(ipc_thread_id), | 77 ipc_thread_id_(ipc_thread_id), |
| 78 ipc_cursor_id_(kNoCursor), | 78 ipc_cursor_id_(kNoCursor), |
| 79 host_transaction_id_(host_transaction_id), | 79 host_transaction_id_(host_transaction_id), |
| 80 origin_url_(origin_url), | 80 origin_url_(origin_url), |
| 81 ipc_database_id_(kNoDatabase), | 81 ipc_database_id_(kNoDatabase), |
| 82 ipc_database_callbacks_id_(ipc_database_callbacks_id), | 82 ipc_database_callbacks_id_(ipc_database_callbacks_id), |
| 83 data_loss_(blink::WebIDBDataLossNone), | 83 data_loss_(blink::WebIDBDataLossNone), |
| 84 sent_blocked_(false) { | 84 sent_blocked_(false) {} |
| 85 } | |
| 86 | 85 |
| 87 IndexedDBCallbacks::~IndexedDBCallbacks() {} | 86 IndexedDBCallbacks::~IndexedDBCallbacks() {} |
| 88 | 87 |
| 89 void IndexedDBCallbacks::OnError(const IndexedDBDatabaseError& error) { | 88 void IndexedDBCallbacks::OnError(const IndexedDBDatabaseError& error) { |
| 90 DCHECK(dispatcher_host_.get()); | 89 DCHECK(dispatcher_host_.get()); |
| 91 | 90 |
| 92 dispatcher_host_->Send(new IndexedDBMsg_CallbacksError( | 91 dispatcher_host_->Send(new IndexedDBMsg_CallbacksError( |
| 93 ipc_thread_id_, ipc_callbacks_id_, error.code(), error.message())); | 92 ipc_thread_id_, ipc_callbacks_id_, error.code(), error.message())); |
| 94 dispatcher_host_ = NULL; | 93 dispatcher_host_ = NULL; |
| 95 | 94 |
| (...skipping 16 matching lines...) Expand all Loading... |
| 112 | 111 |
| 113 std::vector<base::string16> list; | 112 std::vector<base::string16> list; |
| 114 for (unsigned i = 0; i < value.size(); ++i) | 113 for (unsigned i = 0; i < value.size(); ++i) |
| 115 list.push_back(value[i]); | 114 list.push_back(value[i]); |
| 116 | 115 |
| 117 dispatcher_host_->Send(new IndexedDBMsg_CallbacksSuccessStringList( | 116 dispatcher_host_->Send(new IndexedDBMsg_CallbacksSuccessStringList( |
| 118 ipc_thread_id_, ipc_callbacks_id_, list)); | 117 ipc_thread_id_, ipc_callbacks_id_, list)); |
| 119 dispatcher_host_ = NULL; | 118 dispatcher_host_ = NULL; |
| 120 } | 119 } |
| 121 | 120 |
| 122 void IndexedDBCallbacks::OnBlocked(int64 existing_version) { | 121 void IndexedDBCallbacks::OnBlocked(int64_t existing_version) { |
| 123 DCHECK(dispatcher_host_.get()); | 122 DCHECK(dispatcher_host_.get()); |
| 124 | 123 |
| 125 DCHECK_EQ(kNoCursor, ipc_cursor_id_); | 124 DCHECK_EQ(kNoCursor, ipc_cursor_id_); |
| 126 // No transaction/db callbacks for DeleteDatabase. | 125 // No transaction/db callbacks for DeleteDatabase. |
| 127 DCHECK_EQ(kNoTransaction == host_transaction_id_, | 126 DCHECK_EQ(kNoTransaction == host_transaction_id_, |
| 128 kNoDatabaseCallbacks == ipc_database_callbacks_id_); | 127 kNoDatabaseCallbacks == ipc_database_callbacks_id_); |
| 129 DCHECK_EQ(kNoDatabase, ipc_database_id_); | 128 DCHECK_EQ(kNoDatabase, ipc_database_id_); |
| 130 | 129 |
| 131 if (sent_blocked_) | 130 if (sent_blocked_) |
| 132 return; | 131 return; |
| (...skipping 11 matching lines...) Expand all Loading... |
| 144 } | 143 } |
| 145 | 144 |
| 146 void IndexedDBCallbacks::OnDataLoss(blink::WebIDBDataLoss data_loss, | 145 void IndexedDBCallbacks::OnDataLoss(blink::WebIDBDataLoss data_loss, |
| 147 std::string data_loss_message) { | 146 std::string data_loss_message) { |
| 148 DCHECK_NE(blink::WebIDBDataLossNone, data_loss); | 147 DCHECK_NE(blink::WebIDBDataLossNone, data_loss); |
| 149 data_loss_ = data_loss; | 148 data_loss_ = data_loss; |
| 150 data_loss_message_ = data_loss_message; | 149 data_loss_message_ = data_loss_message; |
| 151 } | 150 } |
| 152 | 151 |
| 153 void IndexedDBCallbacks::OnUpgradeNeeded( | 152 void IndexedDBCallbacks::OnUpgradeNeeded( |
| 154 int64 old_version, | 153 int64_t old_version, |
| 155 scoped_ptr<IndexedDBConnection> connection, | 154 scoped_ptr<IndexedDBConnection> connection, |
| 156 const IndexedDBDatabaseMetadata& metadata) { | 155 const IndexedDBDatabaseMetadata& metadata) { |
| 157 DCHECK(dispatcher_host_.get()); | 156 DCHECK(dispatcher_host_.get()); |
| 158 | 157 |
| 159 DCHECK_EQ(kNoCursor, ipc_cursor_id_); | 158 DCHECK_EQ(kNoCursor, ipc_cursor_id_); |
| 160 DCHECK_NE(kNoTransaction, host_transaction_id_); | 159 DCHECK_NE(kNoTransaction, host_transaction_id_); |
| 161 DCHECK_EQ(kNoDatabase, ipc_database_id_); | 160 DCHECK_EQ(kNoDatabase, ipc_database_id_); |
| 162 DCHECK_NE(kNoDatabaseCallbacks, ipc_database_callbacks_id_); | 161 DCHECK_NE(kNoDatabaseCallbacks, ipc_database_callbacks_id_); |
| 163 | 162 |
| 164 dispatcher_host_->RegisterTransactionId(host_transaction_id_, origin_url_); | 163 dispatcher_host_->RegisterTransactionId(host_transaction_id_, origin_url_); |
| 165 int32 ipc_database_id = | 164 int32_t ipc_database_id = |
| 166 dispatcher_host_->Add(connection.release(), ipc_thread_id_, origin_url_); | 165 dispatcher_host_->Add(connection.release(), ipc_thread_id_, origin_url_); |
| 167 if (ipc_database_id < 0) | 166 if (ipc_database_id < 0) |
| 168 return; | 167 return; |
| 169 ipc_database_id_ = ipc_database_id; | 168 ipc_database_id_ = ipc_database_id; |
| 170 IndexedDBMsg_CallbacksUpgradeNeeded_Params params; | 169 IndexedDBMsg_CallbacksUpgradeNeeded_Params params; |
| 171 params.ipc_thread_id = ipc_thread_id_; | 170 params.ipc_thread_id = ipc_thread_id_; |
| 172 params.ipc_callbacks_id = ipc_callbacks_id_; | 171 params.ipc_callbacks_id = ipc_callbacks_id_; |
| 173 params.ipc_database_id = ipc_database_id; | 172 params.ipc_database_id = ipc_database_id; |
| 174 params.ipc_database_callbacks_id = ipc_database_callbacks_id_; | 173 params.ipc_database_callbacks_id = ipc_database_callbacks_id_; |
| 175 params.old_version = old_version; | 174 params.old_version = old_version; |
| (...skipping 14 matching lines...) Expand all Loading... |
| 190 const IndexedDBDatabaseMetadata& metadata) { | 189 const IndexedDBDatabaseMetadata& metadata) { |
| 191 DCHECK(dispatcher_host_.get()); | 190 DCHECK(dispatcher_host_.get()); |
| 192 | 191 |
| 193 DCHECK_EQ(kNoCursor, ipc_cursor_id_); | 192 DCHECK_EQ(kNoCursor, ipc_cursor_id_); |
| 194 DCHECK_NE(kNoTransaction, host_transaction_id_); | 193 DCHECK_NE(kNoTransaction, host_transaction_id_); |
| 195 DCHECK_NE(ipc_database_id_ == kNoDatabase, !connection); | 194 DCHECK_NE(ipc_database_id_ == kNoDatabase, !connection); |
| 196 DCHECK_NE(kNoDatabaseCallbacks, ipc_database_callbacks_id_); | 195 DCHECK_NE(kNoDatabaseCallbacks, ipc_database_callbacks_id_); |
| 197 | 196 |
| 198 scoped_refptr<IndexedDBCallbacks> self(this); | 197 scoped_refptr<IndexedDBCallbacks> self(this); |
| 199 | 198 |
| 200 int32 ipc_object_id = kNoDatabase; | 199 int32_t ipc_object_id = kNoDatabase; |
| 201 // Only register if the connection was not previously sent in OnUpgradeNeeded. | 200 // Only register if the connection was not previously sent in OnUpgradeNeeded. |
| 202 if (ipc_database_id_ == kNoDatabase) { | 201 if (ipc_database_id_ == kNoDatabase) { |
| 203 ipc_object_id = dispatcher_host_->Add( | 202 ipc_object_id = dispatcher_host_->Add( |
| 204 connection.release(), ipc_thread_id_, origin_url_); | 203 connection.release(), ipc_thread_id_, origin_url_); |
| 205 } | 204 } |
| 206 | 205 |
| 207 dispatcher_host_->Send(new IndexedDBMsg_CallbacksSuccessIDBDatabase( | 206 dispatcher_host_->Send(new IndexedDBMsg_CallbacksSuccessIDBDatabase( |
| 208 ipc_thread_id_, | 207 ipc_thread_id_, |
| 209 ipc_callbacks_id_, | 208 ipc_callbacks_id_, |
| 210 ipc_database_callbacks_id_, | 209 ipc_database_callbacks_id_, |
| (...skipping 130 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 341 const IndexedDBKey& primary_key, | 340 const IndexedDBKey& primary_key, |
| 342 IndexedDBValue* value) { | 341 IndexedDBValue* value) { |
| 343 DCHECK(dispatcher_host_.get()); | 342 DCHECK(dispatcher_host_.get()); |
| 344 | 343 |
| 345 DCHECK_EQ(kNoCursor, ipc_cursor_id_); | 344 DCHECK_EQ(kNoCursor, ipc_cursor_id_); |
| 346 DCHECK_EQ(kNoTransaction, host_transaction_id_); | 345 DCHECK_EQ(kNoTransaction, host_transaction_id_); |
| 347 DCHECK_EQ(kNoDatabase, ipc_database_id_); | 346 DCHECK_EQ(kNoDatabase, ipc_database_id_); |
| 348 DCHECK_EQ(kNoDatabaseCallbacks, ipc_database_callbacks_id_); | 347 DCHECK_EQ(kNoDatabaseCallbacks, ipc_database_callbacks_id_); |
| 349 DCHECK_EQ(blink::WebIDBDataLossNone, data_loss_); | 348 DCHECK_EQ(blink::WebIDBDataLossNone, data_loss_); |
| 350 | 349 |
| 351 int32 ipc_object_id = dispatcher_host_->Add(cursor.get()); | 350 int32_t ipc_object_id = dispatcher_host_->Add(cursor.get()); |
| 352 scoped_ptr<IndexedDBMsg_CallbacksSuccessIDBCursor_Params> params( | 351 scoped_ptr<IndexedDBMsg_CallbacksSuccessIDBCursor_Params> params( |
| 353 new IndexedDBMsg_CallbacksSuccessIDBCursor_Params()); | 352 new IndexedDBMsg_CallbacksSuccessIDBCursor_Params()); |
| 354 params->ipc_thread_id = ipc_thread_id_; | 353 params->ipc_thread_id = ipc_thread_id_; |
| 355 params->ipc_callbacks_id = ipc_callbacks_id_; | 354 params->ipc_callbacks_id = ipc_callbacks_id_; |
| 356 params->ipc_cursor_id = ipc_object_id; | 355 params->ipc_cursor_id = ipc_object_id; |
| 357 params->key = key; | 356 params->key = key; |
| 358 params->primary_key = primary_key; | 357 params->primary_key = primary_key; |
| 359 if (value && !value->empty()) | 358 if (value && !value->empty()) |
| 360 std::swap(params->value.bits, value->bits); | 359 std::swap(params->value.bits, value->bits); |
| 361 // TODO(alecflett): Avoid a copy here: the whole params object is | 360 // TODO(alecflett): Avoid a copy here: the whole params object is |
| (...skipping 212 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 574 DCHECK_EQ(kNoTransaction, host_transaction_id_); | 573 DCHECK_EQ(kNoTransaction, host_transaction_id_); |
| 575 DCHECK_EQ(kNoDatabase, ipc_database_id_); | 574 DCHECK_EQ(kNoDatabase, ipc_database_id_); |
| 576 DCHECK_EQ(kNoDatabaseCallbacks, ipc_database_callbacks_id_); | 575 DCHECK_EQ(kNoDatabaseCallbacks, ipc_database_callbacks_id_); |
| 577 DCHECK_EQ(blink::WebIDBDataLossNone, data_loss_); | 576 DCHECK_EQ(blink::WebIDBDataLossNone, data_loss_); |
| 578 | 577 |
| 579 dispatcher_host_->Send(new IndexedDBMsg_CallbacksSuccessIndexedDBKey( | 578 dispatcher_host_->Send(new IndexedDBMsg_CallbacksSuccessIndexedDBKey( |
| 580 ipc_thread_id_, ipc_callbacks_id_, value)); | 579 ipc_thread_id_, ipc_callbacks_id_, value)); |
| 581 dispatcher_host_ = NULL; | 580 dispatcher_host_ = NULL; |
| 582 } | 581 } |
| 583 | 582 |
| 584 void IndexedDBCallbacks::OnSuccess(int64 value) { | 583 void IndexedDBCallbacks::OnSuccess(int64_t value) { |
| 585 DCHECK(dispatcher_host_.get()); | 584 DCHECK(dispatcher_host_.get()); |
| 586 | 585 |
| 587 DCHECK_EQ(kNoCursor, ipc_cursor_id_); | 586 DCHECK_EQ(kNoCursor, ipc_cursor_id_); |
| 588 DCHECK_EQ(kNoTransaction, host_transaction_id_); | 587 DCHECK_EQ(kNoTransaction, host_transaction_id_); |
| 589 DCHECK_EQ(kNoDatabase, ipc_database_id_); | 588 DCHECK_EQ(kNoDatabase, ipc_database_id_); |
| 590 DCHECK_EQ(kNoDatabaseCallbacks, ipc_database_callbacks_id_); | 589 DCHECK_EQ(kNoDatabaseCallbacks, ipc_database_callbacks_id_); |
| 591 DCHECK_EQ(blink::WebIDBDataLossNone, data_loss_); | 590 DCHECK_EQ(blink::WebIDBDataLossNone, data_loss_); |
| 592 | 591 |
| 593 dispatcher_host_->Send(new IndexedDBMsg_CallbacksSuccessInteger( | 592 dispatcher_host_->Send(new IndexedDBMsg_CallbacksSuccessInteger( |
| 594 ipc_thread_id_, ipc_callbacks_id_, value)); | 593 ipc_thread_id_, ipc_callbacks_id_, value)); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 608 ipc_thread_id_, ipc_callbacks_id_)); | 607 ipc_thread_id_, ipc_callbacks_id_)); |
| 609 dispatcher_host_ = NULL; | 608 dispatcher_host_ = NULL; |
| 610 } | 609 } |
| 611 | 610 |
| 612 void IndexedDBCallbacks::SetConnectionOpenStartTime( | 611 void IndexedDBCallbacks::SetConnectionOpenStartTime( |
| 613 const base::TimeTicks& start_time) { | 612 const base::TimeTicks& start_time) { |
| 614 connection_open_start_time_ = start_time; | 613 connection_open_start_time_ = start_time; |
| 615 } | 614 } |
| 616 | 615 |
| 617 } // namespace content | 616 } // namespace content |
| OLD | NEW |