Merge WebKit at r67908: Initial merge by Git

Change-Id: I43a553e7b3299b28cb6ee8aa035ed70fe342b972

1 files changed, 95 insertions, 0 deletions

diff --git a/WebCore/storage/wince/DatabaseThreadWinCE.cpp b/WebCore/storage/wince/DatabaseThreadWinCE.cpp
new file mode 100644
index 0000000..d81145d
--- /dev/null
+++ b/WebCore/storage/wince/DatabaseThreadWinCE.cpp
@@ -0,0 +1,95 @@
+/*
+ * Copyright (C) 2009 Torch Mobile, 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 library is distributed in the hope that i will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ *  Library General Public License for more details.
+ *
+ *  You should have received a copy of the GNU Library General Public License
+ *  along with this library; see the file COPYING.LIB.  If not, write to
+ *  the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+ *  Boston, MA 02110-1301, USA.
+ */
+
+#include "config.h"
+#include "DatabaseThread.h"
+
+#include "Database.h"
+#include "DatabaseTask.h"
+
+namespace WebCore {
+
+DatabaseThread::DatabaseThread()
+: m_timer(this, &DatabaseThread::timerFired)
+{
+}
+
+DatabaseThread::~DatabaseThread()
+{
+}
+
+void DatabaseThread::requestTermination()
+{
+    m_queue.clear();
+}
+
+bool DatabaseThread::terminationRequested() const
+{
+    return m_queue.isEmpty();
+}
+
+void DatabaseThread::timerFired(Timer<DatabaseThread>*)
+{
+    if (!m_queue.isEmpty()) {
+        RefPtr<DatabaseTask> task = m_queue.first();
+        task->performTask();
+        m_queue.removeFirst();
+        if (!m_queue.isEmpty())
+            m_timer.startOneShot(0);
+    }
+}
+
+void DatabaseThread::scheduleTask(PassRefPtr<DatabaseTask> task)
+{
+    m_queue.append(task);
+    if (!m_timer.isActive())
+        m_timer.startOneShot(0);
+}
+
+void DatabaseThread::scheduleImmediateTask(PassRefPtr<DatabaseTask> task)
+{
+    task->performTask();
+}
+
+void DatabaseThread::unscheduleDatabaseTasks(Database* database)
+{
+    Deque<RefPtr<DatabaseTask> > reservedTasks;
+    for (Deque<RefPtr<DatabaseTask> >::const_iterator i = m_queue.begin(); i != m_queue.end(); ++i) {
+        if ((*i)->database() != database)
+            reservedTasks.append(*i);
+    }
+
+    m_queue.swap(reservedTasks);
+}
+
+void DatabaseThread::recordDatabaseOpen(Database* database)
+{
+    notImplemented();
+}
+
+void DatabaseThread::recordDatabaseClosed(Database* database)
+{
+    notImplemented();
+}
+
+} // namespace WebCore