| Index: third_party/WebKit/Source/modules/webdatabase/Database.cpp
|
| diff --git a/third_party/WebKit/Source/modules/webdatabase/Database.cpp b/third_party/WebKit/Source/modules/webdatabase/Database.cpp
|
| index 545f8bce84dc5377b67feaa0ca2dfbc3c8e1800a..32b524b370a84d4dc98121a9bee10bf021f930b1 100644
|
| --- a/third_party/WebKit/Source/modules/webdatabase/Database.cpp
|
| +++ b/third_party/WebKit/Source/modules/webdatabase/Database.cpp
|
| @@ -215,7 +215,7 @@ Database::Database(DatabaseContext* databaseContext, const String& name, const S
|
| , m_transactionInProgress(false)
|
| , m_isTransactionQueueEnabled(true)
|
| {
|
| - m_contextThreadSecurityOrigin = m_databaseContext->securityOrigin()->isolatedCopy();
|
| + m_contextThreadSecurityOrigin = m_databaseContext->getSecurityOrigin()->isolatedCopy();
|
|
|
| m_databaseAuthorizer = DatabaseAuthorizer::create(infoTableName);
|
|
|
| @@ -224,11 +224,11 @@ Database::Database(DatabaseContext* databaseContext, const String& name, const S
|
|
|
| {
|
| SafePointAwareMutexLocker locker(guidMutex());
|
| - m_guid = guidForOriginAndName(securityOrigin()->toString(), name);
|
| + m_guid = guidForOriginAndName(getSecurityOrigin()->toString(), name);
|
| guidCount().add(m_guid);
|
| }
|
|
|
| - m_filename = DatabaseManager::manager().fullPathForDatabase(securityOrigin(), m_name);
|
| + m_filename = DatabaseManager::manager().fullPathForDatabase(getSecurityOrigin(), m_name);
|
|
|
| m_databaseThreadSecurityOrigin = m_contextThreadSecurityOrigin->isolatedCopy();
|
| ASSERT(m_databaseContext->databaseThread());
|
| @@ -260,13 +260,13 @@ DEFINE_TRACE(Database)
|
| bool Database::openAndVerifyVersion(bool setVersionInNewDatabase, DatabaseError& error, String& errorMessage)
|
| {
|
| TaskSynchronizer synchronizer;
|
| - if (!databaseContext()->databaseThreadAvailable())
|
| + if (!getDatabaseContext()->databaseThreadAvailable())
|
| return false;
|
|
|
| DatabaseTracker::tracker().prepareToOpenDatabase(this);
|
| bool success = false;
|
| OwnPtr<DatabaseOpenTask> task = DatabaseOpenTask::create(this, setVersionInNewDatabase, &synchronizer, error, errorMessage, success);
|
| - databaseContext()->databaseThread()->scheduleTask(task.release());
|
| + getDatabaseContext()->databaseThread()->scheduleTask(task.release());
|
| synchronizer.waitForTaskCompletion();
|
|
|
| return success;
|
| @@ -274,8 +274,8 @@ bool Database::openAndVerifyVersion(bool setVersionInNewDatabase, DatabaseError&
|
|
|
| void Database::close()
|
| {
|
| - ASSERT(databaseContext()->databaseThread());
|
| - ASSERT(databaseContext()->databaseThread()->isDatabaseThread());
|
| + ASSERT(getDatabaseContext()->databaseThread());
|
| + ASSERT(getDatabaseContext()->databaseThread()->isDatabaseThread());
|
|
|
| {
|
| MutexLocker locker(m_transactionInProgressMutex);
|
| @@ -294,7 +294,7 @@ void Database::close()
|
| }
|
|
|
| closeDatabase();
|
| - databaseContext()->databaseThread()->recordDatabaseClosed(this);
|
| + getDatabaseContext()->databaseThread()->recordDatabaseClosed(this);
|
| }
|
|
|
| SQLTransactionBackend* Database::runTransaction(SQLTransaction* transaction, bool readOnly, const ChangeVersionData* data)
|
| @@ -330,11 +330,11 @@ void Database::scheduleTransaction()
|
| if (m_isTransactionQueueEnabled && !m_transactionQueue.isEmpty())
|
| transaction = m_transactionQueue.takeFirst();
|
|
|
| - if (transaction && databaseContext()->databaseThreadAvailable()) {
|
| + if (transaction && getDatabaseContext()->databaseThreadAvailable()) {
|
| OwnPtr<DatabaseTransactionTask> task = DatabaseTransactionTask::create(transaction);
|
| WTF_LOG(StorageAPI, "Scheduling DatabaseTransactionTask %p for transaction %p\n", task.get(), task->transaction());
|
| m_transactionInProgress = true;
|
| - databaseContext()->databaseThread()->scheduleTask(task.release());
|
| + getDatabaseContext()->databaseThread()->scheduleTask(task.release());
|
| } else {
|
| m_transactionInProgress = false;
|
| }
|
| @@ -342,22 +342,22 @@ void Database::scheduleTransaction()
|
|
|
| void Database::scheduleTransactionStep(SQLTransactionBackend* transaction)
|
| {
|
| - if (!databaseContext()->databaseThreadAvailable())
|
| + if (!getDatabaseContext()->databaseThreadAvailable())
|
| return;
|
|
|
| OwnPtr<DatabaseTransactionTask> task = DatabaseTransactionTask::create(transaction);
|
| WTF_LOG(StorageAPI, "Scheduling DatabaseTransactionTask %p for the transaction step\n", task.get());
|
| - databaseContext()->databaseThread()->scheduleTask(task.release());
|
| + getDatabaseContext()->databaseThread()->scheduleTask(task.release());
|
| }
|
|
|
| SQLTransactionClient* Database::transactionClient() const
|
| {
|
| - return databaseContext()->databaseThread()->transactionClient();
|
| + return getDatabaseContext()->databaseThread()->transactionClient();
|
| }
|
|
|
| SQLTransactionCoordinator* Database::transactionCoordinator() const
|
| {
|
| - return databaseContext()->databaseThread()->transactionCoordinator();
|
| + return getDatabaseContext()->databaseThread()->transactionCoordinator();
|
| }
|
|
|
| // static
|
| @@ -546,8 +546,8 @@ bool Database::performOpenAndVerify(bool shouldSetVersionInNewDatabase, Database
|
|
|
| reportOpenDatabaseResult(0, -1, 0, WTF::monotonicallyIncreasingTime() - callStartTime); // OK
|
|
|
| - if (databaseContext()->databaseThread())
|
| - databaseContext()->databaseThread()->recordDatabaseOpen(this);
|
| + if (getDatabaseContext()->databaseThread())
|
| + getDatabaseContext()->databaseThread()->recordDatabaseOpen(this);
|
| return true;
|
| }
|
|
|
| @@ -712,7 +712,7 @@ void Database::reportOpenDatabaseResult(int errorSite, int webSqlErrorCode, int
|
| {
|
| if (Platform::current()->databaseObserver()) {
|
| Platform::current()->databaseObserver()->reportOpenDatabaseResult(
|
| - createDatabaseIdentifierFromSecurityOrigin(securityOrigin()),
|
| + createDatabaseIdentifierFromSecurityOrigin(getSecurityOrigin()),
|
| stringIdentifier(), errorSite, webSqlErrorCode, sqliteErrorCode,
|
| duration);
|
| }
|
| @@ -722,7 +722,7 @@ void Database::reportChangeVersionResult(int errorSite, int webSqlErrorCode, int
|
| {
|
| if (Platform::current()->databaseObserver()) {
|
| Platform::current()->databaseObserver()->reportChangeVersionResult(
|
| - createDatabaseIdentifierFromSecurityOrigin(securityOrigin()),
|
| + createDatabaseIdentifierFromSecurityOrigin(getSecurityOrigin()),
|
| stringIdentifier(), errorSite, webSqlErrorCode, sqliteErrorCode);
|
| }
|
| }
|
| @@ -731,7 +731,7 @@ void Database::reportStartTransactionResult(int errorSite, int webSqlErrorCode,
|
| {
|
| if (Platform::current()->databaseObserver()) {
|
| Platform::current()->databaseObserver()->reportStartTransactionResult(
|
| - createDatabaseIdentifierFromSecurityOrigin(securityOrigin()),
|
| + createDatabaseIdentifierFromSecurityOrigin(getSecurityOrigin()),
|
| stringIdentifier(), errorSite, webSqlErrorCode, sqliteErrorCode);
|
| }
|
| }
|
| @@ -740,7 +740,7 @@ void Database::reportCommitTransactionResult(int errorSite, int webSqlErrorCode,
|
| {
|
| if (Platform::current()->databaseObserver()) {
|
| Platform::current()->databaseObserver()->reportCommitTransactionResult(
|
| - createDatabaseIdentifierFromSecurityOrigin(securityOrigin()),
|
| + createDatabaseIdentifierFromSecurityOrigin(getSecurityOrigin()),
|
| stringIdentifier(), errorSite, webSqlErrorCode, sqliteErrorCode);
|
| }
|
| }
|
| @@ -749,7 +749,7 @@ void Database::reportExecuteStatementResult(int errorSite, int webSqlErrorCode,
|
| {
|
| if (Platform::current()->databaseObserver()) {
|
| Platform::current()->databaseObserver()->reportExecuteStatementResult(
|
| - createDatabaseIdentifierFromSecurityOrigin(securityOrigin()),
|
| + createDatabaseIdentifierFromSecurityOrigin(getSecurityOrigin()),
|
| stringIdentifier(), errorSite, webSqlErrorCode, sqliteErrorCode);
|
| }
|
| }
|
| @@ -758,27 +758,27 @@ void Database::reportVacuumDatabaseResult(int sqliteErrorCode)
|
| {
|
| if (Platform::current()->databaseObserver()) {
|
| Platform::current()->databaseObserver()->reportVacuumDatabaseResult(
|
| - createDatabaseIdentifierFromSecurityOrigin(securityOrigin()),
|
| + createDatabaseIdentifierFromSecurityOrigin(getSecurityOrigin()),
|
| stringIdentifier(), sqliteErrorCode);
|
| }
|
| }
|
|
|
| void Database::logErrorMessage(const String& message)
|
| {
|
| - executionContext()->addConsoleMessage(ConsoleMessage::create(StorageMessageSource, ErrorMessageLevel, message));
|
| + getExecutionContext()->addConsoleMessage(ConsoleMessage::create(StorageMessageSource, ErrorMessageLevel, message));
|
| }
|
|
|
| -ExecutionContext* Database::executionContext() const
|
| +ExecutionContext* Database::getExecutionContext() const
|
| {
|
| - return databaseContext()->executionContext();
|
| + return getDatabaseContext()->getExecutionContext();
|
| }
|
|
|
| void Database::closeImmediately()
|
| {
|
| - ASSERT(executionContext()->isContextThread());
|
| - if (databaseContext()->databaseThreadAvailable() && opened()) {
|
| + ASSERT(getExecutionContext()->isContextThread());
|
| + if (getDatabaseContext()->databaseThreadAvailable() && opened()) {
|
| logErrorMessage("forcibly closing database");
|
| - databaseContext()->databaseThread()->scheduleTask(DatabaseCloseTask::create(this, 0));
|
| + getDatabaseContext()->databaseThread()->scheduleTask(DatabaseCloseTask::create(this, 0));
|
| }
|
| }
|
|
|
| @@ -821,7 +821,7 @@ void Database::runTransaction(
|
| bool readOnly,
|
| const ChangeVersionData* changeVersionData)
|
| {
|
| - ASSERT(executionContext()->isContextThread());
|
| + ASSERT(getExecutionContext()->isContextThread());
|
| // FIXME: Rather than passing errorCallback to SQLTransaction and then
|
| // sometimes firing it ourselves, this code should probably be pushed down
|
| // into Database so that we only create the SQLTransaction if we're
|
| @@ -836,7 +836,7 @@ void Database::runTransaction(
|
| ASSERT(callback == originalErrorCallback);
|
| if (callback) {
|
| OwnPtr<SQLErrorData> error = SQLErrorData::create(SQLError::UNKNOWN_ERR, "database has been closed");
|
| - executionContext()->postTask(BLINK_FROM_HERE, createSameThreadTask(&callTransactionErrorCallback, callback, error.release()));
|
| + getExecutionContext()->postTask(BLINK_FROM_HERE, createSameThreadTask(&callTransactionErrorCallback, callback, error.release()));
|
| }
|
| }
|
| }
|
| @@ -845,7 +845,7 @@ void Database::scheduleTransactionCallback(SQLTransaction* transaction)
|
| {
|
| // The task is constructed in a database thread, and destructed in the
|
| // context thread.
|
| - executionContext()->postTask(BLINK_FROM_HERE, createCrossThreadTask(&SQLTransaction::performPendingCallback, transaction));
|
| + getExecutionContext()->postTask(BLINK_FROM_HERE, createCrossThreadTask(&SQLTransaction::performPendingCallback, transaction));
|
| }
|
|
|
| Vector<String> Database::performGetTableNames()
|
| @@ -884,21 +884,21 @@ Vector<String> Database::tableNames()
|
| // this may not be true anymore.
|
| Vector<String> result;
|
| TaskSynchronizer synchronizer;
|
| - if (!databaseContext()->databaseThreadAvailable())
|
| + if (!getDatabaseContext()->databaseThreadAvailable())
|
| return result;
|
|
|
| OwnPtr<DatabaseTableNamesTask> task = DatabaseTableNamesTask::create(this, &synchronizer, result);
|
| - databaseContext()->databaseThread()->scheduleTask(task.release());
|
| + getDatabaseContext()->databaseThread()->scheduleTask(task.release());
|
| synchronizer.waitForTaskCompletion();
|
|
|
| return result;
|
| }
|
|
|
| -SecurityOrigin* Database::securityOrigin() const
|
| +SecurityOrigin* Database::getSecurityOrigin() const
|
| {
|
| - if (executionContext()->isContextThread())
|
| + if (getExecutionContext()->isContextThread())
|
| return m_contextThreadSecurityOrigin.get();
|
| - if (databaseContext()->databaseThread()->isDatabaseThread())
|
| + if (getDatabaseContext()->databaseThread()->isDatabaseThread())
|
| return m_databaseThreadSecurityOrigin.get();
|
| return 0;
|
| }
|
|
|