Rollback transactions by observing them weakly from DatabaseSync.

Source/modules/webdatabase/SQLTransactionBackendSync.cpp

 /*
  * Copyright (C) 2010 Google Inc. All rights reserved.
  * Copyright (C) 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:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
@@ skipping 42 matching lines @@
 
 SQLTransactionBackendSync::SQLTransactionBackendSync(DatabaseSync* db, PassOwnPtr<SQLTransactionSyncCallback> callback, bool readOnly)
     : m_database(db)
     , m_callback(callback)
     , m_readOnly(readOnly)
     , m_hasVersionMismatch(false)
     , m_modifiedDatabase(false)
     , m_transactionClient(adoptPtr(new SQLTransactionClient()))
 {
     ASSERT(m_database->executionContext()->isContextThread());
+#if ENABLE(OILPAN)
+    m_database->registerTransaction(static_cast<SQLTransactionSync*>(this));
+#endif
+}
+
+void SQLTransactionBackendSync::rollbackIfInProgress()
+{
+    ASSERT(!m_database->executionContext() || m_database->executionContext()->isContextThread());
+    if (m_sqliteTransaction && m_sqliteTransaction->inProgress())
+        rollback();
 }
 
 SQLTransactionBackendSync::~SQLTransactionBackendSync()
 {
-    ASSERT(m_database->executionContext()->isContextThread());
-    if (m_sqliteTransaction && m_sqliteTransaction->inProgress())
-        rollback();
+#if ENABLE(OILPAN)
+    ASSERT(!m_sqliteTransaction || !m_sqliteTransaction->inProgress());
+#else
+    rollbackIfInProgress();
+#endif
+}
+
+void SQLTransactionBackendSync::trace(Visitor* visitor)
+{
+    visitor->trace(m_database);
 }
 
 PassRefPtr<SQLResultSet> SQLTransactionBackendSync::executeSQL(const String& sqlStatement, const Vector<SQLValue>& arguments, ExceptionState& exceptionState)
 {
     ASSERT(m_database->executionContext()->isContextThread());
 
     m_database->setLastErrorMessage("");
 
     if (!m_database->opened()) {
         m_database->setLastErrorMessage("cannot executeSQL because the database is not open");
@@ skipping 142 matching lines @@
     if (m_database->hadDeletes())
         m_database->incrementalVacuumIfNeeded();
 
     // The commit was successful. If the transaction modified this database, notify the delegates.
     if (m_modifiedDatabase)
         m_transactionClient->didCommitWriteTransaction(database());
 
     m_database->reportCommitTransactionResult(0, -1, 0); // OK
 }
 
+// This can be called while doing weak processing. Do not allocate new on-heap objects.
 void SQLTransactionBackendSync::rollback()
 {
-    ASSERT(m_database->executionContext()->isContextThread());
+    ASSERT(!m_database->executionContext() || m_database->executionContext()->isContextThread());
     m_database->disableAuthorizer();
     if (m_sqliteTransaction) {
         m_sqliteTransaction->rollback();
         m_sqliteTransaction.clear();
     }
     m_database->enableAuthorizer();
 
     ASSERT(!m_database->sqliteDatabase().transactionInProgress());
 }
 
 } // namespace WebCore