OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2013 Apple Inc. All rights reserved. | 2 * Copyright (C) 2013 Apple 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 | 5 * modification, are permitted provided that the following conditions |
6 * are met: | 6 * are met: |
7 * 1. Redistributions of source code must retain the above copyright | 7 * 1. Redistributions of source code must retain the above copyright |
8 * notice, this list of conditions and the following disclaimer. | 8 * notice, this list of conditions and the following disclaimer. |
9 * 2. Redistributions in binary form must reproduce the above copyright | 9 * 2. Redistributions in binary form must reproduce the above copyright |
10 * notice, this list of conditions and the following disclaimer in the | 10 * notice, this list of conditions and the following disclaimer in the |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
48 #include "modules/webdatabase/SQLTransactionErrorCallback.h" | 48 #include "modules/webdatabase/SQLTransactionErrorCallback.h" |
49 #include "modules/webdatabase/sqlite/SQLiteStatement.h" | 49 #include "modules/webdatabase/sqlite/SQLiteStatement.h" |
50 #include "modules/webdatabase/sqlite/SQLiteTransaction.h" | 50 #include "modules/webdatabase/sqlite/SQLiteTransaction.h" |
51 #include "platform/Logging.h" | 51 #include "platform/Logging.h" |
52 #include "platform/heap/SafePoint.h" | 52 #include "platform/heap/SafePoint.h" |
53 #include "public/platform/Platform.h" | 53 #include "public/platform/Platform.h" |
54 #include "public/platform/WebDatabaseObserver.h" | 54 #include "public/platform/WebDatabaseObserver.h" |
55 #include "public/platform/WebSecurityOrigin.h" | 55 #include "public/platform/WebSecurityOrigin.h" |
56 #include "wtf/Atomics.h" | 56 #include "wtf/Atomics.h" |
57 #include "wtf/CurrentTime.h" | 57 #include "wtf/CurrentTime.h" |
| 58 #include <memory> |
58 | 59 |
59 // Registering "opened" databases with the DatabaseTracker | 60 // Registering "opened" databases with the DatabaseTracker |
60 // ======================================================= | 61 // ======================================================= |
61 // The DatabaseTracker maintains a list of databases that have been | 62 // The DatabaseTracker maintains a list of databases that have been |
62 // "opened" so that the client can call interrupt or delete on every database | 63 // "opened" so that the client can call interrupt or delete on every database |
63 // associated with a DatabaseContext. | 64 // associated with a DatabaseContext. |
64 // | 65 // |
65 // We will only call DatabaseTracker::addOpenDatabase() to add the database | 66 // We will only call DatabaseTracker::addOpenDatabase() to add the database |
66 // to the tracker as opened when we've succeeded in opening the database, | 67 // to the tracker as opened when we've succeeded in opening the database, |
67 // and will set m_opened to true. Similarly, we only call | 68 // and will set m_opened to true. Similarly, we only call |
(...skipping 190 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
258 } | 259 } |
259 | 260 |
260 bool Database::openAndVerifyVersion(bool setVersionInNewDatabase, DatabaseError&
error, String& errorMessage) | 261 bool Database::openAndVerifyVersion(bool setVersionInNewDatabase, DatabaseError&
error, String& errorMessage) |
261 { | 262 { |
262 TaskSynchronizer synchronizer; | 263 TaskSynchronizer synchronizer; |
263 if (!getDatabaseContext()->databaseThreadAvailable()) | 264 if (!getDatabaseContext()->databaseThreadAvailable()) |
264 return false; | 265 return false; |
265 | 266 |
266 DatabaseTracker::tracker().prepareToOpenDatabase(this); | 267 DatabaseTracker::tracker().prepareToOpenDatabase(this); |
267 bool success = false; | 268 bool success = false; |
268 OwnPtr<DatabaseOpenTask> task = DatabaseOpenTask::create(this, setVersionInN
ewDatabase, &synchronizer, error, errorMessage, success); | 269 std::unique_ptr<DatabaseOpenTask> task = DatabaseOpenTask::create(this, setV
ersionInNewDatabase, &synchronizer, error, errorMessage, success); |
269 getDatabaseContext()->databaseThread()->scheduleTask(std::move(task)); | 270 getDatabaseContext()->databaseThread()->scheduleTask(std::move(task)); |
270 synchronizer.waitForTaskCompletion(); | 271 synchronizer.waitForTaskCompletion(); |
271 | 272 |
272 return success; | 273 return success; |
273 } | 274 } |
274 | 275 |
275 void Database::close() | 276 void Database::close() |
276 { | 277 { |
277 ASSERT(getDatabaseContext()->databaseThread()); | 278 ASSERT(getDatabaseContext()->databaseThread()); |
278 ASSERT(getDatabaseContext()->databaseThread()->isDatabaseThread()); | 279 ASSERT(getDatabaseContext()->databaseThread()->isDatabaseThread()); |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
324 | 325 |
325 void Database::scheduleTransaction() | 326 void Database::scheduleTransaction() |
326 { | 327 { |
327 ASSERT(!m_transactionInProgressMutex.tryLock()); // Locked by caller. | 328 ASSERT(!m_transactionInProgressMutex.tryLock()); // Locked by caller. |
328 SQLTransactionBackend* transaction = nullptr; | 329 SQLTransactionBackend* transaction = nullptr; |
329 | 330 |
330 if (m_isTransactionQueueEnabled && !m_transactionQueue.isEmpty()) | 331 if (m_isTransactionQueueEnabled && !m_transactionQueue.isEmpty()) |
331 transaction = m_transactionQueue.takeFirst(); | 332 transaction = m_transactionQueue.takeFirst(); |
332 | 333 |
333 if (transaction && getDatabaseContext()->databaseThreadAvailable()) { | 334 if (transaction && getDatabaseContext()->databaseThreadAvailable()) { |
334 OwnPtr<DatabaseTransactionTask> task = DatabaseTransactionTask::create(t
ransaction); | 335 std::unique_ptr<DatabaseTransactionTask> task = DatabaseTransactionTask:
:create(transaction); |
335 WTF_LOG(StorageAPI, "Scheduling DatabaseTransactionTask %p for transacti
on %p\n", task.get(), task->transaction()); | 336 WTF_LOG(StorageAPI, "Scheduling DatabaseTransactionTask %p for transacti
on %p\n", task.get(), task->transaction()); |
336 m_transactionInProgress = true; | 337 m_transactionInProgress = true; |
337 getDatabaseContext()->databaseThread()->scheduleTask(std::move(task)); | 338 getDatabaseContext()->databaseThread()->scheduleTask(std::move(task)); |
338 } else { | 339 } else { |
339 m_transactionInProgress = false; | 340 m_transactionInProgress = false; |
340 } | 341 } |
341 } | 342 } |
342 | 343 |
343 void Database::scheduleTransactionStep(SQLTransactionBackend* transaction) | 344 void Database::scheduleTransactionStep(SQLTransactionBackend* transaction) |
344 { | 345 { |
345 if (!getDatabaseContext()->databaseThreadAvailable()) | 346 if (!getDatabaseContext()->databaseThreadAvailable()) |
346 return; | 347 return; |
347 | 348 |
348 OwnPtr<DatabaseTransactionTask> task = DatabaseTransactionTask::create(trans
action); | 349 std::unique_ptr<DatabaseTransactionTask> task = DatabaseTransactionTask::cre
ate(transaction); |
349 WTF_LOG(StorageAPI, "Scheduling DatabaseTransactionTask %p for the transacti
on step\n", task.get()); | 350 WTF_LOG(StorageAPI, "Scheduling DatabaseTransactionTask %p for the transacti
on step\n", task.get()); |
350 getDatabaseContext()->databaseThread()->scheduleTask(std::move(task)); | 351 getDatabaseContext()->databaseThread()->scheduleTask(std::move(task)); |
351 } | 352 } |
352 | 353 |
353 SQLTransactionClient* Database::transactionClient() const | 354 SQLTransactionClient* Database::transactionClient() const |
354 { | 355 { |
355 return getDatabaseContext()->databaseThread()->transactionClient(); | 356 return getDatabaseContext()->databaseThread()->transactionClient(); |
356 } | 357 } |
357 | 358 |
358 SQLTransactionCoordinator* Database::transactionCoordinator() const | 359 SQLTransactionCoordinator* Database::transactionCoordinator() const |
(...skipping 443 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
802 } | 803 } |
803 | 804 |
804 void Database::readTransaction( | 805 void Database::readTransaction( |
805 SQLTransactionCallback* callback, | 806 SQLTransactionCallback* callback, |
806 SQLTransactionErrorCallback* errorCallback, | 807 SQLTransactionErrorCallback* errorCallback, |
807 VoidCallback* successCallback) | 808 VoidCallback* successCallback) |
808 { | 809 { |
809 runTransaction(callback, errorCallback, successCallback, true); | 810 runTransaction(callback, errorCallback, successCallback, true); |
810 } | 811 } |
811 | 812 |
812 static void callTransactionErrorCallback(SQLTransactionErrorCallback* callback,
PassOwnPtr<SQLErrorData> errorData) | 813 static void callTransactionErrorCallback(SQLTransactionErrorCallback* callback,
std::unique_ptr<SQLErrorData> errorData) |
813 { | 814 { |
814 callback->handleEvent(SQLError::create(*errorData)); | 815 callback->handleEvent(SQLError::create(*errorData)); |
815 } | 816 } |
816 | 817 |
817 void Database::runTransaction( | 818 void Database::runTransaction( |
818 SQLTransactionCallback* callback, | 819 SQLTransactionCallback* callback, |
819 SQLTransactionErrorCallback* errorCallback, | 820 SQLTransactionErrorCallback* errorCallback, |
820 VoidCallback* successCallback, | 821 VoidCallback* successCallback, |
821 bool readOnly, | 822 bool readOnly, |
822 const ChangeVersionData* changeVersionData) | 823 const ChangeVersionData* changeVersionData) |
823 { | 824 { |
824 ASSERT(getExecutionContext()->isContextThread()); | 825 ASSERT(getExecutionContext()->isContextThread()); |
825 // FIXME: Rather than passing errorCallback to SQLTransaction and then | 826 // FIXME: Rather than passing errorCallback to SQLTransaction and then |
826 // sometimes firing it ourselves, this code should probably be pushed down | 827 // sometimes firing it ourselves, this code should probably be pushed down |
827 // into Database so that we only create the SQLTransaction if we're | 828 // into Database so that we only create the SQLTransaction if we're |
828 // actually going to run it. | 829 // actually going to run it. |
829 #if ENABLE(ASSERT) | 830 #if ENABLE(ASSERT) |
830 SQLTransactionErrorCallback* originalErrorCallback = errorCallback; | 831 SQLTransactionErrorCallback* originalErrorCallback = errorCallback; |
831 #endif | 832 #endif |
832 SQLTransaction* transaction = SQLTransaction::create(this, callback, success
Callback, errorCallback, readOnly); | 833 SQLTransaction* transaction = SQLTransaction::create(this, callback, success
Callback, errorCallback, readOnly); |
833 SQLTransactionBackend* transactionBackend = runTransaction(transaction, read
Only, changeVersionData); | 834 SQLTransactionBackend* transactionBackend = runTransaction(transaction, read
Only, changeVersionData); |
834 if (!transactionBackend) { | 835 if (!transactionBackend) { |
835 SQLTransactionErrorCallback* callback = transaction->releaseErrorCallbac
k(); | 836 SQLTransactionErrorCallback* callback = transaction->releaseErrorCallbac
k(); |
836 ASSERT(callback == originalErrorCallback); | 837 ASSERT(callback == originalErrorCallback); |
837 if (callback) { | 838 if (callback) { |
838 OwnPtr<SQLErrorData> error = SQLErrorData::create(SQLError::UNKNOWN_
ERR, "database has been closed"); | 839 std::unique_ptr<SQLErrorData> error = SQLErrorData::create(SQLError:
:UNKNOWN_ERR, "database has been closed"); |
839 getExecutionContext()->postTask(BLINK_FROM_HERE, createSameThreadTas
k(&callTransactionErrorCallback, callback, passed(std::move(error)))); | 840 getExecutionContext()->postTask(BLINK_FROM_HERE, createSameThreadTas
k(&callTransactionErrorCallback, callback, passed(std::move(error)))); |
840 } | 841 } |
841 } | 842 } |
842 } | 843 } |
843 | 844 |
844 void Database::scheduleTransactionCallback(SQLTransaction* transaction) | 845 void Database::scheduleTransactionCallback(SQLTransaction* transaction) |
845 { | 846 { |
846 // The task is constructed in a database thread, and destructed in the | 847 // The task is constructed in a database thread, and destructed in the |
847 // context thread. | 848 // context thread. |
848 getExecutionContext()->postTask(BLINK_FROM_HERE, createCrossThreadTask(&SQLT
ransaction::performPendingCallback, wrapCrossThreadPersistent(transaction))); | 849 getExecutionContext()->postTask(BLINK_FROM_HERE, createCrossThreadTask(&SQLT
ransaction::performPendingCallback, wrapCrossThreadPersistent(transaction))); |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
880 Vector<String> Database::tableNames() | 881 Vector<String> Database::tableNames() |
881 { | 882 { |
882 // FIXME: Not using isolatedCopy on these strings looks ok since threads | 883 // FIXME: Not using isolatedCopy on these strings looks ok since threads |
883 // take strict turns in dealing with them. However, if the code changes, | 884 // take strict turns in dealing with them. However, if the code changes, |
884 // this may not be true anymore. | 885 // this may not be true anymore. |
885 Vector<String> result; | 886 Vector<String> result; |
886 TaskSynchronizer synchronizer; | 887 TaskSynchronizer synchronizer; |
887 if (!getDatabaseContext()->databaseThreadAvailable()) | 888 if (!getDatabaseContext()->databaseThreadAvailable()) |
888 return result; | 889 return result; |
889 | 890 |
890 OwnPtr<DatabaseTableNamesTask> task = DatabaseTableNamesTask::create(this, &
synchronizer, result); | 891 std::unique_ptr<DatabaseTableNamesTask> task = DatabaseTableNamesTask::creat
e(this, &synchronizer, result); |
891 getDatabaseContext()->databaseThread()->scheduleTask(std::move(task)); | 892 getDatabaseContext()->databaseThread()->scheduleTask(std::move(task)); |
892 synchronizer.waitForTaskCompletion(); | 893 synchronizer.waitForTaskCompletion(); |
893 | 894 |
894 return result; | 895 return result; |
895 } | 896 } |
896 | 897 |
897 SecurityOrigin* Database::getSecurityOrigin() const | 898 SecurityOrigin* Database::getSecurityOrigin() const |
898 { | 899 { |
899 if (getExecutionContext()->isContextThread()) | 900 if (getExecutionContext()->isContextThread()) |
900 return m_contextThreadSecurityOrigin.get(); | 901 return m_contextThreadSecurityOrigin.get(); |
901 if (getDatabaseContext()->databaseThread()->isDatabaseThread()) | 902 if (getDatabaseContext()->databaseThread()->isDatabaseThread()) |
902 return m_databaseThreadSecurityOrigin.get(); | 903 return m_databaseThreadSecurityOrigin.get(); |
903 return 0; | 904 return 0; |
904 } | 905 } |
905 | 906 |
906 bool Database::opened() | 907 bool Database::opened() |
907 { | 908 { |
908 return static_cast<bool>(acquireLoad(&m_opened)); | 909 return static_cast<bool>(acquireLoad(&m_opened)); |
909 } | 910 } |
910 | 911 |
911 } // namespace blink | 912 } // namespace blink |
OLD | NEW |