IDBTransactionCoordinator.cpp [plain text]
#include "config.h"
#include "IDBTransactionCoordinator.h"
#if ENABLE(INDEXED_DATABASE)
#include "IDBDatabaseBackendImpl.h"
#include "IDBObjectStoreBackendInterface.h"
#include "IDBTransactionBackendImpl.h"
#include "ScriptExecutionContext.h"
namespace WebCore {
PassRefPtr<IDBTransactionCoordinator> IDBTransactionCoordinator::create()
{
return adoptRef(new IDBTransactionCoordinator());
}
IDBTransactionCoordinator::IDBTransactionCoordinator()
{
}
IDBTransactionCoordinator::~IDBTransactionCoordinator()
{
}
void IDBTransactionCoordinator::didCreateTransaction(IDBTransactionBackendImpl* transaction)
{
ASSERT(!m_transactions.contains(transaction));
m_transactions.add(transaction, transaction);
}
void IDBTransactionCoordinator::didStartTransaction(IDBTransactionBackendImpl* transaction)
{
ASSERT(m_transactions.contains(transaction));
m_startedTransactions.add(transaction);
processStartedTransactions();
}
void IDBTransactionCoordinator::didFinishTransaction(IDBTransactionBackendImpl* transaction)
{
ASSERT(m_transactions.contains(transaction));
if (m_startedTransactions.contains(transaction)) {
ASSERT(!m_runningTransactions.contains(transaction));
m_startedTransactions.remove(transaction);
} else if (m_runningTransactions.contains(transaction))
m_runningTransactions.remove(transaction);
m_transactions.remove(transaction);
processStartedTransactions();
}
#ifndef NDEBUG
bool IDBTransactionCoordinator::isActive(IDBTransactionBackendImpl* transaction)
{
bool found = false;
if (m_startedTransactions.contains(transaction))
found = true;
if (m_runningTransactions.contains(transaction)) {
ASSERT(!found);
found = true;
}
ASSERT(found == m_transactions.contains(transaction));
return found;
}
#endif
void IDBTransactionCoordinator::processStartedTransactions()
{
if (!m_runningTransactions.isEmpty())
return;
if (m_startedTransactions.isEmpty())
return;
IDBTransactionBackendImpl* transaction = *m_startedTransactions.begin();
m_startedTransactions.remove(transaction);
m_runningTransactions.add(transaction);
transaction->run();
}
};
#endif // ENABLE(INDEXED_DATABASE)