| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (C) 2012 Google Inc. All rights reserved. | 2 * Copyright (C) 2012 Google Inc. All rights reserved. |
| 3 * | 3 * |
| 4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
| 5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
| 6 * met: | 6 * met: |
| 7 * | 7 * |
| 8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
| 9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
| 10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
| (...skipping 59 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 70 using blink::protocol::IndexedDB::KeyRange; | 70 using blink::protocol::IndexedDB::KeyRange; |
| 71 using blink::protocol::IndexedDB::ObjectStore; | 71 using blink::protocol::IndexedDB::ObjectStore; |
| 72 using blink::protocol::IndexedDB::ObjectStoreIndex; | 72 using blink::protocol::IndexedDB::ObjectStoreIndex; |
| 73 | 73 |
| 74 typedef blink::protocol::BackendCallback RequestCallback; | 74 typedef blink::protocol::BackendCallback RequestCallback; |
| 75 typedef blink::protocol::IndexedDB::Backend::RequestDatabaseNamesCallback Reques
tDatabaseNamesCallback; | 75 typedef blink::protocol::IndexedDB::Backend::RequestDatabaseNamesCallback Reques
tDatabaseNamesCallback; |
| 76 typedef blink::protocol::IndexedDB::Backend::RequestDatabaseCallback RequestData
baseCallback; | 76 typedef blink::protocol::IndexedDB::Backend::RequestDatabaseCallback RequestData
baseCallback; |
| 77 typedef blink::protocol::IndexedDB::Backend::RequestDataCallback RequestDataCall
back; | 77 typedef blink::protocol::IndexedDB::Backend::RequestDataCallback RequestDataCall
back; |
| 78 typedef blink::protocol::IndexedDB::Backend::ClearObjectStoreCallback ClearObjec
tStoreCallback; | 78 typedef blink::protocol::IndexedDB::Backend::ClearObjectStoreCallback ClearObjec
tStoreCallback; |
| 79 | 79 |
| 80 using indexed_db::mojom::blink::CursorDirection; |
| 81 |
| 80 namespace blink { | 82 namespace blink { |
| 81 | 83 |
| 82 namespace IndexedDBAgentState { | 84 namespace IndexedDBAgentState { |
| 83 static const char indexedDBAgentEnabled[] = "indexedDBAgentEnabled"; | 85 static const char indexedDBAgentEnabled[] = "indexedDBAgentEnabled"; |
| 84 }; | 86 }; |
| 85 | 87 |
| 86 namespace { | 88 namespace { |
| 87 | 89 |
| 88 class GetDatabaseNamesCallback final : public EventListener { | 90 class GetDatabaseNamesCallback final : public EventListener { |
| 89 WTF_MAKE_NONCOPYABLE(GetDatabaseNamesCallback); | 91 WTF_MAKE_NONCOPYABLE(GetDatabaseNamesCallback); |
| (...skipping 443 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 533 } | 535 } |
| 534 | 536 |
| 535 IDBRequest* idbRequest; | 537 IDBRequest* idbRequest; |
| 536 if (!m_indexName.isEmpty()) { | 538 if (!m_indexName.isEmpty()) { |
| 537 IDBIndex* idbIndex = indexForObjectStore(idbObjectStore, m_indexName
); | 539 IDBIndex* idbIndex = indexForObjectStore(idbObjectStore, m_indexName
); |
| 538 if (!idbIndex) { | 540 if (!idbIndex) { |
| 539 m_requestCallback->sendFailure("Could not get index"); | 541 m_requestCallback->sendFailure("Could not get index"); |
| 540 return; | 542 return; |
| 541 } | 543 } |
| 542 | 544 |
| 543 idbRequest = idbIndex->openCursor(getScriptState(), m_idbKeyRange.ge
t(), WebIDBCursorDirectionNext); | 545 idbRequest = idbIndex->openCursor(getScriptState(), m_idbKeyRange.ge
t(), CursorDirection::Next); |
| 544 } else { | 546 } else { |
| 545 idbRequest = idbObjectStore->openCursor(getScriptState(), m_idbKeyRa
nge.get(), WebIDBCursorDirectionNext); | 547 idbRequest = idbObjectStore->openCursor(getScriptState(), m_idbKeyRa
nge.get(), CursorDirection::Next); |
| 546 } | 548 } |
| 547 OpenCursorCallback* openCursorCallback = OpenCursorCallback::create(getS
criptState(), std::move(m_requestCallback), m_skipCount, m_pageSize); | 549 OpenCursorCallback* openCursorCallback = OpenCursorCallback::create(getS
criptState(), std::move(m_requestCallback), m_skipCount, m_pageSize); |
| 548 idbRequest->addEventListener(EventTypeNames::success, openCursorCallback
, false); | 550 idbRequest->addEventListener(EventTypeNames::success, openCursorCallback
, false); |
| 549 } | 551 } |
| 550 | 552 |
| 551 RequestCallback* getRequestCallback() override { return m_requestCallback.ge
t(); } | 553 RequestCallback* getRequestCallback() override { return m_requestCallback.ge
t(); } |
| 552 DataLoader(ScriptState* scriptState, std::unique_ptr<RequestDataCallback> re
questCallback, const String& objectStoreName, const String& indexName, IDBKeyRan
ge* idbKeyRange, int skipCount, unsigned pageSize) | 554 DataLoader(ScriptState* scriptState, std::unique_ptr<RequestDataCallback> re
questCallback, const String& objectStoreName, const String& indexName, IDBKeyRan
ge* idbKeyRange, int skipCount, unsigned pageSize) |
| 553 : ExecutableWithDatabase(scriptState) | 555 : ExecutableWithDatabase(scriptState) |
| 554 , m_requestCallback(std::move(requestCallback)) | 556 , m_requestCallback(std::move(requestCallback)) |
| 555 , m_objectStoreName(objectStoreName) | 557 , m_objectStoreName(objectStoreName) |
| (...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 804 clearObjectStore->start(idbFactory, document->getSecurityOrigin(), databaseN
ame); | 806 clearObjectStore->start(idbFactory, document->getSecurityOrigin(), databaseN
ame); |
| 805 } | 807 } |
| 806 | 808 |
| 807 DEFINE_TRACE(InspectorIndexedDBAgent) | 809 DEFINE_TRACE(InspectorIndexedDBAgent) |
| 808 { | 810 { |
| 809 visitor->trace(m_inspectedFrames); | 811 visitor->trace(m_inspectedFrames); |
| 810 InspectorBaseAgent::trace(visitor); | 812 InspectorBaseAgent::trace(visitor); |
| 811 } | 813 } |
| 812 | 814 |
| 813 } // namespace blink | 815 } // namespace blink |
| OLD | NEW |