| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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_cursor_impl.h" | 5 #include "content/browser/indexed_db/indexed_db_cursor.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "content/browser/indexed_db/indexed_db_backing_store.h" | 8 #include "content/browser/indexed_db/indexed_db_backing_store.h" |
| 9 #include "content/browser/indexed_db/indexed_db_callbacks_wrapper.h" | 9 #include "content/browser/indexed_db/indexed_db_callbacks_wrapper.h" |
| 10 #include "content/browser/indexed_db/indexed_db_database.h" |
| 10 #include "content/browser/indexed_db/indexed_db_database_error.h" | 11 #include "content/browser/indexed_db/indexed_db_database_error.h" |
| 11 #include "content/browser/indexed_db/indexed_db_database_impl.h" | |
| 12 #include "content/browser/indexed_db/indexed_db_tracing.h" | 12 #include "content/browser/indexed_db/indexed_db_tracing.h" |
| 13 #include "content/browser/indexed_db/indexed_db_transaction.h" | 13 #include "content/browser/indexed_db/indexed_db_transaction.h" |
| 14 #include "content/common/indexed_db/indexed_db_key_range.h" | 14 #include "content/common/indexed_db/indexed_db_key_range.h" |
| 15 | 15 |
| 16 namespace content { | 16 namespace content { |
| 17 | 17 |
| 18 class IndexedDBCursorImpl::CursorIterationOperation | 18 class IndexedDBCursor::CursorIterationOperation |
| 19 : public IndexedDBTransaction::Operation { | 19 : public IndexedDBTransaction::Operation { |
| 20 public: | 20 public: |
| 21 CursorIterationOperation(scoped_refptr<IndexedDBCursorImpl> cursor, | 21 CursorIterationOperation(scoped_refptr<IndexedDBCursor> cursor, |
| 22 scoped_ptr<IndexedDBKey> key, | 22 scoped_ptr<IndexedDBKey> key, |
| 23 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) | 23 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) |
| 24 : cursor_(cursor), key_(key.Pass()), callbacks_(callbacks) {} | 24 : cursor_(cursor), key_(key.Pass()), callbacks_(callbacks) {} |
| 25 virtual void Perform(IndexedDBTransaction* transaction) OVERRIDE; | 25 virtual void Perform(IndexedDBTransaction* transaction) OVERRIDE; |
| 26 | 26 |
| 27 private: | 27 private: |
| 28 scoped_refptr<IndexedDBCursorImpl> cursor_; | 28 scoped_refptr<IndexedDBCursor> cursor_; |
| 29 scoped_ptr<IndexedDBKey> key_; | 29 scoped_ptr<IndexedDBKey> key_; |
| 30 scoped_refptr<IndexedDBCallbacksWrapper> callbacks_; | 30 scoped_refptr<IndexedDBCallbacksWrapper> callbacks_; |
| 31 }; | 31 }; |
| 32 | 32 |
| 33 class IndexedDBCursorImpl::CursorAdvanceOperation | 33 class IndexedDBCursor::CursorAdvanceOperation |
| 34 : public IndexedDBTransaction::Operation { | 34 : public IndexedDBTransaction::Operation { |
| 35 public: | 35 public: |
| 36 CursorAdvanceOperation(scoped_refptr<IndexedDBCursorImpl> cursor, | 36 CursorAdvanceOperation(scoped_refptr<IndexedDBCursor> cursor, |
| 37 uint32 count, | 37 uint32 count, |
| 38 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) | 38 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) |
| 39 : cursor_(cursor), count_(count), callbacks_(callbacks) {} | 39 : cursor_(cursor), count_(count), callbacks_(callbacks) {} |
| 40 virtual void Perform(IndexedDBTransaction* transaction) OVERRIDE; | 40 virtual void Perform(IndexedDBTransaction* transaction) OVERRIDE; |
| 41 | 41 |
| 42 private: | 42 private: |
| 43 scoped_refptr<IndexedDBCursorImpl> cursor_; | 43 scoped_refptr<IndexedDBCursor> cursor_; |
| 44 uint32 count_; | 44 uint32 count_; |
| 45 scoped_refptr<IndexedDBCallbacksWrapper> callbacks_; | 45 scoped_refptr<IndexedDBCallbacksWrapper> callbacks_; |
| 46 }; | 46 }; |
| 47 | 47 |
| 48 class IndexedDBCursorImpl::CursorPrefetchIterationOperation | 48 class IndexedDBCursor::CursorPrefetchIterationOperation |
| 49 : public IndexedDBTransaction::Operation { | 49 : public IndexedDBTransaction::Operation { |
| 50 public: | 50 public: |
| 51 CursorPrefetchIterationOperation( | 51 CursorPrefetchIterationOperation( |
| 52 scoped_refptr<IndexedDBCursorImpl> cursor, | 52 scoped_refptr<IndexedDBCursor> cursor, |
| 53 int number_to_fetch, | 53 int number_to_fetch, |
| 54 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) | 54 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) |
| 55 : cursor_(cursor), | 55 : cursor_(cursor), |
| 56 number_to_fetch_(number_to_fetch), | 56 number_to_fetch_(number_to_fetch), |
| 57 callbacks_(callbacks) {} | 57 callbacks_(callbacks) {} |
| 58 virtual void Perform(IndexedDBTransaction* transaction) OVERRIDE; | 58 virtual void Perform(IndexedDBTransaction* transaction) OVERRIDE; |
| 59 | 59 |
| 60 private: | 60 private: |
| 61 scoped_refptr<IndexedDBCursorImpl> cursor_; | 61 scoped_refptr<IndexedDBCursor> cursor_; |
| 62 int number_to_fetch_; | 62 int number_to_fetch_; |
| 63 scoped_refptr<IndexedDBCallbacksWrapper> callbacks_; | 63 scoped_refptr<IndexedDBCallbacksWrapper> callbacks_; |
| 64 }; | 64 }; |
| 65 | 65 |
| 66 IndexedDBCursorImpl::IndexedDBCursorImpl( | 66 IndexedDBCursor::IndexedDBCursor( |
| 67 scoped_ptr<IndexedDBBackingStore::Cursor> cursor, | 67 scoped_ptr<IndexedDBBackingStore::Cursor> cursor, |
| 68 indexed_db::CursorType cursor_type, | 68 indexed_db::CursorType cursor_type, |
| 69 IndexedDBDatabase::TaskType task_type, | 69 IndexedDBDatabase::TaskType task_type, |
| 70 IndexedDBTransaction* transaction) | 70 IndexedDBTransaction* transaction) |
| 71 : task_type_(task_type), | 71 : task_type_(task_type), |
| 72 cursor_type_(cursor_type), | 72 cursor_type_(cursor_type), |
| 73 transaction_(transaction), | 73 transaction_(transaction), |
| 74 cursor_(cursor.Pass()), | 74 cursor_(cursor.Pass()), |
| 75 closed_(false) { | 75 closed_(false) { |
| 76 transaction_->RegisterOpenCursor(this); | 76 transaction_->RegisterOpenCursor(this); |
| 77 } | 77 } |
| 78 | 78 |
| 79 IndexedDBCursorImpl::~IndexedDBCursorImpl() { | 79 IndexedDBCursor::~IndexedDBCursor() { |
| 80 transaction_->UnregisterOpenCursor(this); | 80 transaction_->UnregisterOpenCursor(this); |
| 81 } | 81 } |
| 82 | 82 |
| 83 void IndexedDBCursorImpl::ContinueFunction( | 83 void IndexedDBCursor::ContinueFunction( |
| 84 scoped_ptr<IndexedDBKey> key, | 84 scoped_ptr<IndexedDBKey> key, |
| 85 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) { | 85 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) { |
| 86 IDB_TRACE("IndexedDBCursorImpl::continue"); | 86 IDB_TRACE("IndexedDBCursor::continue"); |
| 87 | 87 |
| 88 transaction_->ScheduleTask( | 88 transaction_->ScheduleTask( |
| 89 task_type_, new CursorIterationOperation(this, key.Pass(), callbacks)); | 89 task_type_, new CursorIterationOperation(this, key.Pass(), callbacks)); |
| 90 } | 90 } |
| 91 | 91 |
| 92 void IndexedDBCursorImpl::Advance( | 92 void IndexedDBCursor::Advance( |
| 93 uint32 count, | 93 uint32 count, |
| 94 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) { | 94 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) { |
| 95 IDB_TRACE("IndexedDBCursorImpl::advance"); | 95 IDB_TRACE("IndexedDBCursor::advance"); |
| 96 | 96 |
| 97 transaction_->ScheduleTask( | 97 transaction_->ScheduleTask( |
| 98 new CursorAdvanceOperation(this, count, callbacks)); | 98 new CursorAdvanceOperation(this, count, callbacks)); |
| 99 } | 99 } |
| 100 | 100 |
| 101 void IndexedDBCursorImpl::CursorAdvanceOperation::Perform( | 101 void IndexedDBCursor::CursorAdvanceOperation::Perform( |
| 102 IndexedDBTransaction* /*transaction*/) { | 102 IndexedDBTransaction* /*transaction*/) { |
| 103 IDB_TRACE("CursorAdvanceOperation"); | 103 IDB_TRACE("CursorAdvanceOperation"); |
| 104 if (!cursor_->cursor_ || !cursor_->cursor_->Advance(count_)) { | 104 if (!cursor_->cursor_ || !cursor_->cursor_->Advance(count_)) { |
| 105 cursor_->cursor_.reset(); | 105 cursor_->cursor_.reset(); |
| 106 callbacks_->OnSuccess(static_cast<std::vector<char>*>(NULL)); | 106 callbacks_->OnSuccess(static_cast<std::vector<char>*>(NULL)); |
| 107 return; | 107 return; |
| 108 } | 108 } |
| 109 | 109 |
| 110 callbacks_->OnSuccess( | 110 callbacks_->OnSuccess( |
| 111 cursor_->key(), cursor_->primary_key(), cursor_->Value()); | 111 cursor_->key(), cursor_->primary_key(), cursor_->Value()); |
| 112 } | 112 } |
| 113 | 113 |
| 114 void IndexedDBCursorImpl::CursorIterationOperation::Perform( | 114 void IndexedDBCursor::CursorIterationOperation::Perform( |
| 115 IndexedDBTransaction* /*transaction*/) { | 115 IndexedDBTransaction* /*transaction*/) { |
| 116 IDB_TRACE("CursorIterationOperation"); | 116 IDB_TRACE("CursorIterationOperation"); |
| 117 if (!cursor_->cursor_ || !cursor_->cursor_->ContinueFunction(key_.get())) { | 117 if (!cursor_->cursor_ || !cursor_->cursor_->ContinueFunction(key_.get())) { |
| 118 cursor_->cursor_.reset(); | 118 cursor_->cursor_.reset(); |
| 119 callbacks_->OnSuccess(static_cast<std::vector<char>*>(NULL)); | 119 callbacks_->OnSuccess(static_cast<std::vector<char>*>(NULL)); |
| 120 return; | 120 return; |
| 121 } | 121 } |
| 122 | 122 |
| 123 callbacks_->OnSuccess( | 123 callbacks_->OnSuccess( |
| 124 cursor_->key(), cursor_->primary_key(), cursor_->Value()); | 124 cursor_->key(), cursor_->primary_key(), cursor_->Value()); |
| 125 } | 125 } |
| 126 | 126 |
| 127 void IndexedDBCursorImpl::PrefetchContinue( | 127 void IndexedDBCursor::PrefetchContinue( |
| 128 int number_to_fetch, | 128 int number_to_fetch, |
| 129 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) { | 129 scoped_refptr<IndexedDBCallbacksWrapper> callbacks) { |
| 130 IDB_TRACE("IndexedDBCursorImpl::prefetch_continue"); | 130 IDB_TRACE("IndexedDBCursor::prefetch_continue"); |
| 131 | 131 |
| 132 transaction_->ScheduleTask( | 132 transaction_->ScheduleTask( |
| 133 task_type_, | 133 task_type_, |
| 134 new CursorPrefetchIterationOperation(this, number_to_fetch, callbacks)); | 134 new CursorPrefetchIterationOperation(this, number_to_fetch, callbacks)); |
| 135 } | 135 } |
| 136 | 136 |
| 137 void IndexedDBCursorImpl::CursorPrefetchIterationOperation::Perform( | 137 void IndexedDBCursor::CursorPrefetchIterationOperation::Perform( |
| 138 IndexedDBTransaction* /*transaction*/) { | 138 IndexedDBTransaction* /*transaction*/) { |
| 139 IDB_TRACE("CursorPrefetchIterationOperation"); | 139 IDB_TRACE("CursorPrefetchIterationOperation"); |
| 140 | 140 |
| 141 std::vector<IndexedDBKey> found_keys; | 141 std::vector<IndexedDBKey> found_keys; |
| 142 std::vector<IndexedDBKey> found_primary_keys; | 142 std::vector<IndexedDBKey> found_primary_keys; |
| 143 std::vector<std::vector<char> > found_values; | 143 std::vector<std::vector<char> > found_values; |
| 144 | 144 |
| 145 if (cursor_->cursor_) | 145 if (cursor_->cursor_) |
| 146 cursor_->saved_cursor_.reset(cursor_->cursor_->Clone()); | 146 cursor_->saved_cursor_.reset(cursor_->cursor_->Clone()); |
| 147 const size_t max_size_estimate = 10 * 1024 * 1024; | 147 const size_t max_size_estimate = 10 * 1024 * 1024; |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 179 | 179 |
| 180 if (!found_keys.size()) { | 180 if (!found_keys.size()) { |
| 181 callbacks_->OnSuccess(static_cast<std::vector<char>*>(NULL)); | 181 callbacks_->OnSuccess(static_cast<std::vector<char>*>(NULL)); |
| 182 return; | 182 return; |
| 183 } | 183 } |
| 184 | 184 |
| 185 callbacks_->OnSuccessWithPrefetch( | 185 callbacks_->OnSuccessWithPrefetch( |
| 186 found_keys, found_primary_keys, found_values); | 186 found_keys, found_primary_keys, found_values); |
| 187 } | 187 } |
| 188 | 188 |
| 189 void IndexedDBCursorImpl::PrefetchReset(int used_prefetches, int) { | 189 void IndexedDBCursor::PrefetchReset(int used_prefetches, int) { |
| 190 IDB_TRACE("IndexedDBCursorImpl::prefetch_reset"); | 190 IDB_TRACE("IndexedDBCursor::prefetch_reset"); |
| 191 cursor_.swap(saved_cursor_); | 191 cursor_.swap(saved_cursor_); |
| 192 saved_cursor_.reset(); | 192 saved_cursor_.reset(); |
| 193 | 193 |
| 194 if (closed_) | 194 if (closed_) |
| 195 return; | 195 return; |
| 196 if (cursor_) { | 196 if (cursor_) { |
| 197 for (int i = 0; i < used_prefetches; ++i) { | 197 for (int i = 0; i < used_prefetches; ++i) { |
| 198 bool ok = cursor_->ContinueFunction(); | 198 bool ok = cursor_->ContinueFunction(); |
| 199 DCHECK(ok); | 199 DCHECK(ok); |
| 200 } | 200 } |
| 201 } | 201 } |
| 202 } | 202 } |
| 203 | 203 |
| 204 void IndexedDBCursorImpl::Close() { | 204 void IndexedDBCursor::Close() { |
| 205 IDB_TRACE("IndexedDBCursorImpl::close"); | 205 IDB_TRACE("IndexedDBCursor::close"); |
| 206 closed_ = true; | 206 closed_ = true; |
| 207 cursor_.reset(); | 207 cursor_.reset(); |
| 208 saved_cursor_.reset(); | 208 saved_cursor_.reset(); |
| 209 } | 209 } |
| 210 | 210 |
| 211 } // namespace content | 211 } // namespace content |
| OLD | NEW |