1/* 2 * Copyright (C) 2008 Apple Inc. All Rights Reserved. 3 * 4 * Redistribution and use in source and binary forms, with or without 5 * modification, are permitted provided that the following conditions 6 * are met: 7 * 1. Redistributions of source code must retain the above copyright 8 * notice, this list of conditions and the following disclaimer. 9 * 2. Redistributions in binary form must reproduce the above copyright 10 * notice, this list of conditions and the following disclaimer in the 11 * documentation and/or other materials provided with the distribution. 12 * 13 * THIS SOFTWARE IS PROVIDED BY APPLE INC. ``AS IS'' AND ANY 14 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 15 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 16 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR 17 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 18 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 19 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 20 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY 21 * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 22 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 23 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 24 */ 25 26#include "config.h" 27#include "StorageSyncManager.h" 28 29#include "EventNames.h" 30#include "FileSystem.h" 31#include "Frame.h" 32#include "FrameTree.h" 33#include "StorageThread.h" 34#include "Page.h" 35#include "PageGroup.h" 36#include "StorageAreaSync.h" 37#include <wtf/MainThread.h> 38#include <wtf/StdLibExtras.h> 39#include <wtf/text/CString.h> 40 41namespace WebCore { 42 43PassRefPtr<StorageSyncManager> StorageSyncManager::create(const String& path) 44{ 45 return adoptRef(new StorageSyncManager(path)); 46} 47 48StorageSyncManager::StorageSyncManager(const String& path) 49 : m_thread(StorageThread::create()) 50 , m_path(path.isolatedCopy()) 51{ 52 ASSERT(isMainThread()); 53 ASSERT(!m_path.isEmpty()); 54 m_thread->start(); 55} 56 57StorageSyncManager::~StorageSyncManager() 58{ 59 ASSERT(isMainThread()); 60 ASSERT(!m_thread); 61} 62 63// Called on a background thread. 64String StorageSyncManager::fullDatabaseFilename(const String& databaseIdentifier) 65{ 66 if (!makeAllDirectories(m_path)) { 67 LOG_ERROR("Unabled to create LocalStorage database path %s", m_path.utf8().data()); 68 return String(); 69 } 70 71 return pathByAppendingComponent(m_path, databaseIdentifier + ".localstorage"); 72} 73 74void StorageSyncManager::dispatch(const Function<void ()>& function) 75{ 76 ASSERT(isMainThread()); 77 ASSERT(m_thread); 78 79 if (m_thread) 80 m_thread->dispatch(function); 81} 82 83void StorageSyncManager::close() 84{ 85 ASSERT(isMainThread()); 86 87 if (m_thread) { 88 m_thread->terminate(); 89 m_thread = nullptr; 90 } 91} 92 93} // namespace WebCore 94