Enable per thread heap for database thread

third_party/WebKit/Source/modules/webdatabase/SQLTransaction.cpp

 /*
  * Copyright (C) 2007, 2008, 2013 Apple Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1.  Redistributions of source code must retain the above copyright
  *     notice, this list of conditions and the following disclaimer.
  * 2.  Redistributions in binary form must reproduce the above copyright
@@ skipping 17 matching lines @@
 
 #include "modules/webdatabase/SQLTransaction.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/html/VoidCallback.h"
 #include "core/inspector/InspectorInstrumentation.h"
 #include "modules/webdatabase/Database.h"
 #include "modules/webdatabase/DatabaseAuthorizer.h"
 #include "modules/webdatabase/DatabaseContext.h"
+#include "modules/webdatabase/DatabaseThread.h"
 #include "modules/webdatabase/SQLError.h"
 #include "modules/webdatabase/SQLStatementCallback.h"
 #include "modules/webdatabase/SQLStatementErrorCallback.h"
 #include "modules/webdatabase/SQLTransactionBackend.h"
 #include "modules/webdatabase/SQLTransactionCallback.h"
 #include "modules/webdatabase/SQLTransactionClient.h" // FIXME: Should be used in the backend only.
 #include "modules/webdatabase/SQLTransactionErrorCallback.h"
 #include "platform/Logging.h"
 #include "wtf/StdLibExtras.h"
 #include "wtf/Vector.h"
 
 namespace blink {
 
 SQLTransaction* SQLTransaction::create(Database* db, SQLTransactionCallback* callback,
     VoidCallback* successCallback, SQLTransactionErrorCallback* errorCallback, bool readOnly)
 {
     return new SQLTransaction(db, callback, successCallback, errorCallback, readOnly);
 }
 
 SQLTransaction::SQLTransaction(Database* db, SQLTransactionCallback* callback,
     VoidCallback* successCallback, SQLTransactionErrorCallback* errorCallback,
     bool readOnly)
     : m_database(db)
     , m_callback(callback)
     , m_successCallback(successCallback)
     , m_errorCallback(errorCallback)
     , m_executeSqlAllowed(false)
     , m_readOnly(readOnly)
 {
+    DCHECK(isMainThread());
     ASSERT(m_database);
     InspectorInstrumentation::asyncTaskScheduled(db->getExecutionContext(), "SQLTransaction", this, true);
 }
 
 SQLTransaction::~SQLTransaction()
 {
 }
 
 DEFINE_TRACE(SQLTransaction)
 {
@@ skipping 116 matching lines @@
     }
 
     clearCallbacks();
 
     // Spec 4.3.2.10: Rollback the transaction.
     return SQLTransactionState::CleanupAfterTransactionErrorCallback;
 }
 
 SQLTransactionState SQLTransaction::deliverStatementCallback()
 {
+    DCHECK(isMainThread());
     // Spec 4.3.2.6.6 and 4.3.2.6.3: If the statement callback went wrong, jump to the transaction error callback
     // Otherwise, continue to loop through the statement queue
     m_executeSqlAllowed = true;
 
     SQLStatement* currentStatement = m_backend->currentStatement();
     ASSERT(currentStatement);
 
     bool result = currentStatement->performCallback(this);
 
     m_executeSqlAllowed = false;
 
     if (result) {
         m_database->reportCommitTransactionResult(2, SQLError::UNKNOWN_ERR, 0);
         m_transactionError = SQLErrorData::create(SQLError::UNKNOWN_ERR, "the statement callback raised an exception or statement error callback did not return false");
         return nextStateForTransactionError();
     }
     return SQLTransactionState::RunStatements;
 }
 
 SQLTransactionState SQLTransaction::deliverQuotaIncreaseCallback()
 {
+    DCHECK(isMainThread());
     ASSERT(m_backend->currentStatement());
 
     bool shouldRetryCurrentStatement = m_database->transactionClient()->didExceedQuota(database());
     m_backend->setShouldRetryCurrentStatement(shouldRetryCurrentStatement);
 
     return SQLTransactionState::RunStatements;
 }
 
 SQLTransactionState SQLTransaction::deliverSuccessCallback()
 {
+    DCHECK(isMainThread());
     InspectorInstrumentation::AsyncTask asyncTask(m_database->getExecutionContext(), this);
     InspectorInstrumentation::asyncTaskCanceled(m_database->getExecutionContext(), this);
 
     // Spec 4.3.2.8: Deliver success callback.
     if (VoidCallback* successCallback = m_successCallback.release())
         successCallback->handleEvent();
 
     clearCallbacks();
 
     // Schedule a "post-success callback" step to return control to the database thread in case there
@@ skipping 12 matching lines @@
 
 SQLTransactionState SQLTransaction::sendToBackendState()
 {
     ASSERT(m_nextState != SQLTransactionState::Idle);
     m_backend->requestTransitToState(m_nextState);
     return SQLTransactionState::Idle;
 }
 
 void SQLTransaction::performPendingCallback()
 {
+    DCHECK(isMainThread());
     computeNextStateAndCleanupIfNeeded();
     runStateMachine();
 }
 
 void SQLTransaction::executeSQL(const String& sqlStatement, const Vector<SQLValue>& arguments, SQLStatementCallback* callback, SQLStatementErrorCallback* callbackError, ExceptionState& exceptionState)
 {
+    DCHECK(isMainThread());
     if (!m_executeSqlAllowed) {
         exceptionState.throwDOMException(InvalidStateError, "SQL execution is disallowed.");
         return;
     }
 
     if (!m_database->opened()) {
         exceptionState.throwDOMException(InvalidStateError, "The database has not been opened.");
         return;
     }
 
@@ skipping 49 matching lines @@
     m_successCallback.clear();
     m_errorCallback.clear();
 }
 
 SQLTransactionErrorCallback* SQLTransaction::releaseErrorCallback()
 {
     return m_errorCallback.release();
 }
 
 } // namespace blink