1 /*
2 * Copyright (C) 2009 Torch Mobile, 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 library is distributed in the hope that i will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 * Library General Public License for more details.
17 *
18 * You should have received a copy of the GNU Library General Public License
19 * along with this library; see the file COPYING.LIB. If not, write to
20 * the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
21 * Boston, MA 02110-1301, USA.
22 */
23
24 #include "config.h"
25 #include "DatabaseThread.h"
26
27 #include "Database.h"
28 #include "DatabaseTask.h"
29
30 namespace WebCore {
31
DatabaseThread()32 DatabaseThread::DatabaseThread()
33 : m_timer(this, &DatabaseThread::timerFired)
34 {
35 }
36
~DatabaseThread()37 DatabaseThread::~DatabaseThread()
38 {
39 }
40
requestTermination()41 void DatabaseThread::requestTermination()
42 {
43 m_queue.clear();
44 }
45
terminationRequested() const46 bool DatabaseThread::terminationRequested() const
47 {
48 return m_queue.isEmpty();
49 }
50
timerFired(Timer<DatabaseThread> *)51 void DatabaseThread::timerFired(Timer<DatabaseThread>*)
52 {
53 if (!m_queue.isEmpty()) {
54 RefPtr<DatabaseTask> task = m_queue.first();
55 task->performTask();
56 m_queue.removeFirst();
57 if (!m_queue.isEmpty())
58 m_timer.startOneShot(0);
59 }
60 }
61
scheduleTask(PassRefPtr<DatabaseTask> task)62 void DatabaseThread::scheduleTask(PassRefPtr<DatabaseTask> task)
63 {
64 m_queue.append(task);
65 if (!m_timer.isActive())
66 m_timer.startOneShot(0);
67 }
68
scheduleImmediateTask(PassRefPtr<DatabaseTask> task)69 void DatabaseThread::scheduleImmediateTask(PassRefPtr<DatabaseTask> task)
70 {
71 task->performTask();
72 }
73
unscheduleDatabaseTasks(Database * database)74 void DatabaseThread::unscheduleDatabaseTasks(Database* database)
75 {
76 Deque<RefPtr<DatabaseTask> > reservedTasks;
77 for (Deque<RefPtr<DatabaseTask> >::const_iterator i = m_queue.begin(); i != m_queue.end(); ++i) {
78 if ((*i)->database() != database)
79 reservedTasks.append(*i);
80 }
81
82 m_queue.swap(reservedTasks);
83 }
84
recordDatabaseOpen(Database * database)85 void DatabaseThread::recordDatabaseOpen(Database* database)
86 {
87 notImplemented();
88 }
89
recordDatabaseClosed(Database * database)90 void DatabaseThread::recordDatabaseClosed(Database* database)
91 {
92 notImplemented();
93 }
94
95 } // namespace WebCore
96