IDBTransactionCoordinator.cpp [plain text]
#include "config.h"
#include "IDBTransactionCoordinator.h"
#if ENABLE(INDEXED_DATABASE)
#include "IDBDatabaseCallbacks.h"
#include "IDBTransactionBackend.h"
namespace WebCore {
IDBTransactionCoordinator::IDBTransactionCoordinator()
{
}
IDBTransactionCoordinator::~IDBTransactionCoordinator()
{
}
void IDBTransactionCoordinator::didCreateTransaction(IDBTransactionBackend* transaction)
{
ASSERT(!m_transactions.contains(transaction));
m_transactions.add(transaction, transaction);
}
void IDBTransactionCoordinator::didStartTransaction(IDBTransactionBackend* transaction)
{
ASSERT(m_transactions.contains(transaction));
m_queuedTransactions.add(transaction);
processStartedTransactions();
}
void IDBTransactionCoordinator::didFinishTransaction(IDBTransactionBackend* transaction)
{
ASSERT(m_transactions.contains(transaction));
if (m_queuedTransactions.contains(transaction)) {
ASSERT(!m_startedTransactions.contains(transaction));
m_queuedTransactions.remove(transaction);
} else if (m_startedTransactions.contains(transaction))
m_startedTransactions.remove(transaction);
m_transactions.remove(transaction);
processStartedTransactions();
}
#ifndef NDEBUG
bool IDBTransactionCoordinator::isActive(IDBTransactionBackend* transaction)
{
bool found = false;
if (m_queuedTransactions.contains(transaction))
found = true;
if (m_startedTransactions.contains(transaction)) {
ASSERT(!found);
found = true;
}
ASSERT(found == m_transactions.contains(transaction));
return found;
}
#endif
void IDBTransactionCoordinator::processStartedTransactions()
{
if (m_queuedTransactions.isEmpty())
return;
ASSERT(m_startedTransactions.isEmpty() || (*m_startedTransactions.begin())->mode() != IndexedDB::TransactionMode::VersionChange);
ListHashSet<IDBTransactionBackend*>::const_iterator it = m_queuedTransactions.begin();
while (it != m_queuedTransactions.end()) {
IDBTransactionBackend* transaction = *it;
++it;
if (canRunTransaction(transaction)) {
m_queuedTransactions.remove(transaction);
m_startedTransactions.add(transaction);
transaction->run();
}
}
}
bool IDBTransactionCoordinator::canRunTransaction(IDBTransactionBackend* transaction)
{
ASSERT(m_queuedTransactions.contains(transaction));
UNUSED_PARAM(transaction);
return !m_startedTransactions.size();
}
};
#endif // ENABLE(INDEXED_DATABASE)