Index: content/child/indexed_db/webidbdatabase_impl.cc |
diff --git a/content/child/indexed_db/webidbdatabase_impl.cc b/content/child/indexed_db/webidbdatabase_impl.cc |
deleted file mode 100644 |
index 2a4f8486bc5593027d2a6a6b5e551c71c96996e5..0000000000000000000000000000000000000000 |
--- a/content/child/indexed_db/webidbdatabase_impl.cc |
+++ /dev/null |
@@ -1,329 +0,0 @@ |
-// Copyright 2013 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "content/child/indexed_db/webidbdatabase_impl.h" |
- |
-#include <stddef.h> |
- |
-#include <string> |
-#include <vector> |
- |
-#include "base/stl_util.h" |
-#include "content/child/indexed_db/indexed_db_dispatcher.h" |
-#include "content/child/indexed_db/indexed_db_key_builders.h" |
-#include "content/child/thread_safe_sender.h" |
-#include "content/child/worker_thread_registry.h" |
-#include "content/common/indexed_db/indexed_db_messages.h" |
-#include "third_party/WebKit/public/platform/WebBlobInfo.h" |
-#include "third_party/WebKit/public/platform/WebString.h" |
-#include "third_party/WebKit/public/platform/WebVector.h" |
-#include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBKeyPath.h" |
-#include "third_party/WebKit/public/platform/modules/indexeddb/WebIDBMetadata.h" |
- |
-using blink::WebBlobInfo; |
-using blink::WebIDBCallbacks; |
-using blink::WebIDBCursor; |
-using blink::WebIDBDatabase; |
-using blink::WebIDBDatabaseCallbacks; |
-using blink::WebIDBMetadata; |
-using blink::WebIDBKey; |
-using blink::WebIDBKeyPath; |
-using blink::WebIDBKeyRange; |
-using blink::WebIDBObserver; |
-using blink::WebString; |
-using blink::WebVector; |
- |
-namespace content { |
- |
-WebIDBDatabaseImpl::WebIDBDatabaseImpl(int32_t ipc_database_id, |
- int32_t ipc_database_callbacks_id, |
- ThreadSafeSender* thread_safe_sender) |
- : ipc_database_id_(ipc_database_id), |
- ipc_database_callbacks_id_(ipc_database_callbacks_id), |
- thread_safe_sender_(thread_safe_sender) {} |
- |
-WebIDBDatabaseImpl::~WebIDBDatabaseImpl() { |
- // It's not possible for there to be pending callbacks that address this |
- // object since inside WebKit, they hold a reference to the object which owns |
- // this object. But, if that ever changed, then we'd need to invalidate |
- // any such pointers. |
- thread_safe_sender_->Send( |
- new IndexedDBHostMsg_DatabaseDestroyed(ipc_database_id_)); |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->DatabaseDestroyed(ipc_database_id_); |
-} |
- |
-void WebIDBDatabaseImpl::createObjectStore(long long transaction_id, |
- long long object_store_id, |
- const WebString& name, |
- const WebIDBKeyPath& key_path, |
- bool auto_increment) { |
- IndexedDBHostMsg_DatabaseCreateObjectStore_Params params; |
- params.ipc_database_id = ipc_database_id_; |
- params.transaction_id = transaction_id; |
- params.object_store_id = object_store_id; |
- params.name = name; |
- params.key_path = IndexedDBKeyPathBuilder::Build(key_path); |
- params.auto_increment = auto_increment; |
- |
- thread_safe_sender_->Send( |
- new IndexedDBHostMsg_DatabaseCreateObjectStore(params)); |
-} |
- |
-void WebIDBDatabaseImpl::deleteObjectStore(long long transaction_id, |
- long long object_store_id) { |
- thread_safe_sender_->Send(new IndexedDBHostMsg_DatabaseDeleteObjectStore( |
- ipc_database_id_, transaction_id, object_store_id)); |
-} |
- |
-void WebIDBDatabaseImpl::createTransaction( |
- long long transaction_id, |
- WebIDBDatabaseCallbacks* callbacks, |
- const WebVector<long long>& object_store_ids, |
- blink::WebIDBTransactionMode mode) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RequestIDBDatabaseCreateTransaction( |
- ipc_database_id_, transaction_id, callbacks, object_store_ids, mode); |
-} |
- |
-void WebIDBDatabaseImpl::close() { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RemoveIDBObservers(observer_ids_); |
- dispatcher->RequestIDBDatabaseClose(ipc_database_id_, |
- ipc_database_callbacks_id_); |
-} |
- |
-void WebIDBDatabaseImpl::versionChangeIgnored() { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->NotifyIDBDatabaseVersionChangeIgnored(ipc_database_id_); |
-} |
- |
-int32_t WebIDBDatabaseImpl::addObserver( |
- std::unique_ptr<WebIDBObserver> observer, |
- long long transaction_id) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- |
- int32_t observer_id = dispatcher->AddIDBObserver( |
- ipc_database_id_, transaction_id, std::move(observer)); |
- observer_ids_.insert(observer_id); |
- return observer_id; |
-} |
- |
-void WebIDBDatabaseImpl::removeObservers( |
- const WebVector<int32_t>& observer_ids_to_remove) { |
- std::vector<int32_t> remove_observer_ids( |
- observer_ids_to_remove.data(), |
- observer_ids_to_remove.data() + observer_ids_to_remove.size()); |
- for (int32_t id : observer_ids_to_remove) |
- observer_ids_.erase(id); |
- |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RemoveIDBObserversFromDatabase(ipc_database_id_, |
- remove_observer_ids); |
-} |
- |
-void WebIDBDatabaseImpl::get(long long transaction_id, |
- long long object_store_id, |
- long long index_id, |
- const WebIDBKeyRange& key_range, |
- bool key_only, |
- WebIDBCallbacks* callbacks) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RequestIDBDatabaseGet(ipc_database_id_, |
- transaction_id, |
- object_store_id, |
- index_id, |
- IndexedDBKeyRangeBuilder::Build(key_range), |
- key_only, |
- callbacks); |
-} |
- |
-void WebIDBDatabaseImpl::getAll(long long transaction_id, |
- long long object_store_id, |
- long long index_id, |
- const WebIDBKeyRange& key_range, |
- long long max_count, |
- bool key_only, |
- WebIDBCallbacks* callbacks) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RequestIDBDatabaseGetAll( |
- ipc_database_id_, transaction_id, object_store_id, index_id, |
- IndexedDBKeyRangeBuilder::Build(key_range), key_only, max_count, |
- callbacks); |
-} |
- |
-void WebIDBDatabaseImpl::put(long long transaction_id, |
- long long object_store_id, |
- const blink::WebData& value, |
- const blink::WebVector<WebBlobInfo>& web_blob_info, |
- const WebIDBKey& key, |
- blink::WebIDBPutMode put_mode, |
- WebIDBCallbacks* callbacks, |
- const WebVector<long long>& web_index_ids, |
- const WebVector<WebIndexKeys>& web_index_keys) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RequestIDBDatabasePut(ipc_database_id_, |
- transaction_id, |
- object_store_id, |
- value, |
- web_blob_info, |
- IndexedDBKeyBuilder::Build(key), |
- put_mode, |
- callbacks, |
- web_index_ids, |
- web_index_keys); |
-} |
- |
-void WebIDBDatabaseImpl::setIndexKeys( |
- long long transaction_id, |
- long long object_store_id, |
- const WebIDBKey& primary_key, |
- const WebVector<long long>& index_ids, |
- const WebVector<WebIndexKeys>& index_keys) { |
- IndexedDBHostMsg_DatabaseSetIndexKeys_Params params; |
- params.ipc_database_id = ipc_database_id_; |
- params.transaction_id = transaction_id; |
- params.object_store_id = object_store_id; |
- params.primary_key = IndexedDBKeyBuilder::Build(primary_key); |
- |
- DCHECK_EQ(index_ids.size(), index_keys.size()); |
- params.index_keys.resize(index_ids.size()); |
- for (size_t i = 0, len = index_ids.size(); i < len; ++i) { |
- params.index_keys[i].first = index_ids[i]; |
- params.index_keys[i].second.resize(index_keys[i].size()); |
- for (size_t j = 0; j < index_keys[i].size(); ++j) { |
- params.index_keys[i].second[j] = |
- IndexedDBKey(IndexedDBKeyBuilder::Build(index_keys[i][j])); |
- } |
- } |
- |
- thread_safe_sender_->Send(new IndexedDBHostMsg_DatabaseSetIndexKeys(params)); |
-} |
- |
-void WebIDBDatabaseImpl::setIndexesReady( |
- long long transaction_id, |
- long long object_store_id, |
- const WebVector<long long>& web_index_ids) { |
- std::vector<int64_t> index_ids(web_index_ids.data(), |
- web_index_ids.data() + web_index_ids.size()); |
- thread_safe_sender_->Send(new IndexedDBHostMsg_DatabaseSetIndexesReady( |
- ipc_database_id_, transaction_id, object_store_id, index_ids)); |
-} |
- |
-void WebIDBDatabaseImpl::openCursor(long long transaction_id, |
- long long object_store_id, |
- long long index_id, |
- const WebIDBKeyRange& key_range, |
- blink::WebIDBCursorDirection direction, |
- bool key_only, |
- blink::WebIDBTaskType task_type, |
- WebIDBCallbacks* callbacks) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RequestIDBDatabaseOpenCursor( |
- ipc_database_id_, |
- transaction_id, |
- object_store_id, |
- index_id, |
- IndexedDBKeyRangeBuilder::Build(key_range), |
- direction, |
- key_only, |
- task_type, |
- callbacks); |
-} |
- |
-void WebIDBDatabaseImpl::count(long long transaction_id, |
- long long object_store_id, |
- long long index_id, |
- const WebIDBKeyRange& key_range, |
- WebIDBCallbacks* callbacks) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RequestIDBDatabaseCount( |
- ipc_database_id_, |
- transaction_id, |
- object_store_id, |
- index_id, |
- IndexedDBKeyRangeBuilder::Build(key_range), |
- callbacks); |
-} |
- |
-void WebIDBDatabaseImpl::deleteRange(long long transaction_id, |
- long long object_store_id, |
- const WebIDBKeyRange& key_range, |
- WebIDBCallbacks* callbacks) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RequestIDBDatabaseDeleteRange( |
- ipc_database_id_, |
- transaction_id, |
- object_store_id, |
- IndexedDBKeyRangeBuilder::Build(key_range), |
- callbacks); |
-} |
- |
-void WebIDBDatabaseImpl::clear(long long transaction_id, |
- long long object_store_id, |
- WebIDBCallbacks* callbacks) { |
- IndexedDBDispatcher* dispatcher = |
- IndexedDBDispatcher::ThreadSpecificInstance(thread_safe_sender_.get()); |
- dispatcher->RequestIDBDatabaseClear( |
- ipc_database_id_, transaction_id, object_store_id, callbacks); |
-} |
- |
-void WebIDBDatabaseImpl::createIndex(long long transaction_id, |
- long long object_store_id, |
- long long index_id, |
- const WebString& name, |
- const WebIDBKeyPath& key_path, |
- bool unique, |
- bool multi_entry) { |
- IndexedDBHostMsg_DatabaseCreateIndex_Params params; |
- params.ipc_database_id = ipc_database_id_; |
- params.transaction_id = transaction_id; |
- params.object_store_id = object_store_id; |
- params.index_id = index_id; |
- params.name = name; |
- params.key_path = IndexedDBKeyPathBuilder::Build(key_path); |
- params.unique = unique; |
- params.multi_entry = multi_entry; |
- |
- thread_safe_sender_->Send(new IndexedDBHostMsg_DatabaseCreateIndex(params)); |
-} |
- |
-void WebIDBDatabaseImpl::deleteIndex(long long transaction_id, |
- long long object_store_id, |
- long long index_id) { |
- thread_safe_sender_->Send(new IndexedDBHostMsg_DatabaseDeleteIndex( |
- ipc_database_id_, transaction_id, object_store_id, index_id)); |
-} |
- |
-void WebIDBDatabaseImpl::abort(long long transaction_id) { |
- thread_safe_sender_->Send( |
- new IndexedDBHostMsg_DatabaseAbort(ipc_database_id_, transaction_id)); |
-} |
- |
-void WebIDBDatabaseImpl::commit(long long transaction_id) { |
- thread_safe_sender_->Send( |
- new IndexedDBHostMsg_DatabaseCommit(ipc_database_id_, transaction_id)); |
-} |
- |
-void WebIDBDatabaseImpl::ackReceivedBlobs(const WebVector<WebString>& uuids) { |
- DCHECK(uuids.size()); |
- std::vector<std::string> param(uuids.size()); |
- for (size_t i = 0; i < uuids.size(); ++i) |
- param[i] = uuids[i].latin1().data(); |
- thread_safe_sender_->Send(new IndexedDBHostMsg_AckReceivedBlobs(param)); |
-} |
- |
-} // namespace content |