DatabaseTrackerChromium.cpp [plain text]
#include "config.h"
#include "DatabaseTracker.h"
#include "CString.h"
#include "Database.h"
#include "DatabaseObserver.h"
#include "DatabaseThread.h"
#include "QuotaTracker.h"
#include "ScriptExecutionContext.h"
#include "SecurityOrigin.h"
#include "SQLiteFileSystem.h"
#include <wtf/HashSet.h>
#include <wtf/MainThread.h>
#include <wtf/StdLibExtras.h>
namespace WebCore {
DatabaseTracker& DatabaseTracker::tracker()
{
DEFINE_STATIC_LOCAL(DatabaseTracker, tracker, ());
return tracker;
}
DatabaseTracker::DatabaseTracker()
{
SQLiteFileSystem::registerSQLiteVFS();
}
bool DatabaseTracker::canEstablishDatabase(ScriptExecutionContext*, const String&, const String&, unsigned long)
{
return true;
}
void DatabaseTracker::setDatabaseDetails(SecurityOrigin*, const String&, const String&, unsigned long)
{
}
String DatabaseTracker::fullPathForDatabase(SecurityOrigin* origin, const String& name, bool)
{
return origin->databaseIdentifier() + "/" + name + "#";
}
void DatabaseTracker::addOpenDatabase(Database* database)
{
ASSERT(database->scriptExecutionContext()->isContextThread());
DatabaseObserver::databaseOpened(database);
}
class TrackerRemoveOpenDatabaseTask : public ScriptExecutionContext::Task {
public:
static PassOwnPtr<TrackerRemoveOpenDatabaseTask> create(PassRefPtr<Database> database)
{
return new TrackerRemoveOpenDatabaseTask(database);
}
virtual void performTask(ScriptExecutionContext* context)
{
DatabaseTracker::tracker().removeOpenDatabase(m_database.get());
}
private:
TrackerRemoveOpenDatabaseTask(PassRefPtr<Database> database)
: m_database(database)
{
}
RefPtr<Database> m_database;
};
void DatabaseTracker::removeOpenDatabase(Database* database)
{
if (!database->scriptExecutionContext()->isContextThread()) {
database->scriptExecutionContext()->postTask(TrackerRemoveOpenDatabaseTask::create(database));
return;
}
DatabaseObserver::databaseClosed(database);
}
unsigned long long DatabaseTracker::getMaxSizeForDatabase(const Database* database)
{
ASSERT(currentThread() == database->scriptExecutionContext()->databaseThread()->getThreadID());
unsigned long long spaceAvailable = 0;
unsigned long long databaseSize = 0;
QuotaTracker::instance().getDatabaseSizeAndSpaceAvailableToOrigin(
database->securityOrigin()->databaseIdentifier(),
database->stringIdentifier(), &databaseSize, &spaceAvailable);
return databaseSize + spaceAvailable;
}
}