LocalStorageThread.cpp [plain text]
#include "config.h"
#include "LocalStorageThread.h"
#include "LocalStorage.h"
#include "LocalStorageArea.h"
#include "LocalStorageTask.h"
namespace WebCore {
PassRefPtr<LocalStorageThread> LocalStorageThread::create()
{
return adoptRef(new LocalStorageThread);
}
LocalStorageThread::LocalStorageThread()
: m_threadID(0)
{
m_selfRef = this;
}
bool LocalStorageThread::start()
{
MutexLocker lock(m_threadCreationMutex);
if (m_threadID)
return true;
m_threadID = createThread(LocalStorageThread::localStorageThreadStart, this, "WebCore::LocalStorage");
return m_threadID;
}
void* LocalStorageThread::localStorageThreadStart(void* thread)
{
return static_cast<LocalStorageThread*>(thread)->localStorageThread();
}
void* LocalStorageThread::localStorageThread()
{
{
MutexLocker lock(m_threadCreationMutex);
}
while (true) {
RefPtr<LocalStorageTask> task;
if (!m_queue.waitForMessage(task))
break;
task->performTask();
}
detachThread(m_threadID);
m_threadID = 0;
m_selfRef = 0;
return 0;
}
void LocalStorageThread::scheduleImport(PassRefPtr<LocalStorage> storage)
{
ASSERT(!m_queue.killed() && m_threadID);
m_queue.append(LocalStorageTask::createImport(storage));
}
void LocalStorageThread::scheduleSync(PassRefPtr<LocalStorage> storage)
{
ASSERT(!m_queue.killed() && m_threadID);
m_queue.append(LocalStorageTask::createSync(storage));
}
void LocalStorageThread::scheduleImport(PassRefPtr<LocalStorageArea> area)
{
ASSERT(!m_queue.killed() && m_threadID);
m_queue.append(LocalStorageTask::createImport(area));
}
void LocalStorageThread::scheduleSync(PassRefPtr<LocalStorageArea> area)
{
ASSERT(!m_queue.killed() && m_threadID);
m_queue.append(LocalStorageTask::createSync(area));
}
void LocalStorageThread::terminate()
{
ASSERT(isMainThread());
ASSERT(!m_queue.killed() && m_threadID);
if (!m_threadID)
return;
MutexLocker locker(m_terminateLock);
m_queue.append(LocalStorageTask::createTerminate(this));
m_terminateCondition.wait(m_terminateLock);
}
void LocalStorageThread::performTerminate()
{
ASSERT(!isMainThread());
m_queue.kill();
MutexLocker locker(m_terminateLock);
m_terminateCondition.signal();
}
}