diff options
author | Steve Block <steveblock@google.com> | 2011-05-06 11:45:16 +0100 |
---|---|---|
committer | Steve Block <steveblock@google.com> | 2011-05-12 13:44:10 +0100 |
commit | cad810f21b803229eb11403f9209855525a25d57 (patch) | |
tree | 29a6fd0279be608e0fe9ffe9841f722f0f4e4269 /Source/WebCore/storage/StorageAreaSync.cpp | |
parent | 121b0cf4517156d0ac5111caf9830c51b69bae8f (diff) | |
download | external_webkit-cad810f21b803229eb11403f9209855525a25d57.zip external_webkit-cad810f21b803229eb11403f9209855525a25d57.tar.gz external_webkit-cad810f21b803229eb11403f9209855525a25d57.tar.bz2 |
Merge WebKit at r75315: Initial merge by git.
Change-Id: I570314b346ce101c935ed22a626b48c2af266b84
Diffstat (limited to 'Source/WebCore/storage/StorageAreaSync.cpp')
-rw-r--r-- | Source/WebCore/storage/StorageAreaSync.cpp | 432 |
1 files changed, 432 insertions, 0 deletions
diff --git a/Source/WebCore/storage/StorageAreaSync.cpp b/Source/WebCore/storage/StorageAreaSync.cpp new file mode 100644 index 0000000..f2008ab --- /dev/null +++ b/Source/WebCore/storage/StorageAreaSync.cpp @@ -0,0 +1,432 @@ +/* + * Copyright (C) 2008, 2009, 2010 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 + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY APPLE INC. ``AS IS'' AND ANY + * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE + * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR + * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY + * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include "config.h" +#include "StorageAreaSync.h" + +#if ENABLE(DOM_STORAGE) + +#include "EventNames.h" +#include "FileSystem.h" +#include "HTMLElement.h" +#include "SQLiteFileSystem.h" +#include "SQLiteStatement.h" +#include "SecurityOrigin.h" +#include "StorageAreaImpl.h" +#include "StorageSyncManager.h" +#include "SuddenTermination.h" +#include <wtf/text/CString.h> + +namespace WebCore { + +// If the StorageArea undergoes rapid changes, don't sync each change to disk. +// Instead, queue up a batch of items to sync and actually do the sync at the following interval. +static const double StorageSyncInterval = 1.0; + +// A sane limit on how many items we'll schedule to sync all at once. This makes it +// much harder to starve the rest of LocalStorage and the OS's IO subsystem in general. +static const int MaxiumItemsToSync = 100; + +inline StorageAreaSync::StorageAreaSync(PassRefPtr<StorageSyncManager> storageSyncManager, PassRefPtr<StorageAreaImpl> storageArea, const String& databaseIdentifier) + : m_syncTimer(this, &StorageAreaSync::syncTimerFired) + , m_itemsCleared(false) + , m_finalSyncScheduled(false) + , m_storageArea(storageArea) + , m_syncManager(storageSyncManager) + , m_databaseIdentifier(databaseIdentifier.crossThreadString()) + , m_clearItemsWhileSyncing(false) + , m_syncScheduled(false) + , m_syncInProgress(false) + , m_databaseOpenFailed(false) + , m_importComplete(false) +{ + ASSERT(isMainThread()); + ASSERT(m_storageArea); + ASSERT(m_syncManager); +} + +PassRefPtr<StorageAreaSync> StorageAreaSync::create(PassRefPtr<StorageSyncManager> storageSyncManager, PassRefPtr<StorageAreaImpl> storageArea, const String& databaseIdentifier) +{ + RefPtr<StorageAreaSync> area = adoptRef(new StorageAreaSync(storageSyncManager, storageArea, databaseIdentifier)); + + // FIXME: If it can't import, then the default WebKit behavior should be that of private browsing, + // not silently ignoring it. https://bugs.webkit.org/show_bug.cgi?id=25894 + if (!area->m_syncManager->scheduleImport(area.get())) + area->m_importComplete = true; + + return area.release(); +} + +StorageAreaSync::~StorageAreaSync() +{ + ASSERT(isMainThread()); + ASSERT(!m_syncTimer.isActive()); + ASSERT(m_finalSyncScheduled); +} + +void StorageAreaSync::scheduleFinalSync() +{ + ASSERT(isMainThread()); + // FIXME: We do this to avoid races, but it'd be better to make things safe without blocking. + blockUntilImportComplete(); + m_storageArea = 0; // This is done in blockUntilImportComplete() but this is here as a form of documentation that we must be absolutely sure the ref count cycle is broken. + + if (m_syncTimer.isActive()) + m_syncTimer.stop(); + else { + // The following is balanced by the call to enableSuddenTermination in the + // syncTimerFired function. + disableSuddenTermination(); + } + // FIXME: This is synchronous. We should do it on the background process, but + // we should do it safely. + m_finalSyncScheduled = true; + syncTimerFired(&m_syncTimer); + m_syncManager->scheduleDeleteEmptyDatabase(this); +} + +void StorageAreaSync::scheduleItemForSync(const String& key, const String& value) +{ + ASSERT(isMainThread()); + ASSERT(!m_finalSyncScheduled); + + m_changedItems.set(key, value); + if (!m_syncTimer.isActive()) { + m_syncTimer.startOneShot(StorageSyncInterval); + + // The following is balanced by the call to enableSuddenTermination in the + // syncTimerFired function. + disableSuddenTermination(); + } +} + +void StorageAreaSync::scheduleClear() +{ + ASSERT(isMainThread()); + ASSERT(!m_finalSyncScheduled); + + m_changedItems.clear(); + m_itemsCleared = true; + if (!m_syncTimer.isActive()) { + m_syncTimer.startOneShot(StorageSyncInterval); + + // The following is balanced by the call to enableSuddenTermination in the + // syncTimerFired function. + disableSuddenTermination(); + } +} + +void StorageAreaSync::syncTimerFired(Timer<StorageAreaSync>*) +{ + ASSERT(isMainThread()); + + bool partialSync = false; + { + MutexLocker locker(m_syncLock); + + // Do not schedule another sync if we're still trying to complete the + // previous one. But, if we're shutting down, schedule it anyway. + if (m_syncInProgress && !m_finalSyncScheduled) { + ASSERT(!m_syncTimer.isActive()); + m_syncTimer.startOneShot(StorageSyncInterval); + return; + } + + if (m_itemsCleared) { + m_itemsPendingSync.clear(); + m_clearItemsWhileSyncing = true; + m_itemsCleared = false; + } + + HashMap<String, String>::iterator changed_it = m_changedItems.begin(); + HashMap<String, String>::iterator changed_end = m_changedItems.end(); + for (int count = 0; changed_it != changed_end; ++count, ++changed_it) { + if (count >= MaxiumItemsToSync && !m_finalSyncScheduled) { + partialSync = true; + break; + } + m_itemsPendingSync.set(changed_it->first.crossThreadString(), changed_it->second.crossThreadString()); + } + + if (partialSync) { + // We can't do the fast path of simply clearing all items, so we'll need to manually + // remove them one by one. Done under lock since m_itemsPendingSync is modified by + // the background thread. + HashMap<String, String>::iterator pending_it = m_itemsPendingSync.begin(); + HashMap<String, String>::iterator pending_end = m_itemsPendingSync.end(); + for (; pending_it != pending_end; ++pending_it) + m_changedItems.remove(pending_it->first); + } + + if (!m_syncScheduled) { + m_syncScheduled = true; + + // The following is balanced by the call to enableSuddenTermination in the + // performSync function. + disableSuddenTermination(); + + m_syncManager->scheduleSync(this); + } + } + + if (partialSync) { + // If we didn't finish syncing, then we need to finish the job later. + ASSERT(!m_syncTimer.isActive()); + m_syncTimer.startOneShot(StorageSyncInterval); + } else { + // The following is balanced by the calls to disableSuddenTermination in the + // scheduleItemForSync, scheduleClear, and scheduleFinalSync functions. + enableSuddenTermination(); + + m_changedItems.clear(); + } +} + +void StorageAreaSync::openDatabase(OpenDatabaseParamType openingStrategy) +{ + ASSERT(!isMainThread()); + ASSERT(!m_database.isOpen()); + ASSERT(!m_databaseOpenFailed); + + String databaseFilename = m_syncManager->fullDatabaseFilename(m_databaseIdentifier); + + if (!fileExists(databaseFilename) && openingStrategy == SkipIfNonExistent) + return; + + if (databaseFilename.isEmpty()) { + LOG_ERROR("Filename for local storage database is empty - cannot open for persistent storage"); + markImported(); + m_databaseOpenFailed = true; + return; + } + + if (!m_database.open(databaseFilename)) { + LOG_ERROR("Failed to open database file %s for local storage", databaseFilename.utf8().data()); + markImported(); + m_databaseOpenFailed = true; + return; + } + + if (!m_database.executeCommand("CREATE TABLE IF NOT EXISTS ItemTable (key TEXT UNIQUE ON CONFLICT REPLACE, value TEXT NOT NULL ON CONFLICT FAIL)")) { + LOG_ERROR("Failed to create table ItemTable for local storage"); + markImported(); + m_databaseOpenFailed = true; + return; + } +} + +void StorageAreaSync::performImport() +{ + ASSERT(!isMainThread()); + ASSERT(!m_database.isOpen()); + + openDatabase(SkipIfNonExistent); + if (!m_database.isOpen()) { + markImported(); + return; + } + + SQLiteStatement query(m_database, "SELECT key, value FROM ItemTable"); + if (query.prepare() != SQLResultOk) { + LOG_ERROR("Unable to select items from ItemTable for local storage"); + markImported(); + return; + } + + HashMap<String, String> itemMap; + + int result = query.step(); + while (result == SQLResultRow) { + itemMap.set(query.getColumnText(0), query.getColumnText(1)); + result = query.step(); + } + + if (result != SQLResultDone) { + LOG_ERROR("Error reading items from ItemTable for local storage"); + markImported(); + return; + } + + HashMap<String, String>::iterator it = itemMap.begin(); + HashMap<String, String>::iterator end = itemMap.end(); + + for (; it != end; ++it) + m_storageArea->importItem(it->first, it->second); + + markImported(); +} + +void StorageAreaSync::markImported() +{ + MutexLocker locker(m_importLock); + m_importComplete = true; + m_importCondition.signal(); +} + +// FIXME: In the future, we should allow use of StorageAreas while it's importing (when safe to do so). +// Blocking everything until the import is complete is by far the simplest and safest thing to do, but +// there is certainly room for safe optimization: Key/length will never be able to make use of such an +// optimization (since the order of iteration can change as items are being added). Get can return any +// item currently in the map. Get/remove can work whether or not it's in the map, but we'll need a list +// of items the import should not overwrite. Clear can also work, but it'll need to kill the import +// job first. +void StorageAreaSync::blockUntilImportComplete() +{ + ASSERT(isMainThread()); + + // Fast path. We set m_storageArea to 0 only after m_importComplete being true. + if (!m_storageArea) + return; + + MutexLocker locker(m_importLock); + while (!m_importComplete) + m_importCondition.wait(m_importLock); + m_storageArea = 0; +} + +void StorageAreaSync::sync(bool clearItems, const HashMap<String, String>& items) +{ + ASSERT(!isMainThread()); + + if (items.isEmpty() && !clearItems) + return; + if (m_databaseOpenFailed) + return; + if (!m_database.isOpen()) + openDatabase(CreateIfNonExistent); + if (!m_database.isOpen()) + return; + + // If the clear flag is set, then we clear all items out before we write any new ones in. + if (clearItems) { + SQLiteStatement clear(m_database, "DELETE FROM ItemTable"); + if (clear.prepare() != SQLResultOk) { + LOG_ERROR("Failed to prepare clear statement - cannot write to local storage database"); + return; + } + + int result = clear.step(); + if (result != SQLResultDone) { + LOG_ERROR("Failed to clear all items in the local storage database - %i", result); + return; + } + } + + SQLiteStatement insert(m_database, "INSERT INTO ItemTable VALUES (?, ?)"); + if (insert.prepare() != SQLResultOk) { + LOG_ERROR("Failed to prepare insert statement - cannot write to local storage database"); + return; + } + + SQLiteStatement remove(m_database, "DELETE FROM ItemTable WHERE key=?"); + if (remove.prepare() != SQLResultOk) { + LOG_ERROR("Failed to prepare delete statement - cannot write to local storage database"); + return; + } + + HashMap<String, String>::const_iterator end = items.end(); + + for (HashMap<String, String>::const_iterator it = items.begin(); it != end; ++it) { + // Based on the null-ness of the second argument, decide whether this is an insert or a delete. + SQLiteStatement& query = it->second.isNull() ? remove : insert; + + query.bindText(1, it->first); + + // If the second argument is non-null, we're doing an insert, so bind it as the value. + if (!it->second.isNull()) + query.bindText(2, it->second); + + int result = query.step(); + if (result != SQLResultDone) { + LOG_ERROR("Failed to update item in the local storage database - %i", result); + break; + } + + query.reset(); + } +} + +void StorageAreaSync::performSync() +{ + ASSERT(!isMainThread()); + + bool clearItems; + HashMap<String, String> items; + { + MutexLocker locker(m_syncLock); + + ASSERT(m_syncScheduled); + + clearItems = m_clearItemsWhileSyncing; + m_itemsPendingSync.swap(items); + + m_clearItemsWhileSyncing = false; + m_syncScheduled = false; + m_syncInProgress = true; + } + + sync(clearItems, items); + + { + MutexLocker locker(m_syncLock); + m_syncInProgress = false; + } + + // The following is balanced by the call to disableSuddenTermination in the + // syncTimerFired function. + enableSuddenTermination(); +} + +void StorageAreaSync::deleteEmptyDatabase() +{ + ASSERT(!isMainThread()); + if (!m_database.isOpen()) + return; + + SQLiteStatement query(m_database, "SELECT COUNT(*) FROM ItemTable"); + if (query.prepare() != SQLResultOk) { + LOG_ERROR("Unable to count number of rows in ItemTable for local storage"); + return; + } + + int result = query.step(); + if (result != SQLResultRow) { + LOG_ERROR("No results when counting number of rows in ItemTable for local storage"); + return; + } + + int count = query.getColumnInt(0); + if (!count) { + query.finalize(); + m_database.close(); + String databaseFilename = m_syncManager->fullDatabaseFilename(m_databaseIdentifier); + if (!SQLiteFileSystem::deleteDatabaseFile(databaseFilename)) + LOG_ERROR("Failed to delete database file %s\n", databaseFilename.utf8().data()); + } +} + +} // namespace WebCore + +#endif // ENABLE(DOM_STORAGE) |